Skip to content

Commit 32281cc

Browse files
committed
modify spelling
1 parent daf1e24 commit 32281cc

File tree

6 files changed

+19
-13
lines changed
  • db2/db2-sink/src/main/java/com/dtstack/flink/sql/sink/db
  • oracle/oracle-sink/src/main/java/com/dtstack/flink/sql/sink/oracle
  • polardb/polardb-sink/src/main/java/com/dtstack/flink/sql/sink/polardb
  • postgresql/postgresql-sink/src/main/java/com/dtstack/flink/sql/sink/postgresql
  • rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb
  • sqlserver/sqlserver-sink/src/main/java/com/dtstack/flink/sql/sink/sqlserver

6 files changed

+19
-13
lines changed

db2/db2-sink/src/main/java/com/dtstack/flink/sql/sink/db/DbSink.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,12 @@ public DbSink() {
1515
@Override
1616
public JDBCUpsertOutputFormat getOutputFormat() {
1717
JDBCOptions jdbcOptions = JDBCOptions.builder()
18-
.setDBUrl(dbURL).setDialect(jdbcDialect)
19-
.setUsername(userName).setPassword(password)
20-
.setTableName(tableName).build();
18+
.setDBUrl(dbURL)
19+
.setDialect(jdbcDialect)
20+
.setUsername(userName)
21+
.setPassword(password)
22+
.setTableName(tableName)
23+
.build();
2124

2225
return JDBCUpsertOutputFormat.builder()
2326
.setOptions(jdbcOptions)

oracle/oracle-sink/src/main/java/com/dtstack/flink/sql/sink/oracle/OracleSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public JDBCUpsertOutputFormat getOutputFormat() {
4343
.setUsername(userName)
4444
.setPassword(password)
4545
.setTableName(tableName)
46-
.setScheam(schema)
46+
.setSchema(schema)
4747
.build();
4848

4949
return JDBCUpsertOutputFormat.builder()

polardb/polardb-sink/src/main/java/com/dtstack/flink/sql/sink/polardb/PolardbSink.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,9 +13,12 @@ public PolardbSink() {
1313
@Override
1414
public JDBCUpsertOutputFormat getOutputFormat() {
1515
JDBCOptions jdbcOptions = JDBCOptions.builder()
16-
.setDBUrl(dbURL).setDialect(jdbcDialect)
17-
.setUsername(userName).setPassword(password)
18-
.setTableName(tableName).build();
16+
.setDBUrl(dbURL)
17+
.setDialect(jdbcDialect)
18+
.setUsername(userName)
19+
.setPassword(password)
20+
.setTableName(tableName)
21+
.build();
1922

2023
return JDBCUpsertOutputFormat.builder()
2124
.setOptions(jdbcOptions)

postgresql/postgresql-sink/src/main/java/com/dtstack/flink/sql/sink/postgresql/PostgresqlSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ public JDBCUpsertOutputFormat getOutputFormat() {
4141
.setUsername(userName)
4242
.setPassword(password)
4343
.setTableName(tableName)
44-
.setScheam(schema)
44+
.setSchema(schema)
4545
.build();
4646

4747
return JDBCUpsertOutputFormat.builder()

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/JDBCOptions.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ public static class Builder {
105105
private String driverName;
106106
private String username;
107107
private String password;
108-
private String scheam;
108+
private String schema;
109109
private JDBCDialect dialect;
110110

111111
/**
@@ -144,8 +144,8 @@ public Builder setDriverName(String driverName) {
144144
/**
145145
* optional, schema info
146146
*/
147-
public Builder setScheam(String scheam) {
148-
this.scheam = scheam;
147+
public Builder setSchema(String schema) {
148+
this.schema = schema;
149149
return this;
150150
}
151151

@@ -173,7 +173,7 @@ public JDBCOptions build() {
173173
});
174174
}
175175

176-
return new JDBCOptions(dbURL, tableName, driverName, username, password, scheam, dialect);
176+
return new JDBCOptions(dbURL, tableName, driverName, username, password, schema, dialect);
177177
}
178178
}
179179
}

sqlserver/sqlserver-sink/src/main/java/com/dtstack/flink/sql/sink/sqlserver/SqlserverSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public JDBCUpsertOutputFormat getOutputFormat() {
4343
.setUsername(userName)
4444
.setPassword(password)
4545
.setTableName(tableName)
46-
.setScheam(schema)
46+
.setSchema(schema)
4747
.build();
4848

4949
return JDBCUpsertOutputFormat.builder()

0 commit comments

Comments
 (0)