-
Notifications
You must be signed in to change notification settings - Fork 2.1k
/
SqlClientExample.java
83 lines (72 loc) · 2.96 KB
/
SqlClientExample.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
package io.vertx.example.sqlclient.template_mapping;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Vertx;
import io.vertx.pgclient.PgConnectOptions;
import io.vertx.sqlclient.Pool;
import io.vertx.sqlclient.PoolOptions;
import io.vertx.sqlclient.RowSet;
import io.vertx.sqlclient.SqlConnectOptions;
import io.vertx.sqlclient.SqlResult;
import io.vertx.sqlclient.templates.SqlTemplate;
import org.testcontainers.containers.PostgreSQLContainer;
import java.util.Arrays;
import java.util.Collections;
import java.util.Map;
/*
* @author <a href="mailto:pmlopes@gmail.com">Paulo Lopes</a>
*/
public class SqlClientExample extends AbstractVerticle {
// Convenience method so you can run it in your IDE
public static void main(String[] args) {
PostgreSQLContainer<?> postgres = new PostgreSQLContainer<>();
postgres.start();
PgConnectOptions options = new PgConnectOptions()
.setPort(postgres.getMappedPort(5432))
.setHost(postgres.getContainerIpAddress())
.setDatabase(postgres.getDatabaseName())
.setUser(postgres.getUsername())
.setPassword(postgres.getPassword());
// Uncomment for MySQL
// MySQLContainer<?> mysql = new MySQLContainer<>();
// mysql.start();
// MySQLConnectOptions options = new MySQLConnectOptions()
// .setPort(mysql.getMappedPort(3306))
// .setHost(mysql.getContainerIpAddress())
// .setDatabase(mysql.getDatabaseName())
// .setUser(mysql.getUsername())
// .setPassword(mysql.getPassword());
Vertx vertx = Vertx.vertx();
vertx.deployVerticle(new SqlClientExample(options));
}
private final SqlConnectOptions options;
public SqlClientExample(SqlConnectOptions options) {
this.options = options;
}
@Override
public void start() {
Pool pool = Pool.pool(vertx, options, new PoolOptions().setMaxSize(4));
// create a SQL template for inserting users
SqlTemplate<User, SqlResult<Void>> insertTemplate = SqlTemplate
.forUpdate(pool, "insert into users values (#{id}, #{first_name}, #{last_name})").mapFrom(UserParametersMapper.INSTANCE);
// create a SQL template for querying users
SqlTemplate<Map<String, Object>, RowSet<User>> queryTemplate = SqlTemplate
.forQuery(pool, "select * from users where id = #{id}").mapTo(UserRowMapper.INSTANCE);
// create a test table
pool.query("create table users(id int primary key, first_name varchar(255), last_name varchar(255))")
.execute()
.compose(r ->
// insert some test data
insertTemplate.executeBatch(Arrays.asList(
new User().setId(1).setFirstName("Dale").setLastName("Cooper"),
new User().setId(2).setFirstName("Sherlock").setLastName("Holmes")
))
).compose(r ->
// query some data with arguments
queryTemplate.execute(Collections.singletonMap("id", 2))
).onSuccess(users -> {
for (User user : users) {
System.out.println("user = " + user);
}
}).onFailure(Throwable::printStackTrace);
}
}