Aller au contenu

JDBC

PetraDB inclut un pilote JDBC 4 pour les applications JVM. Le pilote s’enregistre automatiquement via le mécanisme Java ServiceLoader. Il est distribué sous forme d’un fat jar unique sans dépendances transitives.

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'

sbt :

libraryDependencies += "io.github.edadma" % "petradb-jdbc" % "1.5.0"

Ou téléchargez le jar directement depuis Maven Central.

Connection conn = DriverManager.getConnection("jdbc:petradb:memory");

Chaque connexion crée une base de données en mémoire isolée.

Connection conn = DriverManager.getConnection("jdbc:petradb:file:/path/to/database.petra");

Ouvre une base de données existante ou en crée une nouvelle. Extensions de fichiers supportées :

ExtensionBackend
.petraStockage persistant par pages
.ptxtStockage basé sur du texte
autreStockage persistant par pages (par défaut)
Properties props = new Properties();
props.setProperty("user", "username");
props.setProperty("password", "password");
Connection conn = DriverManager.getConnection("jdbc:petradb://localhost:5480", props);
Statement stmt = conn.createStatement();
// Requête
ResultSet rs = stmt.executeQuery("SELECT * FROM users");
// Mise à jour
int rowCount = stmt.executeUpdate("INSERT INTO users (name) VALUES ('Alice')");
// Exécution générale
boolean hasResults = stmt.execute("SELECT 1");

Utilise les placeholders de paramètres ? :

PreparedStatement ps = conn.prepareStatement(
"SELECT * FROM users WHERE id = ? AND active = ?");
ps.setInt(1, 42);
ps.setBoolean(2, true);
ResultSet rs = ps.executeQuery();

Méthodes setter supportées :

MéthodeType SQL
setInt(index, value)INT
setLong(index, value)BIGINT
setFloat(index, value)FLOAT
setDouble(index, value)DOUBLE
setBigDecimal(index, value)NUMERIC
setString(index, value)TEXT
setBoolean(index, value)BOOLEAN
setDate(index, value)DATE
setTimestamp(index, value)TIMESTAMP
setNull(index, sqlType)NULL
setObject(index, value)auto-détecté
Statement stmt = conn.createStatement();
stmt.addBatch("INSERT INTO users (name) VALUES ('Alice')");
stmt.addBatch("INSERT INTO users (name) VALUES ('Bob')");
int[] counts = stmt.executeBatch();
PreparedStatement ps = conn.prepareStatement(
"INSERT INTO users (name, email) VALUES (?, ?)");
ps.setString(1, "Alice");
ps.setString(2, "alice@example.com");
ps.addBatch();
ps.setString(1, "Bob");
ps.setString(2, "bob@example.com");
ps.addBatch();
int[] counts = ps.executeBatch();

Jeux de résultats en lecture seule et en avant uniquement :

ResultSet rs = stmt.executeQuery("SELECT id, name FROM users");
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
// rs.wasNull() vérifie si la dernière valeur lue était NULL
}
rs.close();

Accès aux colonnes par index (base 1) ou par nom :

rs.getInt(1); // par position
rs.getString("name"); // par label

L’auto-commit est activé par défaut. Désactivez-le pour un contrôle explicite des transactions :

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();
}
DatabaseMetaData meta = conn.getMetaData();
// Lister les tables
ResultSet tables = meta.getTables(null, null, null, null);
while (tables.next()) {
String tableName = tables.getString("TABLE_NAME");
}
// Lister les colonnes
ResultSet cols = meta.getColumns(null, null, "users", null);
while (cols.next()) {
String name = cols.getString("COLUMN_NAME");
String type = cols.getString("TYPE_NAME");
boolean nullable = cols.getInt("NULLABLE") == DatabaseMetaData.columnNullable;
}
// Clés primaires
ResultSet pks = meta.getPrimaryKeys(null, null, "users");
// Clés étrangères
ResultSet fks = meta.getImportedKeys(null, null, "orders");
// Index
ResultSet idxs = meta.getIndexInfo(null, null, "users", false, false);

getColumns() retourne COLUMN_SIZE, DECIMAL_DIGITS et CHAR_OCTET_LENGTH basés sur le type et la précision/échelle de chaque colonne :

Type de colonneCOLUMN_SIZEDECIMAL_DIGITSCHAR_OCTET_LENGTH
VARCHAR(n) / CHAR(n)nnulln * 4
TEXT2147483647null2147483647
INT / SERIAL100null
BIGINT / BIGSERIAL190null
NUMERIC(p,s)psnull
BOOLEAN1nullnull
Type PetraDBType JDBCType Java
INT / SERIALTypes.INTEGERInteger
BIGINT / BIGSERIALTypes.BIGINTLong
DOUBLETypes.DOUBLEDouble
NUMERICTypes.NUMERICBigDecimal
TEXT / VARCHAR / CHARTypes.VARCHARString
BOOLEANTypes.BOOLEANBoolean
DATETypes.DATEjava.sql.Date
TIMESTAMPTypes.TIMESTAMPjava.sql.Timestamp
UUID / ENUMTypes.VARCHARString