ADD file via upload

DishDaoImplwcy.java

@@ -0,0 +1,218 @@
+package dao.impl;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+
+import dao.DishDAOwcy;
+import domain.Dishwcy;
+
+public class DishDaoImplwcy implements DishDAOwcy {
+
+	@Override
+	public ArrayList<Dishwcy> findAll() {
+		String sql ="select *from dish";
+		ArrayList<Dishwcy> dishs=new ArrayList<Dishwcy>();
+		try {
+			
+			Connection conn=JDBCUtil.getConnection();
+			
+			PreparedStatement pstm =conn.prepareStatement(sql);
+			ResultSet rs=pstm.executeQuery(sql);
+			while(rs.next()) {
+				Dishwcy pr=new Dishwcy();
+				pr.setDishid(rs.getString("dishid"));
+				pr.setCategory(rs.getString("category"));
+				pr.setCname(rs.getString("cname"));
+				pr.setImage(rs.getString("image"));
+				pr.setDescn(rs.getString("descn"));
+				pr.setUnitcost(rs.getDouble("unitcost"));
+				dishs.add(pr);
+			}
+		} catch (Exception e) {
+			// TODO 自动生成的 catch 块
+			e.printStackTrace();
+		}
+		// TODO 自动生成的方法存根
+		return dishs;
+	}
+
+	@Override
+	public Dishwcy findById(String dishid) {
+		Connection conn=null;
+		PreparedStatement pstm =null;
+		ResultSet rs=null;
+		try {
+			
+			conn=JDBCUtil.getConnection();
+			String sql="select * from dish where dishid=?";
+			pstm = conn.prepareStatement(sql);
+			pstm.setString(1, dishid);
+			rs=pstm.executeQuery();
+			if(rs.next()) {
+				Dishwcy pr=new Dishwcy();
+				pr.setDishid(rs.getString("dishid"));
+				pr.setCategory(rs.getString("category"));
+				pr.setCname(rs.getString("cname"));
+				pr.setImage(rs.getString("image"));
+				pr.setDescn(rs.getString("descn"));
+				pr.setUnitcost(rs.getDouble("unitcost"));
+				return pr;
+			}
+		} catch (Exception e) {
+			// TODO 自动生成的 catch 块
+			e.printStackTrace();
+		}finally {
+			if(rs!=null) {
+				try {
+					rs.close();
+				} catch (SQLException e) {
+				}
+		}
+		if(pstm!=null) {
+			try {
+				rs.close();
+			} catch (SQLException e) {
+			}
+	}
+		if(pstm!=null) {
+			try {
+				rs.close();
+			} catch (SQLException e) {
+			}
+	}
+}
+		return null;
+	}
+
+	@Override
+	public ArrayList<Dishwcy> findByCategory(String category) {
+		Connection conn =null;
+		PreparedStatement pstm =null;
+		ResultSet rs=null;
+		ArrayList<Dishwcy> dishs=new ArrayList<Dishwcy>();
+		
+		try {
+			conn=JDBCUtil.getConnection();
+			String sql="select * from dish where category=?";
+			pstm = conn.prepareStatement(sql);
+			pstm.setString(1, category);
+			rs=pstm.executeQuery();
+			while(rs.next()) {
+				Dishwcy pr=new Dishwcy();
+				pr.setDishid(rs.getString("dishid"));
+				pr.setCategory(rs.getString("category"));
+				pr.setCname(rs.getString("cname"));
+				pr.setImage(rs.getString("image"));
+				pr.setDescn(rs.getString("descn"));;
+				pr.setUnitcost(rs.getDouble("unitcost"));
+				dishs.add(pr);
+			}
+			rs.close();
+			pstm.close();
+			conn.close();
+		} catch (Exception e) {
+			// TODO 自动生成的 catch 块
+			e.printStackTrace();
+		}finally {
+			if(rs!=null) {
+				try {
+					rs.close();
+				} catch (SQLException e) {
+				}
+		}
+		if(pstm!=null) {
+			try {
+				rs.close();
+			} catch (SQLException e) {
+			}
+	}
+		if(pstm!=null) {
+			try {
+				rs.close();
+			} catch (SQLException e) {
+			}
+	}
+}
+		return dishs;
+	}
+
+	@Override
+	public int modify(Dishwcy dish) {
+		String sql="update info ? ?";
+		try {
+			
+			Connection conn=JDBCUtil.getConnection();
+			
+			PreparedStatement pstm = conn.prepareStatement(sql);
+				Dishwcy pr=new Dishwcy();
+				pstm.setString(1, pr.getDishid());
+				pstm.setString(2, pr.getCategory());
+				pstm.setString(3, pr.getCname());
+				pstm.setString(4, pr.getImage());
+				pstm.setString(5, pr.getDescn());
+				pstm.setDouble(6, pr.getUnitcost());
+				int affectedRows = pstm.executeUpdate();
+				System.out.printf("成功更新%d条数据。\n",affectedRows);
+		} catch (Exception e) {
+			// TODO 自动生成的 catch 块
+			e.printStackTrace();
+		}
+		// TODO 自动生成的方法存根
+		return 0;
+	}
+
+	@Override
+	public int delete(Dishwcy dish) {
+		String sql="delect from dish where?";
+		try {
+			
+			Connection conn=JDBCUtil.getConnection();
+			PreparedStatement pstm = conn.prepareStatement(sql);
+			Dishwcy pr=new Dishwcy();
+			pstm.setString(1, pr.getDishid());
+			pstm.setString(2, pr.getCategory());
+			pstm.setString(3, pr.getCname());
+			pstm.setString(4, pr.getImage());
+			pstm.setString(5, pr.getDescn());
+			pstm.setDouble(6, pr.getUnitcost());
+			int affectedRows = pstm.executeUpdate();
+			System.out.printf("成功删除%d条数据。\n",affectedRows);
+
+		} catch (Exception e) {
+			// TODO 自动生成的 catch 块
+			e.printStackTrace();
+		}
+		// TODO 自动生成的方法存根
+		return 0;
+	}
+
+	@Override
+	public int insert(Dishwcy dish) {
+		try {
+			
+			Connection conn=JDBCUtil.getConnection();
+			String sql="insert into dish values(?,?,?,?,?,?)";
+			PreparedStatement pstm = conn.prepareStatement(sql);
+			
+				Dishwcy pr=new Dishwcy();
+				pstm.setString(1, pr.getDishid());
+				pstm.setString(2, pr.getCategory());
+				pstm.setString(3, pr.getCname());
+				pstm.setString(4, pr.getImage());
+				pstm.setString(5, pr.getDescn());
+				pstm.setDouble(6, pr.getUnitcost());
+				
+				int affectedRows=pstm.executeUpdate();
+				System.out.printf("成功插入%d条数据。\n",affectedRows);
+				
+		} catch (Exception e) {
+			return -1;
+		}
+		return 0;
+	}
+
+	
+}