import io.adbcj.Connection;
import io.adbcj.ConnectionManager;
import io.adbcj.DbException;
import io.adbcj.DbFuture;
import io.adbcj.Result;
import io.adbcj.Statement;
import io.adbcj.Value;
public class AdbcjExample {
public static void main(String[] args) {
DbFuture<Connection> futureConnection = connectionManager.connect("jdbc:mysql://localhost:3306/test", "username", "password");
futureConnection.onSuccess(conn -> {
DbFuture<Statement> futureStatement = conn.createStatement();
futureStatement.onSuccess(stmt -> {
DbFuture<Result> futureResult = stmt.executeQuery("SELECT * FROM table");
futureResult.onSuccess(result -> {
for (Value[] row : result) {
// ...
}
});
futureResult.onFailure(e -> {
// ...
});
});
futureStatement.onFailure(e -> {
// ...
});
});
futureConnection.onFailure(e -> {
// ...
});
}
}
