@@ -74,9 +74,9 @@ public void initialize() {
74
74
logger .info ("PARAM -- maxWriteTimeStampFilter: {} datetime is {}" , getMaxWriteTimeStampFilter (),
75
75
Instant .ofEpochMilli (getMaxWriteTimeStampFilter () / 1000 ));
76
76
}
77
- logger .info ("PARAM -- ORIGIN SELECT Query used: {}" , cqlMap . get (CQL .ORIGIN_SELECT ));
78
- logger .info ("PARAM -- TARGET INSERT Query used: {}" , cqlMap . get (CQL .TARGET_INSERT ));
79
- logger .info ("PARAM -- TARGET SELECT Query used: {}" , cqlMap . get (CQL .TARGET_SELECT_ORIGIN_BY_PK ));
77
+ logger .info ("PARAM -- ORIGIN SELECT Query used: {}" , getCql (CQL .ORIGIN_SELECT ));
78
+ logger .info ("PARAM -- TARGET INSERT Query used: {}" , getCql (CQL .TARGET_INSERT ));
79
+ logger .info ("PARAM -- TARGET SELECT Query used: {}" , getCql (CQL .TARGET_SELECT_ORIGIN_BY_PK ));
80
80
}
81
81
82
82
public BoundStatement bindInsert (PreparedStatement insertStatement , Row originRow , Row targetRow ) {
@@ -128,8 +128,6 @@ public BoundStatement selectFromTargetByPK(PreparedStatement selectStatement, Ro
128
128
}
129
129
130
130
private String cqlOriginSelect () {
131
- String selectCols = propertyHelper .getAsString (KnownProperties .ORIGIN_COLUMN_NAMES );
132
-
133
131
final StringBuilder selectTTLWriteTimeCols = new StringBuilder ();
134
132
if (null != getTtlCols ()) {
135
133
getTtlCols ().forEach (col -> {
@@ -157,7 +155,7 @@ private String cqlOriginSelect() {
157
155
keyBinds += " AND " + key + "=?" ;
158
156
}
159
157
}
160
- fullSelectQuery = "SELECT " + selectCols + selectTTLWriteTimeCols + " FROM " + getOriginKeyspaceTable () + " WHERE " + keyBinds ;
158
+ fullSelectQuery = "SELECT " + propertyHelper . getAsString ( KnownProperties . ORIGIN_COLUMN_NAMES ) + selectTTLWriteTimeCols + " FROM " + getOriginKeyspaceTable () + " WHERE " + keyBinds ;
161
159
}
162
160
return fullSelectQuery ;
163
161
}
0 commit comments