开源中国

我们不支持 IE 10 及以下版本浏览器

It appears you’re using an unsupported browser

为了获得更好的浏览体验,我们强烈建议您使用较新版本的 Chrome、 Firefox、 Safari 等,或者升级到最新版本的IE浏览器。 如果您使用的是 IE 11 或以上版本,请关闭“兼容性视图”。
ThinkJDBC首页、文档和下载 - 一行代码搞定数据库操作 - 开源中国社区
全部项目分类
Apache
Java
跨平台
Leytton
分享
收藏
67 人收藏
收录时间:2018-04-21
ThinkJDBC 详细介绍

ThinkJDBC

最新版本 中文文档 English Document Maven CSDN Blog

1 简介

ThinkJD,又名ThinkJDBC,一个简洁而强大的开源JDBC操作库。你可以使用Java像ThinkPHP框架的M方法一样,一行代码搞定数据库操作。ThinkJD会自动管理数据库连接,默认使用完毕或程序异常都会关闭连接以免造成内存溢出。也可以设置手动关闭以复用Connection连接,无需传入连接实例参数,ThinkJD内部已做多线程安全处理,详见【0x0A 多线程安全】。

特性

  • 核心jar包只有30多KB
  • 支持复杂SQL语句以及直接执行SQL语句
  • 自动管理数据库连接
  • 支持增删改查ORM映射
  • 支持字段注解映射
  • 主键、自增、是否ORM字段等属性配置
  • 动态设置>注解设置>全局设置
  • 数据库连接多线程安全
  • 支持数据库连接池
  • 简易的事务操作
  • 支持调试模式,输出SQL语句
  • 基于DBUtils,实在无法满足需求就用它

    先睹为快:

    //数据库配置(只需调用一次)
    D.setDbConfig("jdbc:mysql://127.0.0.1:3306/DbName?characterEncoding=UTF-8","root","root");
    
    //JavaBean模式,自动获取表名、主键、自增属性、字段名和数据
    User user = new User();
    user.setAge(10);
    user.setName("Hello");
    user.setSex(true);
    //插入数据
    long id=D.M(user).add();
    //查询数据
    user=D.M(User.class).find(id);
    //更新数据
    user.setSex(false);
    D.M(user).field("sex").save();//不指定字段名默认更新JavaBean的所有非空属性
    //删除数据
    D.M(user).delete();
    //D.M(User.class).delete(id);
    
    //Table模式,手动指定表名、主键、自增属性、字段名和数据
    //插入数据
    long id=D.M("user").field("name,weight").data("Tom",60).add();
    //更新数据
    D.M("user").field("name,weight").data("Tom",100).where("id=?",id).save();
    //查询数据
    user=D.M(User.class).find(id);
    //删除数据
    D.M("user").delete(id);
    

    项目主页

    https://gitee.com/Leytton/ThinkJD (码云) https://github.com/Leytton/ThinkJD (Github)

    测试项目

    https://github.com/Leytton/ThinkJD_Demo

    2 使用方法

    0x01 添加依赖

    导入Jar包

    ThinkJDBC-x.x.x-full.jar 包含了ThinkJDBC-x.x.x-core.jar核心库和两个依赖库,只需要添加这一个jar包就行了

    • mysql-connector-java-5.1.39.jar
    • commons-dbutils-1.6.jar

    或者

    Maven

    
        com.llqqww
        thinkjdbc
        1.4.4_12
    

    0x02 定义数据库

    ThinkJD支持直接定义用户名密码访问数据库,也支持使用Hikari、C3P0等数据库连接池。

    数据库连接方式有三种:

    (1)配置文件方式

    在项目根目录下添加文件(跟Hikari配置文件格式一样)

    程序第一次启动时会自动加载读取配置文件,如果文件不存在则忽略。【V1.2.4_5 增加功能】

    thinkjdbc.properties

    jdbcUrl = jdbc:mysql://127.0.0.1:3306/thinkjdbc?useUnicode=true&characterEncoding=UTF-8
    dataSource.user = root
    dataSource.password = root
    

    (2)帐号密码方式

    D.setDbConfig("jdbc:mysql://127.0.0.1:3306/database?useUnicode=true&characterEncoding=UTF-8","root","root");
    

    (3)使用数据库连接池

    例如使用Hikari连接池:

    HikariConfig config = new HikariConfig("/hikari.properties");
    HikariDataSource dataSource = new HikariDataSource(config);
    D.setDataSource(dataSource);
    

    注:如果定义了数据库连接池,ThinkJD会优先使用。

    (3)配置表前缀

    只需调用一次,配置表前缀不是必需的

    D.setTablePrefix("jd_");
    //D.M('user') D.M(User.class)将会操作 `jd_user` 表
    

    注:D.M('user').prefix('jd_')方法可单独指定表前缀【V1.2.3新增】

    0x03 连贯操作

    操作 参数 示例 说明
    table table(String table) table("user")  
    pk pk(String key) pk("id")  
    autoInc autoInc(boolean isPkAutoInc) autoInc(false)  
    join join(String join) join("left join machine on user.id=user_id and machine_status=1")  
    field field(String filed) field("id,username")  
    data data(Object... dataParam) data(11,"Leytton")  
    setInc setInc(String key,long num) setInc("gold",5) //gold=gold+5  
    setDec setDec(String key,long num) setDec("gold",5) //gold=gold-5  
    where ①where(String where)
    ②where(String where, Object... whereParam)
    ①where("id=1111 and username='Leytton'")
    ②where("id=? and username=?",1111,"Leytton")
     
    group group(String group) group("type")  
    having having(String having) having("id>1234")  
    order order(String order) order("id desc")  
    asc asc(String key) asc("id")  
    desc desc(String key) desc("id")  
    page page(long page, long rows) page(1,10)  
    limit ①limit(long rows)
    ②limit(long offset, long rows)
    ①limit(10)
    ②limit(1,10)
     
    union union(String union,Boolean isAll) ①union("select * from user_two where id>1234",false)
    ②union("select * from user_two where id>1234",true)
     

    0x04 查询数据

    操作 参数 说明
    select ①<T> List<T> select()
    ②<T> List<T> select(String key, Object value)
     
    find ①<T> T find()
    ②<T> T find(Object value)
    ③<T> T find(String key, Object value)
     
    count ①long count()
    ②long count(String field)
     
    max double max(String field)  
    min double min(String field)  
    avg double avg(String field)  
    sum double sum(String field)  
    //find查询
    //select id,name from jd_user where id>4 order by id asc limit 0,1
    User res = D.M(User.class).field("id,name").where("id>?",4).order("id asc").find();
    
    //find 根据id查询
    //select * from jd_user where id=3 limit 0,1
    User user = D.M(User.class).find(3);
    
    //find根据字段查询
    //select * from jd_user where name='Tom' limit 0,1
    User user=D.M(User.class).fetchSql(true).find("name","Bob");
    
    //where,field过滤
    //select id,name,weight from jd_user where id>3
    List res = D.M(User.class).field("id,name,weight").where("id>3").select();
    
    //group分组查询
    //select sex,sum(weight) as weight,avg(age) as age,count(id) as num from jd_user where id>5 group by sex order by sex desc limit 0,10
    res = D.M(User.class).field("sex,sum(weight) as weight,avg(age) as age,count(id) as num").where("id>?",5).group("sex").order("sex desc").page(1, 10).select();
    
    //join联表查询
    //select jd_user.id,name,weight,sum(gold) as num from jd_user left join jd_gold on user_id=jd_user.id where jd_user.id>3 group by jd_user.id
    res = D.M(User.class).field("jd_user.id,name,weight,sum(gold) as num").join("left join jd_gold on user_id=jd_user.id").where("jd_user.id>3").group("jd_user.id").select();
    
    //union联表查询
    //(select id,name from jd_user where id=4 ) union all (select id,name from jd_user where id<3) union (select id,name from jd_user where id=3)
    res = D.M(User.class).field("id,name").where("id=4").union("select id,name from jd_user where id<3",true)
    	.union("select id,name from jd_user where id=3",false).select();
    
    //统计查询
    long num= new M(User.class).where("id>3").count();
    num= D.M(User.class).fetchSql(true).where("id>3").count("id");
    num= (long) D.M(User.class).fetchSql(false).where("id<0").max("id");
    num= (long) D.M(User.class).where("id<3").max("id");
    num= (long) D.M(User.class).min("id");
    num= (long) D.M(User.class).where("id>3").min("id");
    num= (long) D.M(User.class).fetchSql(false).where("id>3").avg("id");
    double avg= D.M(User.class).fetchSql(false).where("id>3").avg("id");
    num= (long) D.M(User.class).where("id>13441").sum("age");
    

    通过调用fetchSql(true)方法,可以获取到 ThinkJD产生的SQL语句(Exception形式)并且不会执行数据库操作。 fetchSql

    user表结构:

    字段名 数据类型 备注
    id int 用户id,自增长主键
    name varchar 用户名
    age tinyint 年龄
    weight float 体重
    sex tinyint 性别 0女/1男
    time int 时间

    select()和 find()查询结果封装到JavaBean里返回,JavaBean可使用注解映射数据库字段。

    注意:墙裂建议JavaBean字段基础数据类型使用【Integer、Long、Boolean、Float、Double、Byte、Short、Char】 不要使用【integer、long、boolean、float、double、byte、short、char】,因为前者可以赋值为null而后者不行 (null时为0),所以获取到的值是不准确的。ThinkJD的save更新等操作通过判断属性值不为null则加入数据库更新 字段队列。ThinkJD会自动检测以上不符合的数据类型并发出警告。如需关闭调用D.setCheckField(false);

    //@Table(name="user")默认类名为表名,可注解重定义
    public class User {
    	//@Column(isKey=true)默认id为主键、isAutoInc=true自增,可注解重定义
    	private Long id;
    	private Integer age;
    	//@Column(name="user_name")默认属性名为表字段,可注解重定义
    	private String name;
    	private Float weight;
    	private Boolean sex;
    	
    	@Column(isColumn=false)
    	private Integer num;
    	
    	private Long time;
    	
    	public Long getId() {
    		return id;
    	}
    	public void setId(Long id) {
    		this.id = id;
    	}
    	public Integer getAge() {
    		return age;
    	}
    	public void setAge(Integer age) {
    		this.age = age;
    	}
    	public String getName() {
    		return name;
    	}
    	public void setName(String name) {
    		this.name = name;
    	}
    	public Float getWeight() {
    		return weight;
    	}
    	public void setWeight(Float weight) {
    		this.weight = weight;
    	}
    	public Boolean getSex() {
    		return sex;
    	}
    	public void setSex(Boolean sex) {
    		this.sex = sex;
    	}
    	public Integer getNum() {
    		return num;
    	}
    	public void setNum(Integer num) {
    		this.num = num;
    	}
    	public Long getTime() {
    		return time;
    	}
    	public void setTime(Long time) {
    		this.time = time;
    	}
    }
    
    

    0x05 插入数据

    操作 参数 说明
    add long add() Table模式前提方法:data()
    返回自动生成的主键值;
    /*指定插入字段*/
    long id=D.M(User.class).field("name,weight").data("Tom",60).add();
    
    /*不指定插入字段,按表字段顺序插入*/
    id=D.M("user").data(null,"Tom",60,...).add();
    
    /*使用javaBean半自动模式,自动获取表名、主键、字段名,给定data按javaBean属性顺序插入,生成的sql语句如下
     *insert into jd_user (age,name,weight,sex,time) values(?,?,?,...)
     */
    id=D.M(User.class).data("Tom",60,...).add();
    
    //使用javaBean全自动模式,自动获取表名、主键、字段名和数据
    User user = new User();
    user.setId(5);
    user.setAge(10);
    user.setName("Hello");
    
    //insert into jd_user (age,name) values(?,?) Params[10,Hello]
    num=D.M(user).add();
    
    //insert into jd_user (name) values(?) Params[Hello]
    num=D.M(user).field("name").add();
    
    //insert into jd_user (id,age,name) values(?,?,?) Params[5,10,Hello]
    num=D.M(user).autoInc(false).add();
    

    0x06 更新数据

    操作 参数 说明
    save long save() Table模式前提方法:data(),where();
    返回执行生效行数
    long num=D.M("user").field("name,weight").data("Mike",100).where("id=?",1234).save();
    User user = new User();
    user.setId(5);
    user.setAge(10);
    user.setName("Hello");
    
    //update jd_user set age=?,name=? where id=?; Params[10,Hello,5]
    num=D.M(user).save();
    
    //update jd_user set name=? where id=?; Params[Hello,5]
    num=D.M(user).field("name").save();
    
    //update jd_user set id=?,age=?,name=? where id=?; Params[5,10,Hello,4]
    id=D.M(user).autoInc(false).fetchSql(true).where("id=?",user.getId()-1).save();
    

    0x07 删除数据

    操作 参数 说明
    delete long delete() Table模式前提方法:where()
    返回执行生效行数

    注:为防止误删除,where条件不能为空。

    long num=D.M("user").delete(5);//默认为id=?
    num=D.M("user").delete("time",1523681398);//time=?
    num=D.M(User.class).where("id>=?",13421).delete();
    
    //JavaBean模式
    User user=new User();
    user.setId(10L);
    long num=D.M(user).delete();
    

    0x08 执行SQL

    操作 参数 说明
    execute void execute(String... sqls) 直接执行SQL语句
    D.M().execute( sql1 [ sql2 , sql3 ... ] );
    

    0x09 事务支持

    数据库表引擎应该为InnoDB以支持事务操作。 代码示例:

    Connection conn=null;
    try {
    	//获取已开启事务的数据库连接
    	conn = D.M().startTrans();
    	//使用事务连接操作数据库
    	long id=new M("gold").trans(conn).field("user_id,gold,type,time").data(3,5,0,System.currentTimeMillis()/1000).add();
    	System.out.println(id);
    	if(id>0) {
    		throw new SQLException("Transaction Rollback Test");
    	}
    	id=new M("gold").trans(conn).field("user_id,gold,type,time").data(3,5,0,System.currentTimeMillis()/1000).add();
    	System.out.println(id);
    	//提交事务
    	D.M().commit(conn);
    } catch (SQLException e) {
    	e.printStackTrace();
    	try {
    		//事务回滚
    		D.M().rollback(conn);
    	} catch (SQLException e1) {
    		e1.printStackTrace();
    	}
    }
    

     

    0x0A 多线程安全

    【V1.4.4_12功能】

    /*设置数据库操作完毕后不自动关闭
    *此处是为了提高数据库操作性能,不用频繁地获取和关闭连接,同一线程内ThinkJD会使用同一连接;
    *默认自动关闭连接的话,每次操作都会获取一个新的Connection,使用完毕立即自动关闭
    */
    D.setAutoClose(false);
    new Thread(new Runnable() {	
    	@Override
    	public void run() {
    		Gold gold = new Gold();
    		gold.setUser_id(1L);
    		gold.setGold(5);
    		gold.setGold_type(0);
    		try {
    			D.M(gold).add();
    			D.M(gold).add();
    		} catch (SQLException e) {
    			D.closeConn();
    			e.printStackTrace();
    		}
    	}
    }, "Thread_1").start();
    
    new Thread(new Runnable() {
    	
    	@Override
    	public void run() {
    		Gold gold = new Gold();
    		gold.setUser_id(2L);
    		gold.setGold(5);
    		gold.setGold_type(0);
    		try {
    			D.M(gold).add();
    			D.M(gold).add();
    		} catch (SQLException e) {
    			D.closeConn();
    			e.printStackTrace();
    		}
    	}
    }, "Thread_2").start();
    

    获取数据库连接处输出日志为:

    Thread:Thread_1,conn==null:true
    Thread:Thread_2,conn==null:true
    Thread:Thread_2,conn==null:false
    Thread:Thread_1,conn==null:false
    
    

    由此可见,线程1第一次操作数据库时conn为空,会获取一个新的conn,下次操作时conn不为空可以直接使用,直到调用D.closeConn();后conn才会关闭。线程2也是如此。

    3 许可证

    Apache License 2.0

    4 关于

    如果喜欢的话,请点个赞让我知道哦~在找到比它用得更顺手的JDBC库之前,这个项目会持续更新。

ThinkJDBC

选择将代码托管在码云
你还在等什么

可能是中国最大最好的代码托管平台


大家对 ThinkJDBC 的评论 (全部 17 条评论)
{{repayCom.userName}}
zhuweihong
请问,ThinkJDBC的性能跟Mybatis的性能比较,哪个更好?用这个必须要映射实体类,个人感觉没有Mybatis直接用Map方便。对于复查sql,ThinkJDBC的可读性大大降低。
曲终人散111
我怎么不能用,连接数据库就出错!
Leytton
#ThinkJDBC# V1.4.4_12版本发布,希望大家喜欢 :30多KB、 支持复杂SQL语句、 自动管理数据库连接、 支持增删改查ORM映射、 支持字段注解映射、 主键、自增、是否ORM字段等属性配置、 动态设置>注解设置>全局设置、 数据库连接多线程安全、 支持数据库连接池、 简易的事务操作、 支持调试模式,输出SQL语句、 基于DBUtils,实在无法满...
Leytton
@suanmb 感谢支持,希望你喜欢。有更的功能需求尽管提:) #ThinkJDBC#
suanmb
支持,感谢分享
顶部