当前位置: 代码迷 >> Java Web开发 >> 关于java.sql.SQLException: 关闭的 Resultset: next错误有关问题
  详细解决方案

关于java.sql.SQLException: 关闭的 Resultset: next错误有关问题

热度:1255   发布时间:2016-04-16 22:25:29.0
关于java.sql.SQLException: 关闭的 Resultset: next异常问题
这是我写的一个项目中的一个连接、操作数据库的一个工具类,


public class BaseDao {
   protected Connection conn=null;
   protected PreparedStatement ps=null;
   protected Statement stmt=null;
   protected ResultSet rs=null;
   public boolean getConnection(){
   //读出配置信息
   String driver=ConfigManager.getInstance().getString("jdbc.driver_class");
   String url=ConfigManager.getInstance().getString("jdbc.connection.url");
   String username=ConfigManager.getInstance().getString("jdbc.connection.username");
   String password=ConfigManager.getInstance().getString("jdbc.connection.password");
   //加载JDBC驱动   
try {  Class.forName(driver);
//与数据库建立连接
conn=DriverManager.getConnection(url, username, password);
} catch (ClassNotFoundException e) {
e.printStackTrace();
return false;
} catch (SQLException e) {
e.printStackTrace();
return false;
}
   return true;   
   }
   //增删改操作
   public int executeUpdate(String sql,Object[] params){
   int updateRows=0;
   getConnection();
   try {
ps=conn.prepareStatement(sql);
//填充占位符
for(int i=0;i<params.length;i++){
ps.setObject(i+1, params[i]);
}
//System.out.println(sql);
updateRows=ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}finally{
closeResource();
}
  return updateRows; 
   }
   //查询操作
   public ResultSet executeSQL(String sql,Object[] params){
   getConnection();
   try {
ps=conn.prepareStatement(sql);
//填充占位符
for(int i=0;i<params.length;i++){
ps.setObject(i++, params[i]);
}
rs=ps.executeQuery();
} catch (SQLException e) {
e.printStackTrace();
}finally{
closeResource();

  return rs; 
   }
   //关闭资源
   public boolean closeResource(){
   if(rs!=null){
   try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
return false;
}
   }
   if(ps!=null){
   try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
return false;
}
   }
   if(conn!=null){
   try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
return false;
}
   }
   return true;
   }
}

下面是我写的一个接口的实现类


public class BookDaoImpl extends BaseDao implements BookDao {
//获取图书列表
@Override
public List<Book> getBookList() {
List<Book> bookList=new ArrayList<Book>();
try {
//获得Statement对象,执行SQL语句
String sql="select * from books";
Object[] params={};
ResultSet rs=this.executeSQL(sql, params);
//处理执行结果(ResultSet)
while(rs.next()){
System.out.println("运行到这了吗");
int bid =rs.getInt("bid");
String bookname=rs.getString("bookname"); 
String b_price=rs.getString("b_price");   
String image=rs.getString("image"); 
int stock=rs.getInt("stock");
//将图书信息封装成对象
Book book=new Book();
book.setBid(bid);
book.setBookName(bookname);
book.setPrice(b_price);
book.setImage(image);
book.setStock(stock);
//将图书对象放进集合中
bookList.add(book);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
this.closeResource();
}
return bookList;
}
}

下面是我的 一个测试类 当我运行这个类是总是报下面的异常

 public static void main(String[] args) {
BookDaoImpl bookDao=new BookDaoImpl();
 List<Book> bookList=bookDao.getBookList();
    for(Book book:bookList){
   System.out.println(book.getBid()+"\t"+book.getBookName()+"\t"+book.getPrice()+"\t"+book.getStock());
   }

异常查了好多资料都说是多线程并发问题,但是我就是不知道出现在那里,求大神帮助啊!

 java.sql.SQLException: 关闭的 Resultset: next
at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:112)
at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:146)
  相关解决方案