jobsinfodao.java

老牌java开发的物流管理系统 详细的我也没有怎么看 好像是恒基的

package com.wl.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.wl.dbconnection.DBManager;

import com.wl.entity.Jobsinfo;

/**
 * 职务信息dao操作方法封装
 * 
 * @author yuan xinfeng
 * 
 */
public class JobsinfoDAO {

	public JobsinfoDAO() {

	}
	boolean flag;

	/**
	 * 查询所有的职务表中的所有信息
	 * 
	 * @return list
	 */
	// -----------------------查询所有的职务表中的所有信息--------------------------------
	public List<Jobsinfo> selectAllJobsinfo() {
		List<Jobsinfo> list = new ArrayList<Jobsinfo>();
		String sql = "select * from jobsinfotable";
		DBManager db = new DBManager();
		db.openDB();
		try {
			db.ps = db.conn.prepareStatement(sql);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("Id");
				String JobsId = rs.getString("JobsId");
				String JobsName = rs.getString("JobsName");
				String DescribleJobs = rs.getString("DescribleJobs");
				Jobsinfo jobsinfo = new Jobsinfo(id, JobsId, JobsName,
						DescribleJobs);
				list.add(jobsinfo);
			}
		} catch (SQLException e) {
			e.printStackTrace();
			System.out.print("数据库连接失败!");
		} finally {
			db.closeDB();
		}
		return list;
	}

	/**
	 * 根据职务信息自动编号查询职务表信息
	 * 
	 * @param id
	 * @return list
	 */
	// ------------------------根据职务信息自动编号查询职务表信息-----------------------------------------
	public Jobsinfo queryId(int id) {
		DBManager db = new DBManager();
		flag = db.openDB();
		Jobsinfo j = null;
		if(flag)
		{
			try {
				db.ps = db.conn.prepareStatement("select * from jobsinfotable where Id=?");
				db.ps.setInt(1, id);
				ResultSet rs = db.ps.executeQuery();
				while(rs.next()) {
					j = new Jobsinfo(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getString(4));
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			finally{
				db.closeDB();
			}
		}
		return j;
	}

	/**
	 * 根据职务编号查询职务表信息
	 * 
	 * @param Jobsid
	 * @return list
	 */
	// ------------------------根据职务编号查询职务表信息-----------------------------------------
	public List<Jobsinfo> selectJobsinfoByJobsid(String Jobsid) {
		List<Jobsinfo> list = new ArrayList<Jobsinfo>();
		String sql = "select * from jobsinfotable where JobsId=?";
		DBManager db = new DBManager();
		db.openDB();
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, Jobsid);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("Id");
				Jobsid = rs.getString("JobsId");
				String JobsName = rs.getString("JobsName");
				String DescribleJobs = rs.getString("DescribleJobs");
				Jobsinfo jobsinfo = new Jobsinfo(id, Jobsid, JobsName,
						DescribleJobs);
				list.add(jobsinfo);
			}
		} catch (SQLException e) {
			System.out.print("数据库连接失败");
			e.printStackTrace();
		}
		return list;

	}

	/**
	 * 根据职务名称查询职务表信息
	 * 
	 * @param JobsName
	 * @return list
	 */
	// ------------------------根据职务名称查询职务表信息-----------------------------------------
	public List<Jobsinfo> selectJobsinfoByJobsName(String JobsName) {
		List<Jobsinfo> list = new ArrayList<Jobsinfo>();
		String sql = "select * from jobsinfotable where JobsName=?";
		DBManager db = new DBManager();
		db.openDB();
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, JobsName);
			ResultSet rs = db.ps.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("Id");
				String Jobsid = rs.getString("JobsId");
				JobsName = rs.getString("JobsName");
				String DescribleJobs = rs.getString("DescribleJobs");
				Jobsinfo jobsinfo = new Jobsinfo(id, Jobsid, JobsName,
						DescribleJobs);
				list.add(jobsinfo);
			}
		} catch (SQLException e) {
			System.out.print("数据库连接失败");
			e.printStackTrace();
		}
		return list;
	}

	/**
	 * 向职务信息表中添加数据
	 * 
	 * @param jobsinfo
	 * @return boolean
	 */

	// -------------------------------向职务信息表中添加数据---------------------------------------
	public boolean insertJobsinfo(Jobsinfo jobsinfo) {
		String sql = "insert into jobsinfotable(JobsId,JobsName,DescribleJobs) values(?,?,?)";
		DBManager db = new DBManager();
		db.openDB();
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, jobsinfo.getJobsId());
			db.ps.setString(2, jobsinfo.getJobsName());
			db.ps.setString(3, jobsinfo.getDescribleJobs());
			db.ps.executeUpdate();
		} catch (SQLException e) {
			System.out.print("数据库连接失败");
		} finally {
			db.closeDB();
		}
		return true;
	}

	/**
	 * 根据职务信息自动编号删除职务表信息
	 * 
	 * @param id
	 * @return boolean
	 */
	// -----------------------------根据职务信息自动编号删除职务表信息------------------------------------
	public boolean delJobsinfoById(int id) {
		String sql = "delete from jobsinfotable where Id=? ";
		DBManager db = new DBManager();
		db.openDB();
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setInt(1, id);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			db.closeDB();
		}
		return true;

	}

	/**
	 * 根据职务编号删除职务表信息
	 * 
	 * @param jobsid
	 * @return boolean
	 */
	// -----------------------------根据职务编号删除职务表信息------------------------------------
	public boolean delJobsinfoByJobsId(String jobsid) {
		String sql = "delete from jobsinfotable where JobsId =? ";
		DBManager db = new DBManager();
		db.openDB();
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, jobsid);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			db.closeDB();
		}
		return true;
	}

	/**
	 * 根据职务名称删除职务表信息
	 * 
	 * @param jobsname
	 * @return boolean
	 */
	// -----------------------------根据职务名称删除职务表信息------------------------------------
	public boolean delJobsinfoByJobsName(String jobsname) {
		String sql = "delete from jobsinfotable where JobsName =? ";
		DBManager db = new DBManager();
		db.openDB();
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, jobsname);
			db.ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			db.closeDB();
		}
		return true;

	}
	/**
	 * 修改职务信息
	 * @return rows
	 */
	public int updateId(Jobsinfo j) {
		int rows = 0;
		DBManager db = new DBManager();
		db.openDB();
		String sql = "update jobsinfotable set jobsid=?,jobsname=?,describlejobs=? where Id=? ";
		try {
			db.ps = db.conn.prepareStatement(sql);
			db.ps.setString(1, j.getJobsId());
			db.ps.setString(2, j.getJobsName());
			db.ps.setString(3, j.getDescribleJobs());
			db.ps.setInt(4, j.getId());
			rows = db.ps.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally{
			db.closeDB();
		}
		return rows;
	}

}