【DataBase】H2 DateBase的拓展使用

连接模式

　　支持以下连接模式：

• 嵌入模式（使用JDBC的本地连接）
• 服务器模式（使用JDBC或ODBC over TCP / IP进行远程连接）
• 混合模式（同时本地和远程连接）

嵌入模式

　　在嵌入模式下，应用程序使用JDBC从同一JVM中打开数据库。这是最快速，最简单的连接模式。缺点是数据库可能只在任何时候在一个虚拟机（和类加载器）中打开。

　　与所有模式一样，支持持久性和内存数据库。同时打开的数据库数量或打开的连接数量没有限制。
　　

服务器模式

　　使用服务器模式（有时称为远程模式或客户端/服务器模式）时，应用程序使用JDBC或ODBC API远程打开数据库。需要在相同或另一个虚拟机或另一台计算机上启动服务器。许多应用程序可以通过连接到此服务器同时连接到同一数据库。在内部，服务器进程以嵌入模式打开数据库。

　　

混合模式

　　混合模式是嵌入式和服务器模式的组合。连接到数据库的第一个应用程序在嵌入模式下执行此操作，但也启动服务器，以便其他应用程序（在不同进程或虚拟机中运行）可以同时访问相同的数据。本地连接的速度与仅在嵌入模式下使用数据库的速度一样快，而远程连接速度稍慢。

　　

数据库URL概述

此数据库支持多种连接模式和连接设置。这是使用不同的数据库URL实现的。URL中的设置不区分大小写。

话题	URL格式和示例
嵌入式（本地）连接	jdbc:h2:[file:][<path>]<databaseName> jdbc:h2:~/test jdbc:h2:file:/data/sample jdbc:h2:file:C:/data/sample (Windows only)
内存（私有）	jdbc:h2:mem:
内存中（命名）	jdbc:h2:mem:<databaseName> jdbc:h2:mem:test_mem
使用TCP / IP的服务器模式（远程连接）	jdbc:h2:tcp://<server>[:<port>]/[<path>]<databaseName> jdbc:h2:tcp://localhost/~/test jdbc:h2:tcp://dbserv:8084/~/sample jdbc:h2:tcp://localhost/mem:test
使用TLS的服务器模式（远程连接）	jdbc:h2:ssl://<server>[:<port>]/[<path>]<databaseName> jdbc:h2:ssl://localhost:8085/~/sample;

连接到嵌入式（本地）数据库

　　用于连接到本地数据库的数据库URL是jdbc:h2:[file:][<path>]<databaseName>。前缀file:是可选的。如果不使用或仅使用相对路径，则将当前工作目录用作起点。路径和数据库名称的区分大小写取决于操作系统，但建议仅使用小写字母。数据库名称长度必须至少为三个字符（限制File.createTempFile）。数据库名称不得包含分号。要指向用户主目录，请使用~/，如：jdbc:h2:~/test。

内存数据库

　　对于某些用例（例如：快速原型设计，测试，高性能操作，只读数据库），可能不需要保留数据或持久更改数据。此数据库支持内存模式，其中数据不会保留。

　　在某些情况下，只需要一个与内存数据库的连接。这意味着要打开的数据库是私有的。在这种情况下，数据库URL是jdbc:h2:mem:在同一虚拟机中打开两个连接意味着打开两个不同的（私有）数据库。

　　有时需要与同一内存数据库的多个连接。在这种情况下，数据库URL必须包含名称。示例：jdbc:h2:mem:db1。使用此URL访问同一数据库仅适用于同一虚拟机和类装入器环境。

　　要从另一个进程或另一台计算机访问内存数据库，您需要在创建内存数据库的同一进程中启动TCP服务器。然后，其他进程需要使用数据库URL通过TCP / IP或TLS访问数据库，例如：jdbc:h2:tcp://localhost/mem:db1。

　　默认情况下，关闭与数据库的最后一个连接会关闭数据库。对于内存数据库，这意味着内容丢失。要使数据库保持打开状态，请添加;DB_CLOSE_DELAY=-1到数据库URL。要在虚拟机处于活动状态时保留内存数据库的内容，请使用jdbc:h2:mem:test;DB_CLOSE_DELAY=-1。

H2使用

　　JDBC连接内存数据库

　　　　1、编辑测试代码

package com.test.h2;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * Hello world!
 *
 */
public class TestH2Mem {
    public static void main(String[] args) throws SQLException, ClassNotFoundException {

        // 加载HSQL DB的JDBC驱动
        Class.forName("org.h2.Driver");

        // 连接内存库，自动创建内存数据库，得到连接对象 connection
        // DB_CLOSE_DELAY=-1：连接关闭时，保留内存数据库的内容，程序退出才清楚内存数据库内容
        String url = "jdbc:h2:mem:test_mem;DB_CLOSE_DELAY=-1";
        Connection con = DriverManager.getConnection(url, "sa", "");

        // 新建数据表
        String ctreateTable = "DROP TABLE test IF EXISTS; create table test(id integer,name VARCHAR(22) )";
        Statement createStatement = con.createStatement();
        long f1 = createStatement.executeUpdate(ctreateTable);
        System.out.println("创建表：" + f1);

        // 插入数据
        String insertSql = "INSERT INTO test VALUES(1,'小明')";
        Statement insertStatement = con.createStatement();
        long f2 = insertStatement.executeUpdate(insertSql);
        System.out.println("插入数据：" + f2);
        
        // 关闭连接
        con.close();
        
        // 新建连接2
        Connection con2 = DriverManager.getConnection(url, "sa", "");

        // 查询数据
        String selectSql = "select id,name from test";
        PreparedStatement prepareStatement = con2.prepareStatement(selectSql);
        // 发送SQL 返回一个ResultSet
        ResultSet rs = prepareStatement.executeQuery();

        // 编历结果集
        while (rs.next())// 从数据库的取一行数据，是否还有下一行
        {
            int id = rs.getInt(1); // 从1开始
            String name = rs.getString(2);
            System.out.println("id:" + id + "	名称:" + name);
        }

        // 关闭连接
        con2.close();

    }
}

　　　　2、运行结果：

　　　　　　

　　JDBC连接本地数据库

　　　　1、编辑测试代码

package com.test.h2;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * Hello world!
 *
 */
public class TestH2Local {
    public static void main(String[] args) throws SQLException, ClassNotFoundException {

        // 加载HSQL DB的JDBC驱动
        Class.forName("org.h2.Driver");

        // 连接本地数据库，自动创建本地数据库，得到连接对象 connection
        String url = "jdbc:h2:file:D:/data/sample";
        Connection con = DriverManager.getConnection(url, "sa", "");

        // 新建数据表
        String ctreateTable = "DROP TABLE test IF EXISTS; create table test(id integer,name VARCHAR(22) )";
        Statement createStatement = con.createStatement();
        long f1 = createStatement.executeUpdate(ctreateTable);
        System.out.println("创建表：" + f1);

        // 插入数据
        String insertSql = "INSERT INTO test VALUES(1,'小明')";
        Statement insertStatement = con.createStatement();
        long f2 = insertStatement.executeUpdate(insertSql);
        System.out.println("插入数据：" + f2);

        // 查询数据
        String selectSql = "select id,name from test";
        PreparedStatement prepareStatement = con.prepareStatement(selectSql);
        // 发送SQL 返回一个ResultSet
        ResultSet rs = prepareStatement.executeQuery();

        // 编历结果集
        while (rs.next())// 从数据库的取一行数据，是否还有下一行
        {
            int id = rs.getInt(1); // 从1开始
            String name = rs.getString(2);
            System.out.println("id:" + id + "	名称:" + name);
        }

        // 关闭连接
        con.close();

    }
}

　　　　2、运行结果，同上，同时在D盘的data目录中参数数据库文件，如下

　　　　　　

　　　　3、同时可以使用h2连接工具连接sample数据库，连接工具使用方法，参考：【DataBase】H2 DateBase的简单使用

　　　　　　

　　JDBC使用TCP连接远程数据库

　　　　1、从命令行启动服务器工具，即可启动H2的tcp服务

　　　　　　要Server使用默认设置从命令行启动该工具，请运行：java -cp h2*.jar org.h2.tools.Server

　　　　　　

　　　　　　这将使用默认选项启动该工具。要获取选项列表和默认值，请运行：java -cp h2*.jar org.h2.tools.Server -?

　　　　　　配置其他值，如允许其他主机连接TCP，配置TCP端口，命令：java -cp h2-1.4.199.jar org.h2.tools.Server -tcpAllowOthers -tcpPort 9090

　　　　　　

　　　　　　还可以使用代码启动服务

package com.test.h2;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.h2.tools.Server;
import org.h2.util.Tool;

/**
 * Hello world!
 *
 */
public class TestH2TCPServer {
    
    public static void main(String[] args) throws SQLException, ClassNotFoundException, InterruptedException {

        // start the TCP Server
        Server server = Server.createTcpServer(new String[] { "-tcpAllowOthers", "-tcpPort", "9090" }).start();
        System.out.println("TCP Server 启动了......");
        
        Thread.sleep(30000);
        
        // stop the TCP Server
        server.stop();
        System.out.println("TCP Server 停止了......");

    }
}

　　　　2、编辑测试代码

package com.test.h2;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * Hello world!
 *
 */
public class TestH2TCP {
    public static void main(String[] args) throws SQLException, ClassNotFoundException {

        // 加载HSQL DB的JDBC驱动
        Class.forName("org.h2.Driver");

        // 使用TCP/IP的服务器，得到连接对象 connection
        String url = "jdbc:h2:tcp://localhost:9090/D:/data/sample";
        Connection con = DriverManager.getConnection(url, "sa", "");

        // 新建数据表
        String ctreateTable = "DROP TABLE test IF EXISTS; create table test(id integer,name VARCHAR(22) )";
        Statement createStatement = con.createStatement();
        long f1 = createStatement.executeUpdate(ctreateTable);
        System.out.println("创建表：" + f1);

        // 插入数据
        String insertSql = "INSERT INTO test VALUES(1,'小明')";
        Statement insertStatement = con.createStatement();
        long f2 = insertStatement.executeUpdate(insertSql);
        System.out.println("插入数据：" + f2);

        // 查询数据
        String selectSql = "select id,name from test";
        PreparedStatement prepareStatement = con.prepareStatement(selectSql);
        // 发送SQL 返回一个ResultSet
        ResultSet rs = prepareStatement.executeQuery();

        // 编历结果集
        while (rs.next())// 从数据库的取一行数据，是否还有下一行
        {
            int id = rs.getInt(1); // 从1开始
            String name = rs.getString(2);
            System.out.println("id:" + id + "	名称:" + name);
        }

        // 关闭连接
        con.close();

    }
}

　　　　3、运行结果，同上