简易数据库关系映射框架EasyDBO.zip

package com.easyjf.dbo; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.Collection; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import com.easyjf.dbo.config.DBOConfig; import com.easyjf.dbo.sql.*; import javax.sql.DataSource; import org.apache.log4j.Logger; /** * 数据库处理引擎，实现DBObject对象到数据库的转换，完成具体的数据库操作 * @author 蔡世友 * */ public class EasyJDBEngine { private final static Logger logger = Logger.getLogger(EasyJDBEngine.class); private DataSource dataSource; private ISqlQuery sqlQuery; private static EasyJDBEngine engine; public EasyJDBEngine(DataSource dataSource) { this(dataSource,new MySqlQuery()); } public EasyJDBEngine(DataSource dataSource,ISqlQuery sqlQuery) { this.dataSource=dataSource; this.sqlQuery=sqlQuery; } public static EasyJDBEngine getInstance()//数据库操作，将会修改为由配置文件中读取参数 { if(engine==null){ logger.info("初始化数据库查询引擎！"); ISqlQuery dialect=null; try{ dialect=(ISqlQuery)Class.forName(DBOConfig.getInstance().getDialect()).newInstance(); } catch (Exception e) { logger.error("数据库类型(方言)配置错误，系统将使用默认MySQL数据类型方言！"+e); } if(dialect==null)dialect=new MySqlQuery(); engine=new EasyJDBEngine(DataSourceManager.getDataSource(),dialect); } return engine; } public Object uniqueResult(String sql) { Object ret=new Object(); Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { conn = dataSource.getConnection(); ps = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); if(DBOConfig.getInstance().isShow_sql())System.out.println("EasyDBO:"+sql); rs = ps.executeQuery(); if(rs.next())ret=rs.getObject(1); } catch(Exception e) { logger.error("数据查询错误："+e+":sql="+sql); } finally { try{ if (rs != null) rs.close(); if (ps != null) ps.close(); if (conn != null) conn.close(); } catch(Exception e) { logger.error("释放数据库资源错误："+e); } } return ret; } public Object uniqueResult(String sql,Collection params) { Object ret=new Object(); Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { conn = dataSource.getConnection(); ps = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); if(DBOConfig.getInstance().isShow_sql())System.out.println("EasyDBO:"+sql); JDBCUtil.setQueryParams(params,ps); rs = ps.executeQuery(); if(rs.next())ret=rs.getObject(1); } catch(Exception e) { logger.error("数据查询错误："+e+":sql="+sql); } finally { try{ if (rs != null) rs.close(); if (ps != null) ps.close(); if (conn != null) conn.close(); } catch(Exception e) { logger.error("释放数据库资源错误："+e); } } return ret; } public DBObject get(String sql) { return get(sql,null); } public DBObject get(String sql,Collection params)//通过完整的sql语句读取得单个对象 { DBObject obj=new DBObject(); List list = new ArrayList(); list=query(sql,params,0,1); if(list!=null && (list.size()>0)) { obj=(DBObject)list.get(0); //obj.setIdValue(obj.getValue().get(obj.getTable().getId())); } /* Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { conn = dataSource.getConnection(); ps = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); if(DBOConfig.getInstance().isShow_sql())System.out.println("EasyDBO:"+sql); JDBCUtil.setQueryParams(params,ps); rs = ps.executeQuery(); list = JDBCUtil.resultSet2List(rs); if(list!=null && (list.size()>0)) { obj.setValue((Map)list.get(0)); obj.setTable(new DBTable()); //obj.setIdValue(obj.getValue().get(obj.getTable().getId())); } else//没有查询到数据 { return null; } } catch(Exception e) { logger.error("数据查询错误："+e+":sql="+sql); } finally { try{ if (rs != null) rs.close(); if (ps != null) ps.close(); if (conn != null) conn.close(); } catch(Exception e) { logger.error("释放数据库资源错误："+e); } }*/ return obj; } public DBObject get(DBObject obj,Object idvalue)//通过ID值读取数据表数据 { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; if(obj==null)return null; String sql=sqlQuery.getQuerySql(obj); if(sql.equals("")) { logger.error("找不到查询参数!"); return null; } List list = new ArrayList(); try { conn = dataSource.getConnection(); ps = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); if(DBOConfig.getInstance().isShow_sql())System.out.println("EasyDBO:"+sql); JDBCUtil.setQueryParam(idvalue,1,ps); rs = ps.executeQuery(); list = JDBCUtil.resultSet2List(rs); if(list!=null && (list.size()>0)) { obj.setValue((Map)list.get(0)); obj.setIdValue(obj.getValue().get(obj.getTable().getId())); } else//没有查询到数据 { return null; } } catch(Exception e) { logger.error("数据查询错误："+e+":sql="+sql); } finally { try{ if (rs != null) rs.close(); if (ps != null) ps.close(); if (conn != null) conn.close(); } catch(Exception e) { logger.error("释放数据库资源错误："+e); } } return obj; } public DBObject get(DBObject obj,String scope,Collection params)//通过ID值读取数据表数据 { if(obj==null)return null; List list = new ArrayList(); String sql=sqlQuery.getQuerySql(obj,scope); list=query(sql,params,0,1); if(list!=null && (list.size()>0)) { DBObject dbo=(DBObject)list.get(0); obj.setValue(dbo.getValue()); obj.setIdValue(obj.get(obj.getTable().getId())); } else//没有查询到数据 { return null; } return obj; } public boolean add(DBObject obj)//添加一个对象 { String sql=sqlQuery.getInsertSql(obj); if(sql.equals("")) { logger.error("空的sql语句无法执行!"); return false; } Connection conn = null; PreparedStatement ps = null; boolean ret=false; try { conn = dataSource.getConnection(); ps = conn.prepareStatement(sql); if(DBOConfig.getInstance().isShow_sql())System.out.println("EasyDBO:"+sql); if(obj.getValue()!=null) JDBCUtil.setQueryParams(obj.getValue().values(), ps); System.out.println(obj.getValue().size()); if(ps.executeUpdate()>0)ret=true; } catch(Exception e) { logger.error("添加数据错误："+e+":sql="+sql); } finally { try{ if (ps != null) ps.close(); if (conn != null) conn.close(); } catch(Exception e) { logger.error("释放数据库资源错误："+e); } } return ret; } public boolean update(DBObject obj)//修改一个对象 { String sql=sqlQuery.getUpdateSql(obj); if(sql.equals("")) { logger.error("空的sql语句无法执行!"); return false; } Connection conn = null; PreparedStatement ps = null; boolean ret=false; try { conn = dataSource.getConnection(); ps = conn.prepareStatement(sql); if(DBOConfig.getInstance().isShow_sql())System.out