I use Docker:<\/p>\n
<\/p>\n
docker pull cassandra\r\nmkdir ucs-cassandra-db\r\ndocker run -d -P \u00a0--name cassandra -v `pwd`\/ucs-cassandra-db\/:\/var\/lib\/cassandra cassandra<\/pre>\n(Notice that using boot2docker or docker machine on virtual box doesn’t work very well because the directories are created under different user name. \u00a0You have two choices: \u00a0Don’t mount persistent directories with boot2docker or log into the virtual box guest (docker-machine ssh dev) and launch the container there.)<\/p>\n
Make sure its up:<\/p>\n
<\/p>\n
docker inspect cassandra\r\ndocker logs cassandra<\/pre>\nNow lets create a Keyspace (or Database in SQL terms). \u00a0Connect to it by connecting to cassandra where the 9042 port is mapped:<\/p>\n
docker ps\r\n\r\nCONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES\r\na1ec821d4f59 cassandra \"\/docker-entrypoint.s\" 34 minutes ago Up 34 minutes 0.0.0.0:32772->7000\/tcp, 0.0.0.0:32771->7001\/tcp, 0.0.0.0:32770->7199\/tcp, 0.0.0.0:32769->9042\/tcp, 0.0.0.0:32768->9160\/tcp cassandra\r\n<\/pre>\nHere we see that port 9042 is mapped to 32769. \u00a0To connect we run:<\/p>\n
cqlsh 192.168.99.100 32769<\/pre>\nNow we can create the keyspace:<\/p>\n
<\/p>\n
cqlsh> CREATE KEYSPACE ucstechspecs WITH replication = { 'class': 'SimpleStrategy', 'replication_factor': '1' };\r\ncqlsh> USE ucstechspecs;\r\ncqlsh> CREATE TABLE fabricInterconnects (partNumber text, name text, attributes map<text, text>, pictures list<text>, PRIMARY KEY (partNumber));<\/pre>\nNow let’s use it with a Go program.<\/p>\n
go get github.com\/gocql\/gocql<\/code>\r\n<\/pre>\nOur code is pretty simple:<\/p>\n
package main\r\n\r\nimport (\r\n \"fmt\"\r\n \"log\"\r\n\r\n \"github.com\/gocql\/gocql\"\r\n)\r\n\r\nfunc main() {\r\n\r\n fmt.Printf(\"Test\\n\")\r\n cluster := gocql.NewCluster(\"192.168.99.100\")\r\n cluster.Port = 32869\r\n cluster.ProtoVersion = 4 \r\n cluster.Keyspace = \"ucstechspecs\"\r\n session, err := cluster.CreateSession()\r\n defer session.Close()\r\n if err != nil {\r\n fmt.Printf(\"%s\\n\", err)\r\n return\r\n }\r\n\r\n m := make(map[string]string)\r\n m[\"color\"] = \"red\"\r\n m[\"car\"] = \"ferrari\"\r\n\r\n pictures := []string{\"http:\/\/fi.1.org\", \"http:\/\/lmgtfy\"}\r\n\r\n err = session.Query(`INSERT INTO fabricInterconnects (partNumber, name, attributes, pictures) VALUES (?, ?, ?, ?)`,\r\n \"UCSFI-61234\", \"UCS FI 6120\", m, pictures).Exec()\r\n\r\n log.Println(\"Inserted data\")\r\n if err != nil {\r\n log.Fatal(err)\r\n }\r\n\r\n var model string\r\n iter := session.Query(`SELECT name FROM fabricInterconnects WHERE partNumber = ? `,\r\n \"UCSFI-61234\").Iter()\r\n for iter.Scan(&model) {\r\n fmt.Println(\"Model: \", model)\r\n }\r\n if err := iter.Close(); err != nil {\r\n log.Fatal(err)\r\n }\r\n}<\/pre>\nIf that worked then you created an entry and go data back. \u00a0You are now off to the races writing golang code to a cassandra database.<\/p>\n
TODO:<\/p>\n