门户网站代码和数据库

package Tgnet; import java.sql.*; import java.util.*; public class ProductsDao { // 管理员查找数据库中有的总数据 public static int getSupplierTotal() { int ptotal = 0; ResultSet rs = null; String strSql = "select count(*) from Products"; try { rs = baseDao.execSelectSql(strSql); if (rs.next()) { ptotal = rs.getInt(1); } } catch (Exception ex) { System.out.print("getSupplierTotal:" + ex.getMessage()); } return ptotal; } // 用户登陆后根据自己的ID查找数据库中有的总数据 public static int getSupplierTotal(int userID) { int ptotal = 0; ResultSet rs = null; String strSql = "select count(*) from Products where=" + userID + "and StateValue<>3"; try { rs = baseDao.execSelectSql(strSql); if (rs.next()) { ptotal = rs.getInt(1); } } catch (Exception ex) { System.out.print("getSupplierTotal:" + ex.getMessage()); } return ptotal; } // 用户 public static List getProductsList(int userID, int pPage, int pSize) { List productsList = new ArrayList(); int p = (pPage - 1) * pSize; String strSql = "select top pSize * from Products where ProductID not in (select top " + p + " ProductID from Products where UserID=" + userID + "and StateValue<>3 order by ProductID )and UserID=" + userID + " and StateValue<>3 order by ProductID"; ResultSet rs = null; try { rs = baseDao.execSelectSql(strSql); while (rs.next()) { Products product = new Products(); fillSupplier(product, rs); productsList.add(product); } } catch (Exception ex) { System.out.println("用户:" + ex.getMessage()); } baseDao.closeAll(rs, null, null); return productsList; } public static void fillSupplier(Products product, ResultSet rs) throws SQLException { product.setProductID(rs.getInt(1)); product.setProductName(rs.getString(2)); product.setSupplierID(rs.getInt(3)); product.setCategoryID(rs.getInt(4)); product.setUnitPrice(rs.getString(5)); product.setProductDes(rs.getString(6)); product.setUserID(rs.getInt(7)); product.setUpdatedDate(rs.getString(8)); product.setPicture(rs.getString(9)); product.setStateValue(rs.getInt(10)); } // 管理员的 public static List getProductsList(int pPage, int pSize) { List productsList = new ArrayList(); int p = (pPage - 1) * pSize; String strSql = "select top " + pSize + " * from Products where ProductID not in (select top " + p + " ProductID from Products )"; ResultSet rs = null; try { rs = baseDao.execSelectSql(strSql); while (rs.next()) { Products product = new Products(); fillSupplier(product, rs); productsList.add(product); } } catch (Exception ex) { System.out.println("getSupplierList:" + ex.getMessage()); } baseDao.closeAll(rs, null, null); return productsList; } // 产品信息 public List listProducts(int CategoryID) { List list = new ArrayList(); String strSql = "select * from Products where CategoryID=" + CategoryID; // String mysql="select top "+pageSize+" * from messageInfo where id not // in"; // mysql+="(select top "+(curpage-1)*pageSize+" id from messageInfo // where receiveUname='"+uname+"' order by id )"; // mysql+=" and receiveUname='"+uname+"' order by id"; try { ResultSet rs = baseDao.execSelectSql(strSql); while (rs.next()) { Products you = new Products(); you.setProductID(rs.getInt(1)); you.setProductName(rs.getString(2)); you.setSupplierID(rs.getInt(3)); you.setCategoryID(rs.getInt(4)); you.setUnitPrice(rs.getString(5)); you.setProductDes(rs.getString(6)); you.setUserID(rs.getInt(7)); you.setUpdatedDate(rs.getString(8)); you.setPicture(rs.getString(9)); you.setStateValue(rs.getInt(10)); list.add(you); } } catch (Exception ex) { System.out.print("有异常》4》" + ex.getMessage()); } return list; } public static int getMsgCount() { int msgCount = 0; String strSql = "select count(*) from Products"; try { ResultSet rs = baseDao.execSelectSql(strSql); while (rs.next()) { msgCount = rs.getInt(1); } } catch (Exception ex) { System.out.print("getMsgCount:" + ex.getMessage()); } return msgCount; } public static List listProducts2(int pcurPage, int ppageSize) { List list = new ArrayList(); int p = (pcurPage - 1) * ppageSize; // String strSql="select * from Products"; String strSql = "select top " + ppageSize + " * from Products where ProductID not in"; strSql += "(select top " +p + " ProductID from Products order by ProductID)order by ProductID"; try { ResultSet rs = baseDao.execSelectSql(strSql); while (rs.next()) { Products you = new Products(); you.setProductID(rs.getInt(1)); you.setProductName(rs.getString(2)); you.setSupplierID(rs.getInt(3)); you.setCategoryID(rs.getInt(4)); you.setUnitPrice(rs.getString(5)); you.setProductDes(rs.getString(6)); you.setUserID(rs.getInt(7)); you.setUpdatedDate(rs.getString(8)); you.setPicture(rs.getString(9)); you.setStateValue(rs.getInt(10)); you.setHitCount(rs.getInt(11)); you.setScore(rs.getInt(12)); list.add(you); } } catch (Exception ex) { System.out.print("有异常》中间》" + ex.getMessage()); } return list; } public List listProducts2() { List list = new ArrayList(); String strSql = "select * from Products"; // String strSql="select top "+pSize+" * from Products where id not in"; // strSql+="(select top "+(pPage-1)*pSize+" id from messageInfo)"; // mysql+=" and receiveUname='"+uname+"' order by id"; try { ResultSet rs = baseDao.execSelectSql(strSql); while (rs.next()) { Products you = new Products(); you.setProductID(rs.getInt(1)); you.setProductName(rs.getString(2)); you.setSupplierID(rs.getInt(3)); you.setCategoryID(rs.getInt(4)); you.setUnitPrice(rs.getString(5)); you.setProductDes(rs.getString(6)); you.setUserID(rs.getInt(7)); you.setUpdatedDate(rs.getString(8)); you.setPicture(rs.getString(9)); you.setStateValue(rs.getInt(10)); you.setHitCount(rs.getInt(11)); you.setScore(rs.getInt(12)); list.add(you); } } catch (Exception ex) { System.out.print("有异常》6》" + ex.getMessage()); } return list; } // 电子数码显示 public static List getselect() { List list = new ArrayList(); Connection con = null; PreparedStatement psta = null; ResultSet rs = null; String str = "select * from products where CategoryID=4"; try { con = baseDao.getCon(); psta = con.prepareStatement(str); rs = psta.executeQuery(); while (rs.next()) { Products tt = new Products(); tt.setProductName(rs.getString("productName")); tt.setUnitPrice(rs.getString("UnitPrice")); tt.setProductDes(rs.getString("ProductDes")); tt.setUpdatedDate(rs.getString("UpdatedDate")); list.add(tt); } } catch (Exception e) { e.printStackTrace(); } finally { } return list; } // 查询 public Products findsuppliers(int ProductID) { Products ms = new Products(); String strSql = "select * from Products where ProductID=" + ProductID; try { ResultSet rs = baseDao.execSelectSql(strSql); while (rs.next()) { ms.setProductID(rs.getInt(1)); ms.setProductName(rs.getString(2)); ms.setSupplierID(rs.getInt(3)); ms.setCategoryID(rs.getInt(4)); ms.setUnitPrice(rs.getString(5)); ms.setProductDes(rs.getString(6)); ms.setUserID(rs.getInt(7)); ms.setUpdatedDate(rs.getString(8)); ms.setPicture(rs.getString(9)); ms.setStateValue(rs.getShort(10)); } } catch (Exception ex) { } return ms; } // 修改更新 public int update(int ProductID, int statevalue) { int q = 0; String strSql = "update Products set St