HSQL 数据库介绍(2)--使用

一给  金牌会员 | 2024-7-14 21:29:13 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 856|帖子 856|积分 2568

本文主要介绍 HSQLDB 的基本使用，文中所使用到的软件版本：Java 11.0.22、HSQLDB 2.7.2。
1、进程内模式

直接使用 JDBC 连接数据库即可，如果数据库不存在会自动创建。
1.1、file 数据库
  1. @Test
  2. public void inProcessFile() throws SQLException {
  3.     String dbName = "test";
  4.     //用户名密码为第一次连接设置的密码
  5.     Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:file:d:/temp/" + dbName, "admin", "123456");
  6.     log.info("con={}", con);
  7.     business(con);
  8.     con.close();
  9. }
  11. private void business(Connection con) throws SQLException {
  12.     String tableName = "a_student";
  13.     Statement st = con.createStatement();
  14.     String sql = "select 1 from INFORMATION_SCHEMA.TABLES where upper(table_schema)=? and upper(table_name)=?";
  15.     PreparedStatement pst = con.prepareStatement(sql);
  16.     pst.setString(1, "PUBLIC");
  17.     pst.setString(2, tableName.toUpperCase());
  18.     ResultSet rs = pst.executeQuery();
  19.     if (!rs.next()) {//表不存在则创建并初始化数据，这里根据业务需要进行操作
  20.         st.executeUpdate("create table " + tableName + "(id int, name varchar(32))");
  21.         st.executeUpdate("insert into " + tableName + "(id,name) values (1,'李白')");
  22.         st.executeUpdate("insert into " + tableName + "(id,name) values (2,'杜甫')");
  23.     }
  25.     rs = st.executeQuery("select * from " + tableName);
  26.     while (rs.next()) {
  27.         log.info("id={},name={}", rs.getInt("id"), rs.getString("name"));
  28.     }
  29. }
复制代码
1.2、mem 数据库
  1. @Test
  2. public void inProcessMem() throws SQLException {
  3.     String dbName = "test";
  4.     //用户名密码为第一次连接设置的密码
  5.     Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:mem:" + dbName, "admin", "123456");
  6.     log.info("con={}", con);
  7.     business(con);
  8.     con.close();
  9. }
复制代码
1.3、res 数据库
  1. @Test
  2. public void inProcessRes() throws SQLException {
  3.     String dbName = "test";
  4.     //用户名密码为第一次连接设置的密码,数据库文件位于某个依赖 jar 文件的 db 目录中
  5.     Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:res:db/" + dbName, "admin", "123456");
  6.     log.info("con={}", con);
  7.     business(con);
  8.     con.close();
  9. }
复制代码
2、服务器模式

2.1、HyperSQL HSQL Server

可以通过如下命令启动 HyperSQL HSQL Server，假设当前位于 HSQLDB 安装包的 data 目录中：
  1. java -cp ../lib/hsqldb.jar org.hsqldb.server.Server --database.0 file:d:/temp/mydb --dbname.0 test #启动file数据库，数据库文件保存在d:/temp目录下，数据名称为 test
  2. java -cp ../lib/hsqldb.jar org.hsqldb.server.Server --database.0 mem:mydb --dbname.0 test #启动mem数据库，数据名称为 test
复制代码
可以添加其他参数来调解数据库的默认行为，查看所有参数：
  1. java  -cp ../lib/hsqldb.jar org.hsqldb.server.Server --help
复制代码
相关参数如下：
  1. Usage: java org.hsqldb.server.WebServer [options]
  3. +-----------------+------------ +------------+------------------------------+
  4. |     OPTION      |    TYPE     |  DEFAULT   |         DESCRIPTION          |
  5. +-----------------+-------------+------------+------------------------------|
  6. | --help          | -           | -          | displays this message        |
  7. | --address       | name|number | any        | server inet address          |
  8. | --port          | number      | 80/443     | port at which server listens |
  9. | --database.i    | [type]spec  | 0=test     | name of database i           |
  10. | --dbname.i      | alias       | -          | url alias for database i     |
  11. | --root          | path        | ./         | path to web root             |
  12. | --default_page  | file        | index.html | default web page             |
  13. | --silent        | true|false  | true       | false => display all queries |
  14. | --trace         | true|false  | false      | display JDBC trace messages  |
  15. | --tls           | true|false  |            | HTTPS (secure) sockets       |
  16. | --no_system_exit| true|false  | false      | do not issue System.exit()   |
  17. | --remote_open   | true|false  | false      | can open databases remotely  |
  18. | --props         | filepath    |            | file path of properties file |
  19. +-----------------+-------------+------------+------------------------------+
  21. The web server looks for a 'webserver.properties' file in the current directory
  22. and loads properties from it if it exists.
  23. Command line options override those loaded from the 'webserver.properties' file.
复制代码
启动后使用 JDBC 访问数据库：
  1. @Test
  2. public void hsqlServer() throws SQLException {
  3.     String dbName = "test";
  4.     Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:hsql://localhost:9001/" + dbName, "SA", "");
  5.     log.info("con={}", con);
  6.     business(con);
  7.     con.close();
  8. }
复制代码
2.2、HyperSQL HTTP Server

可以通过如下命令启动 HyperSQL HTTP Server，假设当前位于 HSQLDB 安装包的 data 目录中：
  1. java -cp ../lib/hsqldb.jar org.hsqldb.server.WebServer --database.0 file:d:/temp/mydb --dbname.0 test #启动file数据库，数据库文件保存在d:/temp目录下，数据名称为 test
  2. java -cp ../lib/hsqldb.jar org.hsqldb.server.WebServer --database.0 mem:mydb --dbname.0 test #启动mem数据库，数据名称为 test
复制代码
可以添加其他参数来调解数据库的默认行为，查看所有参数：
  1. java  -cp ../lib/hsqldb.jar org.hsqldb.server.WebServer --help
复制代码
相关参数如下：
  1. Usage: java org.hsqldb.server.WebServer [options]
  3. +-----------------+------------ +------------+------------------------------+
  4. |     OPTION      |    TYPE     |  DEFAULT   |         DESCRIPTION          |
  5. +-----------------+-------------+------------+------------------------------|
  6. | --help          | -           | -          | displays this message        |
  7. | --address       | name|number | any        | server inet address          |
  8. | --port          | number      | 80/443     | port at which server listens |
  9. | --database.i    | [type]spec  | 0=test     | name of database i           |
  10. | --dbname.i      | alias       | -          | url alias for database i     |
  11. | --root          | path        | ./         | path to web root             |
  12. | --default_page  | file        | index.html | default web page             |
  13. | --silent        | true|false  | true       | false => display all queries |
  14. | --trace         | true|false  | false      | display JDBC trace messages  |
  15. | --tls           | true|false  |            | HTTPS (secure) sockets       |
  16. | --no_system_exit| true|false  | false      | do not issue System.exit()   |
  17. | --remote_open   | true|false  | false      | can open databases remotely  |
  18. | --props         | filepath    |            | file path of properties file |
  19. +-----------------+-------------+------------+------------------------------+
  21. The web server looks for a 'webserver.properties' file in the current directory
  22. and loads properties from it if it exists.
  23. Command line options override those loaded from the 'webserver.properties' file.
复制代码
启动后使用 JDBC 访问数据库：
  1. @Test
  2. public void httpServer() throws SQLException {
  3.     String dbName = "test";
  4.     Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:http://localhost:80/" + dbName, "SA", "");
  5.     log.info("con={}", con);
  6.     business(con);
  7.     con.close();
  8. }
复制代码
2.3、HyperSQL HTTP Servlet

这种方式使用较少，这里就不详细介绍，可参考源文件 src/org/hsqldb/server/Servlet.java 查看详细信息。
3、混合模式

应用通过代码的方式启动数据库服务，应用内访问数据库可以使用进程模式，其他应用通过服务器模式访问。下面衍生通过代码分别启动 HyperSQL HSQL Server 和 HyperSQL HTTP Server，然后模仿其他应用访问数据库。
3.1、HyperSQL HSQL Server
  1. @Test
  2. public void hsqlServer2() throws Exception {
  3.     HsqlProperties p = new HsqlProperties();
  4.     //三种数据库类型，根据需要选择合适的一个
  5.     p.setProperty("server.database.0","file:d:/temp/mydb");
  6.     //p.setProperty("server.database.0","mem:mydb");
  7.     //p.setProperty("server.database.0","res:db/test");//数据库文件test.xx位于某个依赖jar文件的 db 目录中
  8.     p.setProperty("server.dbname.0","test");
  9.     Server server = new Server();
  10.     server.setProperties(p);
  11.     server.start();
  13.     CountDownLatch countDownLatch = new CountDownLatch(1);
  14.     new Thread(() -> {
  15.         try {
  16.             //模拟其他应用访问
  17.             hsqlServer();
  18.         } catch (Exception e) {
  19.             e.printStackTrace();
  20.         }
  21.         countDownLatch.countDown();
  22.     }).start();
  23.     countDownLatch.await();
  25.     server.shutdownCatalogs(1);
  26.     server.stop();
  27. }
复制代码
Server 的属性设置参数可参考 2.1 中启动数据库时的命令行参数。
3.2、HyperSQL HTTP Server
  1. @Test
  2. public void httpServer2() throws Exception {
  3.     HsqlProperties p = new HsqlProperties();
  4.     //三种数据库类型，根据需要选择合适的一个
  5.     //p.setProperty("server.database.0","file:d:/temp/mydb");
  6.     //p.setProperty("server.database.0","mem:mydb");
  7.     p.setProperty("server.database.0","res:db/test");//数据库文件test.xx位于某个依赖jar文件的 db 目录中
  8.     p.setProperty("server.dbname.0","test");
  10.     WebServer webServer = new WebServer();
  11.     webServer.setProperties(p);
  12.     webServer.start();
  13.    
  14.     CountDownLatch countDownLatch = new CountDownLatch(1);
  15.     new Thread(() -> {
  16.         try {
  17.             //模拟其他应用访问
  18.             httpServer();
  19.         } catch (Exception e) {
  20.             e.printStackTrace();
  21.         }
  22.         countDownLatch.countDown();
  23.     }).start();
  24.     countDownLatch.await();
  26.     webServer.stop();
  27. }
复制代码
WebServer 的属性设置参数可参考 2.2 中启动数据库时的命令行参数。
 
完备代码：
  1. package com.abc.demo.db;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.hsqldb.Server;
  5. import org.hsqldb.persist.HsqlProperties;
  6. import org.hsqldb.server.WebServer;
  7. import org.junit.Test;
  9. import java.sql.*;
  10. import java.util.concurrent.CountDownLatch;
  12. @Slf4j
  13. public class HSQLCase {
  14.     @Test
  15.     public void inProcessFile() throws SQLException {
  16.         String dbName = "test";
  17.         //用户名密码为第一次连接设置的密码
  18.         Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:file:d:/temp/" + dbName, "admin", "123456");
  19.         log.info("con={}", con);
  20.         business(con);
  21.         con.close();
  22.     }
  24.     @Test
  25.     public void inProcessMem() throws SQLException {
  26.         String dbName = "test";
  27.         //用户名密码为第一次连接设置的密码
  28.         Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:mem:" + dbName, "admin", "123456");
  29.         log.info("con={}", con);
  30.         business(con);
  31.         con.close();
  32.     }
  34.     @Test
  35.     public void inProcessRes() throws SQLException {
  36.         String dbName = "test";
  37.         //用户名密码为第一次连接设置的密码,数据库文件位于某个依赖 jar 文件的 db 目录中
  38.         Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:res:db/" + dbName, "admin", "123456");
  39.         log.info("con={}", con);
  40.         business(con);
  41.         con.close();
  42.     }
  44.     @Test
  45.     public void hsqlServer() throws SQLException {
  46.         String dbName = "test";
  47.         Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:hsql://localhost:9001/" + dbName, "SA", "");
  48.         log.info("con={}", con);
  49.         business(con);
  50.         con.close();
  51.     }
  53.     @Test
  54.     public void httpServer() throws SQLException {
  55.         String dbName = "test";
  56.         Connection con = JdbcUtil.getConnection("org.hsqldb.jdbc.JDBCDriver", "jdbc:hsqldb:http://localhost:80/" + dbName, "SA", "");
  57.         log.info("con={}", con);
  58.         business(con);
  59.         con.close();
  60.     }
  62.     @Test
  63.     public void hsqlServer2() throws Exception {
  64.         HsqlProperties p = new HsqlProperties();
  65.         //三种数据库类型，根据需要选择合适的一个
  66.         p.setProperty("server.database.0","file:d:/temp/mydb");
  67.         //p.setProperty("server.database.0","mem:mydb");
  68.         //p.setProperty("server.database.0","res:db/test");//数据库文件test.xx位于某个依赖jar文件的 db 目录中
  69.         p.setProperty("server.dbname.0","test");
  70.         Server server = new Server();
  71.         server.setProperties(p);
  72.         server.start();
  74.         CountDownLatch countDownLatch = new CountDownLatch(1);
  75.         new Thread(() -> {
  76.             try {
  77.                 //模拟其他应用访问
  78.                 hsqlServer();
  79.             } catch (Exception e) {
  80.                 e.printStackTrace();
  81.             }
  82.             countDownLatch.countDown();
  83.         }).start();
  84.         countDownLatch.await();
  86.         server.shutdownCatalogs(1);
  87.         server.stop();
  88.     }
  90.     @Test
  91.     public void httpServer2() throws Exception {
  92.         HsqlProperties p = new HsqlProperties();
  93.         //三种数据库类型，根据需要选择合适的一个
  94.         //p.setProperty("server.database.0","file:d:/temp/mydb");
  95.         //p.setProperty("server.database.0","mem:mydb");
  96.         p.setProperty("server.database.0","res:db/test");//数据库文件test.xx位于某个依赖jar文件的 db 目录中
  97.         p.setProperty("server.dbname.0","test");
  99.         WebServer webServer = new WebServer();
  100.         webServer.setProperties(p);
  101.         webServer.start();
  103.         CountDownLatch countDownLatch = new CountDownLatch(1);
  104.         new Thread(() -> {
  105.             try {
  106.                 //模拟其他应用访问
  107.                 httpServer();
  108.             } catch (Exception e) {
  109.                 e.printStackTrace();
  110.             }
  111.             countDownLatch.countDown();
  112.         }).start();
  113.         countDownLatch.await();
  115.         webServer.stop();
  116.     }
  118.     private void business(Connection con) throws SQLException {
  119.         String tableName = "a_student";
  120.         Statement st = con.createStatement();
  121.         String sql = "select 1 from INFORMATION_SCHEMA.TABLES where upper(table_schema)=? and upper(table_name)=?";
  122.         PreparedStatement pst = con.prepareStatement(sql);
  123.         pst.setString(1, "PUBLIC");
  124.         pst.setString(2, tableName.toUpperCase());
  125.         ResultSet rs = pst.executeQuery();
  126.         if (!rs.next()) {//表不存在则创建并初始化数据，这里根据业务需要进行操作
  127.             st.executeUpdate("create table " + tableName + "(id int, name varchar(32))");
  128.             st.executeUpdate("insert into " + tableName + "(id,name) values (1,'李白')");
  129.             st.executeUpdate("insert into " + tableName + "(id,name) values (2,'杜甫')");
  130.         }
  132.         rs = st.executeQuery("select * from " + tableName);
  133.         while (rs.next()) {
  134.             log.info("id={},name={}", rs.getInt("id"), rs.getString("name"));
  135.         }
  136.     }
  137. }
复制代码
HSQLCase.java
  1. package com.abc.demo.db;
  3. import lombok.extern.slf4j.Slf4j;
  5. import java.sql.*;
  8. @Slf4j
  9. public class JdbcUtil {
  10.     private JdbcUtil() {}
  12.     public static Connection getConnection(String driver, String url, String username, String password) {
  13.         Connection con = null;
  14.         try {
  15.             Class.forName(driver);
  16.             con = DriverManager.getConnection(url, username, password);
  17.         } catch (ClassNotFoundException | SQLException e) {
  18.             log.warn("url={},username={},password={}", url, username, password);
  19.             e.printStackTrace();
  20.         }
  21.         return con;
  22.     }
  23. }
复制代码
JdbcUtil.java 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

一给

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表