Skip to content

Commit 8e7def5

Browse files
Only tests vectors on versions that supports it
1 parent ef211bd commit 8e7def5

File tree

1 file changed

+25
-5
lines changed

1 file changed

+25
-5
lines changed

vector_test.go

Lines changed: 25 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -54,10 +54,14 @@ func TestVector_Marshaler(t *testing.T) {
5454
session := createSession(t)
5555
defer session.Close()
5656

57-
if flagCassVersion.Before(5, 0, 0) {
57+
if *flagDistribution == "cassandra" && flagCassVersion.Before(5, 0, 0) {
5858
t.Skip("Vector types have been introduced in Cassandra 5.0")
5959
}
6060

61+
if *flagDistribution == "scylla" && flagCassVersion.Before(2025, 3, 0) {
62+
t.Skip("Vector types have been introduced in ScyllaDB 2025.3")
63+
}
64+
6165
err := createTable(session, `CREATE TABLE IF NOT EXISTS gocql_test.vector_fixed(id int primary key, vec vector<float, 3>);`)
6266
if err != nil {
6367
t.Fatal(err)
@@ -98,10 +102,14 @@ func TestVector_Types(t *testing.T) {
98102
session := createSession(t)
99103
defer session.Close()
100104

101-
if flagCassVersion.Before(5, 0, 0) {
105+
if *flagDistribution == "cassandra" && flagCassVersion.Before(5, 0, 0) {
102106
t.Skip("Vector types have been introduced in Cassandra 5.0")
103107
}
104108

109+
if *flagDistribution == "scylla" && flagCassVersion.Before(2025, 3, 0) {
110+
t.Skip("Vector types have been introduced in ScyllaDB 2025.3")
111+
}
112+
105113
timestamp1, _ := time.Parse("2006-01-02", "2000-01-01")
106114
timestamp2, _ := time.Parse("2006-01-02 15:04:05", "2024-01-01 10:31:45")
107115
timestamp3, _ := time.Parse("2006-01-02 15:04:05.000", "2024-05-01 10:31:45.987")
@@ -209,10 +217,14 @@ func TestVector_MarshalerUDT(t *testing.T) {
209217
session := createSession(t)
210218
defer session.Close()
211219

212-
if flagCassVersion.Before(5, 0, 0) {
220+
if *flagDistribution == "cassandra" && flagCassVersion.Before(5, 0, 0) {
213221
t.Skip("Vector types have been introduced in Cassandra 5.0")
214222
}
215223

224+
if *flagDistribution == "scylla" && flagCassVersion.Before(2025, 3, 0) {
225+
t.Skip("Vector types have been introduced in ScyllaDB 2025.3")
226+
}
227+
216228
err := createTable(session, `CREATE TYPE gocql_test.person(
217229
first_name text,
218230
last_name text,
@@ -253,10 +265,14 @@ func TestVector_Empty(t *testing.T) {
253265
session := createSession(t)
254266
defer session.Close()
255267

256-
if flagCassVersion.Before(5, 0, 0) {
268+
if *flagDistribution == "cassandra" && flagCassVersion.Before(5, 0, 0) {
257269
t.Skip("Vector types have been introduced in Cassandra 5.0")
258270
}
259271

272+
if *flagDistribution == "scylla" && flagCassVersion.Before(2025, 3, 0) {
273+
t.Skip("Vector types have been introduced in ScyllaDB 2025.3")
274+
}
275+
260276
err := createTable(session, `CREATE TABLE IF NOT EXISTS gocql_test.vector_fixed_null(id int primary key, vec vector<float, 3>);`)
261277
if err != nil {
262278
t.Fatal(err)
@@ -294,10 +310,14 @@ func TestVector_MissingDimension(t *testing.T) {
294310
session := createSession(t)
295311
defer session.Close()
296312

297-
if flagCassVersion.Before(5, 0, 0) {
313+
if *flagDistribution == "cassandra" && flagCassVersion.Before(5, 0, 0) {
298314
t.Skip("Vector types have been introduced in Cassandra 5.0")
299315
}
300316

317+
if *flagDistribution == "scylla" && flagCassVersion.Before(2025, 3, 0) {
318+
t.Skip("Vector types have been introduced in ScyllaDB 2025.3")
319+
}
320+
301321
err := createTable(session, `CREATE TABLE IF NOT EXISTS gocql_test.vector_fixed(id int primary key, vec vector<float, 3>);`)
302322
if err != nil {
303323
t.Fatal(err)

0 commit comments

Comments
 (0)