4.x 驱动程序变更

本节介绍 Neo4j 1.7 驱动程序和 Neo4j 4.x 驱动程序之间的区别。

高级变更

从 4.0 开始，驱动程序旨在提供跨所有语言的用户友好且统一的 API。

在 Neo4j 早期版本中，客户端-服务器通信使用加密的本地连接并默认生成自签名证书。然而，从 4.0 开始，默认设置为未加密。有关更多信息，请参阅 驱动程序手册 → 连接 URI。

Neo4j 4.0 引入了一个与 Reactive Streams 标准兼容的响应式 API。这使得可以对 Cypher® 查询结果的数据流进行细粒度控制，包括在途中暂停或取消的能力。有关更多信息，请参阅 驱动程序手册 → 查询和结果。

当使用 4.x 驱动程序连接到 4.x 数据库时，可以处理多个数据库。从驱动程序 API 的角度来看，这意味着必须选择一个数据库作为会话内事务的执行上下文。这可以在会话构建时配置。如果未选择任何数据库，则驱动程序连接到服务器的默认数据库。

驱动程序 1.7 在 Neo4j 4.x 中以回退模式运行。它们不支持 Neo4j 4.0 及更高版本中引入的功能，例如多数据库、Neo4j Fabric 和细粒度访问控制。要同时在线运行多个数据库并对其执行分布式查询，您必须从 1.7 迁移到 4.x。

本章中的示例主要使用 Java 驱动程序以 Java 编写。但是，类似的代码可以翻译成其他语言。

新功能

  • 从 Neo4j 4.0 开始，数据库、驱动程序和协议的版本方案都已对齐。对于受支持的驱动程序，这意味着版本号从 1.7 变为任何 4.x。

  • 1.7+ 驱动程序与 4.x 服务器通信时可能需要显式关闭加密。这是由于 Neo4j 3.x 和 4.x 之间默认设置的变更。

  • Bolt 4.0 在 4.x 驱动程序和 4.0 服务器中均已实现。

  • 响应式 API 现已随 4.0 服务器提供。要使用响应式 API，起点是驱动程序对象上的 RxSession。

  • 对于 4.0 服务器，现在应该针对特定数据库获取会话实例。因果链在每个数据库上仍然受尊重（事务不能跨多个数据库）。驱动程序本身连接到 Neo4j 数据库管理系统。

  • 添加了新的特性检测方法 driver.supportsMultiDb()，用于查询远程数据库是否支持多数据库。

  • 引入了新的 driver.verifyConnectivity() 方法，用于连接性验证。默认情况下，驱动程序实例在构建后不验证 DBMS 的可用性。

  • 新的连接 URI 方案，包含额外加密和信任信息的变体 - neo4j+s、bolt+s、neo4j+ssc 和 bolt+ssc。其中 +s 变体启用带完整证书检查的加密，而 +ssc 变体启用不带证书检查的加密。后一种变体专门设计用于自签名证书。有关更多信息，请参阅 附加 URI 方案。

示例 1. 检测多数据库支持
import org.neo4j.driver.Driver;
import org.neo4j.driver.Result;
import org.neo4j.driver.Session;
import org.neo4j.driver.SessionConfig;
import org.neo4j.driver.Values;

...
private final Driver driver;
...

public void printGreeting( final String message )
{
   SessionConfig sessionConfig = driver.supportsMultiDb() ? SessionConfig.forDatabase( "neo4j" )
                                                          : SessionConfig.defaultConfig();

   try ( Session session = driver.session( sessionConfig ) )
   {
       String greeting = session.writeTransaction( tx -> {
           Result result = tx.run( "CREATE (a:Greeting) SET a.message = $message RETURN a.message + ', from node ' + id(a)",
                                   Values.parameters( "message", message ) );
           return result.single().get( 0 ).asString();
       } );
       System.out.println( greeting );
   }
}
© . All rights reserved.