Quote table name in OpSetReplicaIdentity

xataio · Nov 24, 2023 · d0acbbb · d0acbbb
1 parent 763dabc
commit d0acbbb
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/migrations/op_set_replica_identity.go b/pkg/migrations/op_set_replica_identity.go
@@ -33,7 +33,9 @@ func (o *OpSetReplicaIdentity) Start(ctx context.Context, conn *sql.DB, stateSch
 	}
 
 	// set the replica identity on the underlying table
-	_, err := conn.ExecContext(ctx, fmt.Sprintf("ALTER TABLE %s REPLICA IDENTITY %s", o.Table, identitySQL))
+	_, err := conn.ExecContext(ctx, fmt.Sprintf("ALTER TABLE %s REPLICA IDENTITY %s",
+		pq.QuoteIdentifier(o.Table),
+		identitySQL))
 	return err
 }