Skip to content

Commit 31ead8e

Browse files
author
chenhongyu05
committed
[Feature][Jdbc] Add String type column split Support by charset-based splitting algorithm
1 parent eda5de8 commit 31ead8e

File tree

1 file changed

+6
-7
lines changed
  • seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/vertica

1 file changed

+6
-7
lines changed

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/vertica/VerticaDialect.java

+6-7
Original file line numberDiff line numberDiff line change
@@ -17,12 +17,13 @@
1717

1818
package org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.vertica;
1919

20-
import org.apache.commons.lang3.StringUtils;
2120
import org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.JdbcRowConverter;
2221
import org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.DatabaseIdentifier;
2322
import org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialect;
2423
import org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialectTypeMapper;
2524

25+
import org.apache.commons.lang3.StringUtils;
26+
2627
import java.util.Arrays;
2728
import java.util.List;
2829
import java.util.Optional;
@@ -110,19 +111,17 @@ public Optional<String> getUpsertStatement(
110111
}
111112

112113
/**
113-
* <a href="https://docs.vertica.com/23.4.x/en/sql-reference/functions/data-type-specific-functions/string-functions/collation/">vertica-collation</a>
114+
* <a
115+
* href="https://docs.vertica.com/23.4.x/en/sql-reference/functions/data-type-specific-functions/string-functions/collation/">vertica-collation</a>
116+
*
114117
* @param collate
115118
* @return
116119
*/
117120
@Override
118121
public String getCollateSql(String collate) {
119122
if (StringUtils.isNotBlank(collate)) {
120123
StringBuilder sql = new StringBuilder();
121-
sql.append("COLLATION(")
122-
.append("char_val")
123-
.append(", '")
124-
.append(collate)
125-
.append("')");
124+
sql.append("COLLATION(").append("char_val").append(", '").append(collate).append("')");
126125
return sql.toString();
127126
} else {
128127
return "char_val";

0 commit comments

Comments
 (0)