fix: fix cdc stream query template (#1498)

ydb-platform · Oct 18, 2024 · 8405466 · 8405466
1 parent e85f70e
commit 8405466
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/containers/Tenant/utils/schemaQueryTemplates.ts b/src/containers/Tenant/utils/schemaQueryTemplates.ts
@@ -179,9 +179,9 @@ export const dropTableIndex = (params?: SchemaQueryParams) => {
     return `ALTER TABLE \`${path || '$path'}\` DROP INDEX \`${indexName || '$indexName'}\`;`;
 };
 
-export const createCdcStreamTemplate = () => {
+export const createCdcStreamTemplate = (params?: SchemaQueryParams) => {
     return `-- docs: https://ydb.tech/docs/en/yql/reference/syntax/create_changefeed
-ADD CHANGEFEED $name WITH (
+ALTER TABLE \`${params?.relativePath || '$path'}\` ADD CHANGEFEED $name WITH (
     MODE = $mode, -- KEYS_ONLY, UPDATES, NEW_IMAGE, OLD_IMAGE, or NEW_AND_OLD_IMAGES
     FORMAT = $format, -- JSON or DEBEZIUM_JSON
     VIRTUAL_TIMESTAMPS = $virtualTimestamps, -- true or false