Connection connection = new LocalConnectionProvider().createConnection("jdbc:adbcj:mysql://localhost:3306/mydatabase", "username", "password");
CompletableFuture<QueryResult> queryFuture = connection.executeQuery("SELECT * FROM mytable");
queryFuture.whenComplete((resultSet, throwable) -> {
});
BatchingPreparedStatementBuilder builder = connection.batchingPreparedStatementBuilder("INSERT INTO mytable (column1, column2) VALUES (?, ?)");
for (int i = 0; i < 1000; i++) {
builder.setString(1, "value1");
builder.setString(2, "value2");
builder.addBatch();
}
CompletableFuture<Void> insertFuture = builder.execute();
insertFuture.whenComplete((result, throwable) -> {
});
connection.close().get();
