File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
cassandra/cassandra-sink/src/main/java/com/dtstack/flink/sql/sink/cassandra Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 6161
6262import java .io .IOException ;
6363import java .net .InetAddress ;
64+ import java .sql .Time ;
65+ import java .sql .Date ;
66+ import java .sql .Timestamp ;
6467import java .sql .DriverManager ;
6568import java .sql .PreparedStatement ;
6669import java .util .ArrayList ;
@@ -234,7 +237,10 @@ private String buildSql(Row row) {
234237 if (row .getField (index ) == null ) {
235238 } else {
236239 fields .append (fieldNames [index ] + "," );
237- if (row .getField (index ) instanceof String ) {
240+ if (row .getField (index ) instanceof String
241+ || row .getField (index ) instanceof Time
242+ || row .getField (index ) instanceof Date
243+ || row .getField (index ) instanceof Timestamp ) {
238244 values .append ("'" + row .getField (index ) + "'" + "," );
239245 } else {
240246 values .append (row .getField (index ) + "," );
You can’t perform that action at this time.
0 commit comments