Skip to content

Commit b6faa86

Browse files
committed
SchemaBuilder add tests
1 parent a4e59b2 commit b6faa86

File tree

4 files changed

+35
-6
lines changed

4 files changed

+35
-6
lines changed

query-builder/src/test/java/com/datastax/oss/driver/api/querybuilder/schema/AlterTableTest.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,4 +108,15 @@ public void should_generate_alter_table_with_no_compression() {
108108
assertThat(alterTable("bar").withNoCompression())
109109
.hasCql("ALTER TABLE bar WITH compression={'sstable_compression':''}");
110110
}
111+
112+
@Test
113+
public void should_generate_alter_table_with_vector() {
114+
assertThat(
115+
alterTable("bar")
116+
.alterColumn(
117+
"v",
118+
DataTypes.custom(
119+
"org.apache.cassandra.db.marshal.VectorType(org.apache.cassandra.db.marshal.FloatType,3)")))
120+
.hasCql("ALTER TABLE bar ALTER v TYPE VECTOR<FLOAT, 3>");
121+
}
111122
}

query-builder/src/test/java/com/datastax/oss/driver/api/querybuilder/schema/AlterTypeTest.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import static com.datastax.oss.driver.api.querybuilder.SchemaBuilder.alterType;
2222

2323
import com.datastax.oss.driver.api.core.type.DataTypes;
24+
import com.datastax.oss.driver.internal.core.type.DefaultVectorType;
2425
import org.junit.Test;
2526

2627
public class AlterTypeTest {
@@ -53,4 +54,10 @@ public void should_generate_alter_table_with_rename_three_columns() {
5354
assertThat(alterType("bar").renameField("x", "y").renameField("u", "v").renameField("b", "a"))
5455
.hasCql("ALTER TYPE bar RENAME x TO y AND u TO v AND b TO a");
5556
}
57+
58+
@Test
59+
public void should_generate_alter_type_with_vector() {
60+
assertThat(alterType("foo", "bar").alterField("vec", new DefaultVectorType(DataTypes.FLOAT, 3)))
61+
.hasCql("ALTER TYPE foo.bar ALTER vec TYPE VECTOR<FLOAT, 3>");
62+
}
5663
}

query-builder/src/test/java/com/datastax/oss/driver/api/querybuilder/schema/CreateTableTest.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import com.datastax.oss.driver.api.querybuilder.SchemaBuilder.RowsPerPartition;
2828
import com.datastax.oss.driver.api.querybuilder.schema.compaction.TimeWindowCompactionStrategy.CompactionWindowUnit;
2929
import com.datastax.oss.driver.api.querybuilder.schema.compaction.TimeWindowCompactionStrategy.TimestampResolution;
30+
import com.datastax.oss.driver.internal.core.type.DefaultVectorType;
3031
import com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap;
3132
import java.nio.charset.StandardCharsets;
3233
import org.junit.Test;
@@ -316,11 +317,11 @@ public void should_generate_create_table_time_window_compaction() {
316317
}
317318

318319
@Test
319-
public void should_generate_vector_column(){
320-
assertThat(createTable("foo")
321-
.withPartitionKey("k", DataTypes.INT)
322-
.withColumn("v", DataTypes.custom("org.apache.cassandra.db.marshal.VectorType(org.apache.cassandra.db.marshal.FloatType,3)")
323-
))
324-
.hasCql("CREATE TABLE foo (k int PRIMARY KEY,v VECTOR<FLOAT, 3>)");
320+
public void should_generate_vector_column() {
321+
assertThat(
322+
createTable("foo")
323+
.withPartitionKey("k", DataTypes.INT)
324+
.withColumn("v", new DefaultVectorType(DataTypes.FLOAT, 3)))
325+
.hasCql("CREATE TABLE foo (k int PRIMARY KEY,v VECTOR<FLOAT, 3>)");
325326
}
326327
}

query-builder/src/test/java/com/datastax/oss/driver/api/querybuilder/schema/CreateTypeTest.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import static com.datastax.oss.driver.api.querybuilder.SchemaBuilder.udt;
2323

2424
import com.datastax.oss.driver.api.core.type.DataTypes;
25+
import com.datastax.oss.driver.internal.core.type.DefaultVectorType;
2526
import org.junit.Test;
2627

2728
public class CreateTypeTest {
@@ -83,4 +84,13 @@ public void should_create_type_with_collections() {
8384
.withField("map", DataTypes.mapOf(DataTypes.INT, DataTypes.TEXT)))
8485
.hasCql("CREATE TYPE ks1.type (map map<int, text>)");
8586
}
87+
88+
@Test
89+
public void should_create_type_with_vector() {
90+
assertThat(
91+
createType("ks1", "type")
92+
.withField("c1", DataTypes.INT)
93+
.withField("vec", new DefaultVectorType(DataTypes.FLOAT, 3)))
94+
.hasCql("CREATE TYPE ks1.type (c1 int,vec VECTOR<FLOAT, 3>)");
95+
}
8696
}

0 commit comments

Comments
 (0)