Skip to content

Nebula Go

Nebula Go is a Golang client for connecting to and managing the NebulaGraph database.

Prerequisites

You have installed Golang 1.13 or later versions.

Compatibility with NebulaGraph

NebulaGraph version Nebula Go version
2.6.2 2.6.0
2.0.1 2.0.0-GA
2.0.0 2.0.0-GA

Download Nebula Go

  • (Recommended) To install a specific version of Nebula Go, use the Git option --branch to specify the branch. For example, to install v2.6.0, run the following command:

    $ git clone --branch v2.6.0 https://github.com/vesoft-inc/nebula-go.git
    
  • To install the daily development version, run the following command to download the source code from the master branch:

    $ git clone https://github.com/vesoft-inc/nebula-go.git
    

Install or update

Run the following command to install or update Nebula Go:

go get -u -v github.com/vesoft-inc/nebula-go/v2@v2.6.0

Core of the example code

This section shows the core of the example code. For all the code, see graph_client_basic_example and graph_client_goroutines_example.

const (
    address = "192.168.xx.1"
    port     = 9669
    username = "root"
    password = "nebula"
)

func main() {
    hostAddress := nebula.HostAddress{Host: address, Port: port}
    hostList := []nebula.HostAddress{hostAddress}
    testPoolConfig := nebula.GetDefaultConf()
    pool, err := nebula.NewConnectionPool(hostList, testPoolConfig, log)
    defer pool.Close()
    session, err := pool.GetSession(username, password)
    defer session.Release()

    checkResultSet := func(prefix string, res *nebula.ResultSet) {
        if !res.IsSucceed() {
            log.Fatal(fmt.Sprintf("%s, ErrorCode: %v, ErrorMsg: %s", prefix, res.GetErrorCode(), res.GetErrorMsg()))
        }
    }
    {
        createSchema := "CREATE SPACE IF NOT EXISTS basic_example_space(vid_type=FIXED_STRING(20)); " +
            "USE basic_example_space;" +
            "CREATE TAG IF NOT EXISTS person(name string, age int);" +
            "CREATE EDGE IF NOT EXISTS like(likeness double)"
        resultSet, err := session.Execute(createSchema)
        checkResultSet(createSchema, resultSet)
    }
    fmt.Print("\n")
    log.Info("Nebula Go Client Basic Example Finished")
}

Last update: March 13, 2023