hm sqlite transactions dont play with begin commit

src/feeds/db.go

@@ -128,20 +128,20 @@ func (f *Feeds) Get(ctx context.Context, id string) (Feed, error) {
 			versions.created_at AS "Version.Created",
 			versions.url AS "Version.URL",
 			versions.cron AS "Version.Cron",
-         (
+			(
-            SELECT executed_at
+				SELECT executed_at
-            FROM "feed.executions"
+				FROM "feed.executions"
-            WHERE entries_id = entry.ID
+				WHERE entries_id = entry.ID
 				ORDER BY executed_at DESC
 				LIMIT 1
-         ) AS "Execution.Executed",
+			) AS "Execution.Executed",
-         (
+			(
-            SELECT versions_created_at
+				SELECT versions_created_at
-            FROM "feed.executions"
+				FROM "feed.executions"
-            WHERE entries_id = entry.ID
+				WHERE entries_id = entry.ID
 				ORDER BY executed_at DESC
 				LIMIT 1
-         ) AS "Execution.Version"
+			) AS "Execution.Version"
 		FROM entry
 		JOIN "feed.versions" version_entries_id ON
 			version_entries_id.entries_id=entry.ID
@@ -196,22 +196,21 @@ func (f *Feeds) oldGet(ctx context.Context, id string) (Feed, error) {
 func (f *Feeds) Insert(ctx context.Context, url, cron string) (string, error) {
 	now := time.Now()
 	id := uuid.New().String()
-	q := `
+	return id, db.Exec(ctx, `
-		BEGIN;
+			BEGIN;
-		INSERT INTO "feed.entries" (
+			INSERT INTO "feed.entries" (
-			id,
+				id,
-			created_at,
+				created_at,
-			updated_at
+				updated_at
-		) VALUES (?, ?, ?);
+			) VALUES ($1, $2, $3);
-		INSERT INTO "feed.versions" (
+			INSERT INTO "feed.versions" (
-			entries_id,
+				entries_id,
-			created_at,
+				created_at,
-			url,
+				url,
-			cron
+				cron
-		) VALUES (?, ?, ?, ?);
+			) VALUES ($4, $5, $6, $7);
-		COMMIT;
+			COMMIT;
-	`
+		`,
-	return id, db.Exec(ctx, q,
 		id, now, now,
 		id, now, url, cron,
 	)

src/feeds/db_test.go

@@ -51,6 +51,36 @@ func TestFeeds(t *testing.T) {
 		if err != nil {
 			t.Fatal("cannot get:", err)
 		}
-		t.Errorf("%+v", got)
+		t.Logf("%+v", got)
+
+		if got.Entry.ID == "" {
+			t.Error("no entry.id")
+		}
+		if got.Entry.Created.IsZero() {
+			t.Error("no entry.created")
+		}
+		if got.Entry.Updated.IsZero() {
+			t.Error("no entry.updated")
+		}
+		if !got.Entry.Deleted.IsZero() {
+			t.Error("entry.deleted")
+		}
+
+		if got.Version.Created.IsZero() {
+			t.Error("no version.created")
+		}
+		if got.Version.URL != "url" {
+			t.Error("no version.url")
+		}
+		if got.Version.Cron != "cron" {
+			t.Error("no version.cron")
+		}
+
+		if !got.Execution.Executed.IsZero() {
+			t.Error("execution.executed")
+		}
+		if !got.Execution.Version.IsZero() {
+			t.Error("execution.version")
+		}
 	})
 }