进一步查询机制

隐式（或自动提交）事务

这是运行 Cypher 查询最基本且有限的形式。驱动程序不会自动重试隐式事务，而对于通过 ExecuteQuery() 和 托管事务 运行的查询则会重试。隐式事务仅应在其他驱动程序查询接口不适用或用于快速原型开发时使用。

您可以使用 SessionWithContext.Run() 方法运行隐式事务。它返回一个需要相应处理的 ResultWithContext 对象。

session := driver.NewSession(ctx, neo4j.SessionConfig{DatabaseName: "neo4j"})
defer session.Close(ctx)
result, err := session.Run(
    ctx,
    "CREATE (p:Person {name: $name}) RETURN p",
    map[string]any{
        "name": "Lucia",
    })

隐式事务最迟在会话销毁时提交，或在同一会话中执行另一个事务之前提交。除此之外，无法明确保证隐式事务在会话生命周期内的具体提交时间。为了确保隐式事务被提交，您可以在其结果上调用 .Consume(ctx) 方法。

由于驱动程序无法确定 SessionWithContext.Run() 调用中的查询是需要数据库的读会话还是写会话，因此它默认为写。如果您的隐式事务只包含读查询，通过在创建会话时设置会话配置 AccessMode: neo4j.AccessModeRead 来让驱动程序知晓可以获得性能提升。

隐式事务是唯一可以用于 CALL { …​ } IN TRANSACTIONS 查询的事务.

导入 CSV 文件

使用 SessionWithContext.Run() 最常见的用例是使用 LOAD CSV Cypher 子句将大型 CSV 文件导入数据库，并防止因事务过大导致的超时错误。

将 CSV 数据导入 Neo4j 数据库
session := driver.NewSession(ctx, neo4j.SessionConfig{DatabaseName: "neo4j"})
defer session.Close(ctx)
result, err := session.Run(
    ctx, `
    LOAD CSV FROM 'https://data.neo4j.com/bands/artists.csv' AS line
    CALL {
        WITH line
        MERGE (:Artist {name: line[1], age: toInteger(line[2])})
    } IN TRANSACTIONS OF 2 ROWS
    `, nil)
summary, _ := result.Consume(ctx)
fmt.Println("Query updated the database?",
    summary.Counters().ContainsUpdates())
尽管 LOAD CSV 提供了便利，但将 CSV 文件解析推迟到您的 Go 应用程序并避免使用 LOAD CSV 并没有什么问题。事实上，将解析逻辑移至应用程序可以为您提供对导入过程的更多控制。有关高效批量数据插入，请参阅性能 → 批量数据创建。

欲了解更多信息，请参阅Cypher → 子句 → 加载 CSV。

事务配置

您可以通过在 SessionWithContext.Run() 调用中第三个参数之后提供配置回调来进一步控制隐式事务。配置回调允许指定查询超时并向事务附加元数据。欲了解更多信息，请参阅事务 — 事务配置。

session := driver.NewSession(ctx, neo4j.SessionConfig{DatabaseName: "neo4j"})
defer session.Close(ctx)
people, err := session.Run(ctx,
    "MATCH (:Person) RETURN count(*) AS n",
    nil,
    neo4j.WithTxTimeout(5*time.Second),  // remember to import `time`
    neo4j.WithTxMetadata(map[string]any{"appName": "peopleTracker"}))

属性键、关系类型和标签中的动态值

通常，您不应将参数直接连接到查询中，而应使用查询参数。然而，在某些情况下，您的查询结构可能会阻止在所有部分使用参数。事实上，尽管参数可用于字面量和表达式以及节点和关系的ID，但它们不能用于以下构造：

  • 属性键，例如 MATCH (n) WHERE n.$param = 'something' 是无效的；

  • 关系类型，例如 MATCH (n)-[:$param]→(m) 是无效的；

  • 标签，例如 MATCH (n:$param) 是无效的。

对于这些查询，您被迫使用字符串拼接。为了防止Cypher 注入，您应该将动态值用反引号括起来并自行转义。请注意 Cypher 处理 Unicode，因此也要处理 Unicode 字面量 \u0060。

在拼接前手动转义动态标签
dangerousLabel := "Person\\u0060n"
// convert \u0060 to literal backtick and then escape backticks
// remember to import `strings`
escapedLabel := strings.ReplaceAll(dangerousLabel, "\\u0060", "`")
escapedLabel = strings.ReplaceAll(escapedLabel, "`", "``")

result, err := neo4j.ExecuteQuery(ctx, driver,
    "MATCH (p:`" + escapedLabel + "` WHERE p.name = $name) RETURN p.name",
    map[string]any{
        "name": "Alice",
    },
    neo4j.EagerResultTransformer,
    neo4j.ExecuteQueryWithDatabase("neo4j"))

另一种避免字符串拼接的变通方法是使用 APOC 过程 apoc.merge.node。它支持动态标签和属性键，但仅适用于节点合并。

使用 apoc.merge.node 创建具有动态标签/属性键的节点
propertyKey := "name"
label := "Person"

result, err := neo4j.ExecuteQuery(ctx, driver,
    "CALL apoc.merge.node($labels, $properties)",
    map[string]any{
        "labels": []string{label},
        "properties": map[string]any{propertyKey: "Alice"},
    },
    neo4j.EagerResultTransformer,
    neo4j.ExecuteQueryWithDatabase("neo4j"))
如果您在 Docker 中运行 Neo4j，则在启动容器时需要启用 APOC。请参阅 APOC → 安装 → Docker。

日志记录

驱动程序将日志记录分为驱动程序事件和 Bolt 事件。要启用驱动程序日志记录，在实例化驱动程序时使用 Config.Log 选项

// import "github.com/neo4j/neo4j-go-driver/v5/neo4j/config"

driver, err := neo4j.NewDriverWithContext(
    dbUri,
    neo4j.BasicAuth(dbUser, dbPassword, ""),
    func(conf *config.Config) {
        conf.Log = neo4j.ConsoleLogger(neo4j.DEBUG)
    })
驱动程序连接时的日志输出示例
2023-07-03 08:07:19.316   INFO  [pool 1] Created
2023-07-03 08:07:19.316   INFO  [router 1] Created {context: map[address:localhost:7687]}
2023-07-03 08:07:19.316   INFO  [driver 1] Created { target: localhost:7687 }
2023-07-03 08:07:19.316  DEBUG  [session 2] Created
2023-07-03 08:07:19.316   INFO  [router 1] Reading routing table from initial router: localhost:7687
2023-07-03 08:07:19.316  DEBUG  [pool 1] Trying to borrow connection from [localhost:7687]
2023-07-03 08:07:19.316   INFO  [pool 1] Connecting to localhost:7687
2023-07-03 08:07:19.320   INFO  [bolt5 bolt-58@localhost:7687] Connected
2023-07-03 08:07:19.320   INFO  [bolt5 bolt-58@localhost:7687] Retrieving routing table
2023-07-03 08:07:19.320  DEBUG  [pool 1] Returning connection to localhost:7687 {alive:true}
2023-07-03 08:07:19.320  DEBUG  [bolt5 bolt-58@localhost:7687] Resetting connection internal state
2023-07-03 08:07:19.320  DEBUG  [router 1] New routing table for 'neo4j', TTL 300
2023-07-03 08:07:19.320  DEBUG  [session 2] Resolved home database, uses db 'neo4j'
2023-07-03 08:07:19.320  DEBUG  [pool 1] Trying to borrow connection from [localhost:7687]
2023-07-03 08:07:19.321  DEBUG  [pool 1] Returning connection to localhost:7687 {alive:true}
2023-07-03 08:07:19.321  DEBUG  [bolt5 bolt-58@localhost:7687] Resetting connection internal state
2023-07-03 08:07:19.321  DEBUG  [router 1] Cleaning up
2023-07-03 08:07:19.321  DEBUG  [session 2] Closed

Bolt 日志记录可以通过以下方式启用：

  • 按查询，使用配置回调 neo4j.ExecuteQueryBoltLogger()。这适用于使用 ExecuteQuery() 运行的单个查询。

  • 按会话，使用配置选项 BoltLogger。这适用于会话内的所有查询。

为使用 ExecuteQuery 运行的查询启用日志记录
result, err := neo4j.ExecuteQuery(ctx, driver,
    "RETURN 42 AS n", nil, neo4j.EagerResultTransformer,
    neo4j.ExecuteQueryWithDatabase("neo4j"),
    neo4j.ExecuteQueryWithBoltLogger(neo4j.ConsoleBoltLogger()))
为会话启用日志记录
session := driver.NewSession(ctx, neo4j.SessionConfig{
    DatabaseName: "neo4j",
    BoltLogger: neo4j.ConsoleBoltLogger(),
})
defer session.Close(ctx)
session.Run(ctx, "RETURN 42 AS n", nil)
Bolt 日志输出示例
2023-07-03 07:57:09.929   BOLT  [bolt-53@localhost:7687] C: BEGIN {"db":"neo4j"}
2023-07-03 07:57:09.930   BOLT  [bolt-53@localhost:7687] S: SUCCESS {}
2023-07-03 07:57:09.930   BOLT  [bolt-53@localhost:7687] C: RUN "RETURN 42 AS n" null null
2023-07-03 07:57:09.930   BOLT  [bolt-53@localhost:7687] C: PULL {"n":1000}
2023-07-03 07:57:09.936   BOLT  [bolt-53@localhost:7687] S: SUCCESS {"fields":["n"],"t_first":5}
2023-07-03 07:57:09.937   BOLT  [bolt-53@localhost:7687] S: RECORD [42]
2023-07-03 07:57:09.937   BOLT  [bolt-53@localhost:7687] S: SUCCESS {"t_first":1,"db":"neo4j"}
2023-07-03 07:57:09.937   BOLT  [bolt-53@localhost:7687] C: COMMIT
2023-07-03 07:57:09.938   BOLT  [bolt-53@localhost:7687] S: SUCCESS {"bookmark":"FB:kcwQhRyDJPONRxudy+QyzPSuSAaQ"}

词汇表

LTS

长期支持版本是指保证在数年内获得支持的版本。Neo4j 4.4 是 LTS 版本，Neo4j 5 也将有 LTS 版本。

Aura

Aura 是 Neo4j 的全托管云服务。它提供免费和付费计划。

Cypher

Cypher 是 Neo4j 的图查询语言，可让您从数据库中检索数据。它类似于 SQL，但专为图设计。

APOC

Awesome Procedures On Cypher (APOC) 是一个包含（许多）无法轻松在 Cypher 本身中表达的函数的库。

Bolt

Bolt 是 Neo4j 实例与驱动程序之间交互使用的协议。它默认监听端口 7687。

ACID

原子性、一致性、隔离性、持久性 (ACID) 是保证数据库事务可靠处理的属性。符合 ACID 标准的数据库管理系统可确保即使发生故障，数据库中的数据也能保持准确和一致。

最终一致性

如果数据库保证所有集群成员在某个时间点最终都会存储最新版本的数据，则该数据库是最终一致的。

因果一致性

如果读写查询被集群的每个成员以相同的顺序看到，则数据库是因果一致的。这比最终一致性更强。

NULL

Null 标记不是一种类型，而是值缺失的占位符。欲了解更多信息，请参阅Cypher → 使用 null。

事务

事务是一个工作单元，它要么整体提交，要么在失败时回滚。一个例子是银行转账：它涉及多个步骤，但所有步骤都必须成功或被撤销，以避免资金从一个账户扣除但未添加到另一个账户。

背压

背压是阻碍数据流动的力。它确保客户端不会被比其处理能力更快的速度的数据所淹没。

事务函数

事务函数是由 ExecuteRead 或 ExecuteWrite 调用执行的回调。在服务器故障的情况下，驱动程序会自动重新执行该回调。

DriverWithContext

一个 DriverWithContext 对象包含与 Neo4j 数据库建立连接所需的详细信息。

© . All rights reserved.