KingbaseES客户端编程开发框架-Dbunit.pdf

KingbaseES 客户端编程开发框架-Dbunit 金仓数据库管理系统 KingbaseES 文档版本：V9（V009R001C001B0024） 发布日期：2023 年 10 月 12 日 北京人大金仓信息技术股份有限公司 目 目 录 录 第 1 章 前言 1 1.1 适用读者 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 1 1.2 相关文档 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 1 1.3 术语 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 1 1.4 手册约定 2 . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 第 2 章 概述 3 第 3 章 Dbunit 使用说明 4 版权声明 9 服务周期承诺 10 I 第 1 章 前言 1 第 章 前言 本文档描述了 DbUnit 的基本概念，以及相关配置和使用方法。 前言部分包含以下主题： • 适用读者 • 相关文档 • 术语 • 手册约定 1.1 适用读者 《KingbaseES DbUnit 指南》面向所有使用 KingbaseES 数据库的用户，主要是数据库管理员和应用程序开发人 员。 1.2 相关文档 有关 DbUnit 的更多信息，请参阅以下资源： About DbUnit 1.3 术语 无 1 第 1 章 前言 1.4 手册约定 本文档中可能出现“注意、提示、警告、另请参阅”等标志，它们所代表的含义如下： 注意: 用于突出重要/关键信息、最佳实践等。 提示: 用于突出小窍门、捷径等。 警告: 用于传递设备或环境安全警示信息，若不避免，可能会导致设备损坏、数据丢失、设备性能降低或其 它不可预知的结果。 另请参阅: 用于突出参考、参阅等。 以下程序代码书写约定适用于本文档： 符号 说明 [] 表示包含一个或多个可选项。不需要输入中括号本身。 {} 表示包含两个以上（含两个）的候选，必须在其中选取一个。不需要输入花括号本身。 | 分割中括号或者花括号中的两个或两个以上选项。不需要输入“|”本身。 ... 表示其之前的元素可以被重复。 斜体 表示占位符或者需要提供特定值的变量。 大写 表示系统提供的元素，以便与用户定义的元素相互区分。除出现在方括号中的元素外，应当按 照顺序逐字输入。当然，部分元素在系统中是大小写不敏感的，因此用户可以根据系统说明以 小写形式输入。 小写 表示由用户提供的元素。 2 第 2 章 概述 2 第 章 概述 DbUnit 是一个基于 Junit 扩展的数据库测试框架。它提供了大量对于数据库相关操作进行抽象和封装的类。它 通过使用用户自定义的数据集以及相关操作使数据库处于一种可知的状态，从而使得测试自动化、可重复和相对独 立。 本章内容主要是对 DbUnit 的使用方法进行简单描述。 3 第3章 3 第 章 DBUNIT 使用说明 Dbunit 使用说明 以下为 DbUnit 使用的示例。DbUnit 的 jar 包可以从官方网站下载，DbUnit 所使用的 JDBC 包 kingbase89.0.0.jar 位于 $KINGBASE_HOME/Interface/jdbc 目录下。使用时将 DbUnit 包和 JDBC 包导入到项目的 Libraries 中并定义相关配置项即可。 a. 建表语句： create table dbtest(id int primary key,name text,resume clob); 表中现有数据： TEST=# select * from dbtest; id | name | resume ----+------+-------------------------1 | Mike | 姓名：张三 英文名：Mike 2 | Jack | 姓名：李四 英文名：Jack (2 rows) b. 准备测试所需数据文件： 插入数据文件 dataset.xml 更新数据文件 dataset2.xml 4 第3章 DBUNIT 使用说明 c. 准备测试所需方法： import java.io.File; import java.io.FileInputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import org.dbunit.DatabaseUnitException; import org.dbunit.database.DatabaseConnection; import org.dbunit.database.IDatabaseConnection; import org.dbunit.database.QueryDataSet; import org.dbunit.dataset.IDataSet; import org.dbunit.dataset.xml.FlatXmlDataSet; import org.dbunit.operation.DatabaseOperation; public class DBUnit { private IDatabaseConnection connection; private QueryDataSet queryDataSet; private Connection jdbcConnection; public DBUnit() { } public DBUnit(String driver, String url, String user, String password) { try { Class.forName(driver); jdbcConnection = DriverManager.getConnection(url, user, password); } catch (Exception e) { e.printStackTrace(); } } public void close() throws SQLException { if (connection != null) { connection.close(); } } public void setSchema(String schema) throws SQLException, DatabaseUnitException { connection = new DatabaseConnection(jdbcConnection, schema); } 5 第3章 DBUNIT 使用说明 public void insertData(IDataSet dataSet) { try { DatabaseOperation.INSERT.execute(connection, dataSet); } catch (Exception e) { e.printStackTrace(); } } public void clean_insertData(IDataSet dataSet) { try { DatabaseOperation.CLEAN_INSERT.execute(connection, dataSet); } catch (Exception e) { e.printStackTrace(); } } public void deleteData(IDataSet dataSet) { try { DatabaseOperation.DELETE.execute(connection, dataSet); } catch (Exception e) { e.printStackTrace(); } } public void updateData(IDataSet dataSet) { try { DatabaseOperation.UPDATE.execute(connection, dataSet); } catch (Exception e) { e.printStackTrace(); } } public QueryDataSet getQueryDataSet() { queryDataSet = new QueryDataSet(connection); return queryDataSet; } public IDataSet getDataSet(String path) { FlatXmlDataSet dataSet = null; try { dataSet = new FlatXmlDataSet(new FileInputStream(new File(path))); } catch (Exception e) { e.printStackTrace(); } return dataSet; 6 第3章 DBUNIT 使用说明 } } d. 测试用例： import java.io.FileWriter; import java.io.IOException; import java.sql.SQLException; import org.dbunit.DatabaseUnitException; import org.dbunit.database.QueryDataSet; import org.dbunit.dataset.Column; import org.dbunit.dataset.IDataSet; import org.dbunit.dataset.ITable; import org.dbunit.dataset.xml.FlatXmlDataSet; import org.junit.After; import org.junit.Before; import org.junit.Test; public class DBUnitTest { private String driver = "com.kingbase8.Driver"; private String url = "jdbc:kingbase8://localhost:54321/TEST"; private String user = "postgres"; private String password = ""; private static final String DATA_BACKUP_FILE = "backup_dbtest.xml"; private DBUnit dbUnit; @Before public void setUp() throws SQLException, DatabaseUnitException, IOException { dbUnit = new DBUnit(driver, url, user, password); dbUnit.setSchema("PUBLIC"); QueryDataSet dataSet = dbUnit.getQueryDataSet(); dataSet.addTable("dbtest"); FlatXmlDataSet.write(dataSet, new FileWriter(DATA_BACKUP_FILE)); System.out.println("------------------------------"); Query(); } @After 7 第3章 DBUNIT 使用说明 public void tearDown() throws SQLException, DatabaseUnitException { Query(); System.out.println("------------------------------"); IDataSet dataSet = dbUnit.getDataSet(DATA_BACKUP_FILE); dbUnit.clean_insertData(dataSet); dbUnit.close(); } @Test public void TestInsert() throws SQLException, DatabaseUnitException { System.out.println("----------Insert----------"); IDataSet dataSet = dbUnit.getDataSet("dataset.xml"); dbUnit.insertData(dataSet); } @Test public void TestUpdate() throws SQLException, DatabaseUnitException { System.out.println("----------Update----------"); IDataSet dataSet = dbUnit.getDataSet("dataset2.xml"); dbUnit.updateData(dataSet); } @Test public void TestDelete() throws SQLException, DatabaseUnitException { System.out.println("----------Delete----------"); IDataSet dataSet = dbUnit.getDataSet("dataset.xml"); dbUnit.deleteData(dataSet); } public void Query() throws SQLException, DatabaseUnitException { QueryDataSet dataSet = dbUnit.getQueryDataSet(); dataSet.addTable("dbtest"); ITable it = dataSet.getTable("dbtest"); Column[] columns = dataSet.getTable("dbtest").getTableMetaData().getColumns(); for (int i = 0; i < it.getRowCount(); i++) { for (int j = 0; j < columns.length; j++) { System.out.print(it.getValue(i, columns[j].getColumnName()) + " "); } System.out.println(); } } } 8 版权声明 版权声明 北京人大金仓信息技术股份有限公司（简称：人大金仓）版权所有，并保留对本手册及本声明的一切权利。 未得到人大金仓的书面许可，任何人不得以任何方式或形式对本手册内的任何部分进行复制、摘录、备份、修 改、传播、翻译成其他语言、将其全部或部分用于商业用途。 免责声明 本手册内容依据现有信息制作，由于产品版本升级或其他原因，其内容有可能变更。人大金仓保留在没有任何通 知或者提示的情况下对手册内容进行修改的权利。 本手册仅作为使用指导，人大金仓在编写本手册时已尽力保证其内容准确可靠，但并不确保手册内容完全没有错 误或遗漏，本手册中的所有信息也不构成任何明示或暗示的担保。 技术支持 • 人大金仓官方网站：http://www.kingbase.com.cn/ • 人大金仓文档中心：http://help.kingbase.com.cn/ • 全国服务热线：400-601-1188 • 人大金仓技术支持与反馈信箱：support@kingbase.com.cn 9 服务周期承诺 服务周期承诺 由于市场需求在不断变化，技术创新和发展的进程不断加剧，产品的版本更迭不可避免。人大金仓对于产品版本 生命周期的有效管理，有助于您提前规划项目，更好地从产品服务终止上过渡。 表 1: KingbaseES 产品生命周期里程碑 关键里程碑点 定义 产品发布日期 产品正式发布版本，即 GA（general availability）版本的发布日期。 停止销售日期 正式停止销售的日期，版本停止接受订单日。该日之后，产品将不再销售。 停止功能升级日期 在该日期之后，不再提供新特性和新硬件支持。但依旧提供错误修复、安全修复、功 能维护等服务。 停止功能维护日期 在该日期之后，不再维护功能，修复问题。但依旧提供安全修复等服务 停止安全维护日期 在该日期之后，不再发布补丁版本修复中高风险漏洞，仅提供有限的支持。 产品服务终止日期 停止提供产品服务和支持的日期。包括软件维护版本，缺陷修复，以及针对该产品的 所有服务支持（包括服务热线和远程/现场支持）。 服务周期策略 金仓数据库管理系统 KingbaseES 产品确保以下的服务周期： 1）产品自发布之日起至产品停止功能升级（包含新特性、新硬件支持）之日不少于 5 年。 2）产品停止功能升级之日起至产品停止功能维护（主要包括问题修复）之日不少于 4 年。 3）产品功能维护停止之日起至产品停止安全维护（包括中高风险漏洞修复）之日不少于 2 年。 服务终止策略 金仓数据库管理系统 KingbaseES 产品确保在销售后，至少提供 6 年的服务支持。 注意: 人大金仓将会综合各方因素来确定产品服务终止日期。并将在实际产品服务终止日期之前至少 90 天，通过公 10 服务周期承诺 开方式宣布产品服务终止日期。 11