这是我写的一个项目中的一个连接、操作数据库的一个工具类,
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)