messagedao.java

采用JAVA开发

package com.gctech.sms.vo;

import java.util.Collection;
import java.util.Vector;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import com.gctech.sms.util.ConnectionManager;
import com.gctech.sms.core.Status;
import org.apache.log4j.Logger;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class MessageDao {
  public MessageDao() {
  }
  static Logger logger = Logger.getLogger(MessageDao.class);
  public static Collection findAll(){
    Collection rt = new Vector();
    Connection con = null;
    Statement stmt = null;
    ResultSet rs = null;
    try{
      con = ConnectionManager.getInstance().getConnection(MessageDao.class);
      stmt = con.createStatement();
      String sql = "SELECT ID,Msg FROM MsgTemplate WHERE STATUS = "+
                             Status.ENABLED.getValue();
      logger.debug(sql);
      rs = stmt.executeQuery(sql);

      while ( rs.next() ){
        MessageVO msg = new MessageVO();
        msg.setId(rs.getString(1));
        msg.setMsg(rs.getString(2));
        rt.add(msg);
      }
    }catch( Throwable e ){
      logger.error(e, e);
    }finally{
      if ( rs != null ){
        try {
          rs.close();
        }
        catch (Throwable ex) {
          logger.error(ex, ex);
        }
      }
      if ( stmt != null ){
        try {
          stmt.close();
        }
        catch (Throwable ex) {
          logger.error(ex, ex);
        }
      }
      if ( con != null ){
        try {
          con.close();
        }
        catch (Throwable ex) {
          logger.error(ex, ex);
        }
      }
      return rt;
    }

  }

}