首页 > 基础资料 博客日记

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

2023-08-03 17:09:17基础资料围观341

本篇文章分享Java创建一个JDBC工具类并解决返回ResultSet的问题,对你有帮助的话记得收藏一下,看Java资料网收获更多编程知识

前段时间做数据源开发时用到了JDBC,碰到了一个问题,记录一下。

创建了一个JDBC工具类用来创建连接,并传入SQL查询,向调用者返回ResultSet对象,随后在工具类中关闭连接。

但是调用之后发现ResultSet始终拿不到数据,最后发现 ResultSet随着工具类中在finally中关闭连接而清空。

百度后发现可以将ResultSet指向CacheRowSetImpl类然后返回的方法,但是部署服务器编译的时候提示 “com.sun.rowset.CachedRowSetImpl 是 Sun 的专用 API,在后续的JDK9版本后(包括JDK9)已经删除”。

原因是CacheRowSetImpl是过时的类,即将在JDK 9的版本中移除,所以不建议使用。

最后,如下所示,既可以给上层返回ResultSet,在上层解析完结果集后还可以关闭连接:

package com.JyoKou.utils;


import java.sql.*;

/**
 * 创建JDBC连接工具类
 *
 * @author JyoKou
 * @since 2022年7月7日
 */
public class JDBCUtils {
    private final Connection conn;
    private final PreparedStatement ps;

    public JDBCUtils(String driver, String url, String userName, String password, String sql) {
        try {
            Class.forName(driver);
            this.conn = DriverManager.getConnection(url, userName, password);
            this.ps = conn.prepareStatement(sql);
        } catch (Exception e) {
            e.printStackTrace();
            throw new BadRequestException(MsgConstants.MSG);
        }
    }

    /**
     * 创建JDBC连接并执行查询语句
     *
     * @return ResultSet结果集
     * @author JyoKou
     * @since 2022年7月7日
     */
    public ResultSet getQuery() {
        ResultSet rs;
        try {
            rs = this.ps.executeQuery();
        } catch (SQLException e) {
            e.printStackTrace();
            throw new BadRequestException(MsgConstants.MSG);
        }
        return rs;
    }

    /**
     * 关闭连接
     *
     * @author JyoKou
     * @since 2022年7月15日
     */
    public void close() {
        try {
            if (this.ps != null) {
                this.ps.close();
            }
            if (this.conn != null) {
                this.conn.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new BadRequestException(MsgConstants.MSG);
        }
    }
}

调用的时候可以这样写:

public Object getDataFromDs(String connectDrivers, BaSysHomepageDatasourceEntity baSysHomepageDatasourceEntity) {
        //JDBC执行查询
        JDBCUtils jdbcUtils = new JDBCUtils(connectDrivers
            , baSysHomepageDatasourceEntity.getDataUrl()
            , baSysHomepageDatasourceEntity.getDataUserName()
            , baSysHomepageDatasourceEntity.getDataUserPwd()
            , homepageCardQueryData.getQuerySql());
        ResultSet resultSet = jdbcUtils.getQuery();
        try {
            if (resultSet.next()) {
                return resultSet.getInt("F_NUM");
            } else {
                throw new BadRequestException(MsgConstants.MSG);
            }
        } catch (SQLException e) {
            e.printStackTrace();
            throw new BadRequestException(MsgConstants.MSG);
        } finally {
            jdbcUtils.close();
        }
    }

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


文章来源:https://www.cnblogs.com/JyoKou/p/16521935.html
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:jacktools123@163.com进行投诉反馈,一经查实,立即删除!

标签:

相关文章

本站推荐

标签云