import org.adbcj.*;
import java.util.concurrent.CompletableFuture;
public class ADBCJExample {
public static void main(String[] args) {
DbConnection connection = ConnectionManager.getConnection("jdbc:adbcj:mydatabase");
final CompletableFuture<Result> future = connection.executeQuery("SELECT * FROM mytable");
future.thenAccept(result -> {
for (Row row : result) {
System.out.println(row.get("column1") + " " + row.get("column2"));
}
});
future.whenComplete((result, throwable) -> {
if (throwable != null) {
} else {
}
connection.close().join();
});
}
}