测试驱动程序

package shujuku.Junit.com; import java.sql.*; public class DBBean { Connection conn=null; ResultSet rs=null; public int executeQuery(String sql){// select rs=null; try{ conn=DBContext.getConnection(); Statement stmt=conn.createStatement(); rs=stmt.executeQuery(sql); }catch(Exception e){ e.printStackTrace(); } int k=0; try { while(rs.next()){ k++; } } catch (SQLException e) { e.printStackTrace(); } closeConnection(); return k; } public int executeInsert(News news){ try{ conn=DBContext.getConnection(); String sql = "insert into news(id,title,kind)" + "values(?,?,?)"; PreparedStatement stmt= conn.prepareStatement(sql); stmt.setInt(1, news.getId()); stmt.setString(2,news.getTitle()); stmt.setString(3, news.getKind()); int i=stmt.executeUpdate(); closeConnection(); return i; }catch(Exception e){ e.printStackTrace(); return -1; } } public int executeDelete(int id){ try{ conn=DBContext.getConnection(); String sql = "delete from news where id=?" ; PreparedStatement stmt= conn.prepareStatement(sql); stmt.setInt(1,id); int i=stmt.executeUpdate(); closeConnection(); return i; }catch(Exception e){ e.printStackTrace(); return -1; } } public int executeDelete(String title){ try{ conn=DBContext.getConnection(); String sql = "delete from news where title =?"; PreparedStatement stmt= conn.prepareStatement(sql); stmt.setString(1, title); int i=stmt.executeUpdate(); closeConnection(); return i; }catch(Exception e){ e.printStackTrace(); return -1; } } public News findById(int id) { News news = null; try { conn=DBContext.getConnection(); String sql = "select * from news where id=?"; PreparedStatement pst = conn.prepareStatement(sql); pst.setInt(1, id); ResultSet rs = pst.executeQuery(); if(rs.next()) { news = myNews(rs); } rs.close(); pst.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return news; } private News myNews(ResultSet rs) throws SQLException { News news = new News(); news.setId(rs.getInt("id")); news.setTitle(rs.getString("title")); news.setKind(rs.getString("kind")); return news; } public void closeConnection(){ try{ if(!conn.isClosed()) conn.close(); }catch(Exception e){ e.printStackTrace(); } } }