Using the DataStax Java Driver for Cassandra

The Cassandra Java Driver is a Java library used to connect and interact with Cassandra databases. It allows developers to directly access and manipulate Cassandra tables within Java applications.

Installation and Configuration

To use the DataStax Java Driver, you first need to add the driver to your Maven or Gradle dependencies.

• Maven:

    com.datastax.driver
    core
    4.12.1

• Gradle:

dependencies {
    implementation 'com.datastax.driver:core:4.12.1'
}

Basic Usage

To use the DataStax Java Driver, you first need to create a connection. Connection properties can be configured according to specific requirements.

creating connection

// Generate connection
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
Session session = cluster.connect();

// Execute SQL statement
session.execute("SELECT * FROM keyspace_name.table_name");

Closing the connection

Closing the connection requires manually calling cluster.close().

Examples: insert, update, and delete operations

insert operation

// Insert data
HashMap data = new HashMap<>();
data.put("column1", "value1");
data.put("column2", "value2");
 session.execute("INSERT INTO keyspace_name.table_name (column1,column2) VALUES (" + data.get("column1") + ","+ data.get("column2") + ")");

update operation

// Update data
HashMap data = new HashMap<>();
data.put("column1", "value3");
session.execute("UPDATE keyspace_name.table_name SET column1=VALUES(column1) WHERE column2='value4'");

delete operation

// Delete data
session.execute("DELETE FROM keyspace_name.table_name WHERE column1='value5' AND column2='value6'");

Example: Complete code for interacting with Cassandra using DataStax Java Driver

public class DataStaxConnection {
    public static void main(String[] args) {
        Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
        Session session = cluster.connect();

        // Insert data
        HashMap data = new HashMap<>();
        data.put("column1", "value1");
        data.put("column2", "value2");

        session.execute("INSERT INTO keyspace_name.table_name (column1,column2) VALUES (" + data.get("column1") + ","+ data.get("column2") + ")");

        // Update data
        HashMap updateData = new HashMap<>();
        updateData.put("column1", "value3");
        session.execute("UPDATE keyspace_name.table_name SET column1=VALUES(column1) WHERE column2='value4'");

        // Delete data
        session.execute("DELETE FROM keyspace_name.table_name WHERE column1='value5' AND column2='value6'");

        // Close connection
        cluster.close();
    }
}

Questions and Solutions

• Error: Driver package not found

Solution: Ensure that the DataStax Java Driver jar is added to your Maven or Gradle dependencies and that the version is consistent.

• Error: Unable to connect to Cassandra

Solution: Check if the Cassandra service is running, verify that the Cassandra nodes are correct, and ensure the Cassandra configuration file (config.ini) is correct.