一、引入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

二、连接配置

1、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

2、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

3、0.0.3版本更新简介 

0.0.3版本相当于上一个版本,主要是增加了连接检测。

连接检测包括3部分:归还连接时检测,连接定时检测,连接泄露检测。

1)检测必须配置的字段:checkConnectionValidationQuery=select 1

2)归还连接时检测

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

配置字段:checkConnectionWhenReturn=true

3)连接定时检测

定时检测连接池中的连接是否可用。如果不可用,就进行关闭处理,防止连接池中存放的连接是无用连接。

配置字段:periodCheckConnectionTimeMin=10,如果值为0,则不进行此项检测

4)连接泄露检测

防止连接被借出之后不归还,可能导致连接池数量很多,但是无可用连接。

配置字段:

forceReturnConnectionTimeHour=6,如果连接借出时长超过这个值,就会关闭连接,然后从连接池之后移除,如果为0,则代表不检测;

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

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

1、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 }

2、对应表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='测试-用户表';

三、创建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);
    }
    
}

四、执行

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;
}

 

内容来源于网络如有侵权请私信删除

文章来源: 博客园

原文链接: https://www.cnblogs.com/shuimutong/p/11391491.html

你还没有登录,请先登录注册
  • 还没有人评论,欢迎说说您的想法!