手写DAO框架（六）-框架使用示例

1、引入pom

<dependency>
    <groupId>me.lovegao</groupId>
    <artifactId>gdao</artifactId>
    <version>0.0.2-SNAPSHOT</version>
</dependency>

须要先将gdao项目（https://github.com/shuimutong/gdao.git）打包加到本地仓库。

0.0.2版本：tag：dev-1-init

0.0.3版本：tag：dev-2-tag-fix

2、链接配置

一、0.0.2版本

##驱动名称
driverName=com.mysql.jdbc.Driver
##链接url
connectionUrl=jdbc:mysql://localhost:3306/simple?useServerPrepStmts=false&rewriteBatchedStatements=true&connectTimeout=1000&useUnicode=true&characterEncoding=utf-8
##用户名
userName=ss
##用户密码
userPassword=111111
##初始化链接数
initConnectionNum=10
##最大链接数
maxConnectionNum=50
##最大查询等待时间
maxQueryTime=3

二、0.0.3配置

##驱动名称
driverName=com.mysql.jdbc.Driver
##链接url
connectionUrl=jdbc:mysql://localhost:3306/simple?useServerPrepStmts=false&rewriteBatchedStatements=true&connectTimeout=1000&useUnicode=true&characterEncoding=utf-8
##用户名
userName=simple
##用户密码
userPassword=123456
##初始化链接数
initConnectionNum=10
##最大链接数
maxConnectionNum=50
##最大查询等待时间
maxQueryTime=3
#########v03##########
#归还链接时检测链接,true false
checkConnectionWhenReturn=true
#链接检测语句（检测必填）
checkConnectionValidationQuery=select 1
#定时检测链接间隔时长（分钟）
periodCheckConnectionTimeMin=10
#链接泄露检测
connectionLeakCheck=true
#链接泄露检测间隔时长（分钟），需大于0
connectionLeakCheckPeriodTimeMin=10
#强制归还链接时长（小时），0表明不检测
forceReturnConnectionTimeHour=6

三、0.0.3版本更新简介 

0.0.3版本至关于上一个版本，主要是增长了链接检测。

链接检测包括3部分：归还链接时检测，链接定时检测，链接泄露检测。

1）检测必须配置的字段：checkConnectionValidationQuery=select 1

2）归还链接时检测

在归还链接时检测链接是否可用。

配置字段：checkConnectionWhenReturn=true

3）链接定时检测

定时检测链接池中的链接是否可用。若是不可用，就进行关闭处理，防止链接池中存放的链接是无用链接。

配置字段：periodCheckConnectionTimeMin=10，若是值为0，则不进行此项检测

4）链接泄露检测

防止链接被借出以后不归还，可能致使链接池数量不少，可是无可用链接。

配置字段：

forceReturnConnectionTimeHour=6，若是链接借出时长超过这个值，就会关闭链接，而后从链接池以后移除，若是为0，则表明不检测；

connectionLeakCheckPeriodTimeMin=10，检测是由线程进行检测的，这个字段表示线程每一个多久检测一次

3、定义数据库对应的类和建表

一、UserDo

 1 package me.lovegao.gdao.dos;
 2 
 3 import me.lovegao.gdao.bean.annotation.GColumn;
 4 import me.lovegao.gdao.bean.annotation.GId;
 5 import me.lovegao.gdao.bean.annotation.GTable;
 6 
 7 @GTable("t_user")
 8 public class UserDo {
 9     @GId(isAutoIncrease=true)
10     @GColumn(name="id")
11     private long id;
12     
13     @GColumn(name="name")
14     private String name;
15     
16     @GColumn(name="age")
17     private int age;
18     
19     public long getId() {
20         return id;
21     }
22     public void setId(long id) {
23         this.id = id;
24     }
25     public String getName() {
26         return name;
27     }
28     public void setName(String name) {
29         this.name = name;
30     }
31     public int getAge() {
32         return age;
33     }
34     public void setAge(int age) {
35         this.age = age;
36     }
37     
38 }

二、对应表sql

CREATE TABLE `t_user` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键',
  `name` varchar(255) NOT NULL DEFAULT '' COMMENT '名称',
  `age` int(15) NOT NULL DEFAULT 0 COMMENT '年龄',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='测试-用户表';

3、建立UserDao

package me.lovegao.gdao.dao;

import me.lovegao.gdao.dos.UserDo;
import me.lovegao.gdao.orm.BaseDao;
import me.lovegao.gdao.sqlexecute.ISqlExecutor;

public class UserDao extends BaseDao<UserDo, Long> {
    public UserDao(ISqlExecutor sqlExecutor) {
        super(sqlExecutor);
    }
    
}

4、执行

public static void main(String[] args) throws Exception {
    ISqlExecutor sqlExecutor = initDao();
    addTest(sqlExecutor);
}
public static void addTest(ISqlExecutor sqlExecutor) throws Exception {
    //实例化UserDao
    UserDao userDao = new UserDao(sqlExecutor);
    UserDo[] uds = listUser(); //获取测试数据
    System.out.println("准备开始添加");
    userDao.add(uds[0]); //添加数据
    System.out.println("开始添加---");
    long t1 = System.currentTimeMillis();
    for(int i=1; i<uds.length; i++) {
        userDao.add(uds[i]);
    }
    long t2 = System.currentTimeMillis();
    double useTime = t2 - t1;
    //5000条，totalUseTime:8629.0ms,avgUseTime:1.7261452290458092ms
    System.out.println("totalUseTime:" + useTime + "ms,avgUseTime:" + useTime/(uds.length-1) + "ms");
}
//初始化资源管理，sql执行
public static ISqlExecutor initDao() throws Exception {
    Properties prop = new Properties();
    String confPath = "/mysql.properties";
    prop.load(DaoTest.class.getResourceAsStream(confPath));
    //0.0.2版本
    DaoResourceManager daoResource = new DaoResourceManager(prop);
    //0.0.3版本
    DaoResourceManager daoResource = new DaoResourceManager(prop, true);
    //获取sql执行器
    ISqlExecutor sqlExecutor = daoResource.getSqlExecutor();
    return sqlExecutor;
}