开源软件名称：

xdao

开源软件地址：

https://gitee.com/steven0lisa/xdao

开源软件介绍：

简介

这是一款小巧的DAO库，提供便捷的SQL执行方式。

额，其实我是看不惯Mybatis，由于我经常要写一些小项目，每次都要动用XML觉得好不爽，所以造了这个轮子。

特点：

轻便，不管你在用哪种数据库管理工具，Hibernate、Mybatis等等，都能使用这个DAO库
性能，底层非常薄的封装
不支持事务，不支持大对象字段

用法

初始化很简单：

XDAO.DataSource ds  = new XDAO.DataSource() {    @Override    public Connection getConnection() {        // 这里返回一个Connection即可，建议换成你项目的连接池        try {            //示例是连接H2数据库            Class.forName("org.h2.Driver");            return DriverManager.getConnection("jdbc:h2:mem:play;MODE=MYSQL", "sa", "");        } catch (Exception e) {            e.printStackTrace();        }        return null;    }};//设置数据源到XDAOXDAO.setDataSource(ds);

比如项目里面有一个Model：

import javax.persistence.Column;import javax.persistence.Table;@Table(name="person") //可选，这个主要是用来解决Java类名和数据库表名不一致的问题public class Person {	public String id;	@Column(name="name")	public String name;	@Column(name="create_time") //可选，这个主要是用来解决Java变量名和数据库列名不一致的问题	public String createTime;}

在项目里面新建一个PersonDAO接口：

@DAO //标记@DAO说明该接口是DAO接口，必须标记public interface PersonDAO {	@SQL("create table person(id varchar(255) not null, name varchar(255), create_time bigint(20) not null default 0)") //书写SQL语句，必须标记	void createPersonTable();	@SQL("insert into person(id, name, create_time) values(@1, @2, #now)") //@表示参数，会被替换成PreparedStatement的?	void insertPerson(String id, String name);	@SQL("insert into person(id, name, create_time) values(@1.id, @1.name, #now)") //@1.id 表示参数数值为方法的第一个参数的id属性    void insertPersonObject(Person person);	@SQL("select * from person where id=@1")	Person findById(String id);	@SQL("select * from person where id=@id and name=@name") //可以通过@SQLParam修改SQL语句的变量名	Person findByIdAndName(@SQLParam("id")String id, @SQLParam("name")String name);	@SQL("select * from person") //当方法返回类型为List，同时有标明泛型，DAO工具则会自动组装查询结果返回	List<Person> findAll();		@SQL("select id from person") //如果只需要其中一列，可以这样写    List<String> findAllId();	@SQL("select count(*) from person") //如果方法返回类型为Long或者Integer，DAO工具则会视为count查询	long countAll();    @SQL(value="insert into person(id, name) values(@1.id, @1.name)", isBatch=true) //当SQL语句为更新、插入或者删除语句，标注isBatch=true，DAO工具则视为批量操作    int[] batchInsert(List<Person> persons);        @SQL("select count(*) from person where id in (:ids)") //:ids表示将参数里面的ids进行展开    long countByUserIds(@SQLParam("ids") List<String> ids);    @SQL("select * from $1 where name = @2") //$表示宏，会完整替换SQL里面的语句    Person findByTableAndName(String tableName, String name);        @SQL("select * from person") //where 条件动态设定 cnd = Cnd.where("name", "=", "steven").or("name", "=", "steven")    Person findByCnd(Cnd cnd, PageInfo pageInfo);	@SQL("select * from person where create_time > 0") //where 条件动态设定（SQL语句已经包含where的条件） cnd = Cnd.create().and("name", "=", "steven").or("name", "=", "steven")	Person findCreateTimeNotEmptyByCnd(Cnd cnd, PageInfo pageInfo);}

PersonDAO的调用：

//通过XDAO创建DAO实例PersonDAO dao = XDAO.get(PersonDAO.class);//可以直接调用接口的方法dao.createPersonTable();dao.insertPerson("abc", "steven");Person person = dao.findById("abc");List<Person> persons = dao.findAll();person = dao.findByCnd(Cnd.where("name", "=", "steven"), null);person = dao.findByCnd(Cnd.where("name", "=", "steven"), Pager.get(dao.countAll())); //带分页

修改日志输出

默认使用的是System.out和System.err，如果项目有自己的日志系统，则可以使用以下的代码：

XDAO.log = new XDAO.Logger(){    //TODO 这里实现Logger的几个方法即可};

依赖

<dependency>    <groupId>commons-lang</groupId>    <artifactId>commons-lang</artifactId>    <version>2.5</version></dependency><dependency>    <groupId>javax.persistence</groupId>    <artifactId>persistence-api</artifactId>    <version>1.0.2</version></dependency>

编译

mvn package

生成的jar在target目录中。

多数据源

稍大的项目里面，经常需要使用多个数据库，进行读写分离。XDAO允许开发者设置多个数据源，同时在DAO接口上指定数据源。下面以常见的读写分离（Master、Slave）来举例子。

初始化：

XDAO.DataSource master  = new XDAO.DataSource() {    @Override    public Connection getConnection() {        // 这里从Master返回一个Connection即可，建议换成你项目的连接池        try {            //示例是连接H2数据库            Class.forName("org.h2.Driver");            return DriverManager.getConnection("jdbc:h2:mem:play;MODE=MYSQL", "sa", "");        } catch (Exception e) {            e.printStackTrace();        }        return null;    }};XDAO.DataSource slave  = new XDAO.DataSource() {    @Override    public Connection getConnection() {        // 这里从Master返回一个Connection即可，建议换成你项目的连接池        try {            //示例是连接H2数据库            Class.forName("org.h2.Driver");            return DriverManager.getConnection("jdbc:h2:mem:play;MODE=MYSQL", "sa", "");        } catch (Exception e) {            e.printStackTrace();        }        return null;    }};//设置数据源到XDAOXDAO.setDataSource(master); //默认数据源XDAO.setDataSource("master", master); //主库XDAO.setDataSource("slave", slave); //从库

下面是SQL模板的示例

@DAO //标记@DAO说明该接口是DAO接口，必须标记@PersistenceUnit(name = "master") //标记使用的数据源,可选public interface PersonDAO {	@SQL("insert into person(id, name, create_time) values(@1.id, @1.name, #now)") //@1.id 表示参数数值为方法的第一个参数的id属性，#now表示当前时间（毫秒）	@PersistenceUnit(name = "master") //insert操作在主库上执行    void insertPersonObject(Person person);        @SQL("select * from person where id=@1")    @PersistenceUnit(name = "slave") //select操作在从库上执行    Person findById(String id);        //如果接口不标记@PersistenceUnit，则默认使用PersonDAO的@PersistenceUnit中数据源    @SQL("select * from $1 where name = @2") //$表示宏，会完整替换SQL里面的语句    Person findByTableAndName(String tableName, String name);    @SQL("select * from user_$1 where id = @2") //利用宏来实现分表    Person findByTableAndName(String userTableSuffix, Long userId);}