JdbcUtil类，jdbcl连接Oracle数据库，封装增删改查方法

╰半夏微凉° 2021-12-03 15:11 240阅读 0赞

JDBCUtil :

package com.macw.util;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.math.BigDecimal;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.ResultSetMetaData;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Properties;
    
    import javax.sql.DataSource;
    
    import com.alibaba.druid.pool.DruidDataSourceFactory;
    
    /** * @author 超伟 * @2019年5月29日 下午3:48:26 * @博客：https://blog.csdn.net/MacWx */
    public class JdbcUtil { 
    	public static DataSource ds;
    	public static final ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
    	// 把流操作提取到静态代码块里面。
    	static { 
    		InputStream in = null;
    		// 创建连接池对象
    		try { 
    			// 创建出Properties对象
    			Properties prop = new Properties();
    			in = JdbcUtil.class.getResourceAsStream("/druid.properties");
    			// 读取文件中的数据
    			prop.load(in);
    			// 创建连接池对象
    			ds = DruidDataSourceFactory.createDataSource(prop);
    		} catch (IOException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    			throw new RuntimeException(e);
    		} catch (ClassNotFoundException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    			throw new RuntimeException(e);
    		} catch (Exception e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} finally { 
    			if (in != null) { 
    				try { 
    					in.close();
    				} catch (IOException e) { 
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    		}
    	}
    
    	/** * * @return */
    	public static Connection getConnection() { 
    		//优先从线程中获取连接
    		Connection conn = tl.get();
    		// 如果没有拿到这个线程，就说明是业务类在调用
    		//如果从线程中获取失败，则再新建和数据库的连接
    		if (conn == null) { 
    			try { 
    				// 用数据库连接池来获取数据库连接
    				conn = ds.getConnection();
    				tl.set(conn);
    			} catch (SQLException e) { 
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    				throw new RuntimeException(e);
    			}
    		}
    
    		return conn;
    	}
    
    	/** * * @param conn * @param ps * @param rs */
    	public static void toClose(Connection conn, PreparedStatement ps,
    			ResultSet rs) { 
    		try { 
    			// 代码不用改，但是含义改变了，把这个连接归还给数据库连接池
    			// //为了代码的健壮性，需要增加非空判断
    			if (rs != null) { 
    				rs.close();
    			}
    		} catch (SQLException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		// 释放ps对象，关闭资源的时候需要注意顺序，后创建的对象，要先关闭。
    		try { 
    			if (ps != null) { 
    				ps.close();
    			}
    		} catch (SQLException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		try { 
    			if (conn != null) { 
    				conn.close();
    				//关闭连接，要从线程中移除
    				tl.remove();
    			}
    		} catch (SQLException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    	
    	/** * 使用jdbc对于增删改方法的封装 * * 对于增删改方法，仍有大部分的冗余代码，但在这些冗余代码中又有一些是不同的 * 例如sql语句，以及传入的参数，所以可把相同的代码封装，不同的代码抽取 * 这只是代码的简化，并不是程序的优化 * * * @param sql 对于sql语句的抽取 * @param obj 可变长参数 * 可变长参数必须是最后一个形参，也只能有一个这样的形参 * 在该方法内部，将obj当成一个数组使用。 * @throws SQLException */
    	public static void update(String sql,Object...obj) throws SQLException{ 
    		Connection conn = null;
    		PreparedStatement ps = null;
    		try{ 
    			//调用本类中的获取连接方法
    			conn = getConnection();
    			ps = conn.prepareStatement(sql);
    			//再判断传入的参数是否为空
    			if (obj != null) { 
    				//如果不为空则挨个赋值
    				for (int i = 0; i < obj.length; i++) { 
    					ps.setObject(i+1, obj[i]);
    				}
    			}
    			ps.executeUpdate();
    		//这里不用catch异常是因为要在dao中去处理
    		}finally{  
    			//这里的conn连接不要关，在services层中去关闭！在services中处理事务！
    			toClose(null, ps, null);
    		}
    	}
    	
    	
    	/* * 反射： * * 什么是类对象和类的对象？ * Student s = new Student(); s是类的对象,是某一个类创建出来的对象，这个类是Student //1.在运行期加载一个类到虚拟机中 Class c = Class.forName(“com.macw.Student”); //c就是Student的类对象 //2. 通过反射创建Student类的对象 Object o = c.newInstance(); //o 是Student类的对象 //3.获取Student类指定的方法 和 获取所有的方法 Method method = c.getMethod(“方法名”,形参类型); //method指某一个方法 method.invoke(对象,实参); //动态调用该方法 Method[] methods = c.getMethods(); //methods指类中所有的方法 * */
    	
    	
    	/** * 查询多条 * <T> 是用来规范泛型的， * @throws SQLException * @throws IllegalAccessException * @throws InstantiationException * @throws InvocationTargetException * @throws IllegalArgumentException * */
    	public static <T> List<T> select(String sql,Class<T> clz,Object...obj) throws SQLException, InstantiationException, IllegalAccessException, IllegalArgumentException, InvocationTargetException{ 
    		Connection conn = null;
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		List<T> list = null;
    		try { 
    			conn = getConnection();
    // 1,预加载SQL语句
    			ps = conn.prepareStatement(sql);
    // 2,设置占位符
    			if (obj != null) { 
    				for (int i = 0; i < obj.length; i++) { 
    					ps.setObject(i+1, obj[i]);
    				}
    			}
    // 3,执行SQL语句
    			rs = ps.executeQuery();
    // 获取查询结果集中的元数据
    // 元数据可以理解为查询结果中的列名
    			ResultSetMetaData md = rs.getMetaData();
    // 获取查询到的列的个数；
    			int columnCount = md.getColumnCount();
    // System.out.println(columnCount);
    			list = new ArrayList<>();
    			T t = null;
    			while(rs.next()){ //while每循环一次，代表一行数据。
    				//clz代表实体类对象，
    // 创建实体类的对象
    				t = clz.newInstance();
    				for (int i = 0; i < columnCount; i++) { //一行数据有几列就循环几次
    // 根据下标获取列名
    					String columnName = md.getColumnName(i+1);
    // 再根据列名获取对应列的值
    					Object value = rs.getObject(columnName);
    // 要将每一列的值赋值给t对象的属性，要要求表中的列名和实体类属性名必须一致！
    // 这是通过字符串拼接成 setName();方法
    					String methodName = "set" + columnName.substring(0, 1).toUpperCase()+
    						columnName.substring(1).toLowerCase();
    // 获取当前实体类中传递过来的所有方法
    					Method[] methods = clz.getMethods();
    // 进行for循环获取所有的set方法
    					for (Method m : methods) { 
    // 判断所有的方法中有没有查询结果列名拼成的set方法
    // 获取实体类中所有的方法名用：m.getName()方法
    						if (m.getName().equals(methodName)) { 
    // Oracle中的number类型对应java中的java.math.BigDecimal类型
    							/** * rs.getInt("id"); 那么number类型就被转换成了int类型； * rs.getDouble("price");那么number类型就转换成了double类型 * rs.getObject("列名"); 那么返回的实际类型是java.math.BigDecimal; * Bigdecimal 没有精度损失，多用户银行等的金融计算； */
    // value如果是Bigdecimal类型，意味着在数据库中是number类型
    // 所以需要强转成int或者double类型
    							if (value == null) { //如果有空的数据，不再强转直接跳过
    								continue;
    							}
    							else if (value instanceof BigDecimal) { 
    									Class<?> c2 = m.getParameterTypes()[0];
    									if (c2.getName().equals("java.lang.Integer")) { 
    										value = ((BigDecimal)value).intValue();
    									}else
    										if(c2.getName().equals("double")){ 
    										value = ((BigDecimal)value).doubleValue();
    									}
    									else
    										if(c2.getName().equals("int")){ 
    										value = ((BigDecimal)value).intValue();
    									}
    							}
    							//动态执行set方法
    							m.invoke(t, value);
    						}
    					}
    					
    				}
    				//while每循环一次，就创建一个实体类对象，给对象的属性赋值，
    // 然后将对象存储到list集合中
    				list.add(t);
    			}
    			
    		}finally{ 
    			toClose(null, ps, rs);
    		}
    		return list;
    	}
    	
    }

jdbcUtil工具类的使用：  
如下所示：

查询方法：

public User selectByNameAndPwd(String username, String password) {
    		// TODO Auto-generated method stub
    		String sql = "select * from t_user where username = ? and password = ?";
    		User u = null;
    		try {
    			List<User> list = JdbcUtil.select(sql, User.class,username,password);
    			for (User user : list) {
    				u = new User(user.getUser_id(),user.getUsername(),user.getPassword());
    			}
    		} catch (InstantiationException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (IllegalAccessException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (IllegalArgumentException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (InvocationTargetException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (SQLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		return u;
    		
    	}
    }

增删改方法：  
增删改都是一样的，都是调用JdbcUtil的update方法，因为增删改执行的方法都是没有返回值的，所以可以统一处理！  
简化jdbc重复代码！

public void updatePwd(int id,String newPassword) {
    		// TODO Auto-generated method stub
    		try {
    			String sql = "update t_user set password = ? where user_id = ?";
    			JdbcUtil.update(sql, newPassword,id);
    		} catch (SQLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}