functiondao.java

Java企业级开发项目实践,这是他的附光盘

//---------------------------------------------------------
// Application: Portal of Enterprice
// Author     : eSingle
// File       : FunctionDAO.java
//
// Copyright 2002 LandSoft Corp.
// Generated at Mon Nov 18 19:57:10 CST 2002
// Created by caoguangxin
// mailto:[e-mail]
//---------------------------------------------------------

package com.landsoft.portal.managent.dao;

import java.io.*;
import java.sql.*;
import java.util.*;
import javax.sql.*;

import com.landsoft.portal.managent.model.*;
import com.landsoft.portal.managent.util.CacheManager;

public class FunctionDAO extends DAO {

  public FunctionDAO(DataSource ds) {
    super(ds);
  }

  public void insert(Function function) throws SQLException {
    String sql;
    sql = "INSERT INTO function (functionname, menuname, systemname) VALUES (?, ?, ?)";
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
      conn = ds.getConnection();
      pstmt = conn.prepareStatement(sql);
      pstmt.setString(1, function.getFunctionname());
      pstmt.setString(2, function.getMenuname());
      pstmt.setString(3, function.getSystemname());
      pstmt.executeUpdate();
      pstmt.close();
      conn.commit();
    } catch (SQLException sqle) {
      close(rs);
      close(pstmt);
      rollback(conn);
      sqle.printStackTrace();
      throw sqle;
    } finally {
    	close(conn);
    }
  }

  public void update(Function function) throws SQLException {
  	Connection conn = null;
  	PreparedStatement pstmt = null;
    try {
      conn = ds.getConnection();
      String sql = "UPDATE function SET  WHERE functionname=? AND menuname=? AND systemname=?";
      pstmt = conn.prepareStatement(sql);
      pstmt.setString(1, function.getFunctionname());
      pstmt.setString(2, function.getMenuname());
      pstmt.setString(3, function.getSystemname());
      pstmt.executeUpdate();
      close(pstmt);
      conn.commit();
    } catch (SQLException e) {
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
  }

  public void delete(String functionname, String menuname, String systemname) throws SQLException {
  	Connection conn = null;
  	PreparedStatement pstmt = null;
    try {
      conn = ds.getConnection();
      String sql = "DELETE FROM function WHERE functionname=? AND menuname=? AND systemname=?";
      pstmt = conn.prepareStatement(sql);
      pstmt.setString(1, functionname);
      pstmt.setString(2, menuname);
      pstmt.setString(3, systemname);
      pstmt.executeUpdate();
      close(pstmt);
      conn.commit();
    } catch (SQLException e) {
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
    String[] objKeys = {"Function", String.valueOf(functionname), String.valueOf(menuname), String.valueOf(systemname)};
    String objKey = CacheManager.createKey(objKeys);
    DAOCacheManager.invalidate(objKey);
  }

  public Function retrieve(String functionname, String menuname, String systemname) throws SQLException {
    String[] objKeys = {"Function", String.valueOf(functionname), String.valueOf(menuname), String.valueOf(systemname)};
    String objKey = CacheManager.createKey(objKeys);
    Function function = (Function) DAOCacheManager.getCache(objKey);
    if (function != null)
      return function;
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
      conn = ds.getConnection();
      String sql = "SELECT * FROM function WHERE functionname=? AND menuname=? AND systemname=?";
      pstmt = conn.prepareStatement(sql);
      pstmt.setString(1, functionname);
      pstmt.setString(2, menuname);
      pstmt.setString(3, systemname);
      rs = pstmt.executeQuery();
      if (rs.next()) {
        function = new Function();
        function.setFunctionname(rs.getString(1));
        function.setMenuname(rs.getString(2));
        function.setSystemname(rs.getString(3));
        populate(function, rs);
      }
      close(rs);
      close(pstmt);
    } catch (SQLException e) {
      close(rs);
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
    DAOCacheManager.putCache(function, objKey, 1);
    return function;
  }
  public List all() throws SQLException {
      ArrayList list  = new ArrayList();
      Connection conn = null;
      PreparedStatement pstmt = null;
      ResultSet rs = null;
      try {
        conn = ds.getConnection();
     String sql = "SELECT functionname, menuname, systemname FROM function";
     pstmt = conn.prepareStatement(sql);
     rs = pstmt.executeQuery();
     while(rs.next()) {
       Function function = new Function();
       function.setFunctionname(rs.getString(1));
       function.setMenuname(rs.getString(2));
       function.setSystemname(rs.getString(3));

       populate(function, rs);
       list.add(function);
        }
        close(rs);
        close(pstmt);
      } catch (SQLException e) {
        close(rs);
        close(pstmt);
        rollback(conn);
        e.printStackTrace();
      } finally {
              close(conn);
      }

      return list;
    }

  public List list() throws SQLException {
    String[] objKeys = {"Function", "list"};
    String objKey = CacheManager.createKey(objKeys);
    ArrayList list = (ArrayList) DAOCacheManager.getCache(objKey);
    if (list != null)
      return list;
    list = new ArrayList();
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
      conn = ds.getConnection();
      String sql = "SELECT functionname, menuname, systemname FROM function";
      pstmt = conn.prepareStatement(sql);
      rs = pstmt.executeQuery();
      while(rs.next()) {
        Function function = new Function();
        function.setFunctionname(rs.getString(1));
        function.setMenuname(rs.getString(2));
        function.setSystemname(rs.getString(3));

        populate(function, rs);
        list.add(function);
      }
      close(rs);
      close(pstmt);
    } catch (SQLException e) {
      close(rs);
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
    DAOCacheManager.putCache(list, objKey, 1);
    return list;
  }

  public List list(int offset, int limit) throws SQLException {
    String[] objKeys = {"Function", "list", String.valueOf(offset), String.valueOf(limit)};
    String objKey = CacheManager.createKey(objKeys);
    ArrayList list = (ArrayList) DAOCacheManager.getCache(objKey);
    if (list != null)
      return list;
    list = new ArrayList();
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
      conn = ds.getConnection();
      String sql = "SELECT functionname, menuname, systemname FROM function";
      pstmt = conn.prepareStatement(sql);
      rs = pstmt.executeQuery();
      if(offset > 0) rs.absolute(offset);
      int recCount = 0;
      while((recCount++ < limit) && rs.next()) {
        Function function = new Function();
        function.setFunctionname(rs.getString(1));
        function.setMenuname(rs.getString(2));
        function.setSystemname(rs.getString(3));

        populate(function, rs);
        list.add(function);
      }
      close(rs);
      close(pstmt);
    } catch (SQLException e) {
      close(rs);
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
    DAOCacheManager.putCache(list, objKey, 1);
    return list;
  }

}