ScyllaDB Module

ScyllaDB is a distributed NoSQL wide-column database for data-intensive apps that require high performance and low latency. It was designed to be compatible with Apache Cassandra while achieving significantly higher throughputs and lower latencies.

Install

npm install @testcontainers/scylladb --save-dev

Examples

Connect:

it("should connect and execute a query", async () => {
  const container = await new ScyllaContainer("scylladb/scylla:6.2.0").start();

  const client = new Client({
    contactPoints: [container.getContactPoint()],
    localDataCenter: container.getDatacenter(),
    keyspace: "system",
  });

  await client.connect();

  const result = await client.execute("SELECT cql_version FROM system.local");
  expect(result.rows[0].cql_version).toBe("3.3.1");

  await client.shutdown();
  await container.stop();
});

Insert & fetch data:

it("should create keyspace, a table, insert data, and retrieve it", async () => {
  const container = await new ScyllaContainer().start();

  const client = new Client({
    contactPoints: [container.getContactPoint()],
    localDataCenter: container.getDatacenter(),
  });

  await client.connect();

  // Create the keyspace
  await client.execute(`
    CREATE KEYSPACE IF NOT EXISTS test_keyspace
    WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '1'}
  `);

  await client.execute("USE test_keyspace");

  // Create the table.
  await client.execute(`
    CREATE TABLE IF NOT EXISTS test_keyspace.users (
      id UUID PRIMARY KEY,
      name text
    )
  `);

  // Insert a record
  const id = "d002cd08-401a-47d6-92d7-bb4204d092f8"; // Fixed UUID for testing
  const username = "Test McTestinson";
  await client.execute("INSERT INTO test_keyspace.users (id, name) VALUES (?, ?)", [id, username]);

  // Fetch and verify the record
  const result = await client.execute("SELECT * FROM test_keyspace.users WHERE id = ?", [id], { prepare: true });
  expect(result.rows[0].name).toEqual(username);

  await client.shutdown();
  await container.stop();
});