嵌入式数据库H2学习总结(二)——在Web应用程序中使用H2数据库

时间  2019-11-21
标签 嵌入 数据库 h2 学习 总结 web 应用 程序 使用 栏目 SQL 繁體版
原文   原文链接

1、搭建测试环境和项目

1.一、搭建JavaWeb测试项目

　　建立一个【H2DBTest】JavaWeb项目，找到H2数据库的jar文件，以下图所示：java

　　

　　H2数据库就一个jar文件，这个Jar文件里面包含了使用JDBC方式链接H2数据库时使用的驱动类，将"h2-1.4.183.jar"加入到【H2DBTest】项目中，以下图所示：sql

　　

1.二、开启H2数据库

　　进入到h2\bin目录，以下图所示：数据库

　　

　　确保H2数据库使用的8082端口没有被其余应用程序占用，正常启动以后输入"http://localhost:8082"进行简单的测试，以下图所示：服务器

　　

　　到此，使用Java操做H2数据库的测试环境就算是搭建完成了。dom

2、在Java中操做H2数据库

2.一、以嵌入式(本地)链接方式链接H2数据库

　　这种链接方式默认状况下只容许有一个客户端链接到H2数据库，有客户端链接到H2数据库以后，此时数据库文件就会被锁定，那么其余客户端就没法再链接了。tcp

　　链接语法：jdbc:h2:[file:][<path>]<databaseName>测试

　　例如：
　　　　jdbc:h2:~/test //链接位于用户目录下的test数据库
　　　　jdbc:h2:file:/data/sample
　　　　jdbc:h2:file:E:/H2/gacl(Windows only)ui

　　编写测试代码，以下：spa

package jdbc.conn.h2.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.UUID;

/**
 * <p>ClassName: H2ConnTest1<p>
 * <p>Description: Java经过JDBC方式链接H2数据库<p>
 * @author xudp
 * @version 1.0 V
 * @createTime 2014-12-18 上午11:22:12
 */
public class H2ConnTest1 {
    //数据库链接URL，当前链接的是E:/H2目录下的gacl数据库
    private static final String JDBC_URL = "jdbc:h2:E:/H2/gacl";
    //链接数据库时使用的用户名
    private static final String USER = "gacl";
    //链接数据库时使用的密码
    private static final String PASSWORD = "123";
    //链接H2数据库时使用的驱动类，org.h2.Driver这个类是由H2数据库本身提供的，在H2数据库的jar包中能够找到
    private static final String DRIVER_CLASS="org.h2.Driver";
    
    public static void main(String[] args) throws Exception {
        // 加载H2数据库驱动
        Class.forName(DRIVER_CLASS);
        // 根据链接URL，用户名，密码获取数据库链接
        Connection conn = DriverManager.getConnection(JDBC_URL, USER, PASSWORD);
        Statement stmt = conn.createStatement();
        //若是存在USER_INFO表就先删除USER_INFO表
        stmt.execute("DROP TABLE IF EXISTS USER_INFO");
        //建立USER_INFO表
        stmt.execute("CREATE TABLE USER_INFO(id VARCHAR(36) PRIMARY KEY,name VARCHAR(100),sex VARCHAR(4))");
        //新增
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','大日如来','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','青龙','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','白虎','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','朱雀','女')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','玄武','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','苍狼','男')");
        //删除
        stmt.executeUpdate("DELETE FROM USER_INFO WHERE name='大日如来'");
        //修改
        stmt.executeUpdate("UPDATE USER_INFO SET name='孤傲苍狼' WHERE name='苍狼'");
        //查询
        ResultSet rs = stmt.executeQuery("SELECT * FROM USER_INFO");
        //遍历结果集
        while (rs.next()) {
            System.out.println(rs.getString("id") + "," + rs.getString("name")+ "," + rs.getString("sex"));
        }
        //释放资源
        stmt.close();
        //关闭链接
        conn.close();
    }
}

　　执行结果以下：code

　　

　　登陆到H2控制台当中也能够看到建立好的USER_INFO表和表里面的数据，以下图所示：

　　

　　这里须要说明一下使用这种"jdbc:h2:E:/H2/gacl"这种方式链接H2数据库容易遇到的问题，若是已经在H2的WebConsole控制台中登陆gacl数据库，以下图所示：

　　

　　此时gacl数据库就会被锁定，此时经过java代码链接gacl数据库时就会出现以下的错误，如所示：

Exception in thread "main" org.h2.jdbc.JdbcSQLException: Database may be already in use: "E:/H2/gacl.mv.db". Possible solutions: close all other connection(s); use the server mode [90020-183]
    at org.h2.message.DbException.getJdbcSQLException(DbException.java:345)
    at org.h2.message.DbException.get(DbException.java:168)
    at org.h2.mvstore.db.MVTableEngine.init(MVTableEngine.java:108)
    at org.h2.engine.Database.getPageStore(Database.java:2376)
    at org.h2.engine.Database.open(Database.java:666)
    at org.h2.engine.Database.openDatabase(Database.java:266)
    at org.h2.engine.Database.<init>(Database.java:260)
    at org.h2.engine.Engine.openSession(Engine.java:60)
    at org.h2.engine.Engine.openSession(Engine.java:167)
    at org.h2.engine.Engine.createSessionAndValidate(Engine.java:145)
    at org.h2.engine.Engine.createSession(Engine.java:128)
    at org.h2.engine.Engine.createSession(Engine.java:26)
    at org.h2.engine.SessionRemote.connectEmbeddedOrServer(SessionRemote.java:347)
    at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:108)
    at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:92)
    at org.h2.Driver.connect(Driver.java:72)
    at java.sql.DriverManager.getConnection(DriverManager.java:571)
    at java.sql.DriverManager.getConnection(DriverManager.java:215)
    at jdbc.conn.h2.test.H2ConnTest1.main(H2ConnTest1.java:33)
Caused by: java.lang.IllegalStateException: The file is locked: nio:E:/H2/gacl.mv.db [1.4.183/7]
    at org.h2.mvstore.DataUtils.newIllegalStateException(DataUtils.java:768)
    at org.h2.mvstore.FileStore.open(FileStore.java:170)
    at org.h2.mvstore.MVStore.<init>(MVStore.java:346)
    at org.h2.mvstore.MVStore$Builder.open(MVStore.java:2754)
    at org.h2.mvstore.db.MVTableEngine$Store.<init>(MVTableEngine.java:162)
    at org.h2.mvstore.db.MVTableEngine.init(MVTableEngine.java:98)
    ... 16 more

　　 引发这个错误的缘由是由于gacl数据库对应的文件已经被锁定了，因此java代码这边没法再访问，为了可以让Java代码可以正常访问，必须把WebConsole控制台那边的链接先断开，

　　

　　断开数据库链接以后，Java代码这边就能够链接上去了。

2.二、使用TCP/IP的服务器模式(远程链接)方式链接H2数据库(推荐)

　　这种链接方式就和其余数据库相似了，是基于Service的形式进行链接的，所以容许多个客户端同时链接到H2数据库

　　链接语法：jdbc:h2:tcp://<server>[:<port>]/[<path>]<databaseName>
　　范例：jdbc:h2:tcp://localhost/~/test

　　测试代码以下：

package jdbc.conn.h2.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.UUID;

/**
 * <p>ClassName: H2ConnTest1<p>
 * <p>Description: Java经过JDBC方式链接H2数据库<p>
 * @author xudp
 * @version 1.0 V
 * @createTime 2014-12-18 上午11:22:12
 */
public class H2ConnTest2 {
    //数据库链接URL，经过使用TCP/IP的服务器模式（远程链接），当前链接的是E:/H2目录下的gacl数据库
    //private static final String JDBC_URL = "jdbc:h2:tcp://localhost/E:/H2/gacl";
    //private static final String JDBC_URL = "jdbc:h2:tcp://127.0.0.1/E:/H2/gacl";
    private static final String JDBC_URL = "jdbc:h2:tcp://192.168.1.144/data/gacl";
    //链接数据库时使用的用户名
    private static final String USER = "gacl";
    //链接数据库时使用的密码
    private static final String PASSWORD = "123";
    //链接H2数据库时使用的驱动类，org.h2.Driver这个类是由H2数据库本身提供的，在H2数据库的jar包中能够找到
    private static final String DRIVER_CLASS="org.h2.Driver";
    
    public static void main(String[] args) throws Exception {
        // 加载H2数据库驱动
        Class.forName(DRIVER_CLASS);
        // 根据链接URL，用户名，密码获取数据库链接
        Connection conn = DriverManager.getConnection(JDBC_URL, USER, PASSWORD);
        Statement stmt = conn.createStatement();
        //若是存在USER_INFO表就先删除USER_INFO表
        stmt.execute("DROP TABLE IF EXISTS USER_INFO");
        //建立USER_INFO表
        stmt.execute("CREATE TABLE USER_INFO(id VARCHAR(36) PRIMARY KEY,name VARCHAR(100),sex VARCHAR(4))");
        //新增
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','大日如来','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','青龙','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','白虎','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','朱雀','女')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','玄武','男')");
        stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','苍狼','男')");
        //删除
        stmt.executeUpdate("DELETE FROM USER_INFO WHERE name='大日如来'");
        //修改
        stmt.executeUpdate("UPDATE USER_INFO SET name='孤傲苍狼' WHERE name='苍狼'");
        //查询
        ResultSet rs = stmt.executeQuery("SELECT * FROM USER_INFO");
        //遍历结果集
        while (rs.next()) {
            System.out.println(rs.getString("id") + "," + rs.getString("name")+ "," + rs.getString("sex"));
        }
        //释放资源
        stmt.close();
        //关闭链接
        conn.close();
    }
}

 

 2.三、H2数据库的内存模式

　　H2数据库被称为内存数据库，由于它支持在内存中建立数据库和表

　　范例以下：

package jdbc.conn.h2.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.UUID;

/**
* @ClassName: TestMemH2
* @Description:H2数据库的内存模式（数据只保存在内存中）
* @author: 孤傲苍狼
* @date: 2014-12-18 下午10:47:01
*
*/ 
public class TestMemH2 {

        //数据库链接URL，经过使用TCP/IP的服务器模式（远程链接），当前链接的是内存里面的gacl数据库
        private static final String JDBC_URL = "jdbc:h2:tcp://localhost/mem:gacl";
        //链接数据库时使用的用户名
        private static final String USER = "gacl";
        //链接数据库时使用的密码
        private static final String PASSWORD = "123";
        //链接H2数据库时使用的驱动类，org.h2.Driver这个类是由H2数据库本身提供的，在H2数据库的jar包中能够找到
        private static final String DRIVER_CLASS="org.h2.Driver";
        
        public static void main(String[] args) throws Exception {
            // 加载H2数据库驱动
            Class.forName(DRIVER_CLASS);
            // 根据链接URL，用户名，密码获取数据库链接
            Connection conn = DriverManager.getConnection(JDBC_URL, USER, PASSWORD);
            Statement stmt = conn.createStatement();
            //若是存在USER_INFO表就先删除USER_INFO表
            stmt.execute("DROP TABLE IF EXISTS USER_INFO");
            //建立USER_INFO表
            stmt.execute("CREATE TABLE USER_INFO(id VARCHAR(36) PRIMARY KEY,name VARCHAR(100),sex VARCHAR(4))");
            //新增
            stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','大日如来','男')");
            stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','青龙','男')");
            stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','白虎','男')");
            stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','朱雀','女')");
            stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','玄武','男')");
            stmt.executeUpdate("INSERT INTO USER_INFO VALUES('" + UUID.randomUUID()+ "','苍狼','男')");
            //删除
            stmt.executeUpdate("DELETE FROM USER_INFO WHERE name='大日如来'");
            //修改
            stmt.executeUpdate("UPDATE USER_INFO SET name='孤傲苍狼' WHERE name='苍狼'");
            //查询
            ResultSet rs = stmt.executeQuery("SELECT * FROM USER_INFO");
            //遍历结果集
            while (rs.next()) {
                System.out.println(rs.getString("id") + "," + rs.getString("name")+ "," + rs.getString("sex"));
            }
            //释放资源
            stmt.close();
            //关闭链接
            conn.close();
        }
}

　　运行结果以下：

　　

　　注意：若是使用H2数据库的内存模式，那么咱们建立的数据库和表都只是保存在内存中，一旦服务器重启，那么内存中的数据库和表就不存在了。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程