跳转到内容

Java 入门

PetraDB 提供标准的 JDBC 4 驱动,因此你可以使用熟悉的 java.sql API — ConnectionStatementResultSetPreparedStatement

Maven:

<dependency>
<groupId>io.github.edadma</groupId>
<artifactId>petradb-jdbc</artifactId>
<version>1.5.0</version>
</dependency>

Gradle:

implementation 'io.github.edadma:petradb-jdbc:1.5.0'

驱动会自动注册 — 无需 Class.forName()

import java.sql.*;
public class Main {
public static void main(String[] args) throws SQLException {
Connection conn = DriverManager.getConnection("jdbc:petradb:memory");
Statement stmt = conn.createStatement();
stmt.executeUpdate("""
CREATE TABLE users (
id SERIAL PRIMARY KEY,
name TEXT NOT NULL,
email TEXT
)
""");
stmt.executeUpdate("INSERT INTO users (name, email) VALUES ('Alice', 'alice@example.com')");
stmt.executeUpdate("INSERT INTO users (name, email) VALUES ('Bob', 'bob@example.com')");
ResultSet rs = stmt.executeQuery("SELECT id, name, email FROM users ORDER BY id");
while (rs.next()) {
System.out.printf("%d: %s <%s>%n",
rs.getInt("id"),
rs.getString("name"),
rs.getString("email"));
}
rs.close();
stmt.close();
conn.close();
}
}

输出:

1: Alice <alice@example.com>
2: Bob <bob@example.com>

对于需要在重启后保留的数据,使用文件连接 URL:

Connection conn = DriverManager.getConnection("jdbc:petradb:file:mydata.petra");

文件在首次使用时创建。支持的扩展名:

扩展名存储类型
.petra防崩溃持久化存储
.ptxt人类可读文本格式
PreparedStatement ps = conn.prepareStatement(
"SELECT * FROM users WHERE name = ? AND id > ?");
ps.setString(1, "Alice");
ps.setInt(2, 0);
ResultSet rs = ps.executeQuery();
conn.setAutoCommit(false);
try {
stmt.executeUpdate("UPDATE accounts SET balance = balance - 100 WHERE id = 1");
stmt.executeUpdate("UPDATE accounts SET balance = balance + 100 WHERE id = 2");
conn.commit();
} catch (SQLException e) {
conn.rollback();
}

查看 JDBC 参考了解完整 API,包括批量操作、元数据、类型映射和服务器连接。