CDM-92: Fix NPE issue with target counter tables with null fields

Author: pravinbhat

RELEASE.md

@@ -1,5 +1,8 @@
 # Release Notes
-## [4.1.3] - 2023-07-06
+## [4.1.4] - 2023-08-16
+- In rare edge situations, counter tables with existing data in Target can have null values on target. This release will handle null values in Target counter table transparently.
+
+## [4.1.3] - 2023-08-14
 - Counter table columns will usually have zeros to begin with, but in rare edge situations, they can have null values. This release will handle null values in counter table transparently.
 
 ## [4.1.2] - 2023-07-06

SIT/smoke/04_counters/setup.cql

@@ -11,4 +11,6 @@ UPDATE origin.smoke_counters set col1=col1+500 where key='record6';
 DROP TABLE IF EXISTS target.smoke_counters;
 CREATE TABLE target.smoke_counters(key text,col1 counter,col2 counter, PRIMARY KEY (key));
 
+UPDATE target.smoke_counters set col1=col1+1 where key='record1';
+
 SELECT * FROM origin.smoke_counters;

pom.xml

@@ -136,7 +136,7 @@
     <connection>scm:git:[email protected]:datastax/cassandra-data-migrator.git</connection>
     <developerConnection>scm:git:[email protected]:datastax/cassandra-data-migrator.git</developerConnection>
     <url>https://github.com/datastax/cassandra-data-migrator</url>
-    <tag>@{project.version}</tag>
+    <tag>@{version}</tag>
   </scm>
 
   <build>

src/main/java/com/datastax/cdm/cql/statement/TargetUpdateStatement.java

@@ -42,35 +42,39 @@ protected BoundStatement bind(Row originRow, Row targetRow, Integer ttl, Long wr
             boundStatement = boundStatement.set(currentBindIndex++, writeTime, Long.class);
         }
 
-        Object bindValue = null;
+        Object bindValueOrg = null;
+        Object bindValueDest = null;
         for (int targetIndex : columnIndexesToBind) {
             int originIndex = cqlTable.getCorrespondingIndex(targetIndex);
 
             try {
-                if(usingCounter && counterIndexes.contains(targetIndex)) {
-                    bindValue = cqlTable.getOtherCqlTable().getData(originIndex, originRow);
-                    if (null == bindValue) {
+                if (usingCounter && counterIndexes.contains(targetIndex)) {
+                    bindValueOrg = cqlTable.getOtherCqlTable().getData(originIndex, originRow);
+                    if (null == bindValueOrg) {
                         currentBindIndex++;
                         continue;
                     }
-                    bindValue = ((Long) bindValue - (null==targetRow ? 0 : (Long) cqlTable.getData(targetIndex, targetRow)));
+                    bindValueDest = (null == targetRow ? 0L : cqlTable.getData(targetIndex, targetRow));
+                    bindValueDest = ((Long) bindValueOrg - (null == bindValueDest ? 0L : (Long) bindValueDest));
                 }
                 else if (targetIndex== explodeMapKeyIndex) {
-                    bindValue = explodeMapKey;
+                    bindValueDest = explodeMapKey;
                 }
                 else if (targetIndex== explodeMapValueIndex) {
-                    bindValue = explodeMapValue;
+                    bindValueDest = explodeMapValue;
                 } else {
                     if (originIndex < 0)
                         // we don't have data to bind for this column; continue to the next targetIndex
                         continue;
-                    bindValue = cqlTable.getOtherCqlTable().getAndConvertData(originIndex, originRow);
+                    bindValueDest = cqlTable.getOtherCqlTable().getAndConvertData(originIndex, originRow);
                 }
 
-                boundStatement = boundStatement.set(currentBindIndex++, bindValue, cqlTable.getBindClass(targetIndex));
+                boundStatement = boundStatement.set(currentBindIndex++, bindValueDest, cqlTable.getBindClass(targetIndex));
             }
             catch (Exception e) {
-                logger.error("Error trying to bind value:" + bindValue + " to column:" + targetColumnNames.get(targetIndex) + " of targetDataType:" + targetColumnTypes.get(targetIndex)+ "/" + cqlTable.getBindClass(targetIndex).getName() + " at column index:" + targetIndex);
+                logger.error("Error trying to bind value:" + bindValueDest + " to column:" +
+                        targetColumnNames.get(targetIndex) + " of targetDataType:" + targetColumnTypes.get(targetIndex) + "/"
+                        + cqlTable.getBindClass(targetIndex).getName() + " at column index:" + targetIndex);
                 throw e;
             }
         }