package com.oa.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import com.oa.dao.Admin_Dao;
import com.oa.vo.AdminVO;
import com.oa.vo.CommentVO;
import com.oa.vo.OrderVO;
import com.oa.vo.ProduceVO;
import com.oa.vo.SortVO;
import com.oa.vo.SupplierVO;
import com.oa.vo.UserVO;
import com.servlet.db.ConnectionMYSQL;
public class Admin_Dao_Impl implements Admin_Dao {
ConnectionMYSQL connmysql = new ConnectionMYSQL();
Connection conn = connmysql.getConnection();
PreparedStatement pstmt = null;
ResultSet rs = null;
int test = 0;
public boolean checkAdmin(AdminVO adminvo)throws Exception {
boolean flag = false;
String sql = "select * from manager where admin_username = ? and admin_password = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, adminvo.getAdmin_username());
pstmt.setString(2, adminvo.getAdmin_password());
rs = pstmt.executeQuery();
if(rs.next()){
flag = true;
}
return flag;
}
public AdminVO selectmanager(int adminID)throws Exception{
String sql = "select * from manager where adminID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, adminID);
rs = pstmt.executeQuery();
AdminVO adminvo = null;
if(rs.next()){
adminvo = new AdminVO();
adminvo.setAdminID(rs.getInt("adminID"));
adminvo.setAdmin_username(rs.getString("admin_username"));
adminvo.setAdmin_password(rs.getString("admin_password"));
}
return adminvo;
}
public AdminVO updateAdminByAdminID(int adminID) throws Exception {
String sql = "select * from manager where adminID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, adminID);
rs = pstmt.executeQuery();
AdminVO adminvo = null;
if(rs.next()){
adminvo = new AdminVO();
adminvo.setAdminID(rs.getInt("adminID"));
adminvo.setAdmin_username(rs.getString("admin_username"));
adminvo.setAdmin_password(rs.getString("admin_password"));
}
return adminvo;
}
public boolean updateAdmin(AdminVO adminvo) throws Exception {
boolean flag = false;
String sql = "update manager set admin_username = ?,admin_password = ? where adminID=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, adminvo.getAdmin_username());
pstmt.setString(2, adminvo.getAdmin_password());
pstmt.setInt(3, adminvo.getAdminID());
test = pstmt.executeUpdate();
if(test == 1){
flag = true;
}
return flag;
}
public List<SortVO> selectSort() throws Exception {
String sql = "select * from sort";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
List<SortVO> sortList = new ArrayList<SortVO>();
SortVO sortvo = null;
while(rs.next()){
sortvo = new SortVO();
sortvo.setSortID(rs.getInt("SortID"));
sortvo.setSortName(rs.getString("Sortname"));
sortList.add(sortvo);
}
return sortList;
}
public boolean addSort(SortVO sortvo) throws Exception {
boolean flag = false;
String sql = "insert into sort(Sortname) values(?)";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, sortvo.getSortName());
test = pstmt.executeUpdate();
if(test == 1){
flag = true;
}
return flag;
}
public boolean deleteSort(int sortID) throws Exception {
boolean flag = false;
String sql = "delete from sort where SortID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, sortID);
test = pstmt.executeUpdate();
if(test == 1){
flag = true;
}
return flag;
}
public SortVO updateSortBySortID(int sortID) throws Exception {
String sql = "select * from sort where SortID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, sortID);
rs = pstmt.executeQuery();
SortVO sortvo = null;
if(rs.next()){
sortvo = new SortVO();
sortvo.setSortID(rs.getInt("SortID"));
sortvo.setSortName(rs.getString("Sortname"));
}
return sortvo;
}
public boolean updateSort(SortVO sortvo) throws Exception {
boolean flag = false;
String sql = "update sort set Sortname = ? where SortID=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, sortvo.getSortName());
pstmt.setInt(2, sortvo.getSortID());
test = pstmt.executeUpdate();
if(test == 1){
flag = true;
}
return flag;
}
public List<SupplierVO> selectSupplier() throws Exception {
String sql = "select * from suppliers";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
List<SupplierVO> supplierList = new ArrayList<SupplierVO>();
SupplierVO suppliervo = null;
while(rs.next()){
suppliervo = new SupplierVO();
suppliervo.setSupplierID(rs.getInt("SupplierID"));
suppliervo.setSupplierName(rs.getString("Suppliername"));
suppliervo.setSupplierAddr(rs.getString("Supplieraddr"));
suppliervo.setSupplierphone(rs.getString("Supplierphone"));
supplierList.add(suppliervo);
}
return supplierList;
}
public boolean addSupplier(SupplierVO suppliervo) throws Exception {
boolean flag = false;
String sql = "insert into suppliers(Suppliername,Supplieraddr,Supplierphone) values(?,?,?)";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,suppliervo.getSupplierName());
pstmt.setString(2,suppliervo.getSupplierAddr());
pstmt.setString(3, suppliervo.getSupplierphone());
test = pstmt.executeUpdate();
if(test == 1){
flag = true;
}
return flag;
}
public boolean deleteSupplier(int supplierID) throws Exception {
boolean flag = false;
String sql = "delete from suppliers where SupplierID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, supplierID);
test = pstmt.executeUpdate();
if(test == 1){
flag = true;
}
return flag;
}
public SupplierVO updateSupplierBySupplierID(int supplierID)
throws Exception {
String sql = "select * from suppliers where SupplierID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, supplierID);
rs = pstmt.executeQuery();
SupplierVO suppliervo = null;
if(rs.next()){
suppliervo = new SupplierVO();
suppliervo.setSupplierID(rs.getInt("SupplierID"));
suppliervo.setSupplierName(rs.getString("Suppliername"));
suppliervo.setSupplierAddr(rs.getString("Supplieraddr"));
suppliervo.setSupplierphone(rs.getString("Supplierphone"));
}
return suppliervo;
}
public boolean updateSupplier(SupplierVO suppliervo) throws Exception {
boolean flag = false;
String sql = "update suppliers set Suppliername = ?,Supplieraddr = ?,Supplierphone = ? where SupplierID=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, suppliervo.getSupplierName());
pstmt.setString(2, suppliervo.getSupplierAddr());
pstmt.setString(3, suppliervo.getSupplierphone());
pstmt.setInt(4, suppliervo.getSupplierID());
test = pstmt.executeUpdate();
if(test == 1){
flag = true;
}
return flag;
}
public List<UserVO> selectUser() throws Exception {
String sql = "select * from user";
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
List<UserVO> userList = new ArrayList<UserVO>();
UserVO uservo = null;
while(rs.next()){
uservo = new UserVO();
uservo.setUID(rs.getInt("UID"));
uservo.setUname(rs.getString("Uname"));
uservo.setMobile(rs.getString("Mobile"));
uservo.setEmail(rs.getString("Email"));
uservo.setType(rs.getString("Type"));
uservo.setAddr(rs.getString("Addr"));
uservo.setAccount(rs.getString("Account"));
uservo.setPassword(rs.getString("Password"));
userList.add(uservo);
}
return userList;
}
public List<UserVO> selectUser(int userID)throws Exception{
String sql = "select * from user where UID = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, userID);
rs = pstmt.executeQuery();
List<UserVO> userList = new ArrayList<UserVO>();
UserVO uservo = null;
while(rs.next()){
uservo = new Use
- 1
- 2
- 3
前往页