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(); } } }


上一篇:
下一篇:
切换中文