如何处理finally中关闭coosection后返回的ResultSet值(错误处理)



这是我的DbOperationProcess代码

在该代码中,用于操作数据库中的任何数据显示错误

例如,对于检索JTable的值,它显示错误

它不能返回任何值为什么?

例如,当调用这个时

StudentView.java

      String query="select * from tbl_student";
      rs=db_obj.getData(query);

这是错误

    java.sql.SQLException: Operation not allowed after ResultSet closed
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1055)
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:956)
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:926)
    at com.mysql.jdbc.ResultSetImpl.checkClosed(ResultSetImpl.java:768)
    at com.mysql.jdbc.ResultSetImpl.next(ResultSetImpl.java:7008)
    at DbApp.ViewStudents.initTable(ViewStudents.java:49)
    at DbApp.ViewStudents.<init>(ViewStudents.java:23)

请纠正我的

package DbApp;
import java.sql.*;
/**
 *
 * @author DELL
 */
public class DbOperationProcess {
    ResultSet rs = null;
    int value = 0;
    Statement st = null;
    Connection conn = null;
    public ResultSet getData(String query) {
        try {
            conn = DbOperation.getConnection();
            st = conn.createStatement();
            rs = st.executeQuery(query);
            System.out.println(query);
        } catch (Exception ae) {
            ae.printStackTrace();
        } finally {
            try {
                DbOperation.closeConnection(rs, st, conn);
            } catch (Exception ae) {
            }
        }
        return rs;
    }
    public void setData(String query) {
        try {
            conn = DbOperation.getConnection();
            st = conn.createStatement();
            st.execute(query);
        } catch (Exception ae) {
            ae.printStackTrace();
        } finally {
            try {
                DbOperation.closeConnection(rs, st, conn);
            } catch (Exception ae) {
            }
        }
    }
    public int setUpdate(String query) {
        try {
            conn = DbOperation.getConnection();
            st = conn.createStatement();
            int value = st.executeUpdate(query);
            System.out.println("query");
        } catch (Exception ae) {
            ae.printStackTrace();
        } finally {
            try {
                DbOperation.closeConnection(rs, st, conn);
            } catch (Exception ae) {
            }
        }
        return value;
    }
}

这是我的DbOperation代码

    /*
     * To change this template, choose Tools | Templates
     * and open the template in the editor.
     */
    package DbApp;
    import java.sql.*;
    /**
     *
     * @author DELL
     */
    public class DbOperation 
    {

        public static Connection getConnection()
        {
        Connection conn=null;;
        try
        {
            String driver = "org.gjt.mm.mysql.Driver";
            String databasename = "db_college";
            String url = "jdbc:mysql://localhost:3306/";
            String username = "root";
            String password = "123456";

            Class.forName(driver);
            conn=DriverManager.getConnection(url+databasename,username,password);
        }
        catch (ClassNotFoundException cnfe) 
        {
            System.out.println("JDBC Driver not found" + cnfe);
        } 
        catch (SQLException sqle) 
        {
            System.out.println("JDBC URL Error " + sqle);
        }
        catch(Exception ae)
        {
            ae.printStackTrace();
        }
        return conn;
        }
        public static void closeConnection(ResultSet rs,Statement st,Connection conn)
        {
        try
        {
           if(rs!=null) 
           {
               rs.close();
           }
           if(st!=null) 
           {
               st.close();
           }
           if(conn!=null) 
           {
               conn.close();
           }
        }
        catch(Exception ae)
        {
        }
        }
    }

您的getData(String query)方法毫无意义。您应该为每个DB查询使用不同的方法。您应该在执行查询后立即使用ResultSet。您不应该返回ResultSet。您应该返回一个对象/对象集合,其中包含查询返回的数据。

您可能认为,通过对所有查询使用相同的ResultSet getData(String query)方法来保存一些代码行,但这种方法不起作用:

  1. 您将向它传递一个静态SQL字符串,而不是向它传递查询参数并使用PreparedStatement执行动态SQL查询,这要安全得多。

  2. 如果你没有用产生数据的方法从ResultSet中提取数据,你就不能关闭ResultSet和DB连接,除非你这样做

您正在显式关闭resultset对象
关闭resultset 后,您正试图通过resultset.next()访问它

您可以尝试使用CachedRowset

        ResultSet resultSet = statement.executeQuery();
        CachedRowset cachedRowset = new CachedRowSetImpl();
        cachedRowset.populate(resultSet);
        return cachedRowset; //returns type ResultSet

在相同的方法中,您可以关闭所有的3-连接、语句、结果集

相关内容

  • 没有找到相关文章

最新更新