1 package com.eshop.dao; 2 3 import java.lang.reflect.Field; 4 import java.lang.reflect.InvocationTargetException; 5 import java.lang.reflect.Method; 6 import java.sql.Connection; 7 import java.sql.DriverManager; 8 import java.sql.PreparedStatement; 9 import java.sql.ResultSet; 10 import java.sql.SQLException; 11 import java.util.ArrayList; 12 import java.util.List; 13 14 15 public class BaseDao { 16 private final String URL="jdbc:oracle:thin:@localhost:1521:orcl";//数据库链接 17 private final String dRIVERString="oracle.jdbc.driver.OracleDriver"; 18 private final String USER="eshop"; 19 private final String PASSWORD="tiger"; 20 21 Connection conn=null; 22 PreparedStatement pstmt =null; 23 24 public void getConnection(){ 25 try { 26 //1.加载驱动 27 Class.forName(dRIVERString); 28 //2.链接数据库 29 //只创建一次链接 30 //问题：若是多我的同时进入数据库（待解决多线程的问题） 31 if(conn==null){ 32 conn= DriverManager.getConnection(URL,USER,PASSWORD); 33 } 34 35 } catch (Exception e) { 36 // TODO Auto-generated catch block 37 e.printStackTrace(); 38 } 39 } 40 41 //封装增删改的方法，返回受影响的行数 42 public int executeUpdate(String sql,List<Object> parm){ 43 getConnection(); 44 int count=0; 45 try { 46 pstmt = conn.prepareStatement(sql) ; 47 if(parm!=null){ 48 for(int i=0;i<parm.size();i++){ 49 pstmt.setObject(i+1, parm.get(i)); 50 } 51 } 52 //执行 53 count=pstmt.executeUpdate(); 54 55 } catch (SQLException e) { 56 // TODO Auto-generated catch block 57 e.printStackTrace(); 58 } 59 return count; 60 61 } 62 63 //封装查询的方法，获取结果集 64 public ResultSet executeQuery(String sql,List<Object> parm){ 65 getConnection(); 66 try { 67 PreparedStatement pstmt = conn.prepareStatement(sql) ; 68 if(parm!=null){ 69 for(int i=0;i<parm.size();i++){ 70 pstmt.setObject(i+1, parm.get(i)); 71 } 72 } 73 //执行 74 ResultSet res=pstmt.executeQuery(); 75 return res; 76 77 } catch (SQLException e) { 78 // TODO Auto-generated catch block 79 e.printStackTrace(); 80 } 81 return null; 82 83 } 84 public <T> List<T> findModelListBySqlAndParam(String sql,List<Object> param,T t) { 85 //定义一个集合来存放须要转成的对象集合 86 List<T> list=new ArrayList<T>(); 87 //获取当前类 88 Class<?> c=t.getClass(); 89 //遍历结果集，封装成外界用户所须要的对象集合 90 //1>获取结果集 91 ResultSet rs=executeQuery(sql, param); 92 //2>开始遍历 93 try { 94 while(rs.next()){ 95 //初始化对象 96 @SuppressWarnings("unchecked") 97 T obj= (T)c.newInstance(); 98 //获取当前类一共多少个属性啊 99 Field[] fields=c.getDeclaredFields(); 100 for(Field f:fields){ 101 //获取当前属性的属性名子 102 String fname=f.getName(); 103 //获取当前的属性的类型(简称) java.lang.String 104 String type=f.getType().getSimpleName(); 105 106 //***************** 取出来当前属性对应的数据库的值了 **************** 107 //在此方法名中要求类的属性名和数据库的字段名相同 108 Object value=null; 109 if(type.equalsIgnoreCase("string")){ 110 value=rs.getString(fname); 111 }else if(type.equalsIgnoreCase("int")){ 112 value=rs.getInt(fname); 113 }else if(type.equalsIgnoreCase("Integer")){ 114 value=rs.getInt(fname); 115 }else if(type.equalsIgnoreCase("Double")){ 116 value=rs.getDouble(fname); 117 }else if(type.equalsIgnoreCase("Float")){ 118 value=rs.getFloat(fname); 119 }else if(type.equalsIgnoreCase("date")){ 120 value=rs.getDate(fname); 121 }else if(type.equalsIgnoreCase("long")){ 122 value=rs.getLong(fname); 123 } 124 //***************** 将取出来当前属性的值设置给当前对象obj**************** 125 //1>获取当前对象的全部set方法，并找到当前取出来的属性对应的set方法 126 Method[] methods=c.getDeclaredMethods();//获取全部的方法 127 for(Method m:methods){ 128 //获取当前方法名 129 String methodName=m.getName(); 130 //判断是否是当前属性 131 if(methodName.equalsIgnoreCase("set"+fname)){ 132 //执行该方法 133 m.invoke(obj, value); 134 } 135 } 136 } 137 list.add(obj); 138 } 139 } catch (InstantiationException e) { 140 // TODO Auto-generated catch block 141 e.printStackTrace(); 142 } catch (IllegalAccessException e) { 143 // TODO Auto-generated catch block 144 e.printStackTrace(); 145 } catch (SecurityException e) { 146 // TODO Auto-generated catch block 147 e.printStackTrace(); 148 } catch (IllegalArgumentException e) { 149 // TODO Auto-generated catch block 150 e.printStackTrace(); 151 } catch (InvocationTargetException e) { 152 // TODO Auto-generated catch block 153 e.printStackTrace(); 154 } catch (SQLException e) { 155 // TODO Auto-generated catch block 156 e.printStackTrace(); 157 } 158 return list; 159 } 160 161 162 163 //获取订单编号 164 public int getSequenceIndex(String seq){ 165 String sql="select "+seq+".nextval num from dual"; 166 getConnection(); 167 ResultSet rs=executeQuery(sql, null); 168 try { 169 if(rs.next()){ 170 return rs.getInt("num"); 171 } 172 } catch (SQLException e) { 173 // TODO Auto-generated catch block 174 e.printStackTrace(); 175 } 176 177 return 0; 178 179 } 180 181 182 183 184 //关闭全部资源 185 public void closeAll(){ 186 try { 187 if(pstmt!=null){ 188 pstmt.close(); 189 pstmt=null;//促进资源快速回收 190 } 191 if(conn!=null) conn.close(); 192 193 194 } catch (SQLException e) { 195 // TODO Auto-generated catch block 196 e.printStackTrace(); 197 } 198 } 199 200 }
封装数据库方法
相关文章
- 1. 封装数据库方法
- 2. 在数据库中查询数据——方法封装
- 3. xml方式封装数据方法
- 4. JDBC链接数据库方法的封装，以及查询数据方法的封装
- 5. python数据库封装的办法
- 6. pythonl连接数据库封装 析构方法
- 7. python工做平常：数据库连接 方法封装
- 8. unity中链接MySQL数据库的方法封装
- 9. 将对数据库的增删改查封装为方法
- 10. C#之链接数据库（二）之封装sql方法
- 更多相关文章...
- • C# 封装 - C#教程
- • PHP 数据库 ODBC - PHP教程
- • Flink 数据传输及反压详解
- • TiDB 在摩拜单车在线数据业务的应用和实践
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
欢迎关注本站公众号,获取更多信息
相关文章