yewudao.java

本程序使用struts+hibernate实现的oa办公系统

package com.km.yewu.data;

import com.km.util.*;

import java.sql.*;
import java.util.Iterator;

import net.sf.hibernate.*;
import net.sf.hibernate.cfg.*;

/**
 * 本类用来操作和业务有关的动作。
 * */
public class YewuDAO {

  /**
   * 新增一条业务
   * */
  public String createYewu(Yewu yewu) {
    String universalid = "";
    Session session = null;
    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      Transaction tx = session.beginTransaction();
      //新增记录
      universalid = (String) session.save(yewu);
      tx.commit();
      session.close();
    }
    catch (HibernateException e) {
      sessionClose(session);
      e.printStackTrace();
    }
    finally {
      sessionClose(session);
    }

    return universalid;
  }

  /**
   * 修改业务
   * */
  public void updateYewu(Yewu yewu) {
    Session session = null;
    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      Transaction tx = session.beginTransaction();

      //修改记录
      session.update(yewu);
      tx.commit();
      session.close();
    }
    catch (Exception e) {
      sessionClose(session);
      e.printStackTrace();
    }
    finally {
      sessionClose(session);
    }

  }

  /**
   * 查询所有的业务并进行分页显示
   * */
  public PageListData getAllyewu(String ownerid, PageListData pageList) {
    String sqlStr = "";
    String addSql = " order by datetime desc";
    Connection connection = null;
    Statement statement = null;
    ResultSet resultSet = null;
    try {
      sqlStr = "select * from yewu where ownerid = '" + ownerid + "'";

      connection = com.db.ConnectionPool.getConnection();
      statement = connection.createStatement();
      PageQuery pageQuery = new PageQuery();
      resultSet = pageQuery.sqlQueryPage(statement, sqlStr, addSql,
                                         pageList);
      for (int i = 0; i < pageList.getPageSize() && resultSet.next(); i++) {
        Yewu yewu = new Yewu();

        yewu.setUniversalid(resultSet.getString("universalid"));
        yewu.setOwnerid(resultSet.getString("ownerid"));
        yewu.setCustomer(resultSet.getString("customer"));
        yewu.setContent(resultSet.getString("content"));
        yewu.setMemo(resultSet.getString("memo"));
        yewu.setTitle(resultSet.getString("title"));
        yewu.setDatetime(resultSet.getString("datetime"));
        yewu.setAccessories(resultSet.getString("accessories"));
        pageList.addData(yewu);

      }

    }
    catch (Exception e) {
      e.printStackTrace();
    }
    finally {
      connectionClose(connection, statement, resultSet);
    }
    return pageList;
  }

  /**
   * 查询特定的业务并进行分页显示
   * */
  public PageListData getSomeyewu(Yewu myyewu,PageListData pageList) {
    String sqlStr = "";
    String addSql = " order by datetime desc";
    Connection connection = null;
    Statement statement = null;
    ResultSet resultSet = null;
    try {
      sqlStr = "select * from yewu where 1＝1 " ;
      if(!myyewu.getTitle().equals(""))
        sqlStr = sqlStr + " and title='"+myyewu.getTitle()+"'";
      if(!myyewu.getCustomer().equals(""))
        sqlStr = sqlStr + " and customer='"+myyewu.getCustomer()+"'";

      connection = com.db.ConnectionPool.getConnection();
      statement = connection.createStatement();
      PageQuery pageQuery = new PageQuery();
      resultSet = pageQuery.sqlQueryPage(statement, sqlStr, addSql,
                                         pageList);
      for (int i = 0; i < pageList.getPageSize() && resultSet.next(); i++) {
        Yewu yewu = new Yewu();

        yewu.setUniversalid(resultSet.getString("universalid"));
        yewu.setOwnerid(resultSet.getString("ownerid"));
        yewu.setCustomer(resultSet.getString("customer"));
        yewu.setContent(resultSet.getString("content"));
        yewu.setMemo(resultSet.getString("memo"));
        yewu.setTitle(resultSet.getString("title"));
        yewu.setDatetime(resultSet.getString("datetime"));
        yewu.setAccessories(resultSet.getString("accessories"));
        pageList.addData(yewu);

      }

    }
    catch (Exception e) {
      e.printStackTrace();
    }
    finally {
      connectionClose(connection, statement, resultSet);
    }
    return pageList;
  }


  /**
   * 本方法的作用：
   * 1、按照universalid查询特定的业务详细内容；
   * 2、在对业务进行修改时候，查询出其基本信息供修改。
   * */
  public Yewu findYwbyUniversalid(String universalid) {
    Yewu yewu = null;
    Session session = null;
    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      //Transaction tx = session.beginTransaction();
      //查询记录
      Query query = session
          .createQuery("select a from Yewu as a where a.universalid = '"
                       + universalid + "'");
      Iterator it = query.iterate();

      if (it.hasNext()) {
        yewu = (Yewu) it.next();

        //tx.commit();
      }
      session.close();

    }
    catch (HibernateException e) {
      sessionClose(session);
      e.printStackTrace();
    }
    finally {
      sessionClose(session);
    }

    return yewu;
  }

  /**
   * 删除公文
   * */
  public void deleteYwbyUniversalid(String universalid) {
    Session session = null;
    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      Transaction tx = session.beginTransaction();
      //查询记录
      session.delete("from Yewu as a where a.universalid = '"
                     + universalid + "'");

      tx.commit();
      session.close();

    }
    catch (HibernateException e) {
      sessionClose(session);
      e.printStackTrace();
    }
    finally {
      sessionClose(session);
    }

  }

  /***************************************************************************
   * 关闭数据库连接的通用方法
   */
  public void connectionClose(Connection connection, Statement statement,
                              ResultSet resultSet) {
    try {
      if (resultSet != null) {
        try {
          resultSet.close();
        }
        catch (SQLException e1) {
          e1.printStackTrace();
        }
      }
      if (statement != null) {
        try {
          statement.close();
        }
        catch (SQLException e1) {
          e1.printStackTrace();
        }
      }
      if (connection != null) {
        try {
          connection.close();
        }
        catch (SQLException e1) {
          e1.printStackTrace();
        }
      }
    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }

  /**
   * 关闭session
   */
  public void sessionClose(Session session) {
    if (session != null) {
      try {
        session.close();
      }
      catch (HibernateException e1) {
        e1.printStackTrace();
      }
    }
  }

}