使用JDBC对不同的mysql表进行查询操作

短命女 2023-10-04 09:54 34阅读 0赞

对不同的表实现通用查询:使用泛型

###### 获取一个对象的方法： ######

public <T> T getInstance(Class<T> clazz,String sql,Object ...args) {
            Connection conn = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
            try {
                conn = JDBCUtils.getConnection();
                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();
                if(rs.next()){
                    T t = clazz.newInstance();
                    //获取列数
                    int columnCount = rsmd.getColumnCount();
                    for (int i = 0;i < columnCount;i++){
                        //获取每个列的列值:通过结果集
                        Object columnValue = rs.getObject(i + 1);
                        //获取每个列的列名:通过元数据
                        //获取列的列名：getColumnName()--------->不推荐使用
                        //获取列的别名：getColumnLabel()
    //                  String columnName = rsmd.getColumnName(i + 1);
                        String columnLabel = rsmd.getColumnLabel(i + 1);
                        //通过反射，将对象的指定的cloumnName属性名赋值为cloumnValue
                        Field field = clazz.getDeclaredField(columnLabel);
                        field.setAccessible(true);
                        field.set(t,columnValue);
                    }
                    return t;
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                JDBCUtils.closeResource(conn,ps,rs);
            }
            return null;
        }

###### 获取一个对象的多条记录 ######

将多条数据封装到集合中

public List getForList(Class clazz, String sql, Object …args) \{\}

public <T> List<T> getForList(Class<T> clazz, String sql, Object ...args) {
            Connection conn = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
            try {
                conn = JDBCUtils.getConnection();
                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();
                //创建集合
                ArrayList<T> list = new ArrayList<>();
                while(rs.next()){
                    T t = clazz.newInstance();
                    //获取列数
                    int columnCount = rsmd.getColumnCount();
                    for (int i = 0;i < columnCount;i++){
                        //获取每个列的列值:通过结果集
                        Object columnValue = rs.getObject(i + 1);
    
                        //获取每个列的列名:通过元数据
                        //获取列的列名：getColumnName()--------->不推荐使用
                        //获取列的别名：getColumnLabel()
    //                  String columnName = rsmd.getColumnName(i + 1);
                        String columnLabel = rsmd.getColumnLabel(i + 1);
                        //通过反射，将对象的指定的cloumnName属性名赋值为cloumnValue
                        Field field = clazz.getDeclaredField(columnLabel);
                        field.setAccessible(true);
                        field.set(t,columnValue);
    
                    }
                    list.add(t);
                }
                return list;
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                JDBCUtils.closeResource(conn,ps,rs);
            }
            return null;
        }