mtdao.java

来自「短信系统SMS：支持普通短信、长短信和wap push短信的发送。」· Java 代码 · 共 99 行

package com.ekun.biz.dao;

import com.ekun.common.db.ClearDBResource;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.sql.PreparedStatement;
import java.sql.Connection;
import com.ekun.common.db.DBManager;
import com.ekun.common.log.Logger;
import com.ekun.common.log.LoggerFactory;
import com.ekun.biz.vo.MtVO;

/**
 * <p>Title: </p>
 * Submit状态表，对应于SUBMITRESPONSE
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author ekun
 * @version 1.0
 */
public class MtDAO
{
  static Logger logger = LoggerFactory.getLogger(MtDAO.class);

  public void insert(MtVO vo)
  {
    Connection conn = null;
    PreparedStatement preparedStatement = null;
    try
    {
      conn = DBManager.getDBConn();
      preparedStatement = conn.prepareStatement("insert into SUBMITRESPONSE(DBMSGID, SMSMSG_ID, RESULT, RESULTDESC) values (?,?,?,?)");
      preparedStatement.setLong(1, Long.parseLong(vo.getDBMSGID()));
      preparedStatement.setString(2, vo.getSMSMSG_ID());
      preparedStatement.setString(3, String.valueOf(vo.getRESULT()));
      preparedStatement.setString(4, vo.getRESULTDESC());
      preparedStatement.execute();
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
      logger.error("写SUBMITRESPONSE表出错!", ex);
    }
  }

  public void batchInsert(MtVO[] vos)
  {
    if((vos == null) || vos.length <= 0)
      return;
    Connection conn = null;
    PreparedStatement preparedStatement = null;
    try
    {
      conn = DBManager.getDBConn();
      preparedStatement = conn.prepareStatement("update alarm_sms set isdone=1,isok=?,erroinfo=?,senttime=now() where id=?");
      for (int i = 0; i < vos.length; i++)
      {
        preparedStatement.setLong(1, (vos[i].getRESULT() == 0 ? 1:0));
        preparedStatement.setString(2, vos[i].getRESULTDESC());
        preparedStatement.setString(3, vos[i].getDBMSGID());
        preparedStatement.addBatch();
      }
      int[] counts = preparedStatement.executeBatch();
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
      logger.error("写SUBMITRESPONSE表出错!", ex);
    }
  }

  public static void main(String[] args)
  {
    MtDAO submitresultdao = new MtDAO();
    MtVO[] vo = new MtVO[2];
    vo[0] = new MtVO();
    vo[0].setDBMSGID("1233");
    vo[0].setSMSMSG_ID("dsaf");
    vo[0].setRESULT(0);

    vo[1] = new MtVO();
    vo[1].setDBMSGID("12323");
    vo[1].setSMSMSG_ID("ds22af");
    vo[1].setRESULT(10);
    submitresultdao.batchInsert(vo);
    submitresultdao.insert(vo[0]);
  }
}