import io.adbcj.*;
public class MultiThreadedExample {
public static void main(String[] args) throws Exception {
ConnectionManager connectionManager = ConnectionManagerProvider.createConnectionManager("jdbc:adbcj:mysql://localhost/test", "username", "password");
for (int i = 0; i < 10; i++) {
Thread thread = new Thread(() -> {
try {
Connection connection = connectionManager.connect().get();
Query query = connection.createQuery("SELECT * FROM table");
query.execute(new Callback<ResultSet>() {
@Override
public void onComplete(ResultSet result, Throwable t) {
if (t != null) {
t.printStackTrace();
} else {
for (Row row : result) {
// ...
}
}
}
});
} catch (Exception e) {
e.printStackTrace();
}
});
thread.start();
}
}
}
