validator/tests: add vector_similarity() function test

Add tests to validate the results of vector_similarity() function.

Refs: scylladb/scylladb#25993

Author: QuerthDP

crates/validator/src/tests/mod.rs

@@ -8,6 +8,7 @@ mod crud;
 mod full_scan;
 mod reconnect;
 mod serde;
+mod vector_similarity;
 
 use crate::ServicesSubnet;
 use crate::dns::Dns;
@@ -221,6 +222,7 @@ pub(crate) async fn register() -> Vec<(String, TestCase)> {
         ("full_scan", full_scan::new().await),
         ("reconnect", reconnect::new().await),
         ("serde", serde::new().await),
+        ("vector_similarity", vector_similarity::new().await),
     ]
     .into_iter()
     .map(|(name, test_case)| (name.to_string(), test_case))

crates/validator/src/tests/vector_similarity.rs

@@ -0,0 +1,212 @@
+/*
+ * Copyright 2025-present ScyllaDB
+ * SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
+ */
+
+use crate::common::*;
+use crate::tests::*;
+use scylla::client::session::Session;
+use std::time::Duration;
+use tracing::info;
+
+pub(crate) async fn new() -> TestCase {
+    let timeout = Duration::from_secs(30);
+    TestCase::empty()
+        .with_init(timeout, init)
+        .with_cleanup(timeout, cleanup)
+        .with_test(
+            "vector_similarity_function_returns_expected_results",
+            timeout,
+            vector_similarity_function_returns_expected_results,
+        )
+        .with_test(
+            "vector_similarity_function_with_clustering_key",
+            timeout,
+            vector_similarity_function_with_clustering_key,
+        )
+        .with_test(
+            "vector_similarity_function_with_multi_column_partition_key",
+            timeout,
+            vector_similarity_function_with_multi_column_partition_key,
+        )
+}
+
+pub(crate) static EMBEDDINGS: [[f32; 3]; 3] = [[1.0, 2.0, 3.0], [4.0, 5.0, 6.0], [7.0, 8.0, 9.0]];
+
+async fn check_similarity_function_results(session: &Session, table: &str, key_column: &str) {
+    let results = get_query_results(
+        format!(
+            "SELECT {key_column}, vector_similarity() FROM {table} ORDER BY v ANN OF [0.0, 0.0, 0.0] LIMIT 5"
+        ),
+        &session,
+    )
+    .await;
+    let rows = results.rows::<(i32, f32)>().expect("failed to get rows");
+    assert_eq!(rows.rows_remaining(), 3);
+
+    // Expected results are calculated using Euclidean distance formula
+    let expected_distances = [(0, 14.0), (1, 77.0), (2, 194.0)];
+    for (i, row) in rows.enumerate() {
+        let row = row.expect("failed to get row");
+        let (key, distance) = row;
+        assert_eq!(
+            (key, distance),
+            expected_distances[i],
+            "Row {i} does not match expected result"
+        );
+    }
+}
+
+async fn vector_similarity_function_returns_expected_results(actors: TestActors) {
+    info!("started");
+
+    let (session, client) = prepare_connection(&actors).await;
+
+    let keyspace = create_keyspace(&session).await;
+    let table = create_table(&session, "pk INT PRIMARY KEY, v VECTOR<FLOAT, 3>", None).await;
+
+    // Insert test data
+    for (i, embedding) in EMBEDDINGS.into_iter().enumerate() {
+        session
+            .query_unpaged(
+                format!("INSERT INTO {table} (pk, v) VALUES (?, ?)"),
+                (i as i32, embedding.as_slice()),
+            )
+            .await
+            .expect("failed to insert data");
+    }
+
+    // Create index with EUCLIDEAN similarity function
+    let index = create_index(
+        &session,
+        &client,
+        &table,
+        "v",
+        Some("{'similarity_function' : 'EUCLIDEAN'}"),
+    )
+    .await;
+
+    wait_for(
+        || async { client.count(&index.keyspace, &index.index).await == Some(3) },
+        "Waiting for 3 vectors to be indexed",
+        Duration::from_secs(5),
+    )
+    .await;
+
+    // Check if the query returns the expected distances
+    check_similarity_function_results(&session, &table, "pk").await;
+
+    // Drop keyspace
+    session
+        .query_unpaged(format!("DROP KEYSPACE {keyspace}"), ())
+        .await
+        .expect("failed to drop a keyspace");
+
+    info!("finished");
+}
+
+async fn vector_similarity_function_with_clustering_key(actors: TestActors) {
+    info!("started");
+
+    let (session, client) = prepare_connection(&actors).await;
+
+    let keyspace = create_keyspace(&session).await;
+    let table = create_table(
+        &session,
+        "pk INT, ck INT, v VECTOR<FLOAT, 3>, PRIMARY KEY (pk, ck)",
+        None,
+    )
+    .await;
+
+    // Insert test data
+    for (i, embedding) in EMBEDDINGS.into_iter().enumerate() {
+        session
+            .query_unpaged(
+                format!("INSERT INTO {table} (pk, ck, v) VALUES (?, ?, ?)"),
+                (123, i as i32, &embedding.as_slice()),
+            )
+            .await
+            .expect("failed to insert data");
+    }
+
+    // Create index with EUCLIDEAN similarity function
+    let index = create_index(
+        &session,
+        &client,
+        &table,
+        "v",
+        Some("{'similarity_function' : 'EUCLIDEAN'}"),
+    )
+    .await;
+
+    wait_for(
+        || async { client.count(&index.keyspace, &index.index).await == Some(3) },
+        "Waiting for 3 vectors to be indexed",
+        Duration::from_secs(5),
+    )
+    .await;
+
+    // Check if the query returns the expected distances
+    check_similarity_function_results(&session, &table, "ck").await;
+
+    // Drop keyspace
+    session
+        .query_unpaged(format!("DROP KEYSPACE {keyspace}"), ())
+        .await
+        .expect("failed to drop a keyspace");
+
+    info!("finished");
+}
+
+async fn vector_similarity_function_with_multi_column_partition_key(actors: TestActors) {
+    info!("started");
+
+    let (session, client) = prepare_connection(&actors).await;
+
+    let keyspace = create_keyspace(&session).await;
+    let table = create_table(
+        &session,
+        "pk1 INT, pk2 INT, v VECTOR<FLOAT, 3>, PRIMARY KEY ((pk1, pk2))",
+        None,
+    )
+    .await;
+
+    // Insert test data
+    for (i, embedding) in EMBEDDINGS.into_iter().enumerate() {
+        session
+            .query_unpaged(
+                format!("INSERT INTO {table} (pk1, pk2, v) VALUES (?, ?, ?)"),
+                (123, i as i32, &embedding.as_slice()),
+            )
+            .await
+            .expect("failed to insert data");
+    }
+
+    // Create index with EUCLIDEAN similarity function
+    let index = create_index(
+        &session,
+        &client,
+        &table,
+        "v",
+        Some("{'similarity_function' : 'EUCLIDEAN'}"),
+    )
+    .await;
+
+    wait_for(
+        || async { client.count(&index.keyspace, &index.index).await == Some(3) },
+        "Waiting for 3 vectors to be indexed",
+        Duration::from_secs(5),
+    )
+    .await;
+
+    // Check if the query returns the expected distances
+    check_similarity_function_results(&session, &table, "pk2").await;
+
+    // Drop keyspace
+    session
+        .query_unpaged(format!("DROP KEYSPACE {keyspace}"), ())
+        .await
+        .expect("failed to drop a keyspace");
+
+    info!("finished");
+}