首页 > 代码库 > JDBC高级部分
JDBC高级部分
/**
采用模版类型，封装了基本数据的CRUD操作
基本属性从外部属性文件读取（如config.properties）
*/
public class BaseDao<T>{ private InputStream in=this.getClass().getResourceAsStream("/com/tank/comm/config.properties"); private Properties properties=new Properties(); Connection conn=null; PreparedStatement pstat=null;; ResultSet res=null; /*public static void main(String[] args) { System.out.println("----------"); new BaseDao().getConn(); System.out.println("----------"); }*/ public Connection getConn() { try { properties.load(in); //System.out.println("加载文件路径"); Class.forName(properties.getProperty("driver")); conn=DriverManager.getConnection(properties.getProperty("url"), properties.getProperty("username"), properties.getProperty("password")); System.out.println("数据库连接成功！"); return conn; } catch(Exception ex) { ex.printStackTrace(); } return null; } /* * 封装方法，用来执行insert，update,delete 功能 ***/ public int executeUpdate(String sql,Object[]param) { int rows=0; try { this.getConn(); pstat=conn.prepareStatement(sql); if(param!=null&¶m.length!=0) { for(int x=0;x<param.length;x++) { pstat.setObject((x+1), param[x]); } } rows=pstat.executeUpdate(); } catch(Exception ex) { ex.printStackTrace(); } finally { this.closeAll(conn, pstat, res); } return rows; } /** *封装执行select语句 * */ public List<T> executeQuery(String sql,Object[]param,Class<T> cls) { List<T> list = new ArrayList<T>(); this.getConn(); try { pstat=conn.prepareStatement(sql); if(param!=null&¶m.length!=0) { for(int x=0;x<param.length;x++) { pstat.setObject((x+1), param[x]); } } res=pstat.executeQuery(); while(res.next()) { //1 创建对象 T obj =cls.newInstance(); //对象属性赋值 Field []fs=cls.getDeclaredFields(); for(int x=0;x<fs.length;x++) { Field f=fs[x]; f.setAccessible(true); //属性的类型 String ct = f.getType().getName(); String name=f.getName(); if(ct.equals("java.lang.String")) { f.set(obj, res.getString(name)); } if(ct.equals("int")) { f.set(obj, res.getInt(name)); } if(ct.equals("double")) { f.set(obj, res.getDouble(name)); } if(ct.equals("java.sql.Date")) { f.set(obj, res.getDate(name)); } if(ct.equals("char")) { f.set(obj, res.getString(name)); } } list.add(obj); } System.out.println("列表长度："+list.size()); return list; } catch(Exception ex) { ex.printStackTrace(); } finally { this.closeAll(conn, pstat, res); } return null; } /** * 重载executeQuery方法 * 增加实体类的指定属性赋值 *
* @param sql 传入的sql语句
@param param 传入的参数数组
@param cls 传入的映射类（用由<T> 指定，避免出现类型转化等警告信息）
@param propertyList 属性集合，可以只为为映射类的指定属性赋值 * */ public List<T> executeQuery(String sql,Object[]param,Class<T> cls,List<String> propertyList){ List<T> list =new ArrayList<T>(); this.getConn(); try{ pstat=conn.prepareStatement(sql); if(param!=null&¶m.length!=0) { for(int x=0;x<param.length;x++) { pstat.setObject((x+1), param[x]); } } res=pstat.executeQuery(); //如果参数集合为空，返回上层默认实体类所有属性赋值 if(propertyList.isEmpty()){ this.executeQuery(sql, param, cls); }else{ //不为空，则为集合内指定属性赋值 //取出实体类的所有属性 while(res.next()){ //创建实例对象 T obj=cls.newInstance(); //获取所有反射属性 Field fields[]=cls.getDeclaredFields(); for(int x=0;x<fields.length;x++) { Field f=fields[x]; f.setAccessible(true); String fname=f.getName(); //判断集合是否包含该属性名，如果包含，为其赋值 if(propertyList.contains(fname)){ String ct=f.getType().getName(); if(ct.equals("java.lang.String")) { f.set(obj, res.getString((fname))); } if(ct.equals("int")) { f.set(obj, res.getInt((fname))); } if(ct.equals("double")) { f.set(obj, res.getDouble((fname))); } if(ct.equals("java.sql.Date")) { f.set(obj, res.getDate((fname))); } if(ct.equals("char")) { f.set(obj, res.getString((fname))); } } } //将对象添加到集合 list.add(obj); } } }catch(Exception e){ e.printStackTrace(); }finally{ this.closeAll(conn, pstat, res); } return list; } //关闭连接，释放资源 public void closeAll(Connection conn,PreparedStatement pstat,ResultSet res) { try { if(res!=null) { res.close(); } if(pstat!=null) { pstat.close(); } if(conn!=null) { conn.close(); } } catch(Exception ex) { ex.printStackTrace(); } } }
JDBC高级部分
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。