个人中心
gpt4 book ai didi

Vert-x-通过异步的方式使用JDBC连接SQL

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 27 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Vert-x-通过异步的方式使用JDBC连接SQL由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

在这篇文章中，我们将会看到怎样在vert.x应用中使用HSQL，当然也可以使用任意JDBC，以及使用vertx-jdbc-client提供的异步的API，这篇文章的代码在github.

异步?

vert.x一个很重要的特点就是它的异步性。使用异步的API，不需要等结果返回，当有结果返回时，vert.x会主动通知。为了说明这个，我们来看一个简单的例子.

我们假设有个add方法。一般来说，会像int r = add(1, 1)这样来使用它。这是一个同步的API，所以你必须等到返回结果。异步的API会是这样：add(1, 1, r -> { /*do something with the result*/})。在这个版本中，你传入了一个Handler，当结果计算出来时才被调用。这个方法不返回任何东西，实现如下:

?
1
2
3
4
public void add( int a, int b, Handler<Integer> resultHandler) {
int r = a + b;
resultHandler.handle(r);
}

为了避免混淆概念，异步API并不是多线程。像我们在add例子里看到的，并没有涉及多线程.

异步JDBC 。

看了一些基本的异步的API，现在了解下vertx-jdbc-client。这个组件能够让我们通过JDBC driver与数据库交互。这些交互都是异步的，以前这样:

?
1
2
String sql = "SELECT * FROM Products" ;
ResultSet rs = stmt.executeQuery(sql);

现在要这样:

?
1
2
3
connection.query( "SELECT * FROM Products" , result -> {
// do something with the result
});

这个模型更高效，当结果出来后vert.x通知，避免了等待结果.

增加maven依赖 。

在pom.xml文件中增加两个 Maven dependencies 。

?
1
2
3
4
5
6
7
8
9
10
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-jdbc-client</artifactId>
<version> 3.1 . 0 </version>
</dependency>
<dependency>
<groupId>org.hsqldb</groupId>
<artifactId>hsqldb</artifactId>
<version> 2.3 . 3 </version>
</dependency>

第一个依赖提供了vertx-jdbc-client，第二个提供了HSQL JDBC的驱动。如果你想使用另外一个数据库，修改这个依赖，同时你还需要修改JDBC url和JDBC driver名.

初始化JDBC client 。

创建JDBC 客户端（client）:

在MyFirstVerticle类中，声明一个新变量JDBCClient jdbc，并且在start方法中添加:

jdbc = JDBCClient.createShared(vertx, config(), "My-Whisky-Collection"),

创建了一个JDBC client实例，使用verticle的配置文件配置JDBC client。这个配置文件需要提供下面的配置才能让JDBC client正常工作:

url－JDBC url，例如：jdbc:hsqldb:mem:db?shutdown=true _driver class－JDBC的驱动，例如：org.hsqldb.jdbcDriver 。

有了client，接下来需要连接数据库。连接数据库是通过使用jdbc.getConnection来实现的，jdbc.getConnection需要传入一个Handler<AsyncResult<SQLConnection>>参数。我们深入的了解下这个类型。首先，这是一个Handler，因此当结果准备好时它就会被调用。这个结果是AsyncResult<SQLConnection>的一个实例。AsyncResult是vert.x提供的一个结构，使用它能够知道连接数据库的操作是成功或失败了。如果成功了，它就会提供一个结果，这里结果是一个SQLConnection的实例.

当你接收一个AsyncResult的实例时，代码通常是:

?
1
2
3
4
5
6
7
if (ar.failed()) {
System.err.println( "The operation has failed...: "
+ ar.cause().getMessage());
} else {
// Use the result:
result = ar.result();
}

需要获取到SQLConnection，然后启动rest的应用。因为变成了异步的，这需要改变启动应用的方式。因此，如果将启动序列划分成多块:

?
1
2
3
4
5
6
startBackend(
(connection) -> createSomeData(connection,
(nothing) -> startWebApp(
(http) -> completeStartup(http, fut)
), fut
), fut);

startBackend- 获取SQLConnection对象，然后调用下一步 createSomeData- 初始化数据库并插入数据。当完成后，调用下一步 startWebApp- 启动web应用 completeStartup- 最后完成启动 fut由vert.x传入，通知已经启动或者启动过程中遇到的问题.

startBackend方法:

?
1
2
3
4
5
6
7
8
9
private void startBackend(Handler<AsyncResult<SQLConnection>> next, Future<Void> fut) {
jdbc.getConnection(ar -> {
if (ar.failed()) {
fut.fail(ar.cause());
} else {
next.handle(Future.succeededFuture(ar.result()));
}
});
}

这个方法获取了一个SQLConnection对象，检查操作是否完成。如果成功，会调用下一步。失败了，就会报告一个错误。其他的方法遵循同样的模式:

检查上一步操作是否成功 。

处理业务逻辑 。

调用下一步 。

SQL 。

客户端已经准备好了，现在写SQL。从createSomeData方法开始，这个方法也是启动顺序中的一部分:

?
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
private void createSomeData(AsyncResult<SQLConnection> result,
Handler<AsyncResult<Void>> next, Future<Void> fut) {
if (result.failed()) {
fut.fail(result.cause());
} else {
SQLConnection connection = result.result();
connection.execute(
"CREATE TABLE IF NOT EXISTS Whisky (id INTEGER IDENTITY, name varchar(100), " +
"origin varchar(100))" ,
ar -> {
if (ar.failed()) {
fut.fail(ar.cause());
connection.close();
return ;
}
connection.query( "SELECT * FROM Whisky" , select -> {
if (select.failed()) {
fut.fail(ar.cause());
connection.close();
return ;
}
if (select.result().getNumRows() == 0 ) {
insert(
new Whisky( "Bowmore 15 Years Laimrig" , "Scotland, Islay" ),
connection,
(v) -> insert( new Whisky( "Talisker 57° North" , "Scotland, Island" ),
connection,
(r) -> {
next.handle(Future.<Void>succeededFuture());
connection.close();
}));
} else {
next.handle(Future.<Void>succeededFuture());
connection.close();
}
});
});
}
}

这个方法检查SQLConnection是否可用，然后执行一些SQL语句。首先，如果表不存在就创建表。看看下面代码:

?
1
2
3
4
connection.execute(
SQL statement,
handler called when the statement has been executed
)

handler接收AsyncResult<Void>，例如：只有是通知而已，没有实际返回的结果.

关闭连接 。

操作完成后，别忘了关闭SQL链接。这个连接会被放入连接池并且可以被重复利用.

在这个handler的代码里，检查了statement是否正确的执行了，如果正确，我们接下来检查表是否含有数据，如果没有，将会使用insert方法插入数据:

  。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
private void insert(Whisky whisky, SQLConnection connection, Handler<AsyncResult<Whisky>> next) {
String sql = "INSERT INTO Whisky (name, origin) VALUES ?, ?" ;
connection.updateWithParams(sql,
new JsonArray().add(whisky.getName()).add(whisky.getOrigin()),
(ar) -> {
if (ar.failed()) {
next.handle(Future.failedFuture(ar.cause()));
return ;
}
UpdateResult result = ar.result();
// Build a new whisky instance with the generated id.
Whisky w = new Whisky(result.getKeys().getInteger( 0 ), whisky.getName(), whisky.getOrigin());
next.handle(Future.succeededFuture(w));
});
}

这个方法使用带有INSERT（插入）statement（声明）的upateWithParams方法，且传入了值。这个方法避免了SQL注入。一旦statement执行了（当数据库没有此条数据就会创建），就创建一个新的Whisky对象，自动生成ID.

带有数据库（SQL）的REST 。

上面的方法都是启动顺序的一部分。但是，关于调用REST API的方法又是怎么样的呢？以getAll方法为例。这个方法被web应用前端调用，并检索存储的所有的产品:

?
1
2
3
4
5
6
7
8
9
10
11
12
private void getAll(RoutingContext routingContext) {
jdbc.getConnection(ar -> {
SQLConnection connection = ar.result();
connection.query( "SELECT * FROM Whisky" , result -> {
List<Whisky> whiskies = result.result().getRows().stream().map(Whisky:: new ).collect(Collectors.toList());
routingContext.response()
.putHeader( "content-type" , "application/json; charset=utf-8" )
.end(Json.encodePrettily(whiskies));
connection.close(); // Close the connection
});
});
}

这个方法获得了一个SQLConnection对象，然后发出一个查询。一旦获取到查询结果，它会像之前的方法一样写HTTP response。getOne、deleteOne、updateOne和addOne方法都是一样的。注意，在response之后，需要要关闭SQL连接.

看下传入到query方法的handler提供的结果。获取了一个包含了查询结果的ResultSet。每一行都是一个JsonObject，因此，如果你有一个数据对象使用JsonObject作为唯一的参数，那么创建这个对象很简单.

测试 。

需要小小的更新下测试程序，增加配置JDBCClient。在MyFirstVerticleTest类中，将setUp方法中创建的DeploymentOption对象修改成:

?
1
2
3
4
5
6
DeploymentOptions options = new DeploymentOptions()
.setConfig(new JsonObject()
.put( "http.port" , port)
.put( "url" , "jdbc:hsqldb:mem:test?shutdown=true" )
.put( "driver_class" , "org.hsqldb.jdbcDriver" )
);

除了http.port，还配置了JDBC url和JDBC驱动。测试时，使用的是一个内存数据库。在src/test/resources/my-it-config.json文件中也要做同样的修改.

?
1
2
3
4
5
{
"http.port" : ${http.port},
"url" : "jdbc:hsqldb:mem:it-test?shutdown=true" ,
"driver_class" : "org.hsqldb.jdbcDriver"
}

src/main/conf/my-application-conf.json文件也同样需要修改，这不是为了测试，而是为了运行这个应用:

?
1
2
3
4
5
{
"http.port" : 8082,
"url" : "jdbc:hsqldb:file:db/whiskies" ,
"driver_class" : "org.hsqldb.jdbcDriver"
}

这里这个JDBC url和上一个文件的有点不一样，因为需要将数据库存储到硬盘中.

展示时间！ 。

开始构建程序:

mvn clean package 。

没有修改API（没有更改发布的java文件和REST接口），测试应该是可以顺利的运行的.

启动应用:

java -jar target/my-first-app-1.0-SNAPSHOT-fat.jar -conf src/main/conf/my-application-conf.json 。

访问http://localhost:8082/assets/index.html，然后，你可以看到这个应用使用的是数据库了。这一次，就算重启应用，这些数据仍然在，因为存储产品被持久化到硬盘里了.

总结 。

这篇文章中，知道了怎么在vert.x里使用JDBC数据库，并没有很多复杂的东西。开始可能会被这个异步的开发模型惊讶到，但是，一旦你开始使用了，你就很难再回去了.

下一次，我们将看到这个应用怎么使用mongoDB来替换HSQL.

欢迎关注<a href="http://quanke.name/"  rel="nofollow" ></a> 。

交流群：231419585 。

转载请注明出处，谢谢 。

最后此篇关于Vert-x-通过异步的方式使用JDBC连接SQL的文章就讲到这里了,如果你想了解更多关于Vert-x-通过异步的方式使用JDBC连接SQL的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

27 4 0
文章推荐： PHP数据类型之布尔型的介绍
文章推荐： Spring3.1.1+MyBatis3.1.1的增、删、查、改以及分页和事务管理
文章推荐： Java实现爬虫给App提供数据（Jsoup 网络爬虫）
文章推荐： 了解Java虚拟机JVM的基本结构及JVM的内存溢出方式
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com