Nebula Go

Nebula Go 是一款 Go 语言的客户端，可以连接、管理 Nebula Graph 图数据库。

前提条件

已安装 Go，版本为 1.13 及以上。

版本对照表

Nebula Graph 版本	Nebula Go 版本
2.6.2	2.6.0
2.0.1	2.0.0-GA
2.0.0	2.0.0-GA

下载 Nebula Go

• （推荐）如果需要下载指定版本的 Nebula Go，请使用选项--branch指定分支。例如安装 v2.6.0发布版本，请执行如下命令：

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

• 如果需要安装日常开发版本，请执行如下命令下载master分支的源码：

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

安装或更新

安装或更新的命令如下：

$ go get -u -v github.com/vesoft-inc/nebula-go/v2@<tag>

tag：指定分支。例如master或2.6.0。

核心代码

详细示例请参见 graph_client_basic_example 和 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")
}

---

最后更新: March 7, 2023