IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

simplify switch

Browse Source
This commit is contained in:
Jonathan Shook
2021-06-11 15:27:22 -05:00
parent 748eebc04c
commit 070086e655
1 changed files with 4 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
driver-cqld3-shaded/src/main/java/io/nosqlbench/activitytype/cql/core/CQLBindHelper.java
View File

@@ -78,14 +78,11 @@ public class CQLBindHelper {
public static BoundStatement bindStatement(Statement statement, String name, Object value, DataType.Name typeName) { public static BoundStatement bindStatement(Statement statement, String name, Object value, DataType.Name typeName) {
switch (typeName) { switch (typeName) {
case TEXT: // TEXT(10, String.class)
case ASCII: // ASCII(1, String.class) case ASCII: // ASCII(1, String.class)
return ((BoundStatement) statement).bind().setString(name, (String) value); return ((BoundStatement) statement).bind().setString(name, (String) value);
case VARCHAR: // VARCHAR(13, String.class) case VARCHAR: // VARCHAR(13, String.class)
return ((BoundStatement) statement).bind().setString(name, (String) value);
case TEXT: // TEXT(10, String.class)
return ((BoundStatement) statement).bind().setString(name, (String) value);
case BIGINT: // BIGINT(2, Long.class) case BIGINT: // BIGINT(2, Long.class)
return ((BoundStatement) statement).bind().setLong(name, (long) value);
case COUNTER: // COUNTER(5, Long.class) case COUNTER: // COUNTER(5, Long.class)
return ((BoundStatement) statement).bind().setLong(name, (long) value); return ((BoundStatement) statement).bind().setLong(name, (long) value);
case BLOB: // BLOB(3, ByteBuffer.class) case BLOB: // BLOB(3, ByteBuffer.class)
@@ -102,23 +99,19 @@ public class CQLBindHelper {
return ((BoundStatement) statement).bind().setFloat(name, (float) value); return ((BoundStatement) statement).bind().setFloat(name, (float) value);
case INET: // INET(16, InetAddress.class) case INET: // INET(16, InetAddress.class)
return ((BoundStatement) statement).bind().setInet(name, (InetAddress) value); return ((BoundStatement) statement).bind().setInet(name, (InetAddress) value);
case INT: // INT(9, Integer.class)
return ((BoundStatement) statement).bind().setInt(name, (int) value);
case TIMESTAMP: // TIMESTAMP(11, Date.class) case TIMESTAMP: // TIMESTAMP(11, Date.class)
return ((BoundStatement) statement).bind().setTimestamp(name, (Date) value); return ((BoundStatement) statement).bind().setTimestamp(name, (Date) value);
case UUID: // UUID(12, UUID.class) case UUID: // UUID(12, UUID.class)
return ((BoundStatement) statement).bind().setUUID(name, (UUID) value);
case TIMEUUID: // TIMEUUID(15, UUID.class) case TIMEUUID: // TIMEUUID(15, UUID.class)
return ((BoundStatement) statement).bind().setUUID(name, (UUID) value); return ((BoundStatement) statement).bind().setUUID(name, (UUID) value);
case VARINT: // VARINT(14, BigInteger.class)
return ((BoundStatement) statement).bind().setInt(name, (int) value);
case UDT: // UDT(48, UDTValue.class) case UDT: // UDT(48, UDTValue.class)
return ((BoundStatement) statement).bind().setUDTValue(name, (UDTValue) value); return ((BoundStatement) statement).bind().setUDTValue(name, (UDTValue) value);
case TUPLE: // TUPLE(49, TupleValue.class case TUPLE: // TUPLE(49, TupleValue.class
return ((BoundStatement) statement).bind().setTupleValue(name, (TupleValue) value); return ((BoundStatement) statement).bind().setTupleValue(name, (TupleValue) value);
case VARINT: // VARINT(14, BigInteger.class)
case SMALLINT: case SMALLINT:
return ((BoundStatement) statement).bind().setInt(name, (int) value);
case TINYINT: case TINYINT:
case INT: // INT(9, Integer.class)
return ((BoundStatement) statement).bind().setInt(name, (int) value); return ((BoundStatement) statement).bind().setInt(name, (int) value);
case DATE: case DATE:
return ((BoundStatement) statement).bind().setDate(name, (LocalDate) value); return ((BoundStatement) statement).bind().setDate(name, (LocalDate) value);
@@ -129,7 +122,7 @@ public class CQLBindHelper {
} }
} }
public static Map<String, String> parseAndGetSpecificBindings(OpDef opDef, ParsedStmt parsed) { public static Map<String, String> parseAndGetSpecificBindings(OpDef<?> opDef, ParsedStmt parsed) {
List<String> spans = new ArrayList<>(); List<String> spans = new ArrayList<>();
String statement = opDef.getStmt(); String statement = opDef.getStmt();