Skip to content

Commit 4af33a0

Browse files
committed
Use slow profile for DDL queries
1 parent edbf967 commit 4af33a0

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

integration-tests/src/test/java/com/datastax/dse/driver/api/core/cql/continuous/ContinuousPagingIT.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,9 @@ public void simple_statement_paging_should_be_resilient_to_schema_change() {
240240
public void prepared_statement_paging_should_be_resilient_to_schema_change() {
241241
CqlSession session = sessionRule.session();
242242
// Create table and prepare select * query against it.
243-
session.execute("CREATE TABLE test_prep (k text PRIMARY KEY, v int)");
243+
session.execute(
244+
SimpleStatement.newInstance("CREATE TABLE test_prep (k text PRIMARY KEY, v int)")
245+
.setExecutionProfile(SessionUtils.slowProfile(session)));
244246
for (int i = 0; i < 100; i++) {
245247
session.execute(String.format("INSERT INTO test_prep (k, v) VALUES ('foo', %d)", i));
246248
}
@@ -267,7 +269,9 @@ public void prepared_statement_paging_should_be_resilient_to_schema_change() {
267269
CqlSession schemaChangeSession =
268270
SessionUtils.newSession(
269271
ccmRule, session.getKeyspace().orElseThrow(IllegalStateException::new));
270-
schemaChangeSession.execute("ALTER TABLE test_prep DROP v;");
272+
schemaChangeSession.execute(
273+
SimpleStatement.newInstance("ALTER TABLE test_prep DROP v;")
274+
.setExecutionProfile(SessionUtils.slowProfile(schemaChangeSession)));
271275
while (it.hasNext()) {
272276
// Each row should have a value for k, v should still be present, but null since column was
273277
// dropped.

0 commit comments

Comments
 (0)