嵌入式数据库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】项目中，以下图所示：web

　　

2、启动H2数据库

　　既然是要将H2数据库做为咱们Web应用的一部分嵌入进来，那么咱们就要在Web应用中启动H2数据库的服务，这样咱们才可以链接到H2数据库，所以咱们能够编写一个专门用于启动H2数据库服务的监听器(Listener)，监听器示例代码以下：sql

package me.gacl.web.listener;

import java.sql.SQLException;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import org.h2.tools.Server;

/**
* @ClassName: H2DBServerStartListener
* @Description: 用于启动H2数据库服务的监听器，在应用系统初始化时就启动H2数据库的服务
* @author: 孤傲苍狼
* @date: 2014-12-20 下午11:43:39
*
*/ 
public class H2DBServerStartListener implements ServletContextListener {

    //H2数据库服务器启动实例
    private Server server;
    /* 
     * Web应用初始化时启动H2数据库
     */
    public void contextInitialized(ServletContextEvent sce) {
        try {  
            System.out.println("正在启动h2数据库...");
            //使用org.h2.tools.Server这个类建立一个H2数据库的服务并启动服务，因为没有指定任何参数，那么H2数据库启动时默认占用的端口就是8082
            server = Server.createTcpServer().start(); 
            System.out.println("h2数据库启动成功...");
        } catch (SQLException e) {  
            System.out.println("启动h2数据库出错：" + e.toString());  
            e.printStackTrace();  
            throw new RuntimeException(e);  
        }  
    }

    /* 
     * Web应用销毁时中止H2数据库
     */
    public void contextDestroyed(ServletContextEvent sce) {
        if (this.server != null) {
            // 中止H2数据库
            this.server.stop();
            this.server = null;
        }
    }
}

 

　　监听器写好以后，咱们在Web.xml文件中注册这个监听器，另外，由于咱们要将H2数据库嵌入到咱们的Web应用当中，为了可以方便访问H2数据库提供的Console，咱们能够在Web.xml文件中配置用于访问H2数据库Console的Servlet。数据库

Web.xml文件的配置以下：服务器

<!-- 使用监听器启动和中止数据库 -->
      <listener>
        <listener-class>me.gacl.web.listener.H2DBServerStartListener</listener-class>
    </listener>
    
    <!-- 使用H2控制台的Servlet H2控制台是一个独立的应用程序，包括它本身的Web服务器，但它能够做为一个servlet做为-->
    <servlet>
        <servlet-name>H2Console</servlet-name>
        <servlet-class>org.h2.server.web.WebServlet</servlet-class>
         <init-param>
            <param-name>webAllowOthers</param-name>
            <param-value></param-value>
        </init-param>
        <init-param>
            <param-name>trace</param-name>
            <param-value></param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <!-- 映射H2控制台的访问路径 -->
    <servlet-mapping>
        <servlet-name>H2Console</servlet-name>
        <url-pattern>/console/*</url-pattern>
    </servlet-mapping>

　配置好Listener和访问Console的Servlet以后，咱们就能够把H2数据库看成是咱们Web应用中的一部分来使用了。app

　　将Web应用部署到Tomcat服务器，当启动Tomcat服务器时，在控制台就能够看到H2数据库启动成功的消息，以下图所示：dom

　　

　　为了进一步验证H2数据库是否真的是经过监听器正常启动了，咱们能够访问一下H2数据库的Console，输入访问地址："http://localhost:8080/H2DBTest/console/"进行访问，以下图所示：tcp

　　

　　可以看到H2数据库Console的登陆页面，说明了H2数据库已经正常启动了。函数

3、向H2数据库注册自定义的数据库函数

　　H2做为一个数据库，和其余类型的数据库同样，会自带有一些数据库函数给咱们使用，可是H2数据库提供的数据库函数有限，没法知足咱们开发中的需求，幸运的是，H2数据库支持自定义数据库函数的，所以咱们能够根据开发中的实际应用场景编写知足咱们需求的数据库函数。工具

　　下面就来讲一下如何实现H2数据库的自定义函数

　　在MySQL数据库中有一个UUID函数是用来生成UUID的，执行"SELECT UUID()"就能够看到UUID函数生成的UUID，以下图所示：

　　

　　而默认状况下，H2数据库是没有提供有UUID这个函数给咱们使用的，以下图所示：

　　

　　那么咱们如今就来实现一个UUID函数，而后注册到H2数据库当中，这样H2数据库就支持UUID函数了，具体作法分为两个步骤：

     　　(1) 使用Java实现自定义函数的方法。

　　　  (2) 将Java的自定义函数注册到H2数据库中。

　　首先咱们来实现这个UUID函数，在java中，生成一个UUID的方法是使用java.util.UUID这个类里面的一个randomUUID()方法生成的，封装成一个uuid方法，代码以下：

package h2db.function.ext;

import java.util.UUID;

/**
* @ClassName: H2DBFunctionExt
* @Description: 针对H2数据库函数的扩展
* @author: 孤傲苍狼
* @date: 2014-12-20 下午11:20:34
*
*/ 
public class H2DBFunctionExt {

    /**
    * 用法：SELECT uuid();
    * H2数据库注册uuid函数：CREATE ALIAS uuid FOR "h2db.function.ext.H2DBFunctionExt.uuid";
    * @Method: uuid
    * @Description: 实现MySQL数据库的uuid函数，用于生成UUID
    * @Anthor:孤傲苍狼
    *
    * @return
    */ 
    public static String uuid(){
        return UUID.randomUUID().toString();
    }
}

　　这样，咱们的uuid函数就算是编写好了，须要注意的是，类和方法必须是公共(Public)的,且方法需为静态(static)的，如方法中使用了Connection对象需将其关闭。

　　接下来咱们要将其注册到H2数据库中，须执行"CREATE ALIAS"语句，SQL语法以下：

CREATE ALIAS [IF NOT EXISTS] newFunctionAliasName [DETERMINISTIC] FOR classAndMethodName

　　其中[]括起来的部分是可选的，本例须执行的语句为：

CREATE ALIAS UUID FOR "h2db.function.ext.H2DBFunctionExt.uuid"

 ，执行结果以下图所示：

　　

　　这样H2数据库中就多了一个UUID函数可使用了，咱们再次执行"SELECT UUID()"语句就能够被H2数据库正常解析了，执行结果以下图所示：

　　

　　以上就是针对H2数据库函数的一个扩展，咱们向H2数据库新增长了一个UUID函数用于生成uuid。所以当H2数据库提供的函数不知足咱们开发中的实际需求时，就可使用这种方式来扩展H2数据库的函数了。接下来演示一下一次性向H2数据库扩展多个函数，咱们编写一个H2DBFunctionExt类，在类中编写针对H2数据库的扩展函数，代码以下：

package h2db.function.ext;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.UUID;

/**
* @ClassName: H2DBFunctionExt
* @Description: 针对H2数据库函数的扩展
* @author: 孤傲苍狼
* @date: 2014-12-20 下午11:20:34
*
*/ 
public class H2DBFunctionExt {

    /**
    * 用法：SELECT uuid();
    * H2数据库注册uuid函数：CREATE ALIAS IF NOT EXISTS uuid FOR "h2db.function.ext.H2DBFunctionExt.uuid";
    * @Method: uuid
    * @Description: 实现MySQL数据库的uuid函数，用于生成UUID
    * @Anthor:孤傲苍狼
    *
    * @return
    */ 
    public static String uuid(){
        return UUID.randomUUID().toString();
    }

    /**
    * H2数据库注册currentTime函数：CREATE ALIAS IF NOT EXISTS currentTime FOR "h2db.function.ext.H2DBFunctionExt.now";
    * @Method: now
    * @Description: 实现MySQL数据库的now()函数，用于生成当前系统时间
    * @Anthor:孤傲苍狼
    *
    * @return
    */ 
    public static String now(){
        return new Date().toLocaleString();
    }
    
    /**
     * H2数据库注册IP函数：CREATE ALIAS IF NOT EXISTS IP FOR "h2db.function.ext.H2DBFunctionExt.getIp";
    * @Method: getIp
    * @Description: 
    * @Anthor:孤傲苍狼
    *
    * @return
    */ 
    public static String getIp(){
        try {
            InetAddress addr = InetAddress.getLocalHost();
            //得到本机IP
            return addr.getHostAddress();
        } catch (UnknownHostException e) {
            e.printStackTrace();
            return "未知的IP地址";
        } 
    }
    
    /**
    * H2数据库注册date_format函数：CREATE ALIAS IF NOT EXISTS date_format FOR "h2db.function.ext.H2DBFunctionExt.date_format";
    * @Method: date_format
    * @Description: 实现MySQL数据库的date_format()函数，用于格式化日期
    * @Anthor:孤傲苍狼
    * @param date
    * @param pattern
    * @return
    */ 
    public static String date_format(String date,String pattern){
        if (date != null) {
            SimpleDateFormat sdf = new SimpleDateFormat(pattern);
            try {
                Date temp = sdf.parse(date);
                return sdf.format(temp);
            } catch (ParseException e) {
                e.printStackTrace();
            }
        }
        return "";
    }
}

　　为了实现批量注册H2数据库的扩展函数，咱们能够编写一个Servlet，专门用于注册扩展函数，代码以下：

package me.gacl.sys.init;


import java.sql.Connection;
import java.sql.Statement;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;

import me.gacl.util.JdbcUtil;

/**
* @ClassName: RegisterH2ExtFuncServlet
* @Description:注册H2数据库的扩展函数
* @author: 孤傲苍狼
* @date: 2014-12-20 下午11:47:03
*
*/ 
public class RegisterH2ExtFuncServlet extends HttpServlet {

    /**
    * @Field: serialVersionUID
    */ 
    private static final long serialVersionUID = 4379248469825545593L;

    public void init() throws ServletException {
        //一、注册uuid函数的SQL语句
        String sql1 = "CREATE ALIAS IF NOT EXISTS uuid FOR \"h2db.function.ext.H2DBFunctionExt.uuid\"";
        //二、注册currentTime函数的SQL语句
        String sql2 = "CREATE ALIAS IF NOT EXISTS currentTime FOR \"h2db.function.ext.H2DBFunctionExt.now\"";
        //三、注册IP函数的SQL语句
        String sql3 = "CREATE ALIAS IF NOT EXISTS IP FOR \"h2db.function.ext.H2DBFunctionExt.getIp\"";
        //四、注册date_format函数的SQL语句
        String sql4 = "CREATE ALIAS IF NOT EXISTS date_format FOR \"h2db.function.ext.H2DBFunctionExt.date_format\"";
        Connection connection = null;
        Statement stmt = null;
        try {
            //获取数据库链接
            connection = JdbcUtil.getConnection();
            //获取Statement对象
            stmt = connection.createStatement();
            //添加要执行的SQL
            stmt.addBatch(sql1);
            stmt.addBatch(sql2);
            stmt.addBatch(sql3);
            stmt.addBatch(sql4);
            //批量执行上述的4条SQL
            stmt.executeBatch();
            System.out.println("H2数据库扩展函数注册成功！");
            stmt.clearBatch();
        } catch (Exception e) {
            System.out.println("H2数据库扩展函数注册失败！");
            e.printStackTrace();
        }finally{
            try {
                stmt.close();
                connection.close();
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }
    }
}

　　在Web.xml中注册RegisterH2ExtFuncServlet

<servlet>
    <description>注册H2数据库的扩展函数</description>
    <servlet-name>RegisterH2DBExtFunction</servlet-name>
    <servlet-class>me.gacl.sys.init.RegisterH2ExtFuncServlet</servlet-class>
    <!-- 
    一、load-on-startup元素标记容器是否在启动的时候就加载这个servlet(实例化并调用其init()方法)。
    二、它的值必须是一个整数，表示servlet应该被载入的顺序
    三、当值为0或者大于0时，表示容器在应用启动时就加载并初始化这个servlet；
    四、当值小于0或者没有指定时，则表示容器在该servlet被选择时才会去加载。
    五、正数的值越小，该servlet的优先级越高，应用启动时就越先加载。
    六、当值相同时，容器就会本身选择顺序来加载。
    因此，<load-on-startup>x</load-on-startup>，中x的取值1，2，3，4，5表明的是优先级，而非启动延迟时间。
     -->
     <load-on-startup>1</load-on-startup>
</servlet>

　　RegisterH2ExtFuncServlet要批量执行SQL语句，所以须要链接上H2数据库才可以执行，工具类JdbcUtil提供了获取数据库链接的方法，JdbcUtil的代码以下：

/**
 * 
 */
package me.gacl.util;

import java.io.InputStream;
import java.sql.Connection;
import java.util.Properties;
import org.h2.jdbcx.JdbcConnectionPool;

public class JdbcUtil {

    /**
     * H2数据库自带的链接池
     */
    private static JdbcConnectionPool cp = null;
    
    static{
        try {
            //加载src目录下的h2config.properties
            InputStream in = JdbcUtil.class.getClassLoader().getResourceAsStream("h2config.properties");
            Properties prop = new Properties();
            prop.load(in);
            //建立数据库链接池
            cp = JdbcConnectionPool.create(prop.getProperty("JDBC_URL"), prop.getProperty("USER"), prop.getProperty("PASSWORD"));
        } catch (Exception e) {
            System.out.println("链接池初始化异常");
            e.printStackTrace();
        }
    }
    
    /**
    * @Method: getConnection
    * @Description:获取数据库链接
    * @Anthor:孤傲苍狼
    * @return
    * @throws Exception
    */ 
    public static Connection getConnection() throws Exception{
        return cp.getConnection();
    }

    public static JdbcConnectionPool getCp() {
        return cp;
    }
}

　　h2config.properties的配置信息以下：

JDBC_URL=jdbc:h2:tcp://localhost/~/h2db
USER=gacl
PASSWORD=123

　　当web应用启动时，就会执行RegisterH2ExtFuncServlet这个Servlet中的init方法，init方法内部的处理就是经过JdbcUtil工具类获取一个H2的数据库链接，而后建立Statement对象，再由Statement对象批量执行SQL向H2数据库注册扩展函数。

　　RegisterH2ExtFuncServlet执行的过程当中若是没有出现任何错误，那就说明全部的针对H2数据库的扩展函数都注册成功了，咱们能够到H2的Console去验证一下上述的4个扩展函数，以下图所示：

　　

　　关于在Web应用中嵌入使用H2数据库，以及针对H2数据库函数的扩展的内容就讲解这么多了。

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