From a15a9ce8f555000a0810c8414433623dbce20ea2 Mon Sep 17 00:00:00 2001 From: Masudur Rahman Date: Sat, 2 Mar 2024 22:21:06 +0600 Subject: [PATCH] Add double quote around db name Signed-off-by: Masudur Rahman --- sql/postgres/lib/table_sync.go | 6 +++--- sql/sqlite/lib/table_sync.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/sql/postgres/lib/table_sync.go b/sql/postgres/lib/table_sync.go index c90c05f..6dc62a6 100644 --- a/sql/postgres/lib/table_sync.go +++ b/sql/postgres/lib/table_sync.go @@ -227,7 +227,7 @@ func createTableQuery(tableName string, fields []fieldInfo) string { } func generateAddColumnQuery(tableName string, missingColumns []string) string { - alterQuery := fmt.Sprintf("ALTER TABLE %s ", tableName) + alterQuery := fmt.Sprintf("ALTER TABLE \"%s\" ", tableName) var addColumns []string for _, col := range missingColumns { addColumns = append(addColumns, fmt.Sprintf("ADD COLUMN %s", col)) @@ -312,7 +312,7 @@ func getUniqueConstraints(ctx context.Context, conn *sql.Conn, tableName string) } func generateDropConstraintStatement(tableName string, uqConstraints [][]string) string { - sql := fmt.Sprintf("ALTER TABLE %s ", tableName) + sql := fmt.Sprintf("ALTER TABLE \"%s\" ", tableName) var dropConstraints []string for i := range uqConstraints { @@ -329,7 +329,7 @@ func generateDropConstraintStatement(tableName string, uqConstraints [][]string) func generateAddConstraintStatement(tableName string, uqGroups [][]string) string { - sql := fmt.Sprintf("ALTER TABLE %s ", tableName) + sql := fmt.Sprintf("ALTER TABLE \"%s\" ", tableName) var addConstraints []string for i, group := range uqGroups { diff --git a/sql/sqlite/lib/table_sync.go b/sql/sqlite/lib/table_sync.go index 534a32a..3a2b887 100644 --- a/sql/sqlite/lib/table_sync.go +++ b/sql/sqlite/lib/table_sync.go @@ -352,7 +352,7 @@ func tableExists(ctx context.Context, conn *sql.Conn, tableName string) (bool, e } func generateAddColumnQuery(tableName string, missingColumns []string) string { - alterQuery := fmt.Sprintf("ALTER TABLE %s ", tableName) + alterQuery := fmt.Sprintf("ALTER TABLE \"%s\" ", tableName) var addColumns []string for _, col := range missingColumns { addColumns = append(addColumns, fmt.Sprintf("ADD COLUMN %s", col))