database {
type = "mysql"
host = "localhost"
port = 3306
user = "root"
password = "password"
database = "mydatabase"
}
import org.adbcj.Connection;
import org.adbcj.DriverManager;
import org.adbcj.Result;
import org.adbcj.Value;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class ADBCJExample {
public static void main(String[] args) {
Connection connection = DriverManager.getConnection("adbcj:mysql://localhost:3306/mydatabase", "root", "password");
CompletableFuture<Result> queryFuture = connection.executeQuery("SELECT * FROM mytable");
queryFuture.thenAccept(result -> {
try {
System.out.println(result.getAffectedRows());
for (Value[] row : result.getRows()) {
System.out.println(row.toString());
}
e.printStackTrace();
}
});
CompletableFuture<Result> updateFuture = connection.executeUpdate("UPDATE mytable SET column1 = 'value' WHERE id = 1");
updateFuture.thenAccept(result -> {
try {
System.out.println(result.getAffectedRows());
e.printStackTrace();
}
});
connection.close();
}
}
