jdbc中PreparedStatment通用增删改查

package loey.DBUtil;  import org.junit.Test;  import java.io.IOException; import java.io.InputStream; import java.sql.*; import java.util.Properties;  /**  * JDBC工具类，简化JDBC编程  */ public class DBUtil {      /**      * 工具类中的构造方法是私有的      * 因为工具类中的方法都是静态的，直接通过类名去调即可。      */     private DBUtil() {      }      private static Properties getProperties(){          //ResourceBundle bundle = ResourceBundle.getBundle("jdbc");         //String driver = bundle.getString("driver");         //String url = bundle.getString("url");         //String user = bundle.getString("user");         //String password = bundle.getString("password");         //String sql = bundle.getString("sql");          // 1.读取配置文件中的4个基本信息         Properties pros = new Properties();          InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");          try {             pros.load(is);         } catch (IOException e) {             e.printStackTrace();         }          return pros;     }      /**      * 静态代码块，类加载的时候执行      * 把注册驱动程序的代码放在静态代码块中，避免多次获取连接对象时重复调用      */     static{         Properties pros = getProperties();         String driver = pros.getProperty("driver");         try {             Class.forName(driver);         } catch (ClassNotFoundException e) {             e.printStackTrace();         }     }      /**      * @return 获取连接      * @throws SQLException      */     public static Connection getConnection(String database) throws Exception {          Properties pros = getProperties();          String url = pros.getProperty("url");         String user = pros.getProperty("user");         String password = pros.getProperty("password");          Connection conn = DriverManager.getConnection(url + database, user, password);          return conn;     }      public static void close(Connection conn, Statement ps, ResultSet rs) {         if (rs != null) {             try {                 rs.close();             } catch (SQLException e) {                 e.printStackTrace();             }         }         if (ps != null) {             try {                 ps.close();             } catch (SQLException e) {                 e.printStackTrace();             }         }         if (conn != null) {             try {                 conn.close();             } catch (SQLException e) {                 e.printStackTrace();             }         }     } }  

	public void update(String sql,Object ...args){//sql中占位符的个数与可变形参的长度相同！ 		Connection conn = null; 		PreparedStatement ps = null; 		try { 			//1.获取数据库的连接 			conn = DBCUtils.getConnection(); 			//2.预编译sql语句，返回PreparedStatement的实例 			ps = conn.prepareStatement(sql); 			//3.填充占位符 			for(int i = 0;i < args.length;i++){ 				ps.setObject(i + 1, args[i]);//小心参数声明错误！！ 			} 			//4.执行 			ps.executeUpdate(); 		} catch (Exception e) { 			e.printStackTrace(); 		}finally{ 			//5.资源的关闭 			JDBCUtils.closeResource(conn, ps); 			 		} 		 		 	} 

    /**      * 说明：      *     1）public 与 返回值中间<T>非常重要，可以理解为声明此方法为泛型方法。      *     2）只有声明了<T>的方法才是泛型方法，泛型类中的使用了泛型的成员方法并不是泛型方法。      *     3）<T>表明该方法将使用泛型类型T，此时才可以在方法中使用泛型类型T。      *     4）与泛型类的定义一样，此处T可以随便写为任意标识，常见的如T、E、K、V等形式的参数常用于表示泛型。      *      * 针对于不同的表的通用的查询操作，返回表中的一条记录      *      * @param clazz 将查询的结果放哪个bean文件中      * @param sql SQL语句      * @param args 占位符的具体信息      * @param <T> 哪个表对应哪个对象      * @return 带查询结果的对象      *      */     public <T> T getInstance(Class<T> clazz,String sql,Object...args){         Connection conn = null;         PreparedStatement ps = null;         ResultSet rs = null;         try {             conn = DBUtil.getConnection("test");              ps = conn.prepareStatement(sql);              for (int i = 0; i < args.length; i++) {                 ps.setObject(i + 1 ,args[i]);             }              rs = ps.executeQuery();              // 获取结果集的元数据 :ResultSetMetaData             ResultSetMetaData rsmd = rs.getMetaData();              //获取列数             int columnCount = rsmd.getColumnCount();              if(rs.next()){                 T t = clazz.newInstance();                 for (int i = 0; i < columnCount; i++) {                      Object columnValue = rs.getObject(i + 1);                      //获取表字段的别名                     String columnLabel = rsmd.getColumnLabel(i + 1);                      Field field = clazz.getDeclaredField(columnLabel);                     field.setAccessible(true);                     field.set(t,columnValue);                 }                  return t;             }         } catch (Exception e) {             e.printStackTrace();         } finally {             DBUtil.close(conn,ps,rs);         }         return null;     } 

    public  <T> List<T> getForList(Class<T> clazz, String sql, Object...args){         Connection conn = null;         PreparedStatement ps = null;         ResultSet rs = null;         try {             conn = DBUtil.getConnection("test");              ps = conn.prepareStatement(sql);              for (int i = 0; i < args.length; i++) {                 ps.setObject(i + 1,args[i]);             }              rs = ps.executeQuery();              ResultSetMetaData rsmd = rs.getMetaData();              int columnCount = rsmd.getColumnCount();              //创建集合对象             ArrayList<T> list = new ArrayList<>();              while(rs.next()){                 T t = clazz.newInstance();                  for (int i = 0; i < columnCount; i++) {                     Object columnValue = rs.getObject(i + 1);                      String columnLabel = rsmd.getColumnLabel(i + 1);                      Field field = clazz.getDeclaredField(columnLabel);                     field.setAccessible(true);                     field.set(t,columnValue);                 }                 list.add(t);             }              return list;         } catch (Exception e) {             e.printStackTrace();         } finally {             DBUtil.close(conn,ps,rs);         }          return null;     }