DBUtil及使用

末蓝、 2023-02-13 11:14 10阅读 0赞

package psdi.cache;
    
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.math.BigDecimal;
    import java.sql.*;
    import java.util.ArrayList;
    import java.util.List;
    
    public class DBUtil {
    
        private static PreparedStatement sta = null; //执行查询语句的类
        private static ResultSet rs = null;   //执行查询语句后返回的结果的类
        private static Connection conn = null;//连接类
    
        //加载驱动
        static {
            try {
                //driver驱动名字
                String driver = "oracle.jdbc.driver.OracleDriver";
                Class.forName(driver);   //dirver就是前面配置的driver名称
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        }
    
        /**
         * @return 连接对象
         */
        public static Connection getConnection() {
            try {
                //连接的url，
                String url = "jdbc:oracle:thin:@//10.68.19.228:1521/orclpdb";
                // oracle数据库的用户名
                String user = "xxx";
                // oracle数据库的用户密码
                String pwd = "xxx";
                conn = DriverManager.getConnection(url, user, pwd);
            } catch (SQLException e) {
                e.printStackTrace();
            }
            return conn;
        }
    
        /**
         * 关闭资源
         */
        public static void close() {
            try {
                if (rs != null) {
                    rs.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                try {
                    if (sta != null) {
                        sta.close();
                    }
                } catch (SQLException e2) {
                    e2.printStackTrace();
                } finally {
                    if (conn != null) {
                        try {
                            conn.close();
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }
        }
    
    
        /**
         * 查询多条
         */
        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 {
                close();
            }
            return list;
        }
    
        /**
         * 使用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中处理事务！
                close();
            }
        }
    
    
        /**
         * 查询示例
         */
        public User selectByNameAndPwd(String username, String password) {
            String sql = "select * from t_user where username = ? and password = ?";
            User u = null;
            try {
                List<User> list = DBUtil.select(sql, User.class,username,password);
                for (User user : list) {
                    u = new User(user.getUserId(),user.getUsername(),user.getPassword());
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
            return u;
        }
    
        /**
         * 增删改示例
         * 增删改都是一样的，都是调用JdbcUtil的update方法，因为增删改执行的方法都是没有返回值的，所以可以统一处理！简化jdbc重复代码！
         */
        public void updatePwd(int id,String newPassword) {
            try {
                String sql = "update t_user set password = ? where user_id = ?";
                DBUtil.update(sql, newPassword,id);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    
    
    }
    
    
    }