//---------------------------------------------------------
// Application: equipment of  System
// Author     : eSingle
// File       : AssetDAO.java
//
// Copyright 2002 LandSoft Corp.
// Generated at Mon Nov 18 20:13:57 CST 2002
// Created by caoguangxin
// mailto:gxcao@mail.tsinghua.edu.cn
//---------------------------------------------------------

package com.landsoft.equipment.dao;

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

import com.landsoft.equipment.model.*;
import com.landsoft.equipment.util.CacheManager;

public class AssetDAO extends DAO {

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

  public void insert(Asset asset) throws SQLException {
    String sql;
    sql = "INSERT INTO asset (assetid, assettypename, purposename, modename, configure, positionname, price, buydate, usedatename, remark, status, assetname, service) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
      conn = ds.getConnection();
      pstmt = conn.prepareStatement(sql);
      pstmt.setInt(1, asset.getAssetid());
      pstmt.setString(2, asset.getAssettypename());
      pstmt.setString(3, asset.getPurposename());
      pstmt.setString(4, asset.getModename());
      pstmt.setString(5, asset.getConfigure());
      pstmt.setString(6, asset.getPositionname());
      pstmt.setString(7, asset.getPrice());
      pstmt.setString(8, asset.getBuydate());
      pstmt.setString(9, asset.getUsedatename());
      pstmt.setString(10, asset.getRemark());
      pstmt.setString(11, asset.getStatus());
      pstmt.setString(12, asset.getAssetname());
      pstmt.setString(13, asset.getService());
      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(Asset asset) throws SQLException {
  	Connection conn = null;
  	PreparedStatement pstmt = null;
    try {
      conn = ds.getConnection();
      String sql = "UPDATE asset SET assettypename=?, purposename=?, modename=?, configure=?, positionname=?, price=?, buydate=?, usedatename=?, remark=?, status=?, assetname=?, service=? WHERE assetid=?";
      pstmt = conn.prepareStatement(sql);
      pstmt.setString(1, asset.getAssettypename());
      pstmt.setString(2, asset.getPurposename());
      pstmt.setString(3, asset.getModename());
      pstmt.setString(4, asset.getConfigure());
      pstmt.setString(5, asset.getPositionname());
      pstmt.setString(6, asset.getPrice());
      pstmt.setString(7, asset.getBuydate());
      pstmt.setString(8, asset.getUsedatename());
      pstmt.setString(9, asset.getRemark());
      pstmt.setString(10, asset.getStatus());
      pstmt.setString(11, asset.getAssetname());
      pstmt.setString(12, asset.getService());
      pstmt.setInt(13, asset.getAssetid());
      pstmt.executeUpdate();
      close(pstmt);
      conn.commit();
    } catch (SQLException e) {
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
  }

  public void delete(int assetid) throws SQLException {
  	Connection conn = null;
  	PreparedStatement pstmt = null;
    try {
      conn = ds.getConnection();
      String sql = "DELETE FROM asset WHERE assetid=?";
      pstmt = conn.prepareStatement(sql);
      pstmt.setInt(1, assetid);
      pstmt.executeUpdate();
      close(pstmt);
      conn.commit();
    } catch (SQLException e) {
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
    String[] objKeys = {"Asset", String.valueOf(assetid)};
    String objKey = CacheManager.createKey(objKeys);
    DAOCacheManager.invalidate(objKey);
  }

  public Asset retrieve(int assetid) throws SQLException {
    String[] objKeys = {"Asset", String.valueOf(assetid)};
    String objKey = CacheManager.createKey(objKeys);
    Asset asset = (Asset) DAOCacheManager.getCache(objKey);
    if (asset != null)
      return asset;
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
      conn = ds.getConnection();
      String sql = "SELECT * FROM asset WHERE assetid=?";
      pstmt = conn.prepareStatement(sql);
      pstmt.setInt(1, assetid);
      rs = pstmt.executeQuery();
      if (rs.next()) {
        asset = new Asset();
        asset.setAssetid(rs.getInt(1));
        //populate(asset, rs);
      }
      close(rs);
      close(pstmt);
    } catch (SQLException e) {
      close(rs);
      close(pstmt);
      rollback(conn);
      e.printStackTrace();
    } finally {
    	close(conn);
    }
    DAOCacheManager.putCache(asset, objKey, 1);
    return asset;
  }

  public List list() throws SQLException {
    String[] objKeys = {"Asset", "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 assettypename, purposename, modename, configure, positionname, price, buydate, usedatename, remark, status, assetname, service, assetid FROM asset";
      pstmt = conn.prepareStatement(sql);
      rs = pstmt.executeQuery();
      while(rs.next()) {
        Asset asset = new Asset();
        populate(asset, rs);
        list.add(asset);
      }
      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 = {"Asset", "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 assettypename, purposename, modename, configure, positionname, price, buydate, usedatename, remark, status, assetname, service, assetid FROM asset";
      pstmt = conn.prepareStatement(sql);
      rs = pstmt.executeQuery();
      if(offset > 0) rs.absolute(offset);
      int recCount = 0;
      while((recCount++ < limit) && rs.next()) {
        Asset asset = new Asset();
        populate(asset, rs);
        list.add(asset);
      }
      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;
  }

}