结果集未打开，尽管我一次只有一个

Question

我知道之前有人就这个问题提出过很多问题，但对于这种情况，我找不到答案。

这是我的代码：

private Collection<Coupon> getCouponsMain(Company company, String filters) throws DAOException
{
    String sql = null;
    if (filters != null)
    {
        sql = "SELECT couponsystem.coupon.* FROM couponsystem.company_coupon LEFT JOIN couponsystem.coupon ON "
            + "couponsystem.company_coupon.COUPON_ID = couponsystem.coupon.ID WHERE couponsystem.company_coupon.COMP_ID = ? AND ?";
    }
    else
    {       
         sql = "SELECT couponsystem.coupon.* FROM couponsystem.company_coupon LEFT JOIN couponsystem.coupon ON "
            + "couponsystem.company_coupon.COUPON_ID = couponsystem.coupon.ID WHERE couponsystem.company_coupon.COMP_ID = ?";           
    }

    try (Connection con = pool.OpenConnection(); PreparedStatement preparedStatement = con.prepareStatement(sql);)
    {   
        // query command

        preparedStatement.setLong(1, company.getId());
        if (filters != null)
        {
            preparedStatement.setString(2, filters);
        }

        ResultSet rs = preparedStatement.executeQuery();

        if (rs.next())
        {
            CouponDBDAO couponDao = new CouponDBDAO();  
            rs.previous();
            return couponDao.BuildCoupons(rs);
        }
        else
        {
            return null;
        }
    }
    catch (SQLException | NullPointerException e)
    {
        throw new DAOException("Failed to retrieve data for all coupons" + e.getMessage());
    }
}

我认为查询本身不是这里的重要问题，但是，一旦我将 next() 用于 ResultSet，我就会收到错误：

java.sql.SQLException: ResultSet 关闭后不允许操作"

这通常发生在同一语句使用两个 rs 时，这次不是这样。

由于之前的方法有很多问题和 BuildCoupons(rs) 问题，这部分也因为同样的原因不能正常工作：

@Override
public Company getCompany(long id) throws DAOException
{
    String sql = "SELECT * FROM couponsystem.company WHERE ID = ?";
    try (Connection con = pool.OpenConnection(); PreparedStatement preparedStatement = con.prepareStatement(sql);)
    {   
        // query command

        preparedStatement.setLong(1, id);

        // query execution
        ResultSet rs = preparedStatement.executeQuery();

        Company comp = new Company();
        if (rs.next())
        {
            //Fill customer object from Customer table              
            comp.setId(rs.getLong("ID"));
            comp.setCompName(rs.getString("COMP_NAME"));
            comp.setPassword(rs.getString("PASSWORD"));
            comp.setEmail(rs.getString("EMAIL"));
            comp.setCoupons(comp.getCoupons());
        }   
        else
        {
            comp = null;
        }

        return comp;
    }
    catch (SQLException e)
    {
        throw new DAOException("Failed to retrieve data for customer id: " + id);
    }
}

顺便说一句 - 使用 MySQL 并且插入、更新和删除查询工作正常，因此与 db 的连接没有问题

另一个更新 - 一旦我将它替换为常规语句，它就可以工作了，但是我当然失去了准备好的语句的所有优点

就像我说的，我创建新代码是为了隔离大程序 这是代码：

public class testState 
{
    public static void main(String[] args) throws SQLException
    {
            DBDAO pool = DBDAO.getInstance();

            String sql = "SELECT ID FROM couponsystem.company WHERE COMP_NAME = ? AND PASSWORD = ?";
            String compName = "t";
            String password = "t";

            pool.CreatePool();
            Connection con = pool.OpenConnection(); 
            PreparedStatement preparedStatement = con.prepareStatement(sql);

                preparedStatement.setString(1, compName);
                preparedStatement.setString(2, password);
preparedStatement.executeQuery();
                ResultSet rs = preparedStatement.executeQuery();

                System.out.println("rs status: " + rs.isClosed());
                if (rs.next())
                {
                    System.out.println("log-in was successfuly performed");
                    System.out.println(rs.getLong(1));
                    System.out.println("hjhjh");
                }
                else
                {
                    System.out.println("-1");
                }

            rs.close();
            preparedStatement.close();
            con.close();
            pool.CloseConnection();
    }
}

Answer 1

问题解决了， 这就是问题所在：

sql = "SELECT couponsystem.coupon.* FROM couponsystem.company_coupon LEFT JOIN couponsystem.coupon ON " + "couponsystem.company_coupon.COUPON_ID = couponsystem.coupon.ID WHERE couponsystem.company_coupon.COMP_ID = ? AND ?";

第二个？是非法的，但异常是 ResultSet 关闭而不是查询问题

Answer 2

问题是您试图返回结果集中的上一条记录，这是不可能的。

了解可滚动结果集并使其不敏感，一旦使用它，您可以使用 rs.previous() 返回上一个记录

ResultSet.TYPE_SCROLL_INSENSITIVE