JDBC对mysql数据库的查找操作

蔚落 2023-10-04 09:54 36阅读 0赞

JDBC查找操作，查找操作相较于增删改复杂，因为查找要考虑查找后的结果处理

public void testQuery1() {
            Connection conn = null;
            PreparedStatement ps = null;
            ResultSet resultSet = null;
            try {
                //1、连接数据库
                conn = JDBCUtils.getConnection();
                //2、预编译sql语句
                String sql = "select id,name,email,birth from customers where id = ?";
                ps = conn.prepareStatement(sql);
                ps.setObject(1,1);
                //3、执行sql语句并返回结果集
                resultSet = ps.executeQuery();
                //4、处理结果集
                if (resultSet.next()){//next()：判断结果集的下一条是否有数据，如果有数据返回true，并且指针下移，
                                      // 如果没有返回false，指针不下移
                    int id = resultSet.getInt(1);
                    String name = resultSet.getString(2);
                    String email = resultSet.getString(3);
                    Date birth = resultSet.getDate(4);
                    //处理结果的几种方式
                    //方式一：直接输出
                    //方式二：封装到数组中
        //            Object[] data = {id, name, email, birth};
                    //方式三：将数据封装为一个对象（推荐）
                    //使用ORM编程思想（Object Relational Mapping）
                    //将白哦中的一个字段对应类的一个属性
                    //表中的每一个记录对应类中的一个对象
                    Customer customer = new Customer(id, name, email, birth);
                    System.out.println(customer);
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                //5、关闭资源
                JDBCUtils.closeResource(conn,ps,resultSet);
            }
        }

创建一个针对于Customers表通用的查询操作：

难点：怎么实现对于不同字段结果动态处理-------------->使用反射

public Customer queryForCustomers(String sql,Object ...args) {
            Connection conn = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
            try {
                //1、连接数据库
                conn = JDBCUtils.getConnection();
                //2、预编译aql，返回PreparedStatement实例
                ps = conn.prepareStatement(sql);
                //3、填充占位符
                for (int i = 0;i < args.length;i++){
                    ps.setObject(i+1,args[i]);
                }
                //4、执行并返回结果集
                rs = ps.executeQuery();
                //获取结果集中的元数据
                ResultSetMetaData rsmd = rs.getMetaData();
                //通过ResultSetMetaData获取结果集中的列数
                int columnCount = rsmd.getColumnCount();
                if(rs.next()){
                    Customer cust = new Customer();
                    for (int i = 0;i < columnCount;i++){
                        //获取每个列的列值
                        Object columnValue = rs.getObject(i + 1);
                        //获取每个列的列名
                        String columnName = rsmd.getColumnName(i+1);
                        //给cust对象指定的columName属性，赋值为columnValue:通过反射
                        Field field = Customer.class.getDeclaredField(columnName);
                        field.setAccessible(true);
                        field.set(cust,columnValue);
                    }
                    return cust;
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                JDBCUtils.closeResource(conn,ps,rs);
            }
            return null;
        }

对于表的字段名和类的属性名不一致的情况下，实现该表的通用查询操作

使用getColumnLaber（）代替getColumnName（）

//获取列的列名：getColumnName()--------->不推荐使用
    //获取列的别名：getColumnLabel()

/**
         * 通用的针对order表的查询操作
         * @return
         */
      public Order orderForQuery(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()){
                  Order order = new Order();
                  //获取列数
                  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 = Order.class.getDeclaredField(columnLabel);
                      field.setAccessible(true);
                      field.set(order,columnValue);
                  }
                  return order;
              }
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              JDBCUtils.closeResource(conn,ps,rs);
          }
          return null;
      }

针对于表的字段名与类的属性名不相同的情况下：

1.  必须声明sql时，使用类的属性名来命名字段的别名
2.  使用ResultSetMetaData时，需要使用getColumnLabel来替换getCounmnName（），获取列的别名