手动实现对数据库中【单行】数据的查询操作(以Customers表为例)

手动实现对数据库中【单行】数据的查询操作(以Customers表为例)

Customers表

 仅仅针对于Customers表的已知列的查询操作：

/***
     * 
     * @Description    针对于Customer表的查询操作
     * @author XiaoFeng  
     * @throws Exception 
     * @date 2020年8月21日下午2:14:45
     */
    @Test
    public void CustomerForQuery() {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            // 建立与数据库的连接
                // 加载资源
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
            Properties pros = new Properties();
            pros.load(is);
                // 获取资源
            String user = pros.getProperty("user");
            String password = pros.getProperty("password");
            String url = pros.getProperty("url");
            String driver = pros.getProperty("driverClass");
                // 加载数据库驱动
            Class.forName(driver);
                // 获取数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 操作数据库
                // 预编译SQL语句，返回PreparedStatement实例对象
            String sql = "select id,name,email,birth from customers where id = ?";
            ps = conn.prepareStatement(sql);
                // 填充占位符
            ps.setObject(1, 5);
                // 执行ps中传入的SQL语句并返回结果集
            rs = ps.executeQuery();
                // 获取结果集中每列的值并封装到数据表对应类的实例化对象中
//         next():判断结果集的下一行是否有数据。如果有数据，返回true并且指针下移；如果返回false,指针不下移。
            if (rs.next()) {
                // 获取当前行中各个字段的值
                int id = rs.getInt(1);
                String name = rs.getString(2);
                String email = rs.getString(3);
                java.sql.Date birth = rs.getDate(4);
                // 将获取的字段值封装到数据表对应类的实例化对象中
                Customer customer = new Customer(id, name, email, birth);
                System.out.println(customer);
            }
            System.out.println("查询完成");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            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();
                }
            }

        }

    }

Customers表的通用查询操作：

/***
     * 
     * @Description 针对于customers表的通用的查询操作
     * @author XiaoFeng
     * @date 2020年8月21日下午2:52:27
     * @return
     * @throws Exception
     */
    public Customer queryForCustomer(String sql, Object... args) {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            // 建立与数据库的连接
                // 加载资源
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
            Properties pros = new Properties();
            pros.load(is);
                // 读取资源
            String user = pros.getProperty("user");
            String password = pros.getProperty("password");
            String url = pros.getProperty("url");
            String driver = pros.getProperty("driverClass");
                // 加载数据库驱动
            Class.forName(driver);
                // 获取数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 操作数据库
                // 预编译SQL语句，返回PreparedStatement实例对象
            ps = conn.prepareStatement(sql);
                // 填充占位符
            for (int i = 0; i < args.length; i++) {
                ps.setObject(i + 1, args[i]);
            }
                // 执行ps中的SQL语句并返回结果集
            rs = ps.executeQuery();
                // 获取结果集的元数据
            ResultSetMetaData rsmd = rs.getMetaData();
                    // 通过元数据获取结果集的列数,从而确定在获取值时循环的次数
            int columnCount = rsmd.getColumnCount();
                // 获取结果集中每一行的每个列值并将值封装到对应的类对象中
            if (rs.next()) {
                Customer customer = new Customer();
                // 循环获取每一行的所有列值
                for (int i = 0; i < columnCount; i++) {
                    Object columnValue = rs.getObject(i + 1);

                    // 将获取到的列值对应的封装到对象的属性中

                        // 通过结果集元数据获取每一列的列名
                    String columnLabel = rsmd.getColumnLabel(i + 1);

                        // 通过属性名获取属性类型,考虑利用反射中 getDeclaredField()
                    Field field = Customer.class.getDeclaredField(columnLabel);
                        // 确保当前的属性是可访问的
                    field.setAccessible(true);
                    field.set(customer, columnValue);
                }
                System.out.println("查询完成");
                return customer;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            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();
                }
            }
        }
        return null;
    }

测试代码：

@Test
    public void testQueryForCustomer() {
        String sql = "select id,name,email,birth from customers where id = ?";
        Customer customer = queryForCustomer(sql, 16);
        System.out.println(customer);
    }