warekinddao.java

销售管理系统 随着我国国民经济的持续发展

package com.dao;

import com.tool.JDBConnection;
import java.util.*;
import com.domain.WareKindVO;
import java.sql.*;

public class WareKindDao {
  private JDBConnection connection = null;
  public WareKindDao() {
    connection = new JDBConnection();
    this.connection.creatConnection(); //利用构造方法调用类中的对象对数据库创建连接
  }

  //查询全部的计量单位
  public List kindSelect() {
    List list = new ArrayList();
    WareKindVO kind = null;
    String sql = "select * from tb_kind order by id";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        kind = new WareKindVO();
        kind.setId(Integer.valueOf(rs.getString(1)));
        kind.setKind_number(rs.getString(2));
        kind.setKind_name(rs.getString(3));
        kind.setKind_remark(rs.getString(4));
        list.add(kind);
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return list;
  }

//以员工编号为条件查询信息
  public WareKindVO kindSelectOne(String number) {
    WareKindVO kind = null;
    String sql = "select * from tb_kind where kind_number='" + number + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        kind = new WareKindVO();
        kind.setId(Integer.valueOf(rs.getString(1)));
        kind.setKind_number(rs.getString(2));
        kind.setKind_name(rs.getString(3));
        kind.setKind_remark(rs.getString(4));
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return kind;
  }

//以名称为条件查询
  public WareKindVO kindSelectName(String name) {
    WareKindVO kind = null;
    String sql = "select * from tb_kind where kind_name='" + name + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        kind = new WareKindVO();
        kind.setId(Integer.valueOf(rs.getString(1)));
        kind.setKind_number(rs.getString(2));
        kind.setKind_name(rs.getString(3));
        kind.setKind_remark(rs.getString(4));
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return kind;
  }

//添加操作
  public void kindInsert(WareKindVO vo) {
    String sql = "insert into tb_kind values ('" + vo.getKind_number() + "','" +
        vo.getKind_name() + "','" + vo.getKind_remark() + "')";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //删除操作
  public void kindDelete(Integer id) {
    String sql = "delete from tb_kind where id='" + id + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //修改编号的操作
  public void kindUpdateNumber(Integer id, String number) {
    String unNumber = "kind-" + String.valueOf(id);
    String sql = "update tb_kind set kind_number='" + unNumber +
        "'  where kind_number='" + number + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //修改操作
  public void kindUpdate(WareKindVO vo) {
    String sql = "update tb_kind set kind_name='" + vo.getKind_name() +
        "',kind_remark='" + vo.getKind_remark() + "' where kind_number='" +
        vo.getKind_number() + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

}