Vert.x，Databases

🕗 发布于 2024-09-27 20:54 java vert.x

Vert.x数据库(访问)简介

Vert.x提供了数据库相关模块(扩展包)，方便我们通过异步方式访问数据库。数据库扩展主要包括：响应式数据库客户端(vertx-xxx-client)和通用JDBC客户端(vertx-jdbc-client)。

响应式数据库客户端是事件驱动和非阻塞的，可以仅仅使用一条线程来处理大量的数据库连接。专注于可伸缩性和低开销。这些客户端还内置连接池，提供了更简单易用的API。目前(v4.5.10)，Vert.x提供主流数据库的响应式客户端，包含: PostgreSQL，MySQL，DB2，Oracle，MSSQL，MongoDB，Redis，Apache Cassandra。

如果不想使用Vert.x提供的响应式数据库客户端(比如某些特性不支持)，或者Vert.x还没提供你所需要访问的数据库的响应式客户端，如: H2，那么可以通过通用JDBC客户端加JDBC驱动方式异步访问对应数据库。

Vert.x通过Sql Client API(vertx-sql-client)使用数据库客户端客户端，类图大致如下:

SQLOperations  <---   SQLClient <--  JDBCClient  <-- Pool <-- JDBCPool <--  JDBCPoolImpl
               <--+
       \- SQLConnection

使用响应式客户端

以MySQL为例，我们首先需要引入vertx-mysql-client依赖:

<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-mysql-client</artifactId>
<version>4.5.10</version>
</dependency>

MySQL客户端的案例:

import java.util.logging.Level;
import java.util.logging.Logger;

import io.vertx.core.Future;
import io.vertx.mysqlclient.MySQLBuilder;
import io.vertx.mysqlclient.MySQLConnectOptions;
import io.vertx.sqlclient.PoolOptions;
import io.vertx.sqlclient.Row;
import io.vertx.sqlclient.RowSet;
import io.vertx.sqlclient.SqlClient;
import io.vertx.sqlclient.Tuple;

public class Db1 {
private static final Logger LOGGER = Logger.getLogger(Db1.class.getName());
public static void main(String[] args) {
MySQLConnectOptions connectOptions = new MySQLConnectOptions()
.setHost("127.0.0.1").setPort(3306)
.setUser("root").setPassword("Passw0rd")
.setDatabase("information_schema")
.addProperty("autoReconnect", "true") //添加连接参数
.addProperty("useSSL","false")
.addProperty("rewriteBatchedStatements", "true");

PoolOptions poolOptions = new PoolOptions().setMaxSize(5);

SqlClient client = MySQLBuilder.client()
.with(poolOptions)
.connectingTo(connectOptions)
.build();

String sqlText = "select table_name, TABLE_ROWS from tables where table_type=? and table_schema=? limit 2";
Future<RowSet<Row>> future = client.preparedQuery(sqlText)
.execute(Tuple.of("BASE TABLE", "performance_schema"));

future.onComplete(ar -> {
if (ar.succeeded()) {
RowSet<Row> rows = ar.result();
for (Row row : rows) {
// 注意: 字段名区分大小写
// 否则抛异常: java.util.NoSuchElementException: Column xxx does not exist
LOGGER.info(row.getString("TABLE_NAME") + ", " + row.getLong("TABLE_ROWS") + " rows.");
}
} else {
LOGGER.log(Level.SEVERE, "", ar.cause());
}
client.close(); // 关闭客户端
});
}
}

使用JDBC客户端

要使用JDBC客户端，需要引入"vertx-jdbc-client"和对应的JDBC驱动，如果使用连接池，还需要引入"agroal-pool"依赖：

<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-jdbc-client</artifactId>
<version>4.5.10</version>
</dependency>
<dependency>
<groupId>io.agroal</groupId>
<artifactId>agroal-pool</artifactId>
<version>2.5</version>
</dependency>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<version>8.4.0</version>
</dependency>

JdbcClient访问MySQL数据库

访问MySQL数据库案例：

import java.util.logging.Level;
import java.util.logging.Logger;

import io.vertx.core.Vertx;
import io.vertx.jdbcclient.JDBCConnectOptions;
import io.vertx.jdbcclient.JDBCPool;
import io.vertx.sqlclient.PoolOptions;
import io.vertx.sqlclient.Row;
import io.vertx.sqlclient.RowSet;
import io.vertx.sqlclient.Tuple;

public class Db2 {
private static final Logger LOGGER = Logger.getLogger(Db2.class.getName());
public static void main(String[] args) {
JDBCConnectOptions connectOptions = new JDBCConnectOptions()
.setJdbcUrl("jdbc:mysql://localhost:3306/information_schema?useSSL=false&autoReconnect=true")
.setUser("root").setPassword("Passw0rd");

PoolOptions poolOptions = new PoolOptions().setMaxSize(5).setName("mysql-conn-pool");

Vertx vertx = Vertx.vertx();

String sqlText = "select table_name, TABLE_ROWS from tables where table_type=? and table_schema=? limit 2";
JDBCPool client = JDBCPool.pool(vertx, connectOptions, poolOptions);

client.preparedQuery(sqlText)
.execute(Tuple.of("BASE TABLE", "performance_schema"))
.onComplete(ar -> {
if (ar.succeeded()) {
RowSet<Row> rows = ar.result();
for (Row row : rows) {
// 注意: 字段名区分大小写
// 否则抛异常: java.util.NoSuchElementException: Column xxx does not exist
LOGGER.info(row.getString("TABLE_NAME") + ", " + row.getLong("TABLE_ROWS") + " rows.");
}
} else {
LOGGER.log(Level.SEVERE, "", ar.cause());
}
client.close(); // 关闭客户端
});
}
}

Retrieving the generated keys

获取自动生成的键值。该功能依赖JDBC驱动的功能。

// 测试表结构: create table tpcc.test1(id int not null auto_increment, name varchar(32), primary key (id));
JDBCPool client = ...
// SqlClient = ... MySQL异步客户端不支持以下用法, lastInsertId.getLong(0)会返回空值。
String sqlText = "insert tpcc.test1(name) values('hello mysql client!')";
client.preparedQuery(sqlText).execute().onSuccess(rows -> {
Row lastInsertId = rows.property(JDBCPool.GENERATED_KEYS);
long newId = lastInsertId.getLong(0);
LOGGER.info("generated keys: " + newId);
client.close();
}).onFailure(e->e.printStackTrace());

使用存储过程和函数

/*
delimiter $$
create procedure tpcc.new_test1(OUT id INT, IN  name VARCHAR(32))
begin
insert tpcc.test1(name) values(name);
select LAST_INSERT_ID() into id;
end $$
delimiter ;
*/
String sqlText = "{call tpcc.new_test1(?, ?)}";
client.preparedQuery(sqlText)
.execute(Tuple.of(SqlOutParam.OUT(JDBCType.INTEGER), "John"))
.onFailure(e -> e.printStackTrace())
.onSuccess(rows -> {
if (rows.property(JDBCPool.OUTPUT)) {
for (Row row : rows) {
LOGGER.info("generated keys: " + row.getLong(0));
}
}
client.close();
});

SQL客户端模版

Vert.x提供一小的工具库SQL Client Templates来便利我们对数据库的访问，要使用SQL客户端模版需要引入vertx-sql-client-templates依赖:

<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-sql-client-templates</artifactId>
<version>4.5.10</version>
</dependency>

使用命名参数


SqlClient client = ...
Map<String, Object> parameters = new HashMap<>();
parameters.put("type", "BASE TABLE");
parameters.put("schema", "performance_schema");

String sqlText = "select table_name, TABLE_ROWS from tables where table_type=#{type} and table_schema=#{schema} limit 2";
SqlTemplate.forQuery(client, sqlText).execute(parameters).onSuccess(rows -> {
for (Row row : rows) {
LOGGER.info(row.getString("TABLE_NAME") + ", " + row.getLong("TABLE_ROWS") + " rows.");
}
client.close();
});

行映射

可以提供一个自定义的RowMapper，将Row映射到一个实体类。

//   Row -> 用户类PsTable
class PsTable {
String tableName;
int rows;

public String getTableName() {
return tableName;
}

public void setTableName(String name) {
tableName = name;
}

public void setRows(int rows) {
this.rows = rows;
}

public int getRows() {
return rows;
}

@Override
public String toString() {
return tableName + ", " + rows + " rows.";
}
}
// ...
SqlTemplate.forQuery(client, sqlText).mapTo(row -> {
PsTable table = new PsTable();
table.setTableName(row.getString("TABLE_NAME"));
table.setRows(row.getInteger("TABLE_ROWS"));
return table;
}).execute(parameters).onSuccess(tables -> {
for (PsTable table : tables) {
LOGGER.info(table.toString());
}
client.close();
});

原文地址：https://blog.csdn.net/Li_Xiang_996/article/details/142584046

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：pysim-4-1.1.17 eUICC ISD-R commands
下一篇：支持分页的环形队列

linux网络编程9
readyState（请求状态）：0为未初始化，1为正在加载，2为已经加载，3为交互中，4为完成；其是HTTP服务器与其他程序进行“交谈”的工具，通过CGI接口能在服务器端运行其他的程序；其最大的优点
阅读更多2024-09-27
springboot 工程读取自定义的xml文件
springboot 读 xml文件
阅读更多2024-09-27
Vulhub TheEther_1.0.1靶机详解
靶机TheEther_1.0.1速刷
阅读更多2024-09-27
JAVA MySQL或SQLSERVER处理大量update语句优化
在 MySQL 或者SQLSERVER 中处理大量 UPDATE 语句时，性能优化是一个关键问题。1、使用 CASE 语句进行批量更新。2、使用 JOIN 进行批量更新。
阅读更多2024-09-27
MySQL 之索引详解
索引是 MySQL 数据库中非常重要的一个概念，合理地使用索引可以大大提高数据库的查询效率。在设计和使用索引时，需要根据实际情况选择合适的索引类型，并尽量避免索引失效的情况。
阅读更多2024-09-27
CTF入门教程（非常详细）从零基础入门到竞赛，看这一篇就够了！
CTF（Capture The Flag）中文一般译作夺旗赛，在网络安全领域中指的是网络安全技术人员之间进行技术竞技的一种比赛形式。CTF起源于1996年DEFCON全球黑客大会，以代替之前黑客们通过
阅读更多2024-09-27
ST188单光束反射式红外光电传感器心率测量原理
由于脉搏跳动时，血液的体积和压力会发生变化，导致血液的透光性也随之变化。传感器中的光敏元件（如光敏三极管）会接收到反射回来的红外光，并将其转换为电信号。由于脉搏跳动引起的血液透光性变化，导致光敏元件接
阅读更多2024-09-27
浙大数据结构：06-图3 六度空间
bfs稍难题
阅读更多2024-09-27
C++多态的实现方式
编译时多态（函数重载和模板）提供了高度的灵活性和类型安全，且没有运行时开销，但它们在需要动态类型判断的场景中力不从心。运行时多态（基于继承的虚函数、函数指针）允许程序在运行时根据对象类型做出决策，非常
阅读更多2024-09-27
【移植】一种快速移植OpenHarmony Linux内核的方法
本文面向希望将 OpenHarmony 移植到三方芯片平台硬件的开发者，介绍一种借助三方芯片平台自带 Linux 内核的现有能力，快速移植 OpenHarmony 到三方芯片平台的方法。不知道学习鸿蒙
阅读更多2024-09-27