f3eade2f62
Drop the AGPL license in favor of a source-available license. See the blog post [1] for details. [1] https://www.scylladb.com/2024/12/18/why-were-moving-to-a-source-available-license/
258 lines
7.5 KiB
Plaintext
258 lines
7.5 KiB
Plaintext
> --
|
|
> -- Modified by ScyllaDB
|
|
> -- from cassandra/test/unit/org/apache/cassandra/cql3/validation/operations/BatchTest.java
|
|
> --
|
|
> --
|
|
> --------------------------------------------------------------------------------
|
|
> --
|
|
> -- Copyright (C) 2016-present ScyllaDB
|
|
> --
|
|
> -- Modified by ScyllaDB
|
|
> --
|
|
> -- SPDX-License-Identifier: (LicenseRef-ScyllaDB-Source-Available-1.0 and Apache-2.0)
|
|
>
|
|
> -- setup
|
|
> CREATE KEYSPACE k WITH replication = {'class': 'NetworkTopologyStrategy', 'replication_factor': 1};
|
|
OK
|
|
> USE k;
|
|
OK
|
|
>
|
|
> -- testBatch
|
|
> CREATE TABLE t (userid text PRIMARY KEY, name text, password text);
|
|
OK
|
|
> BEGIN BATCH
|
|
> INSERT INTO t (userid, password, name) VALUES ('user2', 'ch@ngem3b', 'second user')
|
|
> UPDATE t SET password = 'ps22dhds' WHERE userid = 'user3'
|
|
> INSERT INTO t (userid, password) VALUES ('user4', 'ch@ngem3c')
|
|
> DELETE name FROM t WHERE userid = 'user1'
|
|
> APPLY BATCH;
|
|
OK
|
|
> SELECT * FROM t;
|
|
+----------+-------------+------------+
|
|
| userid | name | password |
|
|
|----------+-------------+------------|
|
|
| user2 | second user | ch@ngem3b |
|
|
| user4 | null | ch@ngem3c |
|
|
| user3 | null | ps22dhds |
|
|
+----------+-------------+------------+
|
|
> DROP TABLE t;
|
|
OK
|
|
> --
|
|
> -- testBatchAndList
|
|
> CREATE TABLE t (k int PRIMARY KEY, l list<int>);
|
|
OK
|
|
> BEGIN BATCH
|
|
> UPDATE t SET l = l + [ 1 ] WHERE k = 0
|
|
> UPDATE t SET l = l + [ 2 ] WHERE k = 0
|
|
> UPDATE t SET l = l + [ 3 ] WHERE k = 0
|
|
> APPLY BATCH;
|
|
OK
|
|
> SELECT l FROM t WHERE k = 0;
|
|
+-----------+
|
|
| l |
|
|
|-----------|
|
|
| [1, 2, 3] |
|
|
+-----------+
|
|
> BEGIN BATCH
|
|
> UPDATE t SET l = [ 1 ] + l WHERE k = 1
|
|
> UPDATE t SET l = [ 2 ] + l WHERE k = 1
|
|
> UPDATE t SET l = [ 3 ] + l WHERE k = 1
|
|
> APPLY BATCH;
|
|
OK
|
|
> SELECT l FROM t WHERE k = 1;
|
|
+-----------+
|
|
| l |
|
|
|-----------|
|
|
| [3, 2, 1] |
|
|
+-----------+
|
|
> DROP TABLE t;
|
|
OK
|
|
> --
|
|
> -- testBatchDeleteInsert
|
|
> CREATE TABLE t (k int, v int, PRIMARY KEY (k, v));
|
|
OK
|
|
> INSERT INTO t (k, v) VALUES (0, 1);
|
|
OK
|
|
> BEGIN BATCH
|
|
> DELETE FROM t WHERE k=0 AND v=1
|
|
> INSERT INTO t (k, v) VALUES (0, 2)
|
|
> APPLY BATCH;
|
|
OK
|
|
> SELECT * FROM t;
|
|
+-----+-----+
|
|
| k | v |
|
|
|-----+-----|
|
|
| 0 | 2 |
|
|
+-----+-----+
|
|
> DROP TABLE t;
|
|
OK
|
|
>
|
|
> -- testBatchWithUnset
|
|
> CREATE TABLE t (k int PRIMARY KEY, s text, i int);
|
|
OK
|
|
> BEGIN BATCH
|
|
> INSERT INTO t JSON '{"k": 100, "s": null}' DEFAULT UNSET
|
|
> INSERT INTO t JSON '{"k": 111, "i": null}' DEFAULT UNSET
|
|
> APPLY BATCH;
|
|
OK
|
|
> SELECT k, s, i FROM t where k in (100,111);
|
|
+-----+------+------+
|
|
| k | s | i |
|
|
|-----+------+------|
|
|
| 100 | null | null |
|
|
| 111 | null | null |
|
|
+-----+------+------+
|
|
> DROP TABLE t;
|
|
OK
|
|
>
|
|
> -- testBatchUpdate
|
|
> CREATE TABLE t (partitionKey int, clustering_1 int, value int, PRIMARY KEY (partitionKey, clustering_1));
|
|
OK
|
|
> INSERT INTO t (partitionKey, clustering_1, value) VALUES (0, 0, 0);
|
|
OK
|
|
> INSERT INTO t (partitionKey, clustering_1, value) VALUES (0, 1, 1);
|
|
OK
|
|
> INSERT INTO t (partitionKey, clustering_1, value) VALUES (0, 2, 2);
|
|
OK
|
|
> INSERT INTO t (partitionKey, clustering_1, value) VALUES (0, 3, 3);
|
|
OK
|
|
> INSERT INTO t (partitionKey, clustering_1, value) VALUES (0, 4, 4);
|
|
OK
|
|
> INSERT INTO t (partitionKey, clustering_1, value) VALUES (0, 5, 5);
|
|
OK
|
|
> INSERT INTO t (partitionKey, clustering_1, value) VALUES (0, 6, 6);
|
|
OK
|
|
>
|
|
> BEGIN BATCH
|
|
> UPDATE t SET value = 7 WHERE partitionKey = 0 AND clustering_1 = 1
|
|
> UPDATE t SET value = 8 WHERE partitionKey = 0 AND (clustering_1) = (2)
|
|
> UPDATE t SET value = 10 WHERE partitionKey = 0 AND clustering_1 IN (3, 4)
|
|
> UPDATE t SET value = 20 WHERE partitionKey = 0 AND (clustering_1) IN ((5), (6))
|
|
> APPLY BATCH;
|
|
OK
|
|
> SELECT * FROM t;
|
|
+----------------+----------------+---------+
|
|
| partitionkey | clustering_1 | value |
|
|
|----------------+----------------+---------|
|
|
| 0 | 0 | 0 |
|
|
| 0 | 1 | 7 |
|
|
| 0 | 2 | 8 |
|
|
| 0 | 3 | 10 |
|
|
| 0 | 4 | 10 |
|
|
| 0 | 5 | 20 |
|
|
| 0 | 6 | 20 |
|
|
+----------------+----------------+---------+
|
|
> DROP TABLE t;
|
|
OK
|
|
>
|
|
> -- testBatchEmpty
|
|
> BEGIN BATCH APPLY BATCH;
|
|
OK
|
|
>
|
|
> -- testBatchMultipleTable
|
|
> CREATE TABLE t1 (k1 int PRIMARY KEY, v11 int, v12 int);
|
|
OK
|
|
> CREATE TABLE t2 (k2 int PRIMARY KEY, v21 int, v22 int);
|
|
OK
|
|
> BEGIN BATCH
|
|
> UPDATE t1 SET v11 = 1 WHERE k1 = 0
|
|
> UPDATE t1 SET v12 = 2 WHERE k1 = 0
|
|
> UPDATE t2 SET v21 = 3 WHERE k2 = 0
|
|
> UPDATE t2 SET v22 = 4 WHERE k2 = 0
|
|
> APPLY BATCH;
|
|
OK
|
|
> SELECT * FROM t1;
|
|
+------+-------+-------+
|
|
| k1 | v11 | v12 |
|
|
|------+-------+-------|
|
|
| 0 | 1 | 2 |
|
|
+------+-------+-------+
|
|
> SELECT * FROM t2;
|
|
+------+-------+-------+
|
|
| k2 | v21 | v22 |
|
|
|------+-------+-------|
|
|
| 0 | 3 | 4 |
|
|
+------+-------+-------+
|
|
> SELECT * FROM t1;
|
|
+------+-------+-------+
|
|
| k1 | v11 | v12 |
|
|
|------+-------+-------|
|
|
| 0 | 1 | 2 |
|
|
+------+-------+-------+
|
|
> SELECT * FROM t2;
|
|
+------+-------+-------+
|
|
| k2 | v21 | v22 |
|
|
|------+-------+-------|
|
|
| 0 | 3 | 4 |
|
|
+------+-------+-------+
|
|
> DROP TABLE t1;
|
|
OK
|
|
> DROP TABLE t2;
|
|
OK
|
|
>
|
|
> -- testBatchWithInRestriction
|
|
> CREATE TABLE t (a int, b int, c int, PRIMARY KEY (a,b));
|
|
OK
|
|
> INSERT INTO t (a,b,c) VALUES (1, 1, 1);
|
|
OK
|
|
> INSERT INTO t (a,b,c) VALUES (1, 2, 2);
|
|
OK
|
|
> INSERT INTO t (a,b,c) VALUES (1, 3, 3);
|
|
OK
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> UPDATE t SET c = 200 WHERE a = 1 AND b IN () IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the clustering key columns is not supported with conditional updates"
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> DELETE FROM t WHERE a = 1 AND b IN () IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the clustering key columns is not supported with conditional deletions"
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> UPDATE t SET c = 200 WHERE a IN () AND b = 1 IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the partition key is not supported with conditional updates"
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> DELETE FROM t WHERE a IN () AND b = 1 IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the partition key is not supported with conditional deletions"
|
|
>
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> UPDATE t SET c = 200 WHERE a = 1 AND b IN (1, 2) IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the clustering key columns is not supported with conditional updates"
|
|
>
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> DELETE FROM t WHERE a = 1 AND b IN (1, 2) IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the clustering key columns is not supported with conditional deletions"
|
|
>
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> UPDATE t SET c = 200 WHERE a IN (1, 2) AND b = 1 IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the partition key is not supported with conditional updates"
|
|
> BEGIN BATCH
|
|
> UPDATE t SET c = 100 WHERE a = 1 AND b = 1 IF c = 1
|
|
> DELETE FROM t WHERE a IN (1, 2) AND b = 1 IF c = 1
|
|
> APPLY BATCH;
|
|
Error from server: code=2200 [Invalid query] message="IN on the partition key is not supported with conditional deletions"
|
|
>
|
|
> SELECT * FROM t;
|
|
+-----+-----+-----+
|
|
| a | b | c |
|
|
|-----+-----+-----|
|
|
| 1 | 1 | 1 |
|
|
| 1 | 2 | 2 |
|
|
| 1 | 3 | 3 |
|
|
+-----+-----+-----+
|
|
> DROP TABLE t;
|
|
OK
|
|
> DROP KEYSPACE k;
|
|
OK
|