运行非阻塞异步查询
异步管理事务
您通过 AsyncSession
运行异步事务。其流程与常规事务类似,不同之处在于异步事务函数返回一个 CompletionStage
对象(该对象可以进一步转换为 CompletableFuture
)。
package demo;
import java.util.Map;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import org.neo4j.driver.async.AsyncSession;
import org.neo4j.driver.AuthTokens;
import org.neo4j.driver.Driver;
import org.neo4j.driver.GraphDatabase;
import org.neo4j.driver.summary.ResultSummary;
import org.neo4j.driver.SessionConfig;
public class App {
public static void main(String... args) throws ExecutionException, InterruptedException {
final String dbUri = "{neo4j-database-uri}";
final String dbUser = "{neo4j-username}";
final String dbPassword = "{neo4j-password}";
try (var driver = GraphDatabase.driver(dbUri, AuthTokens.basic(dbUser, dbPassword))) { (1)
driver.verifyConnectivity();
var summary = printAllPeople(driver);
// Block as long as necessary (for demonstration purposes)
System.out.println(summary.get()); (8)
}
}
public static CompletableFuture<ResultSummary> printAllPeople(Driver driver) {
var session = driver.session(AsyncSession.class, SessionConfig.builder().withDatabase("neo4j").build()); (2)
var query = """
UNWIND ['Alice', 'Bob', 'Sofia', 'Charles'] AS name
MERGE (p:Person {name: name}) RETURN p.name
""";
var summary = session.executeWriteAsync(tx -> tx.runAsync(query) (3)
.thenCompose(resCursor -> resCursor.forEachAsync(record -> { (4)
System.out.println(record.get(0).asString());
})))
.whenComplete((result, error) -> { (5)
session.closeAsync();
})
.toCompletableFuture(); (6)
return summary; (7)
}
}
1 | 驱动程序创建在同步和异步版本中是相同的。 |
2 | 通过将 AsyncSession.class 作为第一个参数提供给 Driver.session() 来创建异步会话,该方法返回一个 AsyncSession 对象。请注意,异步会话不能作为资源与 try 语句一起打开,因为驱动程序无法知道何时可以安全地关闭它们。 |
3 | 对于常规事务,.executeWriteAsync() (和 executeReadAsync() )接受一个事务函数回调。在事务函数内部,使用 .runAsync() 运行查询。每个查询运行都返回一个 CompletionStage 。 |
4 | 可以选择使用 CompletionStage 上的方法在异步运行器中处理结果。查询结果集可作为 async.ResultCursor 使用,它实现了与同步事务类似的结果处理方法集(参见 事务 → 处理查询结果)。内部对象类型与同步情况相同(即 Record ,ResultSummary )。 |
5 | 查询完成后,可以选择运行操作,例如关闭驱动程序会话。 |
6 | CompletableFuture 是一种方便返回给调用者的类型。 |
7 | 与同步事务相反,.executeWriteAsync() 和 executeReadAsync() 只返回结果摘要。结果处理必须在异步运行器内部完成。 |
8 | .get() 会等待未来(future)完成,然后返回其结果。 |
方法 .executeReadAsync() 和 .executeWriteAsync() 已取代 .readTransactionAsync() 和 .writeTransactionAsync() ,后两者在 5.x 版本中已被弃用,并将在 6.0 版本中移除。 |
术语表
- 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 的 DBMS 可确保数据库中的数据在发生故障时仍保持准确和一致。
- 最终一致性
-
如果数据库能够保证所有集群成员都将在某个时间点存储最新版本的数据,则该数据库是最终一致的。
- 因果一致性
-
如果集群的每个成员都以相同的顺序看到读写查询,则数据库是因果一致的。这比最终一致性更强。
- NULL
-
空标记不是一种类型,而是表示值缺失的占位符。有关更多信息,请参阅 Cypher → 使用
null
。 - 事务
-
事务是工作的一个单元,它要么整体提交,要么在失败时回滚。一个例子是银行转账:它涉及多个步骤,但所有步骤都必须成功或被撤销,以避免钱从一个账户中扣除但未添加到另一个账户。
- 背压
-
背压是阻碍数据流动的力。它确保客户端不会因数据传输速度过快而过载。
- 事务函数
-
事务函数是由
executeRead
或executeWrite
调用执行的回调。在服务器故障时,驱动程序会自动重新执行该回调。 - 驱动程序
-
一个
Driver
对象包含与 Neo4j 数据库建立连接所需的详细信息。