jobdao.java

这个是j2eejava web 编程精要十五讲的全部源码。对学习java web编程的人来说是很能得的资料

package foton.job;

import java.util.*;
import java.util.Date;
import java.sql.*;
import foton.util.*;
import foton.util.HibernateUtil;
import foton.job.jobInfo;
import foton.util.Condition;
import org.hibernate.*;

/////////////职位管理模块////////////
//////////// 编写 2006-05-017////////////


public class jobDAO {

 Session session;
 Transaction tx;

  transCode trans = new transCode();


//删除职位信息
   public void delJob(String jobID) throws SQLException
   {
     session = HibernateUtil.currentSession();
       tx = session.beginTransaction();
       //int id = Integer.parseInt(jobID);

       try {
      jobInfo info = (jobInfo)session.get(jobInfo.class, new Integer(Integer.parseInt(jobID)));
       session.delete(info);
       tx.commit();
       session.close();
       } catch(HibernateException e) {
        e.printStackTrace();
        tx.rollback();
       }
     }

   //把职位信息插入数据库中
      public void insertJob(jobInfo info) throws SQLException
      {
        session = HibernateUtil.currentSession();
       tx = session.beginTransaction();

       try {
       session.save(info);
       tx.commit();
       session.close();
       } catch(HibernateException e) {
        e.printStackTrace();
        tx.rollback();
       }

      }


        //更新职位信息
         public void updateJob(jobInfo info) throws SQLException
         {
           session = HibernateUtil.currentSession();
           tx = session.beginTransaction();

        try {
          jobInfo job1 = (jobInfo)session.get(jobInfo.class,new Integer(info.getJobID()));
          job1.setAge(info.getAge());
          job1.setDegree(info.getDegree());
          job1.setDeptName(info.getDeptName());
          job1.setIsUrgent(info.getIsUrgent());
          job1.setJobApplyMode(info.getJobApplyMode());
          job1.setJobArea(info.getJobArea());
          job1.setJobDescription(info.getJobDescription());
          job1.setJobIssueDate(info.getJobIssueDate());
          job1.setJobIsValid(info.getJobIsValid());
          job1.setJobName(info.getJobName());
          job1.setJobNature(info.getJobNature());
          job1.setJobNumber(info.getJobNumber());
          job1.setJobRequirement(info.getJobRequirement());
          job1.setJobType(info.getJobType());
          job1.setJobValidDay(info.getJobValidDay());
          job1.setPastValue(info.getPastValue());
          job1.setSalary(info.getSalary());
          job1.setSex(info.getSex());
          job1.setTitle(info.getTitle());
          job1.setWorkYear(info.getWorkYear());

       session.update(job1);
       tx.commit();
       session.close();
       } catch(HibernateException e) {
        e.printStackTrace();
        tx.rollback();
       }
    }



   // 从数据库取出所有的职位信息

    public ArrayList getJob(Condition condition) {

      int pageNum = condition.getPageNum();
         int currPage = condition.getCurrPage();

         int start = currPage * pageNum;
         int end = start + pageNum;

         String jobType = condition.getJobType();
         jobType=trans.transCode(jobType);
         String jobNature = condition.getJobNature();
         jobNature= trans.transCode(jobNature);
         String jobIsValid = condition.getJobIsValid();
         jobIsValid= trans.transCode(jobIsValid);

         StringBuffer sql = new StringBuffer();

         sql.append( "select {j.*} from job j where job_id!='' ");

         if(!jobType.equals(" "))
           sql.append(" and job_Type = '"+jobType+"'");

         if(!jobNature.equals(" "))
          sql.append( " and job_Nature = '"+jobNature+"'");

         if(!jobIsValid.equals(" "))
        sql.append( "  and job_Is_Valid = '"+jobIsValid+"'");

       sql.append(" order by job_issue_date desc");

        session = HibernateUtil.currentSession();
      tx = session.beginTransaction();
      SQLQuery sqlQuery;
      List list = null;
      ArrayList al = new ArrayList();
      ArrayList result = new ArrayList();

      try {
      sqlQuery = session.createSQLQuery(sql.toString());
        sqlQuery.addEntity("j",jobInfo.class);
        al = (ArrayList)sqlQuery.list();

         condition.setRecordNum(al.size());

         for(int i=start;i<end;i++) {
           if(i<al.size())  {
             jobInfo job = (jobInfo) al.get(i);
             result.add(job);
           }
         }
         condition.setResult(result);
      tx.commit();
      session.close();
      } catch(HibernateException e) {
       e.printStackTrace();
       tx.rollback();
      }

    return result;
   }

   //// 从数据库取出特定的职位信息

        public jobInfo getJob(String jobID) {

          jobInfo info = new jobInfo();

          session = HibernateUtil.currentSession();
          tx = session.beginTransaction();
          SQLQuery sqlQuery;
          List list = null;

          try {
            sqlQuery = session.createSQLQuery("select {j.*} from job j where job_id=?");
            sqlQuery.setInteger(0, Integer.parseInt(jobID));
            sqlQuery.addEntity("j", jobInfo.class);
            list = sqlQuery.list();
            for (int i = 0; i < list.size(); i++) {
              info = (jobInfo) list.get(i);
            }

            tx.commit();
            session.close();
          }
          catch (HibernateException e) {
            e.printStackTrace();
            tx.rollback();
          }

          return info;
        }


}