natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'cassandra-4.1' into trunk

This commit is contained in:
Andrés de la Peña 2022-07-14 15:48:08 +01:00
parent dfd152cfa0 27a31f4cfa
commit 520fb2bb24
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
test/distributed/org/apache/cassandra/distributed/upgrade/BatchUpgradeTest.java
View File

@ -20,6 +20,7 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import org.apache.cassandra.Util;
import org.apache.cassandra.distributed.api.ConsistencyLevel;
import static org.junit.Assert.assertEquals;
@ -31,26 +32,24 @@ public class BatchUpgradeTest extends UpgradeTestBase
{
new TestCase()
.nodes(2)
.nodesToUpgrade(2)
.upgradesToCurrentFrom(v40).setup((cluster) -> {
cluster.schemaChange("CREATE TABLE "+KEYSPACE+".users (" +
cluster.schemaChange("CREATE TABLE " + KEYSPACE + ".users (" +
"userid uuid PRIMARY KEY," +
"firstname ascii," +
"lastname ascii," +
"age int) WITH COMPACT STORAGE");
}).runAfterNodeUpgrade((cluster, node) -> {
cluster.coordinator(2).execute("BEGIN BATCH\n" +
" UPDATE "+KEYSPACE+".users SET age = 37 WHERE userid = f47ac10b-58cc-4372-a567-0e02b2c3d479\n" +
" DELETE firstname, lastname FROM "+KEYSPACE+".users WHERE userid = 550e8400-e29b-41d4-a716-446655440000\n" +
" UPDATE " + KEYSPACE + ".users SET age = 37 WHERE userid = f47ac10b-58cc-4372-a567-0e02b2c3d479\n" +
" DELETE firstname, lastname FROM " + KEYSPACE + ".users WHERE userid = 550e8400-e29b-41d4-a716-446655440000\n" +
"APPLY BATCH", ConsistencyLevel.ALL);
}).runAfterClusterUpgrade((cluster) -> {
assertEquals(0, cluster.get(1).executeInternal("select * from system.batches").length);
assertEquals(0, cluster.get(2).executeInternal("select * from system.batches").length);
Util.spinAssertEquals(0, () -> cluster.get(1).executeInternal("select * from system.batches").length, 10);
Util.spinAssertEquals(0, () -> cluster.get(2).executeInternal("select * from system.batches").length, 10);
assertEquals(0, cluster.get(1).logs().grep("ClassCastException").getResult().size());
assertEquals(0, cluster.get(2).logs().grep("ClassCastException").getResult().size());
})
.run();
}
}