文档章节

嵌入式数据库H2学习总结(三)——在Web应用中嵌入H2数据库

小白的成长
 小白的成长
发布于 2017/05/23 11:06
字数 2682
阅读 34
收藏 1
H2

一、搭建测试环境和项目

1.1、搭建JavaWeb测试项目

  创建一个【H2DBTest】JavaWeb项目,找到H2数据库的jar文件,如下图所示:

  

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

  

二、启动H2数据库

  既然是要将H2数据库作为我们Web应用的一部分嵌入进来,那么我们就要在Web应用中启动H2数据库的服务,这样我们才能够连接到H2数据库,因此我们可以编写一个专门用于启动H2数据库服务的监听器(Listener),监听器示例代码如下:

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应用中的一部分来使用了。

  将Web应用部署到Tomcat服务器,当启动Tomcat服务器时,在控制台就可以看到H2数据库启动成功的消息,如下图所示:

  

  为了进一步验证H2数据库是否真的是通过监听器正常启动了,我们可以访问一下H2数据库的Console,输入访问地址:"http://localhost:8080/H2DBTest/console/"进行访问,如下图所示:

  

  能够看到H2数据库Console的登录页面,说明了H2数据库已经正常启动了。

三、向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 {
        //1、注册uuid函数的SQL语句
        String sql1 = "CREATE ALIAS IF NOT EXISTS uuid FOR \"h2db.function.ext.H2DBFunctionExt.uuid\"";
        //2、注册currentTime函数的SQL语句
        String sql2 = "CREATE ALIAS IF NOT EXISTS currentTime FOR \"h2db.function.ext.H2DBFunctionExt.now\"";
        //3、注册IP函数的SQL语句
        String sql3 = "CREATE ALIAS IF NOT EXISTS IP FOR \"h2db.function.ext.H2DBFunctionExt.getIp\"";
        //4、注册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>
    <!-- 
    1、load-on-startup元素标记容器是否在启动的时候就加载这个servlet(实例化并调用其init()方法)。
    2、它的值必须是一个整数,表示servlet应该被载入的顺序
    3、当值为0或者大于0时,表示容器在应用启动时就加载并初始化这个servlet;
    4、当值小于0或者没有指定时,则表示容器在该servlet被选择时才会去加载。
    5、正数的值越小,该servlet的优先级越高,应用启动时就越先加载。
    6、当值相同时,容器就会自己选择顺序来加载。
    所以,<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数据库函数的扩展的内容就讲解这么多了。

© 著作权归作者所有

小白的成长
粉丝 3
博文 33
码字总数 27165
作品 0
深圳
程序员
私信 提问
Java嵌入式数据库H2学习总结(一)——H2数据库入门

一、H2数据库介绍   常用的开源数据库有:H2,Derby,HSQLDB,MySQL,PostgreSQL。其中H2和HSQLDB类似,十分适合作为嵌入式数据库使用,而其它的数据库大部分都需要安装独立的客户端和服务...

guicaizhou
2016/07/08
0
0
能够可视化访问和查看H2数据库的工具

最近在学习和了解SpringBoot的微服务开发框架,其中SpringBoot默认的持久化数据库就是H2数据库。 稍微科普一下,h2 database 是一个开源免费的嵌入式(Embedding) Java SQL数据库。下载地址:...

chancein007
2017/01/11
0
0
SpringBoot实战(四)之使用JDBC和Spring访问数据库

这里演示的是h2databse示例,所以简单的介绍普及下h2database相关知识 H2数据库是一个开源的关系型数据库。 H2是一个嵌入式数据库引擎,采用java语言编写,不受平台的限制,同时H2提供了一个...

youcongtech
2018/08/03
0
0
mybatis学习笔记

mybatis是一个ORM框架,因为activiti使用了mybatis,所以学习下; mybatis单独运行可以不依靠任何框架,也不需要tomcat; 一,步骤概要: 1,手动创建数据库表,创建一个USER表; 2,创建核心...

安世博
2014/10/17
262
3
H2介绍 – Java嵌入式数据库

H2是一个用Java开发的嵌入式数据库,这里指的嵌入式不是手持设备之类的,而是H2数据库作为一个类库,直接嵌入到上层的应用程序中,与应用运行在同一个进程中。 最大的优势在于可以同应用程序...

Mr&Cheng
2013/01/20
739
0

没有更多内容

加载失败,请刷新页面

加载更多

spring cloud

一、从面试题入手 1.1、什么事微服务 1.2、微服务之间如何独立通讯的 1.3、springCloud和Dubbo有哪些区别 1.通信机制:DUbbo基于RPC远程过程调用;微服务cloud基于http restFUL API 1.4、spr...

榴莲黑芝麻糊
今天
2
0
Executor线程池原理与源码解读

线程池为线程生命周期的开销和资源不足问题提供了解决方 案。通过对多个任务重用线程,线程创建的开销被分摊到了多个任务上。 线程实现方式 Thread、Runnable、Callable //实现Runnable接口的...

小强的进阶之路
昨天
6
0
maven 环境隔离

解决问题 即 在 resource 文件夹下面 ,新增对应的资源配置文件夹,对应 开发,测试,生产的不同的配置内容 <resources> <resource> <directory>src/main/resources.${deplo......

之渊
昨天
8
0
详解箭头函数和普通函数的区别以及箭头函数的注意事项、不适用场景

箭头函数是ES6的API,相信很多人都知道,因为其语法上相对于普通函数更简洁,深受大家的喜爱。就是这种我们日常开发中一直在使用的API,大部分同学却对它的了解程度还是不够深... 普通函数和...

OBKoro1
昨天
7
0
轻量级 HTTP(s) 代理 TinyProxy

CentOS 下安装 TinyProxy yum install -y tinyproxy 启动、停止、重启 # 启动service tinyproxy start# 停止service tinyproxy stop# 重启service tinyproxy restart 相关配置 默认...

Anoyi
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部