用法
将 JDBC 驱动程序添加到您的应用程序,例如作为 Gradle 依赖项
dependencies {
runtimeOnly(org.neo4j:neo4j-jdbc-full-bundle:6.5.1) (1)
}
1 | Maven 项目的坐标相同。 |
然后,您可以像使用任何其他 JDBC 驱动程序一样使用 Neo4j JDBC 驱动程序
如果任何工具询问您具体驱动程序类的名称,它是 org.neo4j.jdbc.Neo4jDriver 。 |
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.List;
public final class Quickstart {
static void queryWithCypher() {
var query = """
MATCH (m:Movie)<-[:ACTED_IN]-(p:Person)
RETURN m.title AS title, collect(p.name) AS actors
ORDER BY m.title
""";
var url = "jdbc:neo4j://localhost:7687";
var username = "neo4j";
var password = "verysecret";
try (var con = DriverManager.getConnection(url, username, password); (1)
var stmt = con.createStatement(); (2)
var result = stmt.executeQuery(query)) { (3)
while (result.next()) { (4)
var movie = result.getString(1); (5)
var actors = (List<String>) result.getObject("actors"); (6)
System.out.printf("%s%n", movie);
actors.forEach(actor -> System.out.printf("\t * %s%n", actor));
}
}
catch (SQLException ex) {
throw new RuntimeException(ex);
}
}
}
1 | 实例化 JDBC 连接。无需事先进行任何类加载,驱动程序将自动注册 |
2 | 创建可复用语句 |
3 | 执行查询 |
4 | 迭代结果,就像使用任何其他 JDBC 结果集一样 |
5 | JDBC 的索引从 1 开始 |
6 | JDBC 还允许按名称检索结果列;Neo4j JDBC 驱动程序还支持复杂对象,例如列表 |
在上面的示例中,我们使用 Neo4j 的通用语言,Cypher®,来查询数据库。Neo4j JDBC 驱动程序也有限地支持使用 SQL。它可以自动或根据具体情况进行此操作。要翻译单个查询,请调用 java.sql.Connection#nativeSQL(String)
并将结果用于您的查询。对于自动翻译,请在实例化驱动程序时将可选的 URL 参数 sql2cypher
设置为 true
。以下示例展示了如何操作
var query = """
SELECT m.title AS title, collect(p.name) AS actors
FROM Person as p
JOIN Movie as m ON (m.id = p.ACTED_IN)
ORDER BY m.title
"""; (1)
var url = "jdbc:neo4j://localhost:7687?enableSQLTranslation=true";
try (var con = DriverManager.getConnection(url, username, password);
var stmt = con.createStatement();
var result = stmt.executeQuery(query)) {
while (result.next()) {
var movie = result.getString(1);
var actors = (List<String>) result.getObject("actors");
System.out.printf("%s%n", movie);
actors.forEach(actor -> System.out.printf("\t * %s%n", actor));
}
}
1 | 此 SQL 查询将被翻译成与上一个示例相同的 Cypher 查询。该方法的其余部分与之前相同。 |
有关更多信息,请参阅SQL 到 Cypher 翻译。
JDBC 规范不支持命名参数,只支持基于索引的参数,从 1
开始。因此,对于所有 PreparedStatement
实例,您需要像这样指定参数
PreparedStatement
一起使用var cypher = "CREATE (m:Movie {title: $1})";
try (var con = DriverManager.getConnection(url, username, password);
PreparedStatement stmt = con.prepareStatement(cypher)) {
stmt.setString(1, "Test");
stmt.executeUpdate();
}
这与 SQL 到 Cypher 的翻译机制无关
PreparedStatement
一起使用(SQL 变体)var sql = "INSERT INTO Movie (title) VALUES (?)";
try (var con = DriverManager.getConnection(url + "?enableSQLTranslation=true", username, password);
PreparedStatement stmt = con.prepareStatement(sql)) {
stmt.setString(1, "Test");
stmt.executeUpdate();
}
要使用命名参数,请将 PreparedStatement
向下转型为 Neo4jPreparedStatement
。
Neo4jPreparedStatement
一起使用var match = "MATCH (n:Movie {title: $title}) RETURN n.title AS title";
try (var con = DriverManager.getConnection(url, username, password);
Neo4jPreparedStatement stmt = (Neo4jPreparedStatement) con.prepareStatement(match)) {
stmt.setString("title", "Test");
try (var resultSet = stmt.executeQuery()) {
while (resultSet.next()) {
LOGGER.info(resultSet.getString("title"));
}
}
}
通过环境变量获取连接
如果您愿意直接依赖 org.neo4j.jdbc.Neo4jDriver
并希望尽可能简单地获取连接,您可能希望使用 fromEnv
// import org.neo4j.jdbc.Neo4jDriver;
try (var con = Neo4jDriver.fromEnv().orElseThrow(); (1)
var stmt = con.createStatement();
var result = stmt.executeQuery(query)) {
// Same loop as earlier
}
catch (SQLException ex) {
throw new RuntimeException(ex);
}
1 | 请注意,我们在此处直接使用具体的驱动程序类,以及方法如何返回一个 Optional:如果找不到所需的连接变量,则无法创建连接。 |
fromEnv
方法查找几个特定的系统环境变量,并且它遵循 12 因素应用原则
-
首先,它在系统环境中查找
-
其次,它在当前工作目录中查找名为
.env
的文件。有重载允许您配置要查找的目录和文件名。
支持的变量包括
NEO4J_URI
-
要连接实例的地址或 URI。
NEO4J_USERNAME
-
(可选)用户名。
NEO4J_PASSWORD
-
(可选)密码。
NEO4J_SQL_TRANSLATION_ENABLED
-
(可选)是否启用完整的 SQL 到 Cypher 翻译,默认为
false
。
系统环境变量和 .env 文件中的信息会合并。例如,如果 NEO4J_SQL_TRANSLATION_ENABLED 存在于系统环境变量中但不存在于 .env 文件中,它仍然会被获取。根据优先级顺序,系统环境变量中的信息始终优先于 .env 文件。 |
此功能对于 Neo4j AuraDB 尤其有用。创建新的 AuraDB 实例时,您可以下载一个 .env
文件,然后直接与 Neo4j JDBC 驱动程序一起使用
try (
var con = Neo4jDriver.fromEnv("Neo4j-cb3d8b2d-Created-2024-02-14.txt")
.orElseThrow();
var stmt = con.createStatement();
var movies = stmt.executeQuery("MATCH (n:Movie) RETURN n.title AS title")
) {
while (movies.next()) {
System.out.println(movies.getString("title"));
}
}