This commit is contained in:
hantmac 2023-08-02 16:57:00 +08:00
parent 404b6946c7
commit 75f2ebc095

View File

@ -32,7 +32,7 @@ public final class DatabendWriterUtil {
LOG.error("Replace mode must has onConflictColumn conf"); LOG.error("Replace mode must has onConflictColumn conf");
return; return;
} }
// for databend if you want to use replace mode, the writeMode should be: "writeMode": "replace (userid)" // for databend if you want to use replace mode, the writeMode should be: "writeMode": "replace"
writeDataSqlTemplate.append("REPLACE INTO %s (") writeDataSqlTemplate.append("REPLACE INTO %s (")
.append(StringUtils.join(columns, ",")).append(") ").append(onConFlictDoString(onConflictColumns)) .append(StringUtils.join(columns, ",")).append(") ").append(onConFlictDoString(onConflictColumns))
.append(" VALUES"); .append(" VALUES");