LqJdbc

• 授权协议: Apache
• 开发语言: Java
• 操作系统: 跨平台
• 软件首页: http://os.zhongziyun.com/code/41750/
• 软件文档: http://os.zhongziyun.com/code/41750/

软件介绍

LqJdbc 可以很轻松的操作数据库，使用了 C3P0 链接池,实现了hibernate的一些简单功能如 save,update,delete,find,create entity，也实现了spring jdbcTemplante的一些简单功能，如queryForList,execute，最新的3.0版，还实现了多数据源操作，可以进行读写分离。

LqJdbc 的好处就在于任何JAVA项目，直接导入 JAR，配制 lqjdbc.properties 即可使用，是轻量级开源项目。

网页底部为项目下载地址

实例:

import java.io.InputStream;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import com.lq.util.jdbc.DatabasesJdbc;
import com.lq.util.jdbc.DatabasesInterfaceT;
import com.lq.util.jdbc.Jdbc;
import com.lq.util.jdbc.LqEntitySql;
import com.lq.util.jdbc.LqJdbcFactory;
import com.lq.util.jdbc.LqResultSet;
import com.lq.util.jdbc.LqShiWu;
import com.lq.util.jdbc.Page;


public class Test {
	
	public static void main(String[] args) {
		
	}
	
	public void pageSelectTest(){
		//SQL SERVER 2005 分页查询用法
		String sql="SELECT ROW_NUMBER() OVER (ORDER BY id) AS RowNumber,* from payinfo";
		String sqlCount="select count(*) from payinfo";
		//其它数据库SQL分页
		sql="SELECT * from payinfo";
		sqlCount="select count(*) from payinfo";
		
		Page page=Jdbc.findPage(sql, 1, 3, sqlCount, new Object[]{});
		System.out.println(page.getData().size());
	}
	
	public void shuoM(){
		/**
		 * 生成实体类
		 */
		Jdbc.createEntity("com.entity","t_user","id");
		/**
		 * 生成插入修改SQL语句
		 */
		Jdbc.createSQL("t_user","id");
		
		//-------------------------下面为SQL语句操作----------------------------------------
		
		/**
		 * 查询
		 */
		Jdbc.find("select * from t_user where id=?", new Object[]{"1"});
		/**
		 * 分页查询
		 */
		Page page=Jdbc.findPage("select * from t_user where id=?", 1, 15, "select count(id) from t_user where id=?", new Object[]{"1"});
		/**
		 * 插入
		 */
		Jdbc.execute("insert into test (name)values(?)", new Object[]{"吃人的肉"});
		/**
		 * 修改
		 */
		Jdbc.execute("update test set name=? where id=?", new Object[]{"吃人的肉1","1"});
		/**
		 * 删除
		 */
		Jdbc.execute("delete from test where id=?",new Object[]{"1"});
		
		//------------------------下面为实体类操作------------------------------------------
		
		final Test test=new Test();
		Jdbc.save(test);//插入
		Jdbc.update(test);//修改
		Jdbc.delete(test);//删除
		List list=Jdbc.find("select * from t_user", Test.class, new Object[]{});//查询返回实体类
		
		//------------------------下面为事务操作------------------------------------------
		
		/**
		 * 事务处理
		 */
		Jdbc.shiwu(new LqShiWu() {
			@Override
			public void shiwu(LqJdbcFactory jdbc) {
				if (1!=1) {//验证判断
					jdbc.shiB=9;//如果验证通过返回自定义的状态码
					return;
				}
				jdbc.find("select * from t_user where id=?", new Object[]{"1"});
				jdbc.execute("insert into test (name)values(?)", new Object[]{"吃人的肉"});
				jdbc.execute("update test set name=? where id=?", new Object[]{"吃人的肉1","1"});
				jdbc.execute("delete from test where id=?",new Object[]{"1"});
				Jdbc.save(test);//插入
				Jdbc.update(test);//修改
				Jdbc.delete(test);//删除
			}
		});
		
		/**
		 * 操作结果集
		 */
		Jdbc.operationResultSet(new LqResultSet() {
			@Override
			public void getResultSet(LqJdbcFactory jdbc) {
				ResultSet rs = jdbc.findResultSet("select photo from t_user where id=?",new Object[]{"5"});
				try {
					while (rs.next()) {
						InputStream in=rs.getBinaryStream("photo");
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		});
		
        /**
         * 多种数据库操作
         */
        final StringBuffer sb=new StringBuffer();
        final List listCs2=new ArrayList();
        Jdbc.sql(new DatabasesInterface() {
            public String oracle() {
                sb.append("select * from admin where id=?");
                listCs2.add("1");
                return null;
            }
            public String mysql() {
                sb.append("select * from admin where id=?");
                listCs2.add("1");
                return null;
            }
            public String sqlserver() {
                sb.append("select * from admin where id=?");
                listCs2.add("1");
                return null;
            }
        });
        List list2=Jdbc.find(sb.toString(),listCs2.toArray());
		System.out.println(list2);

        /**
         * 批量执行
         */
        final String sql="insert into test (name)values(?)";
        Jdbc.piliang(sql,new LqPiLiang() {
            public void piliang(LqJdbcFactory jdbc) {
                for (int i = 0; i < 100; i++) {
                    jdbc.executeS(new Object[]{i+""});
                }
            }
        });
        
        /**
         * 多数据源操作
         */
        Map map=Jdbc.getDSNames();//得到除默认数据源外的所有数据源名称
        List listDdb=Jdbc.find("select * from test");//读取默认数据源
        List listDrdb=Jdbc.getDS(readDB).find("select * from test");//读取第二个数据源
        List listDwdb=Jdbc.getDS(writeDB).find("select * from test");//读取第三个数据源


		
	}
}

下面为配制文件 lqjdbc.properties

#MYSQL_DRIVER
DriverClassName=com.mysql.jdbc.Driver
#MYSQL_URL
AllUrl=jdbc:mysql://127.0.0.1/db4?useOldAliasMetadataBehavior=true&useUnicode=true&characterEncoding=utf-8&rewriteBatchedStatements=true***root***123456
#初始化链接数
InitialPoolSize=50
#最小链接数
MinPoolSize=20
#最大链接数
MaxPoolSize=100
#执行线程数-版本支持2.3以上版本
NumHelperThreads=20
#每页显示多少条数据
PageSize=15
#多少页一组
GroupPageSize=5
#打印日志
SqlLog=true
#是否打印查询耗时-版本支持2.1.9以上版本
SqlSuccessTime=true




#^^^^^^^^^^^^^^^^^^^^^^^读^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
#MYSQL_URL
lqjdbc.appender.query.AllUrl=jdbc:mysql://127.0.0.1/db2?useOldAliasMetadataBehavior=true&useUnicode=true&characterEncoding=utf-8&rewriteBatchedStatements=true***root***123456
#MYSQL_DRIVER
lqjdbc.appender.query.DriverClassName=com.mysql.jdbc.Driver
#初始化链接数
lqjdbc.appender.query.InitialPoolSize=50
#最小链接数
lqjdbc.appender.query.MinPoolSize=20
#最大链接数
lqjdbc.appender.query.MaxPoolSize=100
#执行线程数-版本支持2.3以上版本
lqjdbc.appender.query.NumHelperThreads=20
#每页显示多少条数据
lqjdbc.appender.query.PageSize=15
#多少页一组
lqjdbc.appender.query.GroupPageSize=5
#打印日志
lqjdbc.appender.query.SqlLog=true
#是否打印查询耗时-版本支持2.1.9以上版本
lqjdbc.appender.query.SqlSuccessTime=true






#^^^^^^^^^^^^^^^^^^^^^^^写^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
#MYSQL_URL
lqjdbc.appender.write.AllUrl=jdbc:mysql://127.0.0.1/db3?useOldAliasMetadataBehavior=true&useUnicode=true&characterEncoding=utf-8&rewriteBatchedStatements=true***root***123456
#MYSQL_DRIVER
lqjdbc.appender.write.DriverClassName=com.mysql.jdbc.Driver
#初始化链接数
lqjdbc.appender.write.InitialPoolSize=50
#最小链接数
lqjdbc.appender.write.MinPoolSize=20
#最大链接数
lqjdbc.appender.write.MaxPoolSize=100
#执行线程数-版本支持2.3以上版本
lqjdbc.appender.write.NumHelperThreads=20
#每页显示多少条数据
lqjdbc.appender.write.PageSize=15
#多少页一组
lqjdbc.appender.write.GroupPageSize=5
#打印日志
lqjdbc.appender.write.SqlLog=true
#是否打印查询耗时-版本支持2.1.9以上版本
lqjdbc.appender.write.SqlSuccessTime=true

本文地址：https://www.codercto.com/soft/d/15229.html