fix: conversion of sqlite to postgres syntax (#1569)

freiheit-com · May 2, 2024 · d4aa190 · d4aa190
1 parent 1467368
commit d4aa190
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/services/cd-service/pkg/repository/db.go b/services/cd-service/pkg/repository/db.go
@@ -147,15 +147,15 @@ func RunDBMigrations(cfg DBConfig) error {
 
 func (h *DBHandler) AdaptQuery(query string) string {
 	if h.DriverName == "postgres" {
-		return query
+		return SqliteToPostgresQuery(query)
 	} else if h.DriverName == "sqlite3" {
-		return PostgresToSqliteQuery(query)
+		return query
 	}
 	panic(fmt.Errorf("AdaptQuery: invalid driver: %s", h.DriverName))
 }
 
-// PostgresToSqliteQuery just replaces all "?" into "$1", "$2", etc
-func PostgresToSqliteQuery(query string) string {
+// SqliteToPostgresQuery just replaces all "?" into "$1", "$2", etc
+func SqliteToPostgresQuery(query string) string {
 	var q = query
 	var i = 1
 	for strings.Contains(q, "?") {

diff --git a/services/cd-service/pkg/repository/db_test.go b/services/cd-service/pkg/repository/db_test.go
@@ -134,7 +134,7 @@ INSERT INTO all_apps (version , created , json)  VALUES (1, 	'1713218400', '{"ap
 	}
 }
 
-func TestPostgresToSqliteQuery(t *testing.T) {
+func TestSqliteToPostgresQuery(t *testing.T) {
 	tcs := []struct {
 		Name          string
 		inputQuery    string
@@ -166,7 +166,7 @@ func TestPostgresToSqliteQuery(t *testing.T) {
 		t.Run(tc.Name, func(t *testing.T) {
 			t.Parallel()
 
-			actualQuery := PostgresToSqliteQuery(tc.inputQuery)
+			actualQuery := SqliteToPostgresQuery(tc.inputQuery)
 			if diff := cmp.Diff(tc.expectedQuery, actualQuery); diff != "" {
 				t.Errorf("response mismatch (-want, +got):\n%s", diff)
 			}