基于JSP的网上书店

package com.net.bookstore.daoImpl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.net.bookstore.dao.BookDAO; import com.net.bookstore.dto.Book; import com.net.bookstore.page.PageInfo; import com.net.bookstore.page.impl.IPopulate; import com.net.bookstore.page.impl.PageFactory; import com.net.bookstore.page.impl.PagedStatement; import com.net.bookstore.util.ConnectionProvider; public class BookDAOImp implements BookDAO,IPopulate { /** * 添加图书 */ public boolean addBook(Book book) { ConnectionProvider cp = new ConnectionProvider(); Connection conn=cp.getConnection(); try { //conn.setAutoCommit(false); String sql="insert into book(bookname,bookathor,code,bookprice,discount,bookorder,isbn,wordcount,bookcompany,printtime,presstime,uri,bookcount,discription,in_time) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; PreparedStatement pst=conn.prepareStatement(sql); pst.setString(1, book.getBookName()); pst.setString(2, book.getBookAthor()); pst.setInt(3, book.getCode()); pst.setFloat(4, book.getBookPrice()); pst.setFloat(5, book.getDiscount()); pst.setInt(6, book.getBookOrder()); pst.setInt(7, book.getIsbn()); pst.setInt(8, book.getWordCount()); pst.setString(9, book.getBookCompany()); pst.setString(10, book.getPrintTime());//出版时间 pst.setString(11, book.getPressTime());//印刷时间 pst.setString(12, book.getUri()); pst.setInt(13, book.getBookCount()); pst.setString(14, book.getDiscription()); pst.setDate(15, new java.sql.Date(book.getInTime().getTime())); boolean b=pst.executeUpdate()==1?false:true; //conn.commit(); pst.close(); conn.close(); return b; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return false; } /* * 删除图书 */ /* public boolean deleteAllBooks() { ConnectionProvider cp = new ConnectionProvider(); Connection conn=cp.getConnection(); try { String sql="delete book "; PreparedStatement pst=conn.prepareStatement(sql); int n=pst.executeUpdate(); pst.close(); conn.close(); if(n>=1){ return true; } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return false; }*/ public boolean deleteBook(Book book) { ConnectionProvider cp = new ConnectionProvider(); Connection conn=cp.getConnection(); try { String sql="delete from book where id=?"; PreparedStatement pst=conn.prepareStatement(sql); pst.setInt(1, book.getId()); int n=pst.executeUpdate(); pst.close(); conn.close(); if(n==1){ return true; } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return false; } /* * 以下是按各个条件查询 */ public PageInfo findPagedBooks(int pageNo, int pageSize) { String sql = "select * from book order by id"; PagedStatement pst = PageFactory.getPagedStatementInstance(sql, pageNo, pageSize); pst.registerPopulate(this); //注册一个从ResultSet中提交对象的Popluate return pst.executePagedQuery(); } public PageInfo queryBookByISBN(int pageNo,int pageSize,int isbn) {//按ISBN查询 String sql="select * from book where isbn=?"; PagedStatement pst = PageFactory.getPagedStatementInstance(sql,isbn, pageNo, pageSize); pst.registerPopulate(this); //注册一个从ResultSet中提交对象的Popluate return pst.executePagedQuery(); } public Book queryBookById(int id) {//按ID查询 ConnectionProvider cp = new ConnectionProvider(); Connection conn=cp.getConnection(); try { //conn.setAutoCommit(false); String sql="select * from book where id=?"; PreparedStatement pst=conn.prepareStatement(sql); pst.setInt(1, id); ResultSet rs=pst.executeQuery(); Book book = new Book(); while(rs.next()){ return (Book)populate(rs); } rs.close(); pst.close(); conn.close(); }catch(Exception e){ e.printStackTrace(); } return null; } public PageInfo queryBooksByAthor(int pageNo,int pageSize,String athor) {//按作者查询 String sql="select * from book where bookathor=?"; PagedStatement pst=PageFactory.getPagedStatementInstance(sql,athor, pageNo, pageSize); pst.registerPopulate(this); return pst.executePagedQuery(); } public PageInfo queryBooksByCompany(int pageNo,int pageSize,String company) {//按公司查询 String sql="select * from book where bookcompany=?"; PagedStatement pst=PageFactory.getPagedStatementInstance(sql,company, pageNo, pageSize); pst.registerPopulate(this); return pst.executePagedQuery(); } public PageInfo queryBooksByName(int pageNo,int pageSize,String name) {//按书名查询 String sql="select * from book where bookname=?"; PagedStatement pst=PageFactory.getPagedStatementInstance(sql,name, pageNo, pageSize); pst.registerPopulate(this); return pst.executePagedQuery(); } /** * 模糊查询 按书名 */ public PageInfo queryBooksByLike(int pageNo,int pageSize,String name) {//按书名查询 String sql="select * from book where bookname like ?"; PagedStatement pst=PageFactory.getPagedStatementInstance(sql,"%"+name+"%", pageNo, pageSize); pst.registerPopulate(this); return pst.executePagedQuery(); } /** * 按类型查询 03 09 */ public PageInfo queryBooksByCode(int pageNo,int pageSize,int code) {//按书的类型查询所有 String sql="select * from book where code=?"; PagedStatement pst=PageFactory.getPagedStatementInstance(sql,code, pageNo, pageSize); pst.registerPopulate(this); return pst.executePagedQuery(); } /* * 更改图书信息 */ public boolean updateBook(Book book) { ConnectionProvider cp = new ConnectionProvider(); Connection conn=cp.getConnection(); try { //conn.setAutoCommit(false); String sql="update book set bookname=?,bookathor=?,code=?,bookprice=?,discount=?,bookorder=?,isbn=?,wordcount=?,bookcompany=?,printtime=?,presstime=?,uri=? ,bookcount=?,discription=? where id=?"; PreparedStatement pst=conn.prepareStatement(sql); pst.setString(1, book.getBookName()); pst.setString(2, book.getBookAthor()); pst.setInt(3, book.getCode()); pst.setFloat(4, book.getBookPrice()); pst.setFloat(5, book.getDiscount()); pst.setInt(6, book.getBookOrder()); pst.setInt(7, book.getIsbn()); pst.setInt(8, book.getWordCount()); pst.setString(9, book.getBookCompany()); pst.setString(10, book.getPrintTime());//出版时间 pst.setString(11, book.getPressTime());//印刷时间 pst.setString(12, book.getUri()); pst.setInt(13, book.getBookCount()); pst.setString(14, book.getDiscription()); pst.setInt(15, book.getId()); boolean b=pst.executeUpdate()==1?false:true; //conn.commit(); pst.close(); conn.close(); return b; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return false; } /** * 组装对象，提供代码的重用性 */ public Object populate(ResultSet rs) { Book book = new Book(); try { book.setId(rs.getInt("id")); book.setBookName(rs.getString("bookname")); book.setBookAthor(rs.getString("bookathor")); book.setCode(rs.getInt("code")); book.setBookPrice(rs.getFloat("bookprice")); book.setDiscount(rs.getFloat("discount")); book.setBookOrder(rs.getInt("bookorder")); book.setIsbn(rs.getInt("isbn")); book.setWordCount(rs.getInt("wordcount")); book.setBookCompany(rs.getString("bookcompany")); book.setPrintTime(rs.getString("printtime")); book.setPressTime(rs.getString("presstime")); book.setUri(rs.getString("uri")); book.setBookCount(rs.getInt("bookcount")); book.setDiscription(rs.getString("discription")); book.setInTime(rs.getDate("in_time")); } catch (SQLExcep