fix: use current_schema for postgres TableExists, if schema is unspec…

…ified (#884)
pressly · Jan 7, 2025 · 4337eb2 · 4337eb2
1 parent 779024d
commit 4337eb2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/dialect/dialectquery/postgres.go b/internal/dialect/dialectquery/postgres.go
@@ -50,7 +50,7 @@ func (p *Postgres) TableExists(tableName string) string {
 		q := `SELECT EXISTS ( SELECT 1 FROM pg_tables WHERE schemaname = '%s' AND tablename = '%s' )`
 		return fmt.Sprintf(q, schemaName, tableName)
 	}
-	q := `SELECT EXISTS ( SELECT 1 FROM pg_tables WHERE tablename = '%s' )`
+	q := `SELECT EXISTS ( SELECT 1 FROM pg_tables WHERE (current_schema() IS NULL OR schemaname = current_schema()) AND tablename = '%s' )`
 	return fmt.Sprintf(q, tableName)
 }