submitcommanddao.java

采用JAVA开发

package com.gctech.sms.dao;

import com.gctech.sms.vo.SubmitCommandObject;
import java.sql.Connection;
import java.sql.PreparedStatement;
import com.gctech.sms.util.ConnectionManager;
import org.apache.log4j.Logger;
import java.util.Collection;
import java.util.Vector;
import java.sql.Statement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.sql.SQLException;
import com.gctech.sms.core.Status;
import com.gctech.sms.core.DisplayInWeb;
import com.gctech.sms.core.SubmitStatus;

/**
 * @author 王红宝
 * $Id: SubmitCommandDao.java,v 1.7 2004/05/27 01:57:39 wengjl Exp $
 * */

public class SubmitCommandDao {
  public SubmitCommandDao() {
  }
  static SubmitCommandObject fromResultSet(ResultSet rs) throws SQLException {
    SubmitCommandObject subCmd = new SubmitCommandObject();
    subCmd.setCntBusinessId(rs.getString("CNTBUSINESSID"));
    subCmd.setDescription(rs.getString("DESCRIPTION"));
    subCmd.setFeeBusinessId(rs.getString("FEEBUSINESSID"));
    subCmd.setId(rs.getString("ID"));
    subCmd.setKeyWord(rs.getString("KEYWORD"));
    subCmd.setName(rs.getString("NAME"));
    subCmd.setProvider(rs.getString("PROVIDER"));
    subCmd.setSample(rs.getString("SAMPLE"));
    subCmd.setFeeDesc(rs.getString("FeeStand"));
    subCmd.setSendFreque(rs.getString("SendFreq"));
    subCmd.setSubmitFeeType(rs.getInt("SubmitFeeType"));
    subCmd.setPrice(rs.getDouble("Price"));
    return subCmd;
  }
  public static SubmitCommandObject findByCmd(String cmd){
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet rs = null;
    SubmitCommandObject subCmd = null;
    try{
      con = ConnectionManager.getInstance().getConnection(SubmitCommandDao.class);
      String sql = "select * from submitcommand where KEYWORD=?";
      logger.debug(sql);
      stmt = con.prepareStatement(sql);
      stmt.setString(1, cmd);
      rs = stmt.executeQuery();
      if ( rs.next() ){
        subCmd = fromResultSet(rs);
      }
    }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 subCmd;
  }
  public static SubmitCommandObject findByPk(String svcId){
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet rs = null;
    SubmitCommandObject subCmd = null;
    try{
      con = ConnectionManager.getInstance().getConnection(SubmitCommandDao.class);
      String sql = "select * from submitcommand where ID=?";
      logger.debug(sql);
      stmt = con.prepareStatement(sql);
      stmt.setString(1, svcId);
      rs = stmt.executeQuery();
      if ( rs.next() ){
        subCmd = fromResultSet(rs);
      }
    }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 subCmd;
  }

  public static SubmitCommandObject findByPkAndStatus(String svcId, int status){
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet rs = null;
    SubmitCommandObject subCmd = null;
    try{
      con = ConnectionManager.getInstance().getConnection(SubmitCommandDao.class);
      StringBuffer sql = new StringBuffer("select * from submitcommand where ID=?");
      if ( status != -1 )
        sql.append(" and status="+status);
//      String sql = "select * from submitcommand where ID=? ";
      logger.debug(sql);
      stmt = con.prepareStatement(sql.toString());
      stmt.setString(1, svcId);
      rs = stmt.executeQuery();
      if ( rs.next() ){
        subCmd = fromResultSet(rs);
      }
    }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 subCmd;
  }


  /**
   * 得到某种订阅类型的订阅列表。
   * @param svcType 订阅类型。
   * @return 返回的对象是SubmitCommandObject
   * */
  public static Collection findByServiceType(String svcType){
    return findBySvcTypeStsDis(svcType, -1, -1);
  }

  /**
   * 得到某种订阅类型的订阅列表。
   * @param svcType 订阅类型。
   * @return 返回的对象是SubmitCommandObject
   * */
  public static Collection findBySvcTypeStsDis(String svcType, int status,
      int displayed){
    Collection col = new Vector();
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet rs = null;
    try{
      con = ConnectionManager.getInstance().getConnection(SubmitCommandDao.class);
      StringBuffer sql = new StringBuffer("select * from submitcommand where SERVICETYPEID=?");
      if ( status != -1 )
        sql.append(" and status=").append(status);
      if ( displayed != -1 )
        sql.append(" and displayInWeb=").append(displayed);
      logger.debug(sql);
      stmt = con.prepareStatement(sql.toString());
      stmt.setString(1, svcType);
      rs = stmt.executeQuery();
      while ( rs.next() ){
        SubmitCommandObject subCmd = fromResultSet(rs);
        col.add(subCmd);
      }
    }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 col;
  }


  public static int add(SubmitCommandObject subCmd){
    int rt = -1;
    Connection con = null;
    PreparedStatement pstmt = null;
    try{
      con = ConnectionManager.getInstance().getConnection(SubServiceTypeDao.class);
      pstmt = con.
          prepareStatement("insert into submitcommand(ID,NAME,DESCRIPTION,FEEBUSINESSID,"+
          "CNTBUSINESSID,KEYWORD,SAMPLE,PROVIDER,SERVICETYPEID,price,SubmitFeeType,FeeStand,SendFreq,status,displayInWeb)values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
      //pstmt.setString(1, IDGenerator.nextId(con));
      pstmt.setString(1, subCmd.getId());
      pstmt.setString(2, subCmd.getName());
      pstmt.setString(3, subCmd.getDescription());
      pstmt.setString(4, subCmd.getFeeBusinessId());
      pstmt.setString(5, subCmd.getCntBusinessId());
      pstmt.setString(6, subCmd.getKeyWord());
      pstmt.setString(7, subCmd.getSample());
      pstmt.setString(8, subCmd.getProvider());
      pstmt.setString(9, subCmd.getServiceTypeId());
      pstmt.setDouble(10, subCmd.getPrice());
      pstmt.setInt(11, subCmd.getSubmitFeeType());
      pstmt.setString(12, subCmd.getFeeDesc());
      pstmt.setString(13, subCmd.getSendFreque());
      pstmt.setInt(14, subCmd.getStatus());
      pstmt.setInt(15, subCmd.getDisplayInWeb());
      pstmt.execute();
      rt = 0;
    }catch( Throwable e ){
      logger.error(e, e);
    }finally{
      if ( pstmt != null ){
        try {
          pstmt.close();
        }
        catch (Throwable ex) {
          logger.error(ex, ex);
        }
      }
      if ( con != null ){
        try {
          con.close();
        }
        catch (Throwable ex) {
          logger.error(ex, ex);
        }
      }
      return rt;
    }

  }

  public SubmitCommandObject[] getAllMo(SubmitCommandObject infovalue) throws SQLException {//查询所有数据
        Connection con = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        ArrayList list = new ArrayList();
        try{
          con = ConnectionManager.getInstance().getConnection(SmsServiceDao.class);
          StringBuffer sql = new StringBuffer("select a.id,a.feebusinessid,a.cntbusinessid,");
          sql.append( "a.keyword,a.name,a.description,a.sample,a.provider,a.servicetypeid,");
          sql.append( " a.PRICE,a.SUBMITFEETYPE,a.FEESTAND,a.SENDFREQ,");
          sql.append( " a.STATUS,a.DISPLAYINWEB");
          sql.append( " from submitcommand a");
          sql.append( " where 1=1 ");
          if (infovalue!=null && infovalue.getId()!=null && !infovalue.getId().equals("")){
            sql.append( " and a.id='" + infovalue.getId() + "'");
          }
          if (infovalue!=null && infovalue.getProvider()!=null && !infovalue.getProvider().equals("")){
            sql.append( " and a.provider='" + infovalue.getProvider() + "'");
          }
          //logger.equals(sql.toString());
          logger.debug(sql.toString());
          pstmt = con.prepareStatement(sql.toString());
          rs = pstmt.executeQuery();
          while (rs.next()){
            SubmitCommandObject model = new SubmitCommandObject();
            String id = rs.getString("id");
            if (!rs.wasNull()) model.setId(id);
            String feeid = rs.getString("feebusinessid");
            if (!rs.wasNull()) model.setFeeBusinessId(feeid);
            String cntid = rs.getString("cntbusinessid");
            if (!rs.wasNull()) model.setCntBusinessId(cntid);
            String keyword = rs.getString("keyword");
            if (!rs.wasNull()) model.setKeyWord(keyword);
            String desc = rs.getString("description");
            if (!rs.wasNull()) model.setDescription(desc);
            String sample = rs.getString("sample");