使用 Go 通过 REST API 查询 Neo4j 节点：实战指南-Golang-PHP中文网

使用 Go 通过 REST API 查询 Neo4j 节点：实战指南

DDD

发布： 2025-10-06 11:31:42

原创

580人浏览过

使用 go 通过 rest api 查询 neo4j 节点：实战指南

本文档旨在指导开发者如何使用 Go 语言通过 Neo4j 的 REST API 进行节点查询。我们将重点介绍如何创建节点索引，向索引添加节点，以及使用 Lucene 查询语法检索节点。通过本文，你将学会避免常见的查询错误，并掌握高效的节点查找方法。

前提条件

已安装 Go 语言环境。
已安装 Neo4j 图数据库，并且 REST API 可用。
熟悉 Neo4j 的基本概念，如节点、关系、索引等。
安装 Neo4j Go Driver，例如：go get github.com/neo4j/neo4j-go-driver/v4/neo4j

创建节点索引

首先，我们需要创建一个节点索引，以便能够通过查询快速查找节点。Neo4j 支持多种索引类型，包括 exact 和 fulltext（Lucene）。fulltext 索引更适合于文本搜索。

以下代码片段展示了如何使用 Go 创建一个 fulltext 类型的节点索引：

import (
    "log"
    "github.com/neo4j/neo4j-go-driver/v4/neo4j"
)

func CreateNodeIndex(driver neo4j.Driver, indexName string) error {
    session := driver.NewSession(neo4j.SessionConfig{})
    defer session.Close()

    _, err := session.WriteTransaction(func(transaction neo4j.Transaction) (interface{}, error) {
        query := `CREATE FULLTEXT INDEX $indexName IF NOT EXISTS FOR (n:Node) ON EACH [n.name, n.description]`
        params := map[string]interface{}{
            "indexName": indexName,
        }
        _, err := transaction.Run(query, params)
        return nil, err
    })
    return err
}

登录后复制

代码解释:

neo4j.Driver: Neo4j 驱动实例，用于与数据库建立连接。
driver.NewSession: 创建一个新的会话，用于执行数据库操作。
session.WriteTransaction: 在一个事务中执行写操作，保证数据一致性。
CREATE FULLTEXT INDEX: Cypher 语句，用于创建全文索引。IF NOT EXISTS 避免重复创建索引。FOR (n:Node) 指定索引应用于标签为 Node 的节点。ON EACH [n.name, n.description] 指定索引包含的属性，这里我们索引了 name 和 description 属性。

注意事项:

造点AI

夸克 · 造点AI

325

查看详情

索引名称在 Neo4j 中必须是唯一的。
选择合适的索引类型非常重要，fulltext 索引适用于文本搜索，exact 索引适用于精确匹配。

添加节点到索引

创建索引后，我们需要将节点添加到索引中。这通常在创建或更新节点时完成。

以下代码片段展示了如何创建节点并添加到索引：

func CreateNode(driver neo4j.Driver, name string, description string) (int64, error) {
    session := driver.NewSession(neo4j.SessionConfig{})
    defer session.Close()

    result, err := session.WriteTransaction(func(transaction neo4j.Transaction) (interface{}, error) {
        query := `CREATE (n:Node {name: $name, description: $description}) RETURN id(n)`
        params := map[string]interface{}{
            "name": name,
            "description": description,
        }
        result, err := transaction.Run(query, params)
        if err != nil {
            return nil, err
        }

        record, err := result.Single()
        if err != nil {
            return nil, err
        }

        nodeID := record.Values[0].(int64)
        return nodeID, nil
    })

    if err != nil {
        return 0, err
    }

    nodeID := result.(int64)
    return nodeID, nil
}

登录后复制

代码解释:

CREATE (n:Node {name: $name, description: $description}): Cypher 语句，用于创建带有 name 和 description 属性的 Node 节点。
RETURN id(n): 返回新创建节点的 ID。

注意事项:

确保节点属性与索引定义中的属性匹配。
如果节点属性发生更改，需要更新索引。

使用 Lucene 查询节点

现在我们可以使用 Lucene 查询语法来查找节点。 Lucene 查询语法非常强大，支持各种搜索操作，包括精确匹配、模糊匹配、范围查询等。

以下代码片段展示了如何使用 Lucene 查询节点：

func FindNodeByQuery(driver neo4j.Driver, indexName string, luceneQuery string) ([]interface{}, error) {
    session := driver.NewSession(neo4j.SessionConfig{})
    defer session.Close()

    result, err := session.ReadTransaction(func(transaction neo4j.Transaction) (interface{}, error) {
        query := `CALL db.index.fulltext.queryNodes($indexName, $luceneQuery) YIELD node, score RETURN node`
        params := map[string]interface{}{
            "indexName":   indexName,
            "luceneQuery": luceneQuery,
        }
        result, err := transaction.Run(query, params)
        if err != nil {
            return nil, err
        }

        var nodes []interface{}
        for result.Next() {
            record := result.Record()
            node := record.Values[0]
            nodes = append(nodes, node)
        }

        return nodes, nil
    })

    if err != nil {
        return nil, err
    }

    nodes := result.([]interface{})
    return nodes, nil
}

登录后复制

代码解释:

CALL db.index.fulltext.queryNodes($indexName, $luceneQuery) YIELD node, score RETURN node: Cypher 语句，用于执行 Lucene 查询。db.index.fulltext.queryNodes 是 Neo4j 提供的全文索引查询函数。$indexName 是索引名称，$luceneQuery 是 Lucene 查询字符串。YIELD node, score 返回匹配的节点和得分。RETURN node 返回节点。
result.Next(): 遍历查询结果。
record.Values[0]: 获取节点对象。

示例:

假设我们创建了一个名为 my_index 的索引，并且索引了节点的 name 和 description 属性。

查找 name 属性包含 "test" 的节点：luceneQuery := "name:test*"
查找 description 属性包含 "example" 的节点：luceneQuery := "description:example*"
查找 name 属性包含 "test" 或 description 属性包含 "example" 的节点：luceneQuery := "name:test* OR description:example*"

注意事项:

Lucene 查询语法区分大小写，可以使用 lowercase() 函数进行不区分大小写的查询。
避免在索引键中使用空格，这可能会导致查询问题。
确保使用正确的索引键，例如，如果使用 indexKey := "some_key" 添加数据，则查询时应使用 luceneQuery := "some_key:some*"，而不是 luceneQuery := "indexKey:some*"。

完整示例

以下是一个完整的示例，展示了如何创建索引、添加节点和使用 Lucene 查询节点：

package main

import (
    "fmt"
    "log"

    "github.com/neo4j/neo4j-go-driver/v4/neo4j"
)

func main() {
    driver, err := neo4j.NewDriver("bolt://localhost:7687", neo4j.BasicAuth("neo4j", "password", ""))
    if err != nil {
        log.Fatal(err)
    }
    defer driver.Close()

    indexName := "my_index"
    err = CreateNodeIndex(driver, indexName)
    if err != nil {
        log.Fatal(err)
    }

    nodeID1, err := CreateNode(driver, "test node 1", "This is a test node with example text.")
    if err != nil {
        log.Fatal(err)
    }

    nodeID2, err := CreateNode(driver, "another test node", "Another example node.")
    if err != nil {
        log.Fatal(err)
    }

    luceneQuery := "description:example*"
    nodes, err := FindNodeByQuery(driver, indexName, luceneQuery)
    if err != nil {
        log.Fatal(err)
    }

    fmt.Printf("Found %d nodes with query '%s'\n", len(nodes), luceneQuery)
    for _, node := range nodes {
        fmt.Println(node)
    }

    // Clean up (optional)
    // DeleteNode(driver, nodeID1)
    // DeleteNode(driver, nodeID2)
    // DeleteNodeIndex(driver, indexName)
}

// (Include CreateNodeIndex, CreateNode, FindNodeByQuery functions from previous examples)

登录后复制

总结

本文档介绍了如何使用 Go 语言通过 Neo4j 的 REST API 进行节点查询。我们学习了如何创建节点索引、添加节点到索引，以及使用 Lucene 查询语法检索节点。通过遵循这些步骤，你可以高效地在 Neo4j 图数据库中查找节点。请记住，选择合适的索引类型和使用正确的 Lucene 查询语法是至关重要的。希望本文档能帮助你更好地理解和使用 Neo4j 的 REST API。

以上就是使用 Go 通过 REST API 查询 Neo4j 节点：实战指南的详细内容，更多请关注php中文网其它相关文章！