Skip to content

Commit 2321201

Browse files
committed
Cover LOCAL_SERIAL select in tablet routing matrix
1 parent 82e590e commit 2321201

1 file changed

Lines changed: 14 additions & 0 deletions

File tree

integration-tests/src/test/java/com/datastax/oss/driver/core/metadata/DefaultMetadataTabletMapIT.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44

55
import com.datastax.oss.driver.api.core.CqlIdentifier;
66
import com.datastax.oss.driver.api.core.CqlSession;
7+
import com.datastax.oss.driver.api.core.DefaultConsistencyLevel;
78
import com.datastax.oss.driver.api.core.config.DefaultDriverOption;
89
import com.datastax.oss.driver.api.core.cql.PreparedStatement;
910
import com.datastax.oss.driver.api.core.cql.ResultSet;
@@ -120,6 +121,10 @@ public class DefaultMetadataTabletMapIT {
120121
private static final SimpleStatement STMT_SELECT_CK_CONCRETE =
121122
buildStatement("SELECT pk, ck FROM %s.%s WHERE pk = ? AND ck = 1");
122123

124+
private static final SimpleStatement STMT_SELECT_LOCAL_SERIAL =
125+
buildStatement("SELECT pk,ck FROM %s.%s WHERE pk = ? AND ck = ?")
126+
.setConsistencyLevel(DefaultConsistencyLevel.LOCAL_SERIAL);
127+
123128
private static final SimpleStatement STMT_UPDATE =
124129
buildStatement("UPDATE %s.%s SET val = 1 WHERE pk = ? AND ck = ?");
125130

@@ -195,6 +200,8 @@ public void every_statement_should_deliver_tablet_info() {
195200
statements.put("SELECT_CONCRETE_PREPARED", s -> s.prepare(STMT_SELECT_CONCRETE).bind());
196201
statements.put("SELECT_PK_CONCRETE_PREPARED", s -> s.prepare(STMT_SELECT_PK_CONCRETE).bind(2));
197202
statements.put("SELECT_CK_CONCRETE_PREPARED", s -> s.prepare(STMT_SELECT_CK_CONCRETE).bind(2));
203+
statements.put(
204+
"SELECT_LOCAL_SERIAL_PREPARED", s -> s.prepare(STMT_SELECT_LOCAL_SERIAL).bind(2, 2));
198205
statements.put("INSERT_CONCRETE", s -> STMT_INSERT_CONCRETE);
199206
statements.put("INSERT_PREPARED", s -> s.prepare(STMT_INSERT).bind(2, 2));
200207
statements.put("INSERT_NO_KS_PREPARED", s -> s.prepare(STMT_INSERT_NO_KS).bind(2, 2));
@@ -256,6 +263,13 @@ public void every_statement_should_deliver_tablet_info() {
256263
ex.addSuppressed(e);
257264
throw ex;
258265
}
266+
if (stmtEntry.getKey().contains("LOCAL_SERIAL") && !stmt.isLWT()) {
267+
testErrors.add(
268+
String.format(
269+
"Statement %s on session %s was not recognized as LWT",
270+
stmtEntry.getKey(), sessionEntry.getKey()));
271+
continue;
272+
}
259273
try {
260274
if (!executeOnAllHostsAndReturnIfResultHasTabletsInfo(session, stmt)) {
261275
testErrors.add(

0 commit comments

Comments
 (0)