[update] recover update raw_id

2022-03-30 10:52:08 +08:00
parent df4c178131
commit 01e5370e1c
1 changed files with 2 additions and 5 deletions
@@ -511,13 +511,10 @@ class DataBaseProcess(Process):
    @calculate_time(1)
    def data_meta_update_all_channel_raw_id(self, meta_id:str, raw_id_dict:dict):
        try:
-            sql_str = "UPDATE recording_data_metas SET raw_data = "
+            sql_str = "UPDATE recording_data_metas SET raw_data = jsonb_insert(raw_data, '{%s, -1}', '%s', TRUE) WHERE id = %s;"
            sql_set = []
            for ch in raw_id_dict.keys():
-                sql_str += "jsonb_insert(raw_data -> %s, '{-1}', '%s', TRUE) ||"
-                sql_set.extend([ch, raw_id_dict[ch]])
-            sql_str[:-2] + "WHERE id = %s;"
-            sql_set.append(meta_id)
+                sql_set.append([ch, raw_id_dict[ch], meta_id])
            with self._psql_conn as conn:
                    with conn.cursor() as sql_cursor:
                        execute_batch(sql_cursor, sql_str, sql_set)