深入理解 h2 和 r2dbc-h2

关注
发布于: 2020 年 11 月 20 日
简介本文将会介绍R2DBC的H2实现r2dbc-h2的使用方法和要注意的事项。一起来看看吧。
﻿
H2数据库简介什么是H2数据库呢？
﻿
H2是一个Java SQL database，它是一个开源的数据库，运行起来非常快。
﻿
H2流行的原因是它既可以当做一个独立的服务器，也可以以一个嵌套的服务运行，并且支持纯内存形式运行。
﻿
H2的jar包非常小，只有2M大小，所以非常适合做嵌套式数据库。
﻿
如果作为嵌入式数据库，则需要将h2*.jar添加到classpath中。
﻿
下面是一个简单的建立H2连接的代码：
﻿
import java.sql.*;
public class Test {
    public static void main(String[] a)
            throws Exception {
        Connection conn = DriverManager.
            getConnection("jdbc:h2:~/test", "sa", "");
        // add application code here
        conn.close();
    }
}
﻿
﻿
如果给定地址的数据库并不存在，
﻿
同时H2还提供了一个简单的管理界面，使用下面的命令就可以启动H2管理界面：
﻿
java -jar h2*.jar
﻿
﻿
默认情况下访问http://localhost:8082就可以访问到管理界面：
﻿
﻿
﻿
r2dbc-h2r2dbc-h2是r2dbc spi的一种实现。同样的使用r2dbc-h2也提供了两种h2的模式，一种是文件系统，一种是内存。
﻿
同时还提供了事务支持，prepared statements和batch statements等特性的支持。
﻿
r2dbc-h2的Maven依赖要想使用r2dbc-h2，我们需要添加如下依赖：
﻿
<dependency>
  <groupId>io.r2dbc</groupId>
  <artifactId>r2dbc-h2</artifactId>
  <version>${version}</version>
</dependency>
﻿
﻿
如果你体验snapshot版本，可以添加下面的依赖：
﻿
<dependency>
  <groupId>io.r2dbc</groupId>
  <artifactId>r2dbc-h2</artifactId>
  <version>${version}.BUILD-SNAPSHOT</version>
</dependency>
﻿
<repository>
  <id>spring-libs-snapshot</id>
  <name>Spring Snapshot Repository</name>
  <url>https://repo.spring.io/libs-snapshot</url>
</repository>
﻿
﻿
建立连接h2有两种连接方式，file和内存，我们分别看一下都是怎么建立连接的：
﻿
ConnectionFactory connectionFactory = ConnectionFactories.get("r2dbc:h2:mem:///testdb");
﻿
Publisher<? extends Connection> connectionPublisher = connectionFactory.create();
﻿
﻿
ConnectionFactory connectionFactory = ConnectionFactories.get("r2dbc:h2:file//my/relative/path");
﻿
Publisher<? extends Connection> connectionPublisher = connectionFactory.create();
﻿
﻿
我们还可以通过ConnectionFactoryOptions来创建更加详细的连接信息：
﻿
ConnectionFactoryOptions options = builder()
    .option(DRIVER, "h2")
    .option(PROTOCOL, "...")  // file, mem
    .option(HOST, "…")
    .option(USER, "…")
    .option(PASSWORD, "…")
    .option(DATABASE, "…")
    .build();
﻿
ConnectionFactory connectionFactory = ConnectionFactories.get(options);
﻿
Publisher<? extends Connection> connectionPublisher = connectionFactory.create();
﻿
// Alternative: Creating a Mono using Project Reactor
Mono<Connection> connectionMono = Mono.from(connectionFactory.create());
﻿
﻿
上面的例子中，我们使用到了driver,protocol, host,username,password和database这几个选项，除此之外H2ConnectionOption中定义了其他可以使用的Option：
﻿
public enum H2ConnectionOption {
﻿
    /**
     * FILE|SOCKET|NO
     */
    FILE_LOCK,
﻿
    /**
     * TRUE|FALSE
     */
    IFEXISTS,
﻿
    /**
     * Seconds to stay open or {@literal -1} to to keep in-memory DB open as long as the virtual machine is alive.
     */
    DB_CLOSE_DELAY,
﻿
    /**
     * TRUE|FALSE
     */
    DB_CLOSE_ON_EXIT,
﻿
    /**
     * DML or DDL commands on startup, use "\\;" to chain multiple commands
     */
    INIT,
﻿
    /**
     * 0..3 (0=OFF, 1=ERROR, 2=INFO, 3=DEBUG)
     */
    TRACE_LEVEL_FILE,
﻿
    /**
     *  Megabytes (to override the 16mb default, e.g. 64)
     */
    TRACE_MAX_FILE_SIZE,
﻿
    /**
     * 0..3 (0=OFF, 1=ERROR, 2=INFO, 3=DEBUG)
     */
    TRACE_LEVEL_SYSTEM_OUT,
﻿
    LOG,
﻿
    /**
     * TRUE|FALSE
     */
    IGNORE_UNKNOWN_SETTINGS,
﻿
    /**
     * r|rw|rws|rwd (r=read, rw=read/write)
     */
    ACCESS_MODE_DATA,
﻿
    /**
     * DB2|Derby|HSQLDB|MSSQLServer|MySQL|Oracle|PostgreSQL|Ignite
     */
    MODE,
﻿
    /**
     *  TRUE|FALSE
     */
    AUTO_SERVER,
﻿
    /**
     * A port number
     */
    AUTO_SERVER_PORT,
﻿
    /**
     * Bytes (e.g. 512)
     */
    PAGE_SIZE,
﻿
    /**
     * Number of threads (e.g. 4)
     */
    MULTI_THREADED,
﻿
    /**
     * TQ|SOFT_LRU
     */
    CACHE_TYPE,
﻿
    /**
     * TRUE|FALSE
     */
    PASSWORD_HASH;
}
﻿
﻿
当然还有最直接的database选项：
﻿
r2dbc:h2:file//../relative/file/name
r2dbc:h2:file///absolute/file/name
r2dbc:h2:mem:///testdb
﻿
﻿
我们还可以通过H2特有的代码H2ConnectionFactory来创建：
﻿
H2ConnectionFactory connectionFactory = new H2ConnectionFactory(H2ConnectionConfiguration.builder()
    .inMemory("...")
    .option(H2ConnectionOption.DB_CLOSE_DELAY, "-1")
    .build());
﻿
Mono<Connection> connection = connectionFactory.create();
﻿
﻿
CloseableConnectionFactory connectionFactory = H2ConnectionFactory.inMemory("testdb");
﻿
Mono<Connection> connection = connectionFactory.create();
﻿
﻿
参数绑定在使用prepare statement的时候，我们需要进行参数绑定：
﻿
connection
    .createStatement("INSERT INTO person (id, first_name, last_name) VALUES ($1, $2, $3)")
    .bind("$1", 1)
    .bind("$2", "Walter")
    .bind("$3", "White")
    .execute()
﻿
﻿
除了$符号绑定之外，还支持index绑定，如下所示：
﻿
Statement statement = connection.createStatement("SELECT title FROM books WHERE author = $1 and publisher = $2");
statement.bind(0, "John Doe");
statement.bind(1, "Happy Books LLC");
﻿
﻿
批处理我们来看下r2dbc-h2是怎么来进行批处理的：
﻿
Batch batch = connection.createBatch();
Publisher<? extends Result> publisher = batch.add("SELECT title, author FROM books")
    .add("INSERT INTO books VALUES('John Doe', 'HappyBooks LLC')")
    .execute();
﻿
﻿
事务和Savepointr2dbc还支持事务和savepoint,我们可以在事务中rollback到特定的savepoint。具体的代码如下：
﻿
Publisher<Void> begin = connection.beginTransaction();
﻿
Publisher<Void> insert1 = connection.createStatement("INSERT INTO books VALUES ('John Doe')").execute();
﻿
Publisher<Void> savepoint = connection.createSavepoint("savepoint");
﻿
Publisher<Void> insert2 = connection.createStatement("INSERT INTO books VALUES ('Jane Doe')").execute();
﻿
﻿
Publisher<Void> partialRollback = connection.rollbackTransactionToSavepoint("savepoint");
﻿
﻿
Publisher<Void> commit = connection.commit();
﻿
﻿
本文作者：flydean程序那些事
本文链接：http://www.flydean.com/r2dbc-h2-in-depth/
本文来源：flydean的博客
欢迎关注我的公众号:「程序那些事」最通俗的解读，最深刻的干货，最简洁的教程，众多你不知道的小技巧等你来发现！
﻿
发布于: 2020 年 11 月 20 日阅读数: 170
原文链接:【http://xie.infoq.cn/article/de92f9e2f89ab5c495020b9c9】。文章转载请联系作者。
程序那些事

关注
关注公众号：程序那些事，更多精彩等着你！ 2020.06.07 加入
最通俗的解读，最深刻的干货，最简洁的教程，众多你不知道的小技巧，尽在公众号：程序那些事！
发布
暂无评论
创作场景

深入理解 h2 和 r2dbc-h2

简介

H2数据库简介

r2dbc-h2

r2dbc-h2的Maven依赖

建立连接

参数绑定

批处理

事务和Savepoint

程序那些事

评论
