modao.java

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

package com.ekun.biz.dao;

import com.ekun.biz.vo.MoVO;
import com.ekun.common.log.*;
import java.sql.*;
import com.ekun.common.db.*;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author ekun
 * @version 1.0
 */
public class MoDAO
{
  static Logger logger = LoggerFactory.getLogger(MoDAO.class);

  public void insert(MoVO vo)
  {
    Connection conn = null;
    CallableStatement  proc = null;
    ResultSet rs = null;
    try
    {
      conn = DBManager.getDBConn();
      proc = conn.prepareCall("{call PROC_MO(?, ?, ?)}");
      proc.setString(1, vo.getSFrom());
      proc.setString(2, vo.getSTo());
      proc.setString(3, vo.getSMsg());
      proc.execute();
      ClearDBResource.closeStatment(proc);
      ClearDBResource.closeResultSet(rs);
      ClearDBResource.closeConnection(conn);
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(proc);
      ClearDBResource.closeResultSet(rs);
      ClearDBResource.closeConnection(conn);
      logger.error("调用存储过程PROC_MO出错!", ex);
    }
  }



  public void batchInsert(MoVO[] vos)
  {
    if((vos == null) || vos.length <= 0)
      return;
    Connection conn = null;
    CallableStatement  proc = null;
    ResultSet rs = null;
    try
    {
      conn = DBManager.getDBConn();
      //注意，对于SqlServer, call不能有空格！
      proc = conn.prepareCall("{call PROC_MO(?, ?, ?)}");
      for (int i = 0; i < vos.length; i++)
      {
        proc.setString(1, vos[i].getSFrom());
        proc.setString(2, vos[i].getSTo());
        proc.setString(3, vos[i].getSMsg());
        //proc.addBatch();
        proc.execute();
      }
      //int[] counts = proc.executeBatch();
      ClearDBResource.closeStatment(proc);
      ClearDBResource.closeResultSet(rs);
      ClearDBResource.closeConnection(conn);
      logger.debug("已经有[" + vos.length + "]条MO数据写入数据库！");
    }
    catch (Exception ex)
    {
      ClearDBResource.closeStatment(proc);
      ClearDBResource.closeResultSet(rs);
      ClearDBResource.closeConnection(conn);
      logger.error("调用存储过程PROC_MO出错!", ex);
    }
  }

  public static void main(String[] args)
  {
    MoDAO modao = new MoDAO();
    MoVO[] vos = new MoVO[2];
    vos[0] = new MoVO();
    vos[0].setSFrom("13510328056");
    vos[0].setSTo("123661");
    vos[0].setSMsg("fp adfad");

    vos[1] = new MoVO();
    vos[1].setSFrom("13510328056");
    vos[1].setSTo("123661");
    vos[1].setSMsg("fp adfad");

    modao.batchInsert(vos);
  }
}