[incubator-seatunnel] branch cdc-multiple-table updated: [Feature] Change StarRocks CreatTable Template (#4184)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch cdc-multiple-table
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/cdc-multiple-table by this 
push:
     new 4cf07f3be [Feature] Change StarRocks CreatTable Template (#4184)
4cf07f3be is described below

commit 4cf07f3bebc33761ec23572c1b774bcaedc1fda4
Author: Hisoka <fanjiaemi...@qq.com>
AuthorDate: Wed Feb 22 17:01:09 2023 +0800

    [Feature] Change StarRocks CreatTable Template (#4184)
---
 .../connectors/seatunnel/starrocks/config/SinkConfig.java         | 1 +
 .../seatunnel/starrocks/sink/StarRocksSaveModeUtil.java           | 8 ++++----
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SinkConfig.java
 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SinkConfig.java
index 5ba7543c5..3a6212266 100644
--- 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SinkConfig.java
+++ 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SinkConfig.java
@@ -85,6 +85,7 @@ public class SinkConfig implements Serializable {
         .defaultValue("CREATE TABLE IF NOT EXISTS 
`${database}`.`${table_name}` (\n" +
             "${rowtype_fields}\n" +
             ") ENGINE=OLAP\n" +
+            " PRIMARY KEY (${rowtype_primary_key})\n" +
             "DISTRIBUTED BY HASH (${rowtype_primary_key})" +
             "PROPERTIES (\n" +
             "    \"replication_num\" = \"1\" \n" +
diff --git 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSaveModeUtil.java
 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSaveModeUtil.java
index 2179e77db..93be4e53f 100644
--- 
a/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSaveModeUtil.java
+++ 
b/seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSaveModeUtil.java
@@ -34,10 +34,10 @@ public class StarRocksSaveModeUtil {
         String primaryKey = 
tableSchema.getPrimaryKey().getColumnNames().stream().map(r -> "`" + r + 
"`").collect(Collectors.joining(","));
         String rowTypeFields = 
tableSchema.getColumns().stream().map(StarRocksSaveModeUtil::columnToStarrocksType)
             .collect(Collectors.joining(",\n"));
-        return template.replace(String.format("${%s}", 
SaveModeConstants.DATABASE), database)
-            .replace(String.format("${%s}", SaveModeConstants.TABLE_NAME), 
table)
-            .replace(String.format("${%s}", SaveModeConstants.ROWTYPE_FIELDS), 
rowTypeFields)
-            .replace(String.format("${%s}", 
SaveModeConstants.ROWTYPE_PRIMARY_KEY), primaryKey);
+        return template.replaceAll(String.format("${%s}", 
SaveModeConstants.DATABASE), database)
+            .replaceAll(String.format("${%s}", SaveModeConstants.TABLE_NAME), 
table)
+            .replaceAll(String.format("${%s}", 
SaveModeConstants.ROWTYPE_FIELDS), rowTypeFields)
+            .replaceAll(String.format("${%s}", 
SaveModeConstants.ROWTYPE_PRIMARY_KEY), primaryKey);
     }
 
     static String columnToStarrocksType(Column column) {