import org.adbcj.*;
import org.adbcj.jdbc.*;
public class DatabaseQuery {
public static void main(String[] args) throws Exception {
JdbcDbConnection connection = new JdbcDbConnection("jdbc:mysql://localhost:3306/mydatabase", "username", "password");
DbSession session = connection.connect().get();
// ...
}
}
import org.adbcj.*;
import org.adbcj.jdbc.*;
public class DatabaseQuery {
public static void main(String[] args) throws Exception {
JdbcDbConnection connection = new JdbcDbConnection("jdbc:mysql://localhost:3306/mydatabase", "username", "password");
DbSession session = connection.connect().get();
String sql = "SELECT * FROM mytable";
session.executeQuery(sql).thenAccept(result -> {
try {
while (result.next()) {
String column1 = result.getString("column1");
int column2 = result.getInt("column2");
// ...
}
} catch (Exception ex) {
ex.printStackTrace();
}
}).get();
}
}
import org.adbcj.*;
import org.adbcj.jdbc.*;
public class DatabaseQuery {
public static void main(String[] args) throws Exception {
JdbcDbConnection connection = new JdbcDbConnection("jdbc:mysql://localhost:3306/mydatabase", "username", "password");
DbSession session = connection.connect().get();
// ...
session.close().get();
}
}
