<dependency>
<groupId>io.reactiverse</groupId>
<artifactId>reactive-pg-client</artifactId>
</dependency>
import io.reactiverse.pgclient.*;
public class AsyncDatabaseQuery {
public static void main(String[] args) {
PgConnectOptions connectOptions = new PgConnectOptions()
.setHost("localhost")
.setPort(5432)
.setDatabase("mydatabase")
.setUser("myuser")
.setPassword("mypassword");
PgClient client = PgClient.pool(connectOptions, new PoolOptions());
client.query("SELECT * FROM mytable", ar -> {
if (ar.succeeded()) {
RowSet<Row> result = ar.result();
result.forEach(row -> {
System.out.println(row.getString("column1"));
});
} else {
ar.cause().printStackTrace();
}
client.close();
});
}
}
import io.reactiverse.pgclient.*;
public class AsyncConnectionPool {
public static void main(String[] args) {
PgConnectOptions connectOptions = new PgConnectOptions()
.setHost("localhost")
.setPort(5432)
.setDatabase("mydatabase")
.setUser("myuser")
.setPassword("mypassword");
PoolOptions poolOptions = new PoolOptions()
PgPool client = PgClient.pool(connectOptions, poolOptions);
client.query("SELECT * FROM mytable", ar -> {
});
}
}
client.query("SELECT * FROM mytable", ar -> {
if (ar.succeeded()) {
RowSet<Row> result = ar.result();
result.forEach(row -> {
System.out.println(row.getString("column1"));
});
} else {
ar.cause().printStackTrace();
}
});
