diff --git a/bin/datastore.py b/bin/datastore.py index 7291f75..15e177b 100644 --- a/bin/datastore.py +++ b/bin/datastore.py @@ -412,6 +412,14 @@ class Datastore: """ cursor.execute(qry, (fileinfo["sequence"], fileinfo["line"], ntbp, incr, json.dumps(fileinfo["meta"]))) + + qry = """ + UPDATE raw_lines + SET meta = meta || %s + WHERE sequence = %s; + """ + + cursor.execute(qry, (json.dumps(fileinfo["meta"]), fileinfo["sequence"])) qry = """ INSERT INTO raw_lines_files (sequence, hash) @@ -454,6 +462,14 @@ class Datastore: """ cursor.execute(qry, (fileinfo["sequence"], fileinfo["line"], json.dumps(fileinfo["meta"]))) + + qry = """ + UPDATE raw_lines + SET meta = meta || %s + WHERE sequence = %s; + """ + + cursor.execute(qry, (json.dumps(fileinfo["meta"]), fileinfo["sequence"])) qry = """ INSERT INTO final_lines_files (sequence, hash)