saledao.java

好的超市源码供大家下载

package dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Vector;

import vo.SaleProductVo;

import common.jdbc.DbConnection;
import common.jdbc.DbException;
import common.jdbc.SqlConst;

/**
 * 销售有关操作
 * @author linfeng
 *
 */
public class SaleDao {
  
  /**
   * 获得销售全部信息
   * @return vector
   */
  public Vector getSaleInfo() {
    Vector vector = new Vector();
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet set = null;
    try {
      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(SqlConst.SELECT_SALE_INFO);
      set = stmt.executeQuery();
      while (set.next()) {
        int productId = set.getInt(1);
        String productName = set.getString(2);
        String productType = set.getString(3);
        double productPrice = set.getDouble(4);
        double pricePct = set.getDouble(5);
        int saleNum = set.getInt(6);
        double saleSum = set.getDouble(7);
        String saleDate = set.getString(8);
        SaleProductVo value = new SaleProductVo(productId, productName,
            productType, productPrice,pricePct, saleNum,saleSum, saleDate);
        vector.addElement(value);
      }
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }

    return vector;
  }

  /**
   * 通过输入的商品编号获得全部销售信息
   * @param inputId 商品编号
   * @return v
   */
  public Vector getSaleById(int inputId) {
    Vector v = new Vector();
    Connection con = null;
    PreparedStatement stmt = null;
    boolean flag = false;
    ResultSet set = null;
    try {
      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(SqlConst.SELECT_SALE_BY_ID);
      stmt.setInt(1, inputId);
      set = stmt.executeQuery();
      while (set.next()) {
        int productId = set.getInt(1);
        String productName = set.getString(2);
        String productType = set.getString(3);
        double productPrice = set.getDouble(4);
        double pricePct = set.getDouble(5);
        int saleNum = set.getInt(6);
        double saleSum = set.getDouble(7);
        String saleDate = set.getString(8);
        SaleProductVo value = new SaleProductVo(productId, productName,
            productType, productPrice,pricePct, saleNum,saleSum, saleDate);
        v.addElement(value);
      }
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }
    return v;
  }

  /**
   * 通过输入的商品名称获得全部销售信息
   * @param inputName 商品名称
   * @return v
   */
  public Vector getSaleByName(String inputName) {
    Vector v = new Vector();
    Connection con = null;
    PreparedStatement stmt = null;
    boolean flag = false;
    ResultSet set = null;
    try {
      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(SqlConst.SELECT_SALE_BY_NAME);
      stmt.setString(1, inputName);
      set = stmt.executeQuery();
      while (set.next()) {
        int productId = set.getInt(1);
        String productName = set.getString(2);
        String productType = set.getString(3);
        double productPrice = set.getDouble(4);
        double pricePct = set.getDouble(5);
        int saleNum = set.getInt(6);
        double saleSum = set.getDouble(7);
        String saleDate = set.getString(8);
        SaleProductVo value = new SaleProductVo(productId, productName,
            productType, productPrice,pricePct, saleNum,saleSum, saleDate);
        v.addElement(value);
      }
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }
    return v;
  }

  /**
   * 通过输入的商品类型获得全部销售信息
   * @param inputType 商品类型
   * @return v
   */
  public Vector getSaleByType(String inputType) {
    Vector v = new Vector();
    Connection con = null;
    PreparedStatement stmt = null;
    boolean flag = false;
    ResultSet set = null;
    try {
      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(SqlConst.SELECT_SALE_BY_TYPE);
      stmt.setString(1, inputType);
      set = stmt.executeQuery();
      while (set.next()) {
        int productId = set.getInt(1);
        String productName = set.getString(2);
        String productType = set.getString(3);
        double productPrice = set.getDouble(4);
        double pricePct = set.getDouble(5);
        int saleNum = set.getInt(6);
        double saleSum = set.getDouble(7);
        String saleDate = set.getString(8);
        SaleProductVo value = new SaleProductVo(productId, productName,
            productType, productPrice,pricePct, saleNum,saleSum, saleDate);
        v.addElement(value);
      }
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }
    return v;
  }

  /**
   * 通过输入的售出时间获得全部销售信息
   * @param inputDate 售出时间
   * @return v
   */
  public Vector getSaleByDate(String inputDate) {
    Vector v = new Vector();
    Connection con = null;
    PreparedStatement stmt = null;
    boolean flag = false;
    ResultSet set = null;
    try {
      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(SqlConst.SELECT_SALE_BY_DATE);
      stmt.setString(1, inputDate);
      set = stmt.executeQuery();
      while (set.next()) {
        int productId = set.getInt(1);
        String productName = set.getString(2);
        String productType = set.getString(3);
        double productPrice = set.getDouble(4);
        double pricePct = set.getDouble(5);
        int saleNum = set.getInt(6);
        double saleSum = set.getDouble(7);
        String saleDate = set.getString(8);
        SaleProductVo value = new SaleProductVo(productId, productName,
            productType, productPrice,pricePct, saleNum,saleSum, saleDate);
        v.addElement(value);
      }
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }
    return v;
  }

  /**
   * 将输入的销售信息插入到数据库中
   * @param value SaleProductVo对象
   * @return flag
   * @throws DbException 自定义异常
   */
  public boolean insertSale(SaleProductVo value) throws DbException {
    Connection con = null;
    PreparedStatement stmt = null;
    boolean flag = false;
    try {

      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(SqlConst.INSERT_SALE);
      stmt.setInt(1, value.getProduct_id());
      stmt.setString(2, value.getProduct_name());
      stmt.setString(3, value.getProduct_type());
      stmt.setDouble(4, value.getProduct_price());
      stmt.setDouble(5, value.getPrice_pct());
      stmt.setInt(6, value.getSale_num());
      stmt.setDouble(7, value.getSale_sum());
      stmt.setString(8, value.getSale_date());

      int count = stmt.executeUpdate();
      if (count != 0) {
        flag = true;
      }
    } catch (SQLException e) {
      System.out.println(e.getMessage());
    }
    return flag;

  }
}