Support – Connect to Cassandra with C#

Connect to Cassandra with C#

In this article, we will introduce how to connect to Cassandra by using C#. We will start to install C# development environment and then provide simple demo code for connecting remote server (Cassandra) and local program.

Download Visual Studio Community

Go to visualstudio and choose Community Version to install.

Install Visual Studio

Follow the instructions and install.

Create a new project

Choose Console Project and click Next.

Enter Project Name and click Create

Install Cassandra C# driver

In the left side of your development window, Open Solution View and notice that there is a folder called Packages.

Right-click Packages and click Add Packages…

Find out CassandraCSharpDriver in the window, and click Add Package.

If you unfold the Packages folder, you will see that a list of libraries has been installed in your local project.

Write sample code

Replace public IP, username, and password with your real settings.

using System;
using Cassandra;

namespace Instaclustr.Cassandra.ConnectionSample
{
    class MainClass
    {
        public static void Main(string[] args)
        {
            Console.WriteLine("Hello Cassandra!");

            var cluster = Cluster.Builder()
                                 .AddContactPoints(<PUBLIC IP1>, <PUBLIC IP2>, <PUBLIC IP3>,..)
                                 .WithPort(9042)
                                 .WithLoadBalancingPolicy(new DCAwareRoundRobinPolicy("AWS_VPC_AP_SOUTHEAST_2"))
                                 .WithAuthProvider(new PlainTextAuthProvider(<Username>, <Password>))
                                 .Build();

            // Connect to the nodes using a keyspace
            var session = cluster.Connect("system_distributed");

            // Get name of a Cluster
            Console.WriteLine("The cluster's name is: " + cluster.Metadata.ClusterName);

            // Execute a query on a connection synchronously
            var rs = session.Execute("SELECT * FROM repair_history");

            // Iterate through the RowSet
            foreach (var row in rs)
            {
                var value = row.GetValue<string>("keyspace_name");
                Console.WriteLine(value);
                // Do something with the value
            }
        }
    }
}

using System;

using Cassandra;

namespace Instaclustr.Cassandra.ConnectionSample

{

class MainClass

{

public static void Main(string[] args)

{

Console.WriteLine("Hello Cassandra!");

var cluster = Cluster.Builder()

.AddContactPoints(<PUBLIC IP1>, <PUBLIC IP2>, <PUBLIC IP3>,..)

.WithPort(9042)

.WithLoadBalancingPolicy(new DCAwareRoundRobinPolicy("AWS_VPC_AP_SOUTHEAST_2"))

.WithAuthProvider(new PlainTextAuthProvider(<Username>, <Password>))

.Build();

// Connect to the nodes using a keyspace

var session = cluster.Connect("system_distributed");

// Get name of a Cluster

Console.WriteLine("The cluster's name is: " + cluster.Metadata.ClusterName);

// Execute a query on a connection synchronously

var rs = session.Execute("SELECT * FROM repair_history");

// Iterate through the RowSet

foreach (var row in rs)

{

var value = row.GetValue<string>("keyspace_name");

Console.WriteLine(value);

// Do something with the value

}

Click Run and Start without Debugging, we can see the result as the following