fix: pg tests

formancehq · Sep 13, 2022 · 37353fe · 37353fe
1 parent cd9de06
commit 37353fe
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/pkg/storage/sqlstorage/idempotency.go b/pkg/storage/sqlstorage/idempotency.go
@@ -21,7 +21,7 @@ func (s *Store) CreateIK(ctx context.Context, key string, response idempotency.R
 	ib := sqlbuilder.NewInsertBuilder()
 	q, args := ib.
 		InsertInto(s.schema.Table("idempotency")).
-		Cols("key", "date", "statusCode", "headers", "body", "requestHash").
+		Cols("key", "date", "status_code", "headers", "body", "request_hash").
 		Values(key, time.Now().UTC(), response.StatusCode, string(data), response.Body, response.RequestHash).
 		BuildWithFlavor(s.schema.Flavor())
 
@@ -37,7 +37,7 @@ func (s *Store) CreateIK(ctx context.Context, key string, response idempotency.R
 func (s *Store) ReadIK(ctx context.Context, key string) (*idempotency.Response, error) {
 	sb := sqlbuilder.NewSelectBuilder()
 	q, args := sb.
-		Select("statusCode", "headers", "body", "requestHash").
+		Select("status_code", "headers", "body", "request_hash").
 		From(s.schema.Table("idempotency")).
 		Where(sb.Equal("key", key)).
 		BuildWithFlavor(s.schema.Flavor())

diff --git a/pkg/storage/sqlstorage/migrates/15-add-idempotency-table/postgres.sql b/pkg/storage/sqlstorage/migrates/15-add-idempotency-table/postgres.sql
@@ -1,11 +1,11 @@
 --statement
-CREATE TABLE IF NOT EXISTS "VAR_LEDGER_NAME"."idempotency" (
+CREATE TABLE IF NOT EXISTS "VAR_LEDGER_NAME".idempotency (
     "key" varchar,
     "date" varchar,
-    "statusCode" int,
+    "status_code" int,
     "headers" varchar,
     "body" varchar,
-    "requestHash" varchar,
+    "request_hash" varchar,
 
     PRIMARY KEY("key")
 );
diff --git a/pkg/storage/sqlstorage/migrates/15-add-idempotency-table/sqlite.sql b/pkg/storage/sqlstorage/migrates/15-add-idempotency-table/sqlite.sql
@@ -2,10 +2,10 @@
 CREATE TABLE IF NOT EXISTS idempotency (
    "key" varchar,
    "date" varchar,
-   "statusCode" int,
+   "status_code" int,
    "headers" varchar,
    "body" varchar,
-   "requestHash" varchar,
+   "request_hash" varchar,
 
    PRIMARY KEY("key")
 );