这是我的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)
方法来保存一些代码行,但这种方法不起作用:
-
您将向它传递一个静态SQL字符串,而不是向它传递查询参数并使用PreparedStatement执行动态SQL查询,这要安全得多。
-
如果你没有用产生数据的方法从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-连接、语句、结果集