Fix update bind vars as well

youtube · Mar 24, 2016 · a8d628d · a8d628d
1 parent e5c3b8c
commit a8d628d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/vitess/src/main/java/com/yahoo/ycsb/db/QueryCreator.java b/vitess/src/main/java/com/yahoo/ycsb/db/QueryCreator.java
@@ -201,7 +201,9 @@ public Query createUpdateQuery(String keyspace,
 
     Query query = new Query(sqlBuilder.toString(), keyspace, tabletType, key, keyField);
     for (Entry<String, ByteIterator> val : result.entrySet()) {
-      query.addBindVar(val.getKey(), val.getValue().toString());
+      if (val.getKey() != keyField) {
+        query.addBindVar(val.getKey(), val.getValue().toString());
+      }
     }
 
     return query;