refine

risingwavelabs · Aug 19, 2024 · 4c10666 · 4c10666
1 parent 9bff661
commit 4c10666
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/common/src/cdc/mod.rs b/src/common/src/cdc/mod.rs
@@ -14,5 +14,5 @@
 
 /// Build a unique CDC table identifier from a source ID and external table name
 pub fn build_cdc_table_id(source_id: u32, external_table_name: &str) -> String {
-    format!("{}_{}", source_id, external_table_name)
+    format!("{}.{}", source_id, external_table_name)
 }
diff --git a/src/connector/src/parser/unified/debezium.rs b/src/connector/src/parser/unified/debezium.rs
@@ -13,6 +13,7 @@
 // limitations under the License.
 
 use itertools::Itertools;
+use risingwave_common::build_cdc_table_id;
 use risingwave_common::catalog::{ColumnCatalog, ColumnDesc, ColumnId};
 use risingwave_common::types::{
     DataType, Datum, DatumCow, Scalar, ScalarImpl, ScalarRefImpl, Timestamptz, ToDatumRef,
@@ -232,7 +233,7 @@ pub fn parse_schema_change(
             }
 
             // concatenate the source_id to the cdc_table_id
-            let cdc_table_id = format!("{}_{}", source_id, id.replace('"', ""));
+            let cdc_table_id = build_cdc_table_id(source_id, id.replace('"', ""));
             schema_changes.push(TableSchemaChange {
                 cdc_table_id,
                 columns: column_descs