golang-driver

Golang wrapper of the DataStax/Cassandra C/C++ driver

Basic support for prepared statements and ad hoc queries. Lacking support for collections, but that will be remedied shortly.

Build

1. Build and install the DataStax C/C++ driver
2. Install go get github.com/mstump/golang-driver/cassandra
3. Run the example go run $GOPATH/src/github.com/mstump/golang-driver/examples/basic.go

Example Usage

package main

import (
	"fmt"
	"golang-driver/cassandra"
)

func main() {
	cluster := cassandra.NewCluster()
	cluster.SetContactPoints("cassandra")
	defer cluster.Finalize()

	session := cassandra.NewSession()
	defer session.Finalize()

	sessfuture := cluster.SessionConnect(session)
	sessfuture.Wait()
	defer sessfuture.Finalize()

	statement := cassandra.NewStatement("select cluster_name from system.local;", 0)
	defer statement.Finalize()

	stmtfuture := session.Execute(statement)
	stmtfuture.Wait()
	defer stmtfuture.Finalize()

	result := stmtfuture.Result()
	defer result.Finalize()

	fmt.Printf("Clusters:\r\n")
	for result.Next() {
		var clusterName string
		result.Scan(&clusterName)
		fmt.Printf("%s\n", clusterName)
	}

	fmt.Printf("DONE.\r\n")
}