<dependency>
<groupId>org.adbcj</groupId>
<artifactId>adbcj</artifactId>
<version>0.8.5</version>
</dependency>
implementation 'org.adbcj:adbcj:0.8.5'
import org.adbcj.Connection;
import org.adbcj.ConnectionManager;
import org.adbcj.ConnectionManagerProvider;
ConnectionManager connectionManager = ConnectionManagerProvider.createConnectionManager("adbcj:mysql://localhost/mydatabase", "username", "password");
import org.adbcj.DbFuture;
import org.adbcj.Result;
import org.adbcj.Record;
import org.adbcj.UnsupportedResultCheck;
DbFuture<Result> resultFuture = connection.executeQuery("SELECT * FROM my_table");
resultFuture.addListener(future -> {
Result result = future.getResult();
for (Record record : result) {
}
Throwable error = future.getThrowable();
}
}, UnsupportedResultCheck.INSTANCE);
import org.adbcj.PreparedStatement;
import org.adbcj.UpdateResult;
DbFuture<UpdateResult> updateFuture = connection.executeUpdate("INSERT INTO my_table (column1, column2) VALUES (?, ?)", "value1", "value2");
updateFuture.addListener(future -> {
UpdateResult updateResult = future.getResult();
Throwable error = future.getThrowable();
}
}, UnsupportedResultCheck.INSTANCE);
