Java创建一个JDBC工具类并解决返回ResultSet的问题

前段时间做数据源开发时用到了JDBC，碰到了一个问题，记录一下。
创建了一个JDBC工具类用来创建连接，并传入SQL查询，向调用者返回ResultSet对象，随后在工具类中关闭连接。
但是调用之后发现ResultSet始终拿不到数据，最后发现 ResultSet随着工具类中在finally中关闭连接而清空。
百度后发现可以将ResultSet指向CacheRowSetImpl类然后返回的方法，但是部署服务器编译的时候提示 “com.sun.rowset.CachedRowSetImpl 是 Sun 的专用 API，在后续的JDK9版本后(包括JDK9)已经删除”。
原因是CacheRowSetImpl是过时的类，即将在JDK 9的版本中移除，所以不建议使用。
最后，如下所示，既可以给上层返回ResultSet，在上层解析完结果集后还可以关闭连接：

1. package com.JyoKou.utils;
4. import java.sql.*;
6. /**
7. * 创建JDBC连接工具类
8. *
9. * @author JyoKou
10. * @since 2022年7月7日
11. */
12. public class JDBCUtils {
13.     private final Connection conn;
14.     private final PreparedStatement ps;
16.     public JDBCUtils(String driver, String url, String userName, String password, String sql) {
17.         try {
18.             Class.forName(driver);
19.             this.conn = DriverManager.getConnection(url, userName, password);
20.             this.ps = conn.prepareStatement(sql);
21.         } catch (Exception e) {
22.             e.printStackTrace();
23.             throw new BadRequestException(MsgConstants.MSG);
24.         }
25.     }
27.     /**
28.      * 创建JDBC连接并执行查询语句
29.      *
30.      * @return ResultSet结果集
31.      * @author JyoKou
32.      * @since 2022年7月7日
33.      */
34.     public ResultSet getQuery() {
35.         ResultSet rs;
36.         try {
37.             rs = this.ps.executeQuery();
38.         } catch (SQLException e) {
39.             e.printStackTrace();
40.             throw new BadRequestException(MsgConstants.MSG);
41.         }
42.         return rs;
43.     }
45.     /**
46.      * 关闭连接
47.      *
48.      * @author JyoKou
49.      * @since 2022年7月15日
50.      */
51.     public void close() {
52.         try {
53.             if (this.ps != null) {
54.                 this.ps.close();
55.             }
56.             if (this.conn != null) {
57.                 this.conn.close();
58.             }
59.         } catch (Exception e) {
60.             e.printStackTrace();
61.             throw new BadRequestException(MsgConstants.MSG);
62.         }
63.     }
64. }

复制代码

调用的时候可以这样写：

1. public Object getDataFromDs(String connectDrivers, BaSysHomepageDatasourceEntity baSysHomepageDatasourceEntity) {
2.         //JDBC执行查询
3.         JDBCUtils jdbcUtils = new JDBCUtils(connectDrivers
4.             , baSysHomepageDatasourceEntity.getDataUrl()
5.             , baSysHomepageDatasourceEntity.getDataUserName()
6.             , baSysHomepageDatasourceEntity.getDataUserPwd()
7.             , homepageCardQueryData.getQuerySql());
8.         ResultSet resultSet = jdbcUtils.getQuery();
9.         try {
10.             if (resultSet.next()) {
11.                 return resultSet.getInt("F_NUM");
12.             } else {
13.                 throw new BadRequestException(MsgConstants.MSG);
14.             }
15.         } catch (SQLException e) {
16.             e.printStackTrace();
17.             throw new BadRequestException(MsgConstants.MSG);
18.         } finally {
19.             jdbcUtils.close();
20.         }
21.     }

复制代码

总结：JDBC工具类使用构造函数对成员变量conn进行构造，然后调用查询方法拿到结果集进行解析，解析完毕后再使用JDBCUtils.close()关闭成员变量conn连接。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！