import org.adbcj.Connection;
import org.adbcj.ConnectionManager;
import org.adbcj.ConnectionManagerProvider;
import org.adbcj.DbException;
import org.adbcj.DbFuture;
import org.adbcj.jdbc.AdbcjConnectionManagerProvider;
public class ExampleApplication {
private static final int CONNECTION_POOL_SIZE = 10;
public static void main(String[] args) {
ConnectionManagerProvider.setInstance(new AdbcjConnectionManagerProvider());
ConnectionManager connectionManager = ConnectionManagerProvider.getInstance().createConnectionManager("jdbc:adbcj:mydatabase");
connectionManager.setMaxConnections(CONNECTION_POOL_SIZE);
try {
DbFuture<Connection> future = connectionManager.connect();
future.thenAccept(connection -> {
// ...
connection.close().join();
});
} catch (DbException e) {
e.printStackTrace();
}
}
}