Develop Go Apps

    This tutorial assumes that you have:

    • installed YugabyteDB, created a universe and are able to interact with it using the CQL shell. If not, please follow these steps in the quick start guide.
    • installed Go version 1.8+

    Install Go Cassandra Driver

    To install the driver locally run:

    1. package main;
    3. import (
    4.     "fmt"
    5.     "log"
    6.     "time"
    8.     "github.com/gocql/gocql"
    9. )
    11. func main() {
    12.     // Connect to the cluster.
    13.     cluster := gocql.NewCluster("127.0.0.1", "127.0.0.2", "127.0.0.3")
    15.     // Use the same timeout as the Java driver.
    16.     cluster.Timeout = 12 * time.Second
    18.     // Create the session.
    19.     session, _ := cluster.CreateSession()
    20.     defer session.Close()
    22.     // Set up the keyspace and table.
    23.     if err := session.Query("CREATE KEYSPACE IF NOT EXISTS ybdemo").Exec(); err != nil {
    24.         log.Fatal(err)
    25.     }
    26.     fmt.Println("Created keyspace ybdemo")
    28.     if err := session.Query(`DROP TABLE IF EXISTS ybdemo.employee`).Exec(); err != nil {
    29.         log.Fatal(err)
    30.     }
    31.     var createStmt = `CREATE TABLE ybdemo.employee (id int PRIMARY KEY, 
    32.                                                            name varchar, 
    34.                                                            language varchar)`;
    35.     if err := session.Query(createStmt).Exec(); err != nil {
    36.         log.Fatal(err)
    37.     }
    38.     fmt.Println("Created table ybdemo.employee")
    40.     // Insert into the table.
    41.     var insertStmt string = "INSERT INTO ybdemo.employee(id, name, age, language)" + 
    42.         " VALUES (1, 'John', 35, 'Go')";
    43.     if err := session.Query(insertStmt).Exec(); err != nil {
    44.         log.Fatal(err)
    45.     }
    46.     fmt.Printf("Inserted data: %s\n", insertStmt)
    48.     // Read from the table.
    49.     var name string
    50.     var age int
    51.     var language string
    52.     iter := session.Query(`SELECT name, age, language FROM ybdemo.employee WHERE id = 1`).Iter()
    53.     fmt.Printf("Query for id=1 returned: ");
    54.     for iter.Scan(&name, &age, &language) {
    55.         fmt.Printf("Row[%s, %d, %s]\n", name, age, language)
    56.     }
    58.     if err := iter.Close(); err != nil {
    59.         log.Fatal(err)
    60.     }
    61. }

    Running the app

    To execute the file, run the following command:

    You should see the following as the output.

    1. Created keyspace ybdemo
    2. Created table ybdemo.employee
    3. Inserted data: INSERT INTO ybdemo.employee(id, name, age, language) VALUES (1, 'John', 35, 'Go')
    • installed YugabyteDB, created a universe and are able to interact with it using the Redis shell. If not, please follow these steps in the .
    • installed Go version 1.8+

    Install Go Redis Driver

    To install the driver locally run:

    Create a file ybredis_hello_world.go and copy the contents below.

    3. import (
    4.   "fmt"
    5.   "log"
    7.   "github.com/go-redis/redis"
    8. )
    10. func main() {
    11.   // Connect to the cluster.
    12.   client := redis.NewClient(&redis.Options{
    13.     Addr:     "localhost:6379",
    14.     Password: "", // no password set
    15.     DB:       0,  // use the default DB
    16.   })
    17.   defer client.Close()
    19.   // Insert some data (for user id 1).
    20.   var userid string = "1"
    21.   ok, err := client.HMSet(userid, map[string]interface{}{
    22.         "name": "John",
    23.         "age": "35",
    24.         "language": "Redis"}).Result()
    26.   if (err != nil) {
    27.     log.Fatal(err)
    28.   }
    29.   fmt.Printf("HMSET returned '%s' for id=%s with values: name=John, age=35, language=Redis\n", ok, userid)
    31.   // Query the data.
    32.   result, err := client.HGetAll("1").Result()
    33.   fmt.Printf("Query result for id=%s: '%v'\n", userid, result)
    34. }

    Running the app

    You should see the following as the output.

    2. Query result for id=1: 'map[age:35 language:Redis name:John]'