开源软件名称:easy-jdbc
开源软件地址:https://gitee.com/yydf/easy-jdbc
开源软件介绍:
easy-jdbc一个支持高并发的jdbc链接池,体积小、速度快,目前只支持mysql 如果您觉得好用,请Star
特性- 轻量、高效
- 无复杂配置
- 支持Spring管理
- 直接手写SQL
- 支持返回多个结果集
- 可配置多数据源
- 支持多数据源事务
环境如何使用<dependency> <groupId>cn.4coder</groupId> <artifactId>jdbc</artifactId> <version>0.0.9</version></dependency> - src/main/resources目录下添加jdbc.properties文件:
/* 全局属性 */#jdbc.multiQueries=true 支持多结果查询#jdbc.queryTimeout=5 查询超时时间/* 默认数据源 */jdbc.datasource.driverClassName=com.mysql.jdbc.Driverjdbc.datasource.url=jdbc:mysql://localhost:3306/testjdbc.datasource.username=rootjdbc.datasource.password=123456jdbc.datasource.initialSize=4/* 其它的数据源,以名称区分 */jdbc.datasource.test1.driverClassName=com.mysql.jdbc.Driverjdbc.datasource.test1.url=jdbc:mysql://localhost:3306/test1jdbc.datasource.test1.username=rootjdbc.datasource.test1.password=123456jdbc.datasource.test1.initialSize=2 <!-- 配置 SessionFactory --><bean id="sessionFactory" class="cn.coder.jdbc.spring.SqlSessionFactoryBean" > <!-- 不使用第三方DataSource,注释掉下面一行即可 --> <property name="dataSource" ref="dataSource"></property></bean> SqlSessionFactory.createSessions();//创建全部数据源//获取某个数据源SqlSession session = SqlSessionFactory.getInstance().getSession();//默认数据源SqlSession session1 = SqlSessionFactory.getInstance().getSession("test1");//其它数据源System.out.println(session.selectOne(Integer.class, "select count(1) from weike"));//多数据源事务SqlTranction tran = null;try { tran = session.beginTranction(session1.beginTranction()); session.execute("INSERT INTO weike (title) VALUES (?)", "test"); session1.execute("INSERT INTO test (title) VALUES (?)", "test1"); tran.commit();} catch (Exception e) { if(tran != null) tran.rollback(e);}//销毁数据源SqlSessionFactory.destory(): public class WeikeDao extends DaoSupport { public List<Weike> getDeviceList() { return jdbc().selectList(Weike.class, "select * from weike"); } public void call() { //执行存储过程 Object[] result = jdbc().callProcedure("{call test(?,?)}", System.currentTimeMillis()); //根据索引获取OUT的值 System.out.println(result[1]); } //事务处理 public boolean test() { return tran(new Run(){ @Override public void exec(SqlSession session) { //保持使用同一个session //session.selectList //session.selectOne } }); }} |
请发表评论