Xandra

Fast, simple, and robust Cassandra driver for Elixir.

Xandra is a Cassandra driver built natively in Elixir and focused on speed, simplicity, and robustness. This driver works exclusively with the Cassandra Query Language v3 (CQL3) and the native protocol (v3, and v4 are currently supported).

Features

This library is in its early stages when it comes to features, but we're already successfully using it in production at Forza Football. Currently, the supported features are:

• performing queries (including parameterized queries) on the Cassandra database
• connection pooling
• reconnections in case of connection loss
• prepared queries (including a local cache of prepared queries on a per-connection basis)
• batch queries
• page streaming
• compression
• clustering (random and priority load balancing for now)
• customizable retry strategies for failed queries
• user-defined types
• authentication

In the future, we plan to add more features, like more load balancing strategies for clustering. See the documentation for detailed explanation of how the supported features work.

Installation

Add the :xandra dependency to your mix.exs file:

def deps() do
  [{:xandra, "~> 0.10"}]
end

and add :xandra to your list of applications:

def application() do
  [applications: [:logger, :xandra]]
end

Then, run mix deps.get in your shell to fetch the new dependency.

Overview

The documentation is available on HexDocs.

Connections or pool of connections can be started with Xandra.start_link/1:

{:ok, conn} = Xandra.start_link(nodes: ["127.0.0.1:9042"])

This connection can be used to perform all operations against the Cassandra server.

Executing simple queries looks like this:

statement = "INSERT INTO users (name, postcode) VALUES ('Priam', 67100)"
{:ok, %Xandra.Void{}} = Xandra.execute(conn, statement, _params = [])

Preparing and executing a query:

with {:ok, prepared} <- Xandra.prepare(conn, "SELECT * FROM users WHERE name = ?"),
     {:ok, %Xandra.Page{}} <- Xandra.execute(conn, prepared, [_name = "Priam"]),
     do: Enum.to_list(page)

Xandra supports streaming pages:

prepared = Xandra.prepare!(conn, "SELECT * FROM subscriptions WHERE topic = :topic")
page_stream = Xandra.stream_pages!(conn, prepared, _params = [], page_size: 1_000)

# This is going to execute the prepared query every time a new page is needed:
page_stream
|> Enum.take(10)
|> Enum.each(fn(page) -> IO.puts "Got a bunch of rows: #{inspect(Enum.to_list(page))}" end)

Contributing

To run tests, you need Cassandra running on your machine on port 9042. You can:

• install Cassandra and run it locally

• use Docker to run a Cassandra container locally. If you choose this way, you only need to have Docker installed. To run the test setup, just run:

  docker-compose up

Once you have Cassandra running (one way or the other), run $ mix test to run tests.

License

Xandra is released under the ISC license, see the LICENSE file.