个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
27
4
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
我一直在阅读有关汇编函数的内容，但对于是使用进入和退出还是仅使用调用/返回指令来快速执行，我感到很困惑。一种方式快而另一种方式更小吗？例如，在不内联函数的情况下，在汇编中执行此操作的最快(stdcal
我正在处理一个元组列表，如下所示: res = [('stori', 'JJ'), ('man', 'NN'), ('unnatur', 'JJ'), ('feel', 'NN'), ('pig',
最近我一直在做很多网络或 IO 绑定(bind)操作，使用线程有助于加快代码速度。我注意到我一直在一遍又一遍地编写这样的代码: threads = [] for machine, user, data
假设我有一个名为 user_stats 的资源，其中包含用户拥有的帖子、评论、喜欢和关注者的数量。是否有一种 RESTful 方式只询问该统计数据的一部分(即，对于 user_stats/3，请告诉我
我有一个简单的 api，它的工作原理是这样的: 用户创建一个请求 ( POST /requests ) 另一个用户检索所有请求 ( GET /requests ) 然后向请求添加报价 ( POST /
考虑以下 CDK Python 中的示例(对于这个问题，不需要 AWS 知识，这应该对基本上任何构建器模式都有效，我只是在这个示例中使用 CDK，因为我使用这个库遇到了这个问题。): from aws
Scala 中管理对象池的首选方法是什么？ 我需要单线程创建和删除大规模对象(不需要同步)。在 C++ 中，我使用了静态对象数组。 在 Scala 中处理它的惯用和有效方法是什么？ 最佳答案 我会把它
我有一个带有一些内置方法的类。这是该类的抽象示例: class Foo: def __init__(self): self.a = 0 self.b = 0
返回和检查方法执行的 Pythonic 方式 我目前在 python 代码中使用 golang 编码风格，决定移动 pythonic 方式 例子: import sys from typing imp
我正在开发一个 RESTful API。其中一个 URL 允许调用者通过 id 请求特定人员的记录。 返回该 id 不存在的记录的常规值是什么？服务器是否应该发回一个空对象或者一个 404，或者其他什
我正在使用 pathlib.Path() 检查文件是否存在，并使用 rasterio 将其作为图像打开. filename = pathlib.Path("./my_file-name.tif") 但
我正在寻找一种 Pythonic 方式来从列表和字典创建嵌套字典。以下两个语句产生相同的结果: a = [3, 4] b = {'a': 1, 'b': 2} c = dict(zip(b, a))
我有一个正在操裁剪理设备的脚本。设备有时会发生物理故障，当它发生时，我想重置设备并继续执行脚本。我有这个: while True: do_device_control() device
做组合别名的最pythonic和正确的方法是什么？ 这是一个假设的场景: class House: def cleanup(self, arg1, arg2, kwarg1=False):
我正在开发一个小型客户端服务器程序来收集订单。我想以“REST(ful)方式”来做到这一点。 我想做的是: 收集所有订单行(产品和数量)并将完整订单发送到服务器 目前我看到有两种选择: 将每个订单行发
我知道在 Groovy 中您可以使用字符串调用类/对象上的方法。例如: Foo."get"(1) /* or */ String meth = "get" Foo."$meth"(1) 有没有办法
在 ECMAScript6 中，您可以使用扩展运算符来解构这样的对象 const {a, ...rest} = obj; 它将 obj 浅拷贝到 rest，不带属性 a。 有没有一种干净的方法可以在
我有几个函数返回数字或None。我希望我的包装函数返回第一个不是 None 的结果。除了下面的方法之外，还有其他方法吗？ def func1(): return None def func2(
假设我想设计一个 REST api 来讨论歌曲、专辑和艺术家(实际上我就是这样做的，就像我之前的 1312414 个人一样)。 歌曲资源始终与其所属专辑相关联。相反，专辑资源与其包含的所有歌曲相关联。
这是我认为必须经常出现的问题，但我一直无法找到一个好的解决方案。假设我有一个函数，它可以作为参数传递一个开放资源(如文件或数据库连接对象)，或者需要自己创建一个。如果函数需要自己打开文件，最佳实践通常
我是一名优秀的程序员,十分优秀！