import io.github.adbcj.Connection;
import io.github.adbcj.ConnectionManager;
import io.github.adbcj.DriverManager;
import io.github.adbcj.Record;
import io.github.adbcj.Result;
public class AsyncDatabaseExample {
public static void main(String[] args) {
ConnectionManager connectionManager = DriverManager.getConnectionManager("jdbc:adbcj:my_database_url");
connectionManager.connect(connection -> {
Result result = connection.executeQuery("SELECT * FROM users");
result.onComplete(queryResult -> {
for (Record record : queryResult) {
String username = record.get("username", String.class);
String email = record.get("email", String.class);
System.out.println("Username: " + username + ", Email: " + email);
}
});
});
}
}
