receiptdao.java

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

package com.ekun.biz.dao;

import java.sql.PreparedStatement;
import com.ekun.common.db.ClearDBResource;
import java.sql.ResultSet;
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.ReceiptVO;

/**
 * <p>Title: </p>
 * 对应状态报告表：RECEIPT
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author ekun
 * @version 1.0
 */
public class ReceiptDAO
{
  static Logger logger = LoggerFactory.getLogger(ReceiptDAO.class);
  public void insert(ReceiptVO vo)
  {
    Connection conn = null;
    PreparedStatement preparedStatement = null;
    try
    {
      conn = DBManager.getDBConn();
      String sql = "insert into RECEIPT(SMSMSGID,RECEIVE_TIME, RECEIVE_RESULT) values (?,?,?)";
      preparedStatement = conn.prepareStatement(sql.toString());
      preparedStatement.setString(1, vo.getSMSMSGID());
      preparedStatement.setTimestamp(2, new java.sql.Timestamp(vo.getRECEIVE_TIME().getTime()));
      preparedStatement.setString(3, vo.getRECEIVE_RESULT());
      preparedStatement.execute();
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
      logger.error("写RECEIPT表出错!", ex);
    }
  }

  public void batchInsert(ReceiptVO[] vos)
  {
    if((vos == null) || vos.length <= 0)
      return;
    Connection conn = null;
    PreparedStatement preparedStatement = null;
    try
    {
      conn = DBManager.getDBConn();
      String sql = "insert into RECEIPT(SMSMSGID,RECEIVE_TIME, RECEIVE_RESULT) values (?,?,?)";
      preparedStatement = conn.prepareStatement(sql.toString());
      for (int i = 0; i < vos.length; i++)
      {
        preparedStatement.setString(1, vos[i].getSMSMSGID());
        preparedStatement.setTimestamp(2,
                                       new java.sql.Timestamp(vos[i].getRECEIVE_TIME().
            getTime()));
        preparedStatement.setString(3, vos[i].getRECEIVE_RESULT());
        preparedStatement.addBatch();
      }
      int[] counts = preparedStatement.executeBatch();
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(preparedStatement);
      ClearDBResource.closeConnection(conn);
      logger.error("写RECEIPT表出错!", ex);
    }
  }

  public static void main(String[] args)
  {
    ReceiptDAO receiptdao = new ReceiptDAO();
    ReceiptVO vo = new ReceiptVO();
    vo.setSMSMSGID("asf");
    vo.setRECEIVE_TIME(new java.util.Date());
    vo.setRECEIVE_RESULT("");
    receiptdao.insert(vo);
  }
}