import org.adbcj.Connection;
import org.adbcj.ConnectionManager;
import org.adbcj.DriverManager;
import org.adbcj.PreparedStatement;
import org.adbcj.ResultSet;
import org.adbcj.Value;
import org.adbcj.ConnectionManagerProvider;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AdbcjJdbcDriverExample {
public static void main(String[] args) {
ConnectionManager connectionManager = DriverManager.getConnectionManager("jdbc:mysql://localhost:3306/mydatabase", "username", "password");
CompletableFuture<Connection> connectionFuture = connectionManager.connect();
try {
Connection connection = connectionFuture.get();
PreparedStatement statement = connection.prepareStatement("SELECT * FROM users");
CompletableFuture<ResultSet> resultSetFuture = statement.executeQuery();
ResultSet resultSet = resultSetFuture.get();
while (resultSet.hasNext()) {
Value[] row = resultSet.next().getRow();
for (Value value : row) {
System.out.print(value.getString() + " ");
}
System.out.println();
}
connection.close().get();
e.printStackTrace();
}
}
}
