dutydao.java~3~

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

package com.dao;

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

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

//全部查询
  public List dutySelect() {
    List list = new ArrayList();
    DutyVO duty = null;
    String sql = "select * from tb_duty";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        duty = new DutyVO();
        duty.setId(Integer.valueOf(rs.getString(1)));
        duty.setDuty_number(rs.getString(2));
        duty.setDuty_name(rs.getString(3));
        duty.setDuty_remark(rs.getString(4));
        list.add(duty);
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return list;
  }

  //以名称为条件查询
  public DutyVO unitSelectName(String name) {
    DutyVO duty = null;
    String sql = "select * from tb_duty where duty_name='" + name + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        duty = new DutyVO();
        duty.setId(Integer.valueOf(rs.getString(1)));
        duty.setDuty_number(rs.getString(2));
        duty.setDuty_name(rs.getString(3));
        duty.setDuty_remark(rs.getString(4));
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return duty;
  }

//以编号为条件查询信息
  public DutyVO dutySelectOne(String number) {
    DutyVO duty = null;
    String sql = "select * from tb_duty where duty_number='" + number + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        duty = new DutyVO();
        duty.setId(Integer.valueOf(rs.getString(1)));
        duty.setDuty_number(rs.getString(2));
        duty.setDuty_name(rs.getString(3));
        duty.setDuty_remark(rs.getString(4));
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return duty;
  }

  //修改职务编号
  public void dutyUpdateNumber(String number, Integer id) {
    String sql =
        "update tb_duty set duty_number='" + number +
        "' where id=" + id + "";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

  //添加职务信息
  public void dutyInsert(DutyVO vo) {
    String sql = "insert into tb_duty values ('" + vo.getDuty_number() + "','" +
        vo.getDuty_name() + "','" + vo.getDuty_remark() + "')";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }
}