Skip to content

Commit b78bdbd

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

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceConfig.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public class JdbcSourceConfig implements Serializable {
4747

4848
private StringSplitMode stringSplitMode;
4949

50-
private String collate;
50+
private String stringSplitModeCollate;
5151

5252
public static JdbcSourceConfig of(ReadonlyConfig config) {
5353
JdbcSourceConfig.Builder builder = JdbcSourceConfig.builder();
@@ -61,7 +61,7 @@ public static JdbcSourceConfig of(ReadonlyConfig config) {
6161
&& config.getOptional(JdbcOptions.PARTITION_COLUMN).isPresent();
6262
builder.useDynamicSplitter(!isOldVersion);
6363
builder.stringSplitMode(config.get(JdbcOptions.STRING_SPLIT_MODE));
64-
builder.collate(config.get(JdbcOptions.STRING_SPLIT_MODE_COLLATE));
64+
builder.stringSplitModeCollate(config.get(JdbcOptions.STRING_SPLIT_MODE_COLLATE));
6565
builder.splitSize(config.get(JdbcSourceOptions.SPLIT_SIZE));
6666
builder.splitEvenDistributionFactorUpperBound(
6767
config.get(JdbcSourceOptions.SPLIT_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND));

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ private List<ChunkRange> charsetBasedColumnSplitChunks(
154154
boolean paddingAtEnd = true;
155155
boolean isCaseInsensitive = false;
156156
String collationSequence =
157-
jdbcDialect.getCollationSequence(getOrEstablishConnection(), config.getCollate());
157+
jdbcDialect.getCollationSequence(getOrEstablishConnection(), config.getStringSplitModeCollate());
158158
if (collationSequence.matches(".*[aA][Aa].*")) {
159159
isCaseInsensitive = true;
160160
collationSequence = filterOutUppercase(collationSequence);

seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ private Collection<JdbcSourceSplit> getJdbcSourceStringSplits(
102102
boolean paddingAtEnd = true;
103103
boolean isCaseInsensitive = false;
104104
String collationSequence =
105-
jdbcDialect.getCollationSequence(getOrEstablishConnection(), config.getCollate());
105+
jdbcDialect.getCollationSequence(getOrEstablishConnection(), config.getStringSplitModeCollate());
106106
if (collationSequence.matches(".*[aA][Aa].*")) {
107107
isCaseInsensitive = true;
108108
collationSequence = filterOutUppercase(collationSequence);

0 commit comments

Comments
 (0)