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,当结果计算出来时才被调用。这个方法不返回任何东西,实现如下:

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与数据库交互。这些交互都是异步的,以前这样:

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

现在要这样:

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

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

增加maven依赖

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

<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的实例时,代码通常是:

if (ar.failed()) {
System.err.println("The operation has failed...: "
+ ar.cause().getMessage());
} else {
// Use the result:
result = ar.result();
}

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

startBackend(
(connection) -> createSomeData(connection,
(nothing) -> startWebApp(
(http) -> completeStartup(http, fut)
), fut
), fut);

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

startBackend方法:

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方法开始,这个方法也是启动顺序中的一部分:

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语句。首先,如果表不存在就创建表。看看下面代码:

connection.execute(
SQL statement,
handler called when the statement has been executed
)

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

关闭连接

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

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

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应用前端调用,并检索存储的所有的产品:

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对象修改成:

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文件中也要做同样的修改。

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

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

{
"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

转载请注明出处,谢谢

(0)

相关推荐

  • 详解Java的JDBC中Statement与PreparedStatement对象

    一旦获得一个连接,我们可以与数据库进行交互.在JDBC Statement, CallableStatement 和 PreparedStatement 接口定义的方法和属性,使可以发送SQL或PL/SQL命令和从数据库接收数据. 它们还定义方法,帮助Java和数据库使用SQL数据类型之间转换数据的差异. 下表提供了每个接口的用途概要,了解决定使用哪个接口 Statement 对象: 创建Statement对象 在可以使用Statement对象执行SQL语句,需要使用Connection对象的c

  • 完整java开发中JDBC连接数据库代码和步骤

    JDBC连接数据库 •创建一个以JDBC连接数据库的程序,包含7个步骤: 1.加载JDBC驱动程序: 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机), 这通过java.lang.Class类的静态方法forName(String className)实现. 例如: try{ //加载MySql的驱动类 Class.forName("com.mysql.jdbc.Driver") ; }catch(ClassNotFoundException e){ Sys

  • 解析jdbc处理oracle的clob字段的详解

    import java.io.BufferedOutputStream;import java.io.ByteArrayInputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.Reader;import java.sql.Clob;import java.sql.Connection;import java.sql.ResultSet;

  • 在eclipse导入Java的jar包的方法JDBC(图文说明)

    在使用JDBC编程时需要连接数据库,导入JAR包是必须的,导入其它的jar包方法同样如此,导入的方法是 打开eclipse 1.右击要导入jar包的项目,点properties  2.左边选择java build path,右边选择libraries  3.选择add External jars  4.选择jar包的按照路径下的 确定后就行了. Java连接MySQL的最新驱动包下载地址 http://www.mysql.com/downloads/connector/j 有两种方法导入jar包

  • 基于Java回顾之JDBC的使用详解

    尽管在实际开发过程中,我们一般使用ORM框架来代替传统的JDBC,例如Hibernate或者iBatis,但JDBC是Java用来实现数据访问的基础,掌握它对于我们理解Java的数据操作流程很有帮助. JDBC的全称是Java Database Connectivity. JDBC对数据库进行操作的流程:•连接数据库•发送数据请求,即传统的CRUD指令•返回操作结果集JDBC中常用的对象包括:•ConnectionManager•Connection•Statement•CallableStat

  • jdbc调用mysql存储过程实现代码

    1. 创建存储过程 建立一个MySQL的存储过程 add_pro 复制代码 代码如下: delimiter // drop procedure add_pro // create procedure add_pro(a int , b int , out sum int ) begin set sum = a * b; end; // 2. 调用存储过程 复制代码 代码如下: package com.zhanggaosong; import java.sql.CallableStatement;

  • MyEclipse通过JDBC连接MySQL数据库基本介绍

    1.前提是MyEclipse已经能正常开发Java工程 2.安装MySQL 个人使用的是版本是 mysql-5.0.22-win32.zip 网址:http://www.mysql.com/downloads/mysql/#downloads 3.下载JDBC驱动 个人使用的是 mysql-connector-java-5.1.22.zip,所需要的就是解压缩之后其中的 mysql-connector-java-5.1.22-bin.jar 网址:http://www.mysql.com/dow

  • 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会

  • JDBC连接Sql Server 2005总结

    1.准备工作: 准备相关的软件(Eclipse除外,开源软件可以从官网下载) <1>.Microsoft SQL server 2005 Express Edition 下载地址:http://download.microsoft.com/download/0/9/0/09020fab-d2c3-4a8c-b9e0-db53a7a30ae8/SQLEXPR_CHS.EXE <2>.SQL Server Management Studio 下载地址:http://www.micros

  • jdbc连接sql server数据库问题分析

    SQL Server连接中问题还真多.不进行设置还真连接不上,这里小记一下!(部分资料来源于互联网) JDBC连接MySQL出现的问题 (例子里面自带JDBC2005的驱动,在lib文件夹下,右键点击Build Path--->add to build build path 即可) 运行connectionSqlServer2005包下的JavaConnectionSQL类即可! 1. 驱动问题: JDBC2005与JDBC2008一定要对号入座,否则会报错!(本人用的是2008) 2. 服务启

  • Windows系统下Java连接SQL Server的方法简介

    使用JDBC连接SQL Server 设置SQL Server服务器 我使用的是SQL Server 2005标准版SP2,这些都默认即可,一般不用配置.如果需要配置端口请看下面. 1."开始"→"程序"→"Microsoft SQL Server 2005"→"配置工具"→"SQL Server 配置管理器"→"SQL Server 2005 网络配置"→"MSSQLSERV

  • JDBC连接Access数据库的几种方式介绍

    接下来总结一下常用的几种连接方式. 例如有如下的Access数据库student,表basic,以及6条记录,现在通过几种方式在Jsp中将他们的数据显示出来.如图所示: 对于几种连接Access数据库的方式,基本上都是基于JDBC-ODBC方式的,当然也有纯JDBC驱动的方式.这里我暂时就不说了.对于这几种方式,除了取得连接之处不同外,其他的代码都是一样的.所以这里先写出取得连接的几种方式,然后再用完整的代码进行显示. 方式一:通过JDBC-ODBC方式桥连直接连接: 1.对于这种方式,首先要建

  • Java中JDBC连接池的基本原理及实现方式

    目录 一. 应用程序直接建立数据库连接模型 二.使用数据库连接池优化模型 1.关于连接池中的连接数量的一些规定: 2.编写数据库连接池 创建数据库连接池: 进一步封装一些相关数据库的类的方法 三.两个开源的数据库连接池 1.dbcp连接 (1)导入相关jar包 (2)在项目根目录增加配置文件dbcp.properties (3)程序实现dbcp连接 2.c3p0连接池 (1)导入相关的jar包 (2)在项目根目录下增加配置文件 (3)编写类文件,创建连接池 3.dbcp和c3p0不同之处 一.

  • JDBC连接mysql处理中文时乱码解决办法详解

    JDBC连接mysql处理中文时乱码解决办法详解 近日,整合的项目需要跟一个比较老版本的mysql服务器连接,使用navicat查看,发现此mysql服务器貌似没有设置默认编码,而且从操作此mysql的部分php文件看,应该是使用的gb2312的编码,但是,直接使用jdbc操作,从库中读取出来的中文全都是乱码. 一开始,使用类似entity.setDepartName(new String(rs.getString("hg").getBytes("gbk"), &q

  • JSP使用JDBC连接MYSQL数据库的方法

    本文实例讲述了JSP使用JDBC连接MYSQL数据库的方法.分享给大家供大家参考,具体如下: 1. 可在 http://www.mysql.com/products/connector-j/index.html下载MySQL JDBC驱动程序mysql-connector-java-*.jar,如我下载的是mysql-connector-java-5.1.18-bin.jar并加入到ClassPath下面,或加入到项目中.   2. 注册JDBC驱动程序 try { Class.forName(

  • java使用jdbc连接数据库工具类和jdbc连接mysql数据示例

    这个工具类使用简单,实例化直接调用就可以了,大家还可以方便的根据自己的需要在里面增加自己的功能 复制代码 代码如下: package com.lanp.ajax.db; import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException; /** * 连接数据库的工具类,被定

  • mysql jdbc连接步骤及常见参数

    mysql数据库自不必说,现在很多程序开发应用及站长们常用到,jdbc可能一般会比较陌生一些,jdbc是什么意思?这里也会提到,最主要的是为大家介绍一下,mysql jdbc连接步骤及常见参数详解. jdbc是什么意思? jdbc(java data base connectivity,java数据库连接)是一种用于执行sql语句的javaapi,可以为多种关系数据库提供统一访问,它由一组用java语言编写的类和接口组成.jdbc提供了一种基准,据此可以构建更高级的工具和接口,使数据库开发人员能

随机推荐