quotes for schema and table

2022-01-25 18:57:55 +01:00 · 2022-01-25 18:57:55 +01:00 · eb51428a44
parent 179fcb1126
commit eb51428a44
1 changed files with 2 additions and 1 deletions
--- a/pkg/cluster/streams.go
+++ b/pkg/cluster/streams.go
@ -141,7 +141,8 @@ func (c *Cluster) syncPostgresConfig() error {
 		tableNames := make([]string, len(tables))
 		i := 0
 		for t := range tables {
-			tableNames[i] = fmt.Sprintf("%q", t)
+			tableName, schemaName := getTableSchema(t)
+			tableNames[i] = fmt.Sprintf("%q.%q", schemaName, tableName)
 			i++
 		}
 		tableList := strings.Join(tableNames, ", ")