java:如何用代码控制H2 Database启动

简介: 1、纯手动start/stop 1 package com.cnblogs.yjmyzz.h2; 2 3 import java.sql.Connection; 4 import java.

1、纯手动start/stop

 1 package com.cnblogs.yjmyzz.h2;
 2 
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.sql.ResultSet;
 6 import java.sql.SQLException;
 7 import java.sql.Statement;
 8 
 9 import org.h2.tools.Server;
10 import org.junit.Test;
11 
12 public class H2ServerTest {
13 
14     @Test
15     public void h2Test() {
16         start();
17         crudTest();
18         stop();
19     }
20 
21     private Server server;
22 
23     public void start() {
24         try {
25             System.out.println("正在启动h2...");
26             server = Server.createTcpServer(
27                     new String[] { "-tcp", "-tcpAllowOthers", "-tcpPort",
28                             "8043" }).start();
29             System.out.println("启动成功:" + server.getStatus());
30         } catch (SQLException e) {
31             System.out.println("启动h2出错:" + e.toString());
32 
33             e.printStackTrace();
34             throw new RuntimeException(e);
35         }
36     }
37 
38     public void stop() {
39         if (server != null) {
40             System.out.println("正在关闭h2...");
41             server.stop();
42             System.out.println("关闭成功.");
43         }
44     }
45 
46     public void crudTest() {
47         try {
48             Class.forName("org.h2.Driver");
49 
50             // connect to h2
51             Connection conn = DriverManager.getConnection(
52                     "jdbc:h2:./h2db/sxaz42b4", "sa", "sa");
53 
54             Statement stat = conn.createStatement();
55 
56             // create table
57             stat.execute("CREATE TABLE TEST(NAME VARCHAR)");
58 
59             // insert table
60             stat.execute("INSERT INTO TEST VALUES('菩提树下的杨过')");
61             stat.execute("INSERT INTO TEST VALUES('http://yjmyzz.cnblogs.com/')");
62 
63             // retrive data
64             ResultSet result = stat.executeQuery("select name from test ");
65             int i = 1;
66             while (result.next()) {
67                 System.out.println(i++ + ":" + result.getString("name"));
68             }
69 
70             // drop table
71             stat.execute("DROP TABLE TEST");
72 
73             result.close();
74             stat.close();
75             conn.close();
76         } catch (Exception e) {
77             e.printStackTrace();
78         }
79     }
80 
81 }
View Code

输出:

正在启动h2...
启动成功:TCP server running at tcp://192.168.1.100:8043 (others can connect)
1:菩提树下的杨过
2:http://yjmyzz.cnblogs.com/
正在关闭h2...
关闭成功.

 

2、借助Spring

1     <bean id="h2Server" class="org.h2.tools.Server"
2         factory-method="createTcpServer" init-method="start" destroy-method="stop">
3         <constructor-arg value="-tcp,-tcpAllowOthers,-tcpPort,8043" />
4     </bean>
View Code

示例代码:

 1 package com.cnblogs.yjmyzz.h2;
 2 
 3 import java.sql.SQLException;
 4 
 5 import org.h2.tools.Server;
 6 import org.springframework.context.ApplicationContext;
 7 import org.springframework.context.support.AbstractApplicationContext;
 8 import org.springframework.context.support.ClassPathXmlApplicationContext;
 9 
10 public class App {
11 
12     public static void main(String[] args) throws SQLException,
13             ClassNotFoundException {
14 
15         ApplicationContext context = new ClassPathXmlApplicationContext(
16                 "spring-context.xml");
17 
18         Server h2Server = context.getBean(Server.class);
19         System.out.println(h2Server.getStatus());
20 
21         H2ServerTest test = new H2ServerTest();
22         test.crudTest();
23 
24         ((AbstractApplicationContext) context).close();
25 
26     }
27 
28 }
View Code

输出:

TCP server running at tcp://192.168.1.100:8043 (others can connect)
1:菩提树下的杨过
2:http://yjmyzz.cnblogs.com/

注:用Spring注入的方式,不用刻意手动处理h2Server的start/stop

 

3、随webApp启动时,自动启动h2 server

a) 在web.xml最开头加入下面这段

 1     <!-- h2 -->
 2     <listener>
 3         <listener-class>org.h2.server.web.DbStarter</listener-class>
 4     </listener>
 5     <context-param>
 6         <param-name>db.url</param-name>
 7         <param-value>jdbc:h2:r:/h2db/awbprint/x4z5gjb3</param-value>
 8     </context-param>
 9     <context-param>
10         <param-name>db.user</param-name>
11         <param-value>sa</param-value>
12     </context-param>
13     <context-param>
14         <param-name>db.password</param-name>
15         <param-value>sa</param-value>
16     </context-param>
17     <context-param>
18         <param-name>db.tcpServer</param-name>
19         <param-value>-tcpAllowOthers</param-value>
20     </context-param>
View Code

注:具体的文件位置及用户名、密码请自行修改,如果只允许本机连接,把

    <context-param>
        <param-name>db.tcpServer</param-name>
        <param-value>-tcpAllowOthers</param-value>
    </context-param>

去掉即可.

b) 然后在spring配置中参考下面的内容

 1     <bean id="dataSource" class="org.h2.jdbcx.JdbcConnectionPool"
 2         destroy-method="dispose">
 3         <constructor-arg>
 4             <bean class="org.h2.jdbcx.JdbcDataSource">
 5                 <!-- 文件方式:必须与web.xml中配置的h2db文件名一致 -->
 6                 <property name="URL" value="jdbc:h2:r:/h2db/awbprint/x4z5gjb3" />
 7                 <property name="user" value="sa" />
 8                 <property name="password" value="sa" />
 9             </bean>
10         </constructor-arg>
11     </bean>
View Code

这样,webapp启动时,会先启动h2 server,后面的代码就能连接到h2了。其它应用也可以用 jdbc:h2:tcp://172.21.129.181/r:/h2db/awbprint/x4z5gjb3 的方式连接到该h2 server (中间加粗的红色IP地址,为web server对应的IP地址)

目录
相关文章
|
1月前
|
Java 开发工具
【Azure Storage Account】Java Code访问Storage Account File Share的上传和下载代码示例
本文介绍如何使用Java通过azure-storage-file-share SDK实现Azure文件共享的上传下载。包含依赖引入、客户端创建及完整示例代码,助你快速集成Azure File Share功能。
333 4
|
2月前
|
IDE Java 关系型数据库
Java 初学者学习路线(含代码示例)
本教程为Java初学者设计,涵盖基础语法、面向对象、集合、异常处理、文件操作、多线程、JDBC、Servlet及MyBatis等内容,每阶段配核心代码示例,强调动手实践,助你循序渐进掌握Java编程。
396 3
|
2月前
|
安全 Java 应用服务中间件
Spring Boot + Java 21:内存减少 60%,启动速度提高 30% — 零代码
通过调整三个JVM和Spring Boot配置开关,无需重写代码即可显著优化Java应用性能:内存减少60%,启动速度提升30%。适用于所有在JVM上运行API的生产团队,低成本实现高效能。
276 3
|
2月前
|
Java API 开发工具
【Azure Developer】Java代码实现获取Azure 资源的指标数据却报错 "invalid time interval input"
在使用 Java 调用虚拟机 API 获取指标数据时,因本地时区设置非 UTC,导致时间格式解析错误。解决方法是在代码中手动指定时区为 UTC,使用 `ZoneOffset.ofHours(0)` 并结合 `withOffsetSameInstant` 方法进行时区转换,从而避免因时区差异引发的时间格式问题。
201 3
|
1月前
|
Java 数据处理 API
为什么你的Java代码应该多用Stream?从循环到声明式的思维转变
为什么你的Java代码应该多用Stream?从循环到声明式的思维转变
234 115
|
1月前
|
安全 Java 编译器
为什么你的Java代码需要泛型?类型安全的艺术
为什么你的Java代码需要泛型?类型安全的艺术
171 98
|
2月前
|
Java
java入门代码示例
本文介绍Java入门基础,包含Hello World、变量类型、条件判断、循环及方法定义等核心语法示例,帮助初学者快速掌握Java编程基本结构与逻辑。
403 0
|
3月前
|
人工智能 监控 安全
智慧工地解决方案,java智慧工地程序代码
智慧工地系统融合物联网、AI、大数据等技术,实现对施工现场“人、机、料、法、环”的全面智能监控与管理,提升安全、效率与决策水平。
125 2
|
1月前
|
安全 Java 容器
告别繁琐判空:Optional让你的Java代码更优雅
告别繁琐判空:Optional让你的Java代码更优雅

热门文章

最新文章

下一篇
oss云网关配置