book源代码.zip

package cn.nongda.dao.impl; import cn.nongda.dao.ManagerDao; import cn.nongda.pojo.dto.BookStatus; import cn.nongda.pojo.entity.Book; import cn.nongda.pojo.entity.Category; import cn.nongda.pojo.entity.Manager; import cn.nongda.pojo.entity.User; import cn.nongda.utils.JDBCUtil; import java.sql.*; import java.util.ArrayList; import java.util.List; public class ManagerDaoImpl implements ManagerDao { /** * 跟据账户查询 * @param account * @return */ @Override public Manager findByAccount(String account) { ResultSet rs =null; PreparedStatement pst=null; Manager manager = null; Connection conn = JDBCUtil.getconn(); String sql = "select * from manager where account = ?"; try { pst = conn.prepareStatement(sql); pst.setString(1,account); rs = pst.executeQuery(); while (rs.next()){ manager=new Manager(); manager.setId(rs.getInt(1)); manager.setAccount(rs.getString(2)); manager.setPassword(rs.getString(3)); manager.setStatus(rs.getInt(4)); manager.setIdentity(rs.getInt(5)); } return manager; } catch (SQLException e) { throw new RuntimeException(e); }finally { JDBCUtil.close(conn,pst,rs); } } @Override public Manager checkPassword(String account, String password) { Connection conn=null; ResultSet rs =null; PreparedStatement pst=null; Manager manager = null; conn = JDBCUtil.getconn(); String sql = "select * from manager where account = ? and password =?"; try { pst = conn.prepareStatement(sql); pst.setString(1,account); pst.setString(2,password); rs = pst.executeQuery(); while (rs.next()){ manager=new Manager(); manager.setId(rs.getInt(1)); manager.setAccount(rs.getString(2)); manager.setPassword(rs.getString(3)); manager.setStatus(rs.getInt(4)); manager.setIdentity(rs.getInt(5)); } return manager; } catch (SQLException e) { throw new RuntimeException(e); }finally { JDBCUtil.close(conn,pst,rs); } } @Override public void add(String account, String password) { Connection conn=null; PreparedStatement pst=null; conn = JDBCUtil.getconn(); String sql = "insert into manager(account,password) values (?,?)"; try { pst=conn.prepareStatement(sql); pst.setString(1,account); pst.setString(2,password); pst.executeUpdate(); } catch (SQLException e) { throw new RuntimeException(e); }finally { JDBCUtil.close(conn,pst); } } @Override public Category findByName(String name) { Connection conn=null; ResultSet rs =null; PreparedStatement pst=null; Category category = null; conn = JDBCUtil.getconn(); String sql = "select * from category where name = ?"; try { pst = conn.prepareStatement(sql); pst.setString(1,name); rs = pst.executeQuery(); while (rs.next()){ category=new Category(); category.setId(rs.getInt(1)); category.setName(rs.getString(2)); category.setManagerId(rs.getInt(3)); if (rs.getDate(4) != null) { category.setCreateTime(rs.getString(4)); } else { category.setCreateTime(null); } if (rs.getDate(5) != null) { category.setUpdateTime(rs.getString(5)); } else { category.setUpdateTime(null); } } return category; } catch (SQLException e) { throw new RuntimeException(e); }finally { JDBCUtil.close(conn,pst,rs); } } @Override public void addCategory(Category category) { PreparedStatement pst=null; Connection conn = JDBCUtil.getconn(); String sql = "insert into category(name,manager_id,create_time,update_time) values (?,?,?,?)"; try { pst=conn.prepareStatement(sql); pst.setString(1,category.getName()); System.out.println("Category Name: " + category.getName()); // 调试输出 pst.setInt(2,category.getManagerId()); pst.setDate(3, Date.valueOf(category.getCreateTime())); pst.setDate(4, Date.valueOf(category.getUpdateTime())); pst.executeUpdate(); } catch (SQLException e) { throw new RuntimeException(e); }finally { JDBCUtil.close(conn,pst); } } @Override public Book findBookByName(String bookName) { ResultSet rs =null; PreparedStatement pst=null; Book book =null; Connection conn = JDBCUtil.getconn(); String sql = "select * from book_message where book_name = ?"; try { pst = conn.prepareStatement(sql); pst.setString(1,bookName); rs = pst.executeQuery(); while (rs.next()){ book = new Book( rs.getInt(1), rs.getString(2), rs.getString(3), rs.getString(4), rs.getInt(5), rs.getInt(6), rs.getInt(7), rs.getString(8), rs.getDouble(9), rs.getString(10), rs.getString(11)); } return book; } catch (SQLException e) { throw new RuntimeException(e); }finally { JDBCUtil.close(conn,pst,rs); } } /** * 跟据目录名称查找目录id * @param categoryName * @return */ @Override public Integer findCategoryId(String categoryName) { ResultSet rs =null; PreparedStatement pst=null; Integer id=null; Connection conn = JDBCUtil.getconn(); String sql = "select id from category where name = ?"; try { pst = conn.prepareStatement(sql); pst.setString(1,categoryName); rs = pst.executeQuery(); while (rs.next()){ id=rs.getInt(1); } return id; } catch (SQLException e) { throw new RuntimeException(e); }finally { JDBCUtil.close(conn,pst,rs); } } /** * 添加图书 * @param book */ @Override public void addBook(Book book) { PreparedStatement pst=null; Connection conn = JDBCUtil.getconn(); String sql = "insert into book_message" + "(book_name, auther, introduction, borrow_count, max_count, category_id, publisher, price, create_time, update_time) values (?,?,?,?,?,?,?,?,?,?)"; try { pst=conn.prepareStatement(sql); pst.setString(1,book.getBookName()); pst.setString(2,book.getAuther()); pst.setString(3,book.getIntroduction()); pst.setInt(4,book.getBorrowCount()); pst.setInt(5,book.getMaxCount()); if (book.getCategoryId()!=null) { pst.setInt(6, book.getCategoryId()); }else { pst.setIn