dataupdate.java

smpp java实现

package projectsmpp;

import java.sql.*;
import java.io.*;

public class DataUpdate {
  private static SmObject smobject = null;
  private Connection conn = null;
  private PreparedStatement pstmt = null;
  private PreparedStatement pstmt1 = null;
  private static DataUpdate instance = null;
  public DataUpdate() {
    conn = Dbconnection.getInstance().getConnection();
  }

  public static synchronized DataUpdate getInstance() {
    if (instance == null) {
      instance = new DataUpdate();
    }
    return instance;
  }

//-------------------------------------------------------------------------
//把发送成功的短信存入表，原始表中相应的记录删除
//-------------------------------------------------------------------------
  public void smAddRomove() {
    smobject = getSmObject();
    if (smobject.id != 0) {
      try {
        conn.setAutoCommit(false);
        String sql =
            "insert into smsended(SOURCE_ADDR,DESTI_ADDR,MSG) values(?,?,?)";
        pstmt1 = conn.prepareStatement(
            sql);
        pstmt1.setString(1, smobject.source_addr);
        pstmt1.setString(2, smobject.desti_addr);
        pstmt1.setString(3, smobject.message);
        pstmt1.executeUpdate();
        pstmt = conn.prepareStatement("delete from sm where SM_SEQ_ID=?");
        pstmt.setInt(1, smobject.id);
        pstmt.executeUpdate();
        conn.commit();
      }
      catch (SQLException e) {
        e.printStackTrace();
        try {
          conn.rollback();
        }
        catch (SQLException ee) {
          ee.printStackTrace();
        }
      }
    }
    else {
      try {
        //String sql="insert into smsended"+"("+"FROM"+","+"TO"+","+"MSG"+")"+"values(?,?,?)";
        pstmt1 = conn.prepareStatement(
            "INSERT INTO smsended(SOURCE_ADDR,DESTI_ADDR,MSG)VALUES(?,?,?)"
            );
        pstmt1.setString(1, smobject.source_addr);
        pstmt1.setString(2, smobject.desti_addr);
        pstmt1.setString(3, smobject.message);
        pstmt1.executeUpdate();
      }
      catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }

//--------------------------------------------------------------------
  public void smAddRomove(SmObject smobject) {
  if (smobject.id != 0) {
    try {
      conn.setAutoCommit(false);
      String sql =
          "insert into smsended(SOURCE_ADDR,DESTI_ADDR,MSG) values(?,?,?)";
      pstmt1 = conn.prepareStatement(
          sql);
      pstmt1.setString(1, smobject.source_addr);
      pstmt1.setString(2, smobject.desti_addr);
      pstmt1.setString(3, smobject.message);
      pstmt1.executeUpdate();
      pstmt = conn.prepareStatement("delete from sm where SM_SEQ_ID=?");
      pstmt.setInt(1, smobject.id);
      pstmt.executeUpdate();
      conn.commit();
    }
    catch (SQLException e) {
      e.printStackTrace();
      try {
        conn.rollback();
      }
      catch (SQLException ee) {
        ee.printStackTrace();
      }
    }
  }
  else {
    try {
      //String sql="insert into smsended"+"("+"FROM"+","+"TO"+","+"MSG"+")"+"values(?,?,?)";
      pstmt1 = conn.prepareStatement(
          "INSERT INTO smsended(SOURCE_ADDR,DESTI_ADDR,MSG)VALUES(?,?,?)"
          );
      pstmt1.setString(1, smobject.source_addr);
      pstmt1.setString(2, smobject.desti_addr);
      pstmt1.setString(3, smobject.message);
      pstmt1.executeUpdate();
    }
    catch (SQLException e) {
      e.printStackTrace();
    }
  }
}


//------------------------------------------------------------------------
//把从短信中心接收到的信息存入数据库中
//------------------------------------------------------------------------
  public void smRecievedAdd(String source_addr, String desti_addr,
                            String message) {
    PreparedStatement pstmt2 = null;
    String sql =
        "insert into smreceived(SOURCE_TEL,DESTI_TEL,MSGRECEIVE) values(?,?,?)";
    try {
      pstmt2 = conn.prepareStatement(
          sql);
      pstmt2.setString(1, source_addr);
      pstmt2.setString(2, desti_addr);
      pstmt2.setString(3, message);
      pstmt2.executeUpdate();
    }
    catch (SQLException e) {
      e.printStackTrace();
    }
  }

//-----------------------------------------------------------------------
//获取发送的对象
//------------------------------------------------------------------------
  public static SmObject getSmObject() {
    return smobject;
  }

//-----------------------------------------------------------------------
//给smobject赋值
//------------------------------------------------------------------------
  public static void setSmObject(SmObject smobject1) {
    smobject = smobject1;
  }
  public static void setSmObjectNull(SmObject smobject2)
  {
    smobject2.source_addr=null;
    smobject2.desti_addr=null;
    smobject2.message=null;
    smobject2.id=0;
  }
}