java实训项目 安博教育集团

package com.ambow.ecport.imp; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import java.util.List; import com.ambow.ecport.dao.ProductDao; import com.ambow.ecport.entity.Category; import com.ambow.ecport.entity.Product; import com.ambow.ecport.entity.User; import com.ambow.ecport.exception.ManagerProductException; import com.ambow.ecport.util.DBConnection; /** * 管理数据库中产品表的数据的增删改查操作的类 实现接口中定义的方法 * * @author user * */ public class ProductDaoImp implements ProductDao { // 增加产品的 SQL 语句 private String addSql = "INSERT INTO product (name,descriptions,basePrice,category_id,author,publish,pages, images) " + "VALUES ( ?, ?, ?, ?, ?, ?, ?, ?);"; private String updateSql = "update product set name=?,author=?,publish=?,pages=?,images=?,basePrice=? where category_id=?"; private String deleteSql = "delete from product where product_id=?"; private String selectByID = "select * from product where product_id=?"; private String selectAll = "select * from product"; private String selectCount = "select count(*) as count from product"; /** * 在数据库中增加新的产品 * * @param product * 要添加到数据库中的产品信息 * @throws 抛出专门处理 * product 类型的异常 */ public void add(Product product) throws ManagerProductException { // 定义数据库连接操作所需要的对象 Connection conn = null; PreparedStatement ps = null; DBConnection dbc = null; // 定义数据库连接类对象，用于连接数据库 try { dbc = new DBConnection(); conn = dbc.getConnection(); // 预处理 SQL 语句 ps = conn.prepareStatement(addSql); // 给 SQL 语句中的 ? 赋值 ps.setString(1, product.getName()); ps.setString(2, product.getDescriptions()); ps.setDouble(3, product.getBasePrice()); ps.setInt(4, product.getCategory().getId().intValue()); // 类型 id ps.setString(5, product.getAuthor()); ps.setString(6, product.getPublish()); ps.setInt(7, product.getPages()); // 页数 ps.setString(8, product.getImages()); boolean b = ps.execute(); System.out.println("插入数据的结果 :" + b); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { dbc.closeConnection(conn); } } /** * 删除数据库中一个产品 * * @param product * 要删除的产品信息 * @throws 抛出专门处理 * product 类型的异常 */ public void delete(Product product) throws ManagerProductException { // 定义数据库连接操作所需要的对象 Connection conn = null; PreparedStatement ps = null; DBConnection dbc = null; // 定义数据库连接类对象，用于连接数据库 try { dbc = new DBConnection(); conn = dbc.getConnection(); // 预处理 SQL 语句 ps = conn.prepareStatement(this.deleteSql); // delete from product where product_id=? // 给 SQL 语句中的 ? 赋值 ps.setInt(1, product.getId().intValue()); boolean b = ps.execute(); System.out.println("删除数据的结果 :" + b); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { dbc.closeConnection(conn); } } /** * 更新数据库中一个用户的信息 * * @param product * 要修改的产品信息 * @throws 抛出专门处理 * product 类型的异常 */ public void update(Product product) throws ManagerProductException { // 定义数据库连接操作所需要的对象 Connection conn = null; PreparedStatement ps = null; DBConnection dbc = null; // 定义数据库连接类对象，用于连接数据库 try { dbc = new DBConnection(); conn = dbc.getConnection(); // 预处理 SQL 语句 ps = conn.prepareStatement(this.updateSql); // 给 SQL 语句中的 ? 赋值 ps.setString(1, product.getName()); ps.setString(2, product.getAuthor()); ps.setString(3, product.getPublish()); ps.setInt(4, product.getPages()); // 页数 ps.setString(5, product.getImages()); ps.setDouble(6, product.getBasePrice()); ps.setInt(7, product.getCategory().getId().intValue()); // 类型 id ps.setInt(8, product.getId().intValue()); boolean b = ps.execute(); System.out.println("修改数据的结果 :" + b); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { dbc.closeConnection(conn); } } /** * 根据 id ，查找产品 * * @param id * 要查找的产品的 id * @return Product 查找到的产品对象 * @throws 抛出专门处理 * product 类型的异常 */ public Product findById(Integer id) throws ManagerProductException { Product pro=new Product(); Category category=new Category(); int category_id=0; try { DBConnection dbconn = new DBConnection(); Connection conn=dbconn.getConnection(); Statement stmt=conn.createStatement(); ResultSet rs=stmt.executeQuery("select * from product where product_id="+id); while(rs.next()) { pro.setId(rs.getInt("product_id")); pro.setName(rs.getString("name")); pro.setAuthor(rs.getString("author")); pro.setPublish(rs.getString("publish")); pro.setPages(rs.getInt("pages")); pro.setImages(rs.getString("images")); pro.setBasePrice(rs.getDouble("basePrice")); pro.setDescriptions(rs.getString("descriptions")); category_id=rs.getInt("category_id"); DBConnection dbconn2 = new DBConnection(); Connection conn2=dbconn2.getConnection(); Statement stmt2=conn2.createStatement(); ResultSet rss=stmt2.executeQuery("select * from category where category_id="+category_id); while(rss.next()) { category.setId(rss.getInt("category_id")); category.setName(rss.getString("name")); category.setDescriptions(rss.getString("descriptions")); pro.setCategory(category); } stmt2.close(); conn2.close(); } stmt.close(); conn.close(); } catch(Exception e) { System.out.println(e.getMessage()); } return pro; } /** * 查找全部产品 * * @return 返回保存查找到的所有产品的集合对象 * @throws 抛出专门处理 * product 类型的异常 */ public Collection findAll() throws ManagerProductException { Collection list=new ArrayList(); int category_id=0; try { DBConnection dbconn = new DBConnection(); Connection conn=dbconn.getConnection(); Statement stmt=conn.createStatement(); ResultSet rs=stmt.executeQuery("select * from product"); while(rs.next()) { Product pro=new Product(); pro.setId(rs.getInt("product_id")); pro.setName(rs.getString("name")); pro.setAuthor(rs.getString("author")); pro.setPublish(rs.getString("publish")); pro.setPages(rs.getInt("pages")); pro.setImages(rs.getString("images")); pro.setBasePrice(rs.getDouble("basePrice")); pro.setDescriptions(rs.getString("descriptions")); category_id=rs.getInt("category_id"); Statement stmt2=conn.createStatement(); ResultSet rss=stmt2.executeQuery("select * from category where category_id="+category_id); while(rss.next()) { Category category=new Category(); category.setId(Integer.valueOf(rss.getInt("category_id"))); category.setName(rss.getString("name")); category.setDescriptions(rss.getString("descriptions")); pro.setCategory(category); list.add(pro); } } } catch(Exception e) { System.out.println(e.getMess