Changes
1 changed files (+2/-2)
-
-
@@ -58,7 +58,7 @@ }_, err = tx.Exec(` INSERT INTO projections (projection_name) SELECT ? WHERE NOT EXISTS (SELECT id FROM projections WHERE projection_name = ?); SELECT ? WHERE NOT EXISTS (SELECT id FROM projections WHERE projection_name = ?) `, name, name) if err != nil { return err
-
@@ -66,7 +66,7 @@ }_, err = tx.Exec(` INSERT INTO snapshots (event_seq, projection_id, payload) SELECT ?, id, ? FROM projections WHERE projection_name = ? LIMIT 1; SELECT ?, id, ? FROM projections WHERE projection_name = ? LIMIT 1 `, seq, payload, name) return err
-