前幾日,寫了一篇關(guān)于一個 輕量級數(shù)據(jù)持久化的框架的博客(點擊瀏覽: http://blog.csdn.net/marksinoberg/article/details/53163704 ),讓我收獲很多。很大的一個收獲就是眾多博友紛紛提出了自己的看法,讓我對自己的這套程序有了更加全面的認識。
于是又對此做了進一步的完善,以期能有一個更優(yōu)雅的呈現(xiàn)。支持了更多的拓展和自定義行為。
用法大致和之前的第一個版本相當,但是也稍有不同,下面將以一個小案例來進行闡述。
核心理念
本工具以查詢?yōu)橹饕诵睦砟睿磓uery操作為主,覆蓋了多種查詢方式的自動化運行流程。
其他諸如insert, update, delete以及事務(wù)操作,均由QueryRunner的update方法完成。
配備了自定義大小的數(shù)據(jù)庫連接池,提升程序運行的效率,并由底層自動維護連接池的釋放,申請問題。省心。
如何使用
- Step 1:
首先在項目的src目錄下創(chuàng)建一個db.cfg.xml的文件,格式如下:
<?xml version="1.0" encoding="UTF-8" ?>
<project>
<database name="mysql">
<driver>com.mysql.jdbc.Driver</driver>
<url>jdbc:mysql://localhost:3306/fams</url>
<user>root</user>
<password>mysql</password>
<poolsize>20</poolsize>
</database>
···
</project>
- Step 2:
通過注冊的方式實現(xiàn)配置文件中的數(shù)據(jù)源的配置
Dbhelper.register()即可
- Step 3:
主要的業(yè)務(wù)邏輯操作類QueryRunner,封裝了對數(shù)據(jù)庫JDBC操作的增刪改查等一系列的操作。
對于update方法的JDBC操作,我們無需手動的關(guān)閉數(shù)據(jù)庫連接,僅僅簡單的通過DbHelper的重載的release方法來實現(xiàn)對數(shù)據(jù)庫連接對象,查詢語句以及數(shù)據(jù)集的關(guān)閉操作,自動的維護數(shù)據(jù)庫連接池。是不是感覺很省心啊。
測試實例
這里先根據(jù)數(shù)據(jù)庫中的表結(jié)構(gòu)來創(chuàng)建一個對應(yīng)的Bean對象吧。
/**
* @Date 2016年11月19日
*
* @author Administrator
*/
/**
* @author 郭璞
*
*/
public class DateTest {
private int id;
private String name;
private Date date;
@Override
public String toString() {
return "DateTest [id=" + id + ", name=" + name + ", date=" + date + "]";
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Date getDate() {
return date;
}
public void setDate(Date date) {
this.date = date;
}
}
數(shù)據(jù)庫內(nèi)詳細數(shù)據(jù)信息
mysql> use test;
Database changed
mysql> select * from datetest;
+----+----------+------------+
| id | name | date |
+----+----------+------------+
| 1 | dlut | 2016-07-06 |
| 2 | 清華大學(xué) | 2016-07-03 |
| 3 | 北京大學(xué) | 2016-07-28 |
| 4 | Mark | 2016-08-20 |
| 5 | Tom | 2016-08-19 |
| 6 | Jane | 2016-08-21 |
+----+----------+------------+
6 rows in set (0.00 sec)
mysql>
測試代碼
數(shù)據(jù)庫連接池測試
public static void main(String[] args) throws Exception {
DbHelper helper = new DbHelper();
helper.register();
System.out.println(helper.connpool.size());
Connection conn = helper.getConnection();
System.out.println(helper.connpool.size());
Connection conn1 = helper.getConnection();
System.out.println(helper.connpool.size());
Connection conn2 = helper.getConnection();
System.out.println(helper.connpool.size());
System.out.println(conn.toString());
System.out.println(conn1.toString());
System.out.println(conn2.toString());
helper.release(conn);
System.out.println(helper.connpool.size());
PreparedStatement stmt = conn1.prepareStatement("select * from user");
helper.release(conn2, stmt);
System.out.println(helper.connpool.size());
PreparedStatement stmt1 = conn1.prepareStatement("select * from user");
ResultSet rs = stmt1.executeQuery();
helper.release(conn2, stmt1, rs);
System.out.println(helper.connpool.size());
System.out.println(conn.toString());
System.out.println(conn1.toString());
System.out.println(conn2.toString());
}
測試結(jié)果:
20
19
18
17
dbhelper.DbHelper$MyConnection@28c97a5
dbhelper.DbHelper$MyConnection@6659c656
dbhelper.DbHelper$MyConnection@6d5380c2
18
19
20
dbhelper.DbHelper$MyConnection@28c97a5
dbhelper.DbHelper$MyConnection@6659c656
dbhelper.DbHelper$MyConnection@6d5380c2
測試集
/**
* @Date 2016年11月19日
*
* @author 郭 璞
*
*/
package mp;
import java.sql.Connection;
import java.util.List;
import org.junit.Test;
import dbhelper.DbHelper;
import dbhelper.QueryRunner;
import handlers.BeanHandler;
import handlers.BeanListHandler;
/**
* @author 郭 璞
*
*/
public class TestCase {
@Test
public void testSingleBean() throws Exception {
System.out.println("-----------------testSingleBean-------------------------------------");
String sql = "select * from datetest where id=?";
QueryRunner runner = new QueryRunner();
DbHelper.register();
DbHelper helper = new DbHelper();
Connection conn = helper.getConnection();
DateTest datetest = runner.query(conn, sql, new BeanHandler<DateTest>(DateTest.class), 1);
System.out.println(datetest.toString());
DbHelper.release(conn);
}
@Test
public void testBeanList() throws Exception {
System.out.println("-------------- testBeanList----------------------------------------");
String sql = "select * from datetest";
QueryRunner runner = new QueryRunner();
DbHelper.register();
DbHelper helper = new DbHelper();
Connection conn = helper.getConnection();
List<DateTest> dates = runner.query(conn, sql, new BeanListHandler<DateTest>(DateTest.class));
for (DateTest date : dates) {
System.out.println(date.toString());
}
DbHelper.release(conn);
}
@Test
public void testBeanListWithParams1() throws Exception {
System.out.println("--------------testBeanListWithParams1----------------------------------------");
String sql = "select * from datetest where id in (?, ?, ?)";
QueryRunner runner = new QueryRunner();
DbHelper.register();
DbHelper helper = new DbHelper();
Connection conn = helper.getConnection();
Object[] params = new Object[]{1, 3, 6};
List<DateTest> dates = runner.query(conn, sql, new BeanListHandler<DateTest>(DateTest.class), params);
for (DateTest date : dates) {
System.out.println(date.toString());
}
DbHelper.release(conn);
}
@Test
public void testBeanListWithParams2() throws Exception {
System.out.println("--------------testBeanListWithParams2----------------------------------------");
String sql = "select * from datetest where id in (?, ?, ?) or name = ?";
QueryRunner runner = new QueryRunner();
DbHelper.register();
DbHelper helper = new DbHelper();
Connection conn = helper.getConnection();
Object[] params = new Object[]{1, 3, 6, "Mark"};
List<DateTest> dates = runner.query(conn, sql, new BeanListHandler<DateTest>(DateTest.class), params);
for (DateTest date : dates) {
System.out.println(date.toString());
}
DbHelper.release(conn);
}
@Test
public void testupdate() throws Exception {
System.out.println("--------------testupdate----------------------------------------");
String sql = "update datetest set name=? where name=?";
QueryRunner runner = new QueryRunner();
DbHelper.register();
DbHelper helper = new DbHelper();
Connection conn = helper.getConnection();
Object[] params = new Object[]{"郭璞", "Mark"};
runner.update(conn, sql, params);
DbHelper.release(conn);
}
}
測試結(jié)果:
-----------------testSingleBean-------------------------------------
DateTest [id=1, name=dlut, date=Wed Jul 06 00:00:00 CST 2016]
-------------- testBeanList----------------------------------------
DateTest [id=1, name=dlut, date=Wed Jul 06 00:00:00 CST 2016]
DateTest [id=2, name=清華大學(xué), date=Sun Jul 03 00:00:00 CST 2016]
DateTest [id=3, name=北京大學(xué), date=Thu Jul 28 00:00:00 CST 2016]
DateTest [id=4, name=郭璞, date=Sat Aug 20 00:00:00 CST 2016]
DateTest [id=5, name=Tom, date=Fri Aug 19 00:00:00 CST 2016]
DateTest [id=6, name=Jane, date=Sun Aug 21 00:00:00 CST 2016]
--------------testBeanListWithParams1----------------------------------------
DateTest [id=1, name=dlut, date=Wed Jul 06 00:00:00 CST 2016]
DateTest [id=3, name=北京大學(xué), date=Thu Jul 28 00:00:00 CST 2016]
DateTest [id=6, name=Jane, date=Sun Aug 21 00:00:00 CST 2016]
--------------testBeanListWithParams2----------------------------------------
DateTest [id=1, name=dlut, date=Wed Jul 06 00:00:00 CST 2016]
DateTest [id=3, name=北京大學(xué), date=Thu Jul 28 00:00:00 CST 2016]
DateTest [id=6, name=Jane, date=Sun Aug 21 00:00:00 CST 2016]
--------------testupdate----------------------------------------
數(shù)據(jù)庫中對應(yīng)更新結(jié)果:
mysql> use test;
Database changed
mysql> select * from datetest;
+----+----------+------------+
| id | name | date |
+----+----------+------------+
| 1 | dlut | 2016-07-06 |
| 2 | 清華大學(xué) | 2016-07-03 |
| 3 | 北京大學(xué) | 2016-07-28 |
| 4 | Mark | 2016-08-20 |
| 5 | Tom | 2016-08-19 |
| 6 | Jane | 2016-08-21 |
+----+----------+------------+
6 rows in set (0.00 sec)
mysql> select * from datetest;
+----+----------+------------+
| id | name | date |
+----+----------+------------+
| 1 | dlut | 2016-07-06 |
| 2 | 清華大學(xué) | 2016-07-03 |
| 3 | 北京大學(xué) | 2016-07-28 |
| 4 | 郭璞 | 2016-08-20 |
| 5 | Tom | 2016-08-19 |
| 6 | Jane | 2016-08-21 |
+----+----------+------------+
6 rows in set (0.00 sec)
延伸
由于源代碼可以隨意更改,所以你可以根據(jù)自己的需求來實現(xiàn)私人定制。僅僅需要實現(xiàn)自己的handler接口就可以了。
如果你看到了這篇文章,歡迎給我提issue。當然也可以修改成你自己的工具。