usersubmitdao.java

采用JAVA开发

package com.gctech.sms.dao;

import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import com.gctech.sms.util.ConnectionManager;
import org.apache.log4j.Logger;
import com.gctech.sms.core.SubmitStatus;
import java.sql.PreparedStatement;

/**
 * <p>Title: 用户订阅数据访问</p>
 * <p>Description:用户订阅数据访问。 </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: gctech</p>
 * @author 王红宝
 * @version $Id: UserSubmitDao.java,v 1.2 2004/04/22 01:25:16 wanghb Exp $
 */

public class UserSubmitDao {
  public UserSubmitDao() {
  }
  public static boolean isExist(String destMobile, String serviceId){
    boolean rt = false;
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet rs = null;
    try{
      con = ConnectionManager.getInstance().getConnection(UserSubmitDao.class);
      String sql = "select count(*) from submitrecord where destmobile=?"+
          " and submitid=? and status="+
          SubmitStatus.SUBSCRIBED.getValue();
      logger.debug(sql);
      stmt = con.prepareStatement(sql);
      stmt.setString(1, destMobile);
      stmt.setString(2, serviceId);
      rs = stmt.executeQuery();
      rt = (rs.getInt(1) > 0);
    }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;
  }
  static final Logger logger = Logger.getLogger(UserSubmitDao.class);
}