fujiandao.java

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

package com.km.fujian.data;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Query;
import net.sf.hibernate.Session;
import net.sf.hibernate.SessionFactory;
import net.sf.hibernate.Transaction;
import net.sf.hibernate.cfg.Configuration;

/**
 * 本类用来管理与附件相关的操作。
 *
 * @author Administrator
 */
public class FujianDAO {

  /**
   * 本方法用来新增附件。
   */
  public void createFujian(Fujian fujian) {
    Session session = null;
    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      Transaction tx = session.beginTransaction();
      //新增记录
      session.save(fujian);
      tx.commit();
      session.close();
    }
    catch (HibernateException e) {
      sessionClose(session);
      e.printStackTrace();
    }
    finally {
      sessionClose(session);
    }

  }

  /**
   * 本方法用来查询某个公文/业务对应的全部附件。
   */
  public List getAllfujian(String universalid) {
    List list = new ArrayList();
    Session session = null;
    String sqlStr = "";

    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      //Transaction tx = session.beginTransaction();

      sqlStr = "from Fujian as a where a.universalid = '" + universalid
          + "'";

      //查询记录

      Query query = session.createQuery(sqlStr);
      list = query.list();

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

    }

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

    return list;
  }

  /**
   * 查询附件表中是否存在universalid是某个特定值的附件。
   */
  public String getFjbyUniversalid(String universalid) {
    String result = "";
    String sqlStr = "";
    Session session = null;
    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      sqlStr =
          "select fujian.universalid from Fujian as fujian where fujian.universalid = '"
          + universalid + "'";
      //查询记录
      Query query = session.createQuery(sqlStr);
      Iterator it = query.iterate();

      if (it.hasNext()) {
        result = (String) it.next();
      }
      session.close();
    }
    catch (Exception e) {
      sessionClose(session);
      e.printStackTrace();
    }
    finally {
      sessionClose(session);
    }
    return result;

  }

  /**
   * 删除附件。 @ param param(String),表示参数类型，分为按照附件的id删除和按照附件的universalid删除。 @ param
   *           id(String)
   */
  public int deleteFjbyId(String param, String id) {
    int i = 0;
    Session session = null;
    try {
      SessionFactory sf = new Configuration().configure()
          .buildSessionFactory();
      session = sf.openSession();
      Transaction tx = session.beginTransaction();
      //查询记录
      i = session.delete("from Fujian as fujian where fujian." + param
                         + " = '" + id + "'");

      tx.commit();
      session.close();
    }
    catch (Exception e) {
      sessionClose(session);
      e.printStackTrace();
    }
    finally {
      sessionClose(session);
    }
    return i;
  }

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

}