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
- Build and install the DataStax C/C++ driver
- Install
go get github.com/mstump/golang-driver/cassandra - 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")
}