database.java

办公自动化系统,有人事资源管理模块,考勤管理,审批管理,权限设定等.

package com.lovo.dao.mjy;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.GregorianCalendar;
import java.util.Vector;

import com.lovo.po.mjy.EmpPo;
import com.lovo.po.mjy.LeavePo;
import com.lovo.po.mjy.WorkInfoPo;
import com.lovo.util.DBConnection;
import com.lovo.vo.mjy.TermVo;
import com.mysql.jdbc.PreparedStatement;

public class DataBase {
	
	
	public DataBase(){
		co = DBConnection.getConnection();
	}
	private Connection co=null;
	private PreparedStatement pre = null;
	private ResultSet rs = null;
	
	//查询所有员工的信息
	public Vector getSelectAll(EmpPo e){
		Vector vector = new Vector();
		try {
			pre = (PreparedStatement) co.prepareStatement(SqlSentence.SQL_SELECT_ALL);
			pre.setInt(1,e.getStart());
			pre.setInt(2, 10);
			rs = pre.executeQuery();
			while(rs.next()){
				EmpPo ep = new EmpPo();
				ep.setName(rs.getString(1));
				ep.setGongli(rs.getString(2));
				ep.setTanqing(rs.getString(3));
				ep.setYear(rs.getString(4));
				vector.add(ep);
			}
		}catch (SQLException e1) {
			e1.printStackTrace();
		}
		this.close();
		return vector;
	}
	//查询员工个人信息
	public Vector getSelectPIM(EmpPo e){
		Vector vector = new Vector();
		try {
			pre = (PreparedStatement) co.prepareStatement(SqlSentence.SQL_SELECT_PIM);
			pre.setString(1,e.getId());
			pre.setInt(2,e.getStart());
			pre.setInt(3, 10);
			rs = pre.executeQuery();
			while(rs.next()){
				EmpPo ep = new EmpPo();
				ep.setMyWorkInfoPo(new WorkInfoPo());
				ep.setLaevePo(new LeavePo());
				ep.setName(rs.getString(1));
				ep.getMyWorkInfoPo().getMyDepartment().setName(rs.getString(2));
				ep.getMyWorkInfoPo().getMyPosition().setName(rs.getString(3));
				ep.getLaevePo().setStartTime(rs.getDate(4).toString());
				ep.getLaevePo().setOverTime(rs.getDate(5).toString());
				ep.getLaevePo().setReason(rs.getString(6));
				ep.setTianShu(rs.getString(7));
				vector.add(ep);
			}
		} catch (SQLException e1) {
			e1.printStackTrace();
		}
		this.close();
		return vector;
		
	}
	//查询员工个人有多少条记录
	public EmpPo getCountB(EmpPo e){
		Vector vector = new Vector();
		EmpPo ep = new EmpPo();
		try {
			pre = (PreparedStatement) co.prepareStatement(SqlSentence.SQL_COUNTB);
			pre.setString(1,e.getId());
			rs = pre.executeQuery();
			while(rs.next()){
				ep.setCount(rs.getInt(1));
			}
		} catch (SQLException e1) {
			e1.printStackTrace();
			ep.setCount(0);
		}
		this.close();
		return ep;
		
	}
	//查询所有员工一共有多少条记录
	public EmpPo getCountA(){
		EmpPo ep = new EmpPo();
		try {
			pre = (PreparedStatement) co.prepareStatement(SqlSentence.SQL_COUNTA);
			rs = pre.executeQuery();
			while(rs.next()){
				ep.setYear(rs.getString(1));
				ep.setCount(rs.getInt(2));
			}
		}catch (SQLException e1) {
			ep.setYear("");
			ep.setCount(Integer.parseInt("0"));
		}
		this.close();
		return ep;
	}
	//更新据库的初始数据
	public boolean update(boolean isInitialize){
		if(isInitialize){
			try {
				pre = (PreparedStatement) co.prepareStatement(SqlSentence.SQL_UPDATE);
				if(pre.executeUpdate()>=0){
	    			return true;
	            }else{
	            	return false;
	            }
			} catch (SQLException e) {
			}
			this.closeA();
			return false;
		}else{
			return false;
		}
	}
//	向数据库里插入当前年份
	public boolean updateYear(EmpPo ep){
		try {
			pre = (PreparedStatement) co.prepareStatement(SqlSentence.SQL_UPTADA_YEAR);
			pre.setString(1,ep.getYear());
			if(pre.executeUpdate()>=0){
    			return true;
            }else{
            	return false;
            }
		} catch (SQLException e) {
		}
		this.closeA();
		return false;
	}
	//关闭链接1
	private void closeA(){
		try {
			pre.close();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		try {
			co.close();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
	}
	//关闭链接2
	private void close(){
		try {
			rs.close();
		} catch (SQLException e1) {
			// TODO 自动生成 catch 块
			e1.printStackTrace();
		}
		try {
			pre.close();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		try {
			co.close();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
	}

}