tpushimpl.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.sxit.pim.push;
import java.util.*;
import java.sql.*;
/**
 * <p>类名: TpushImpl</p>
 * <p>功能: push</p>
 * <p>公司: 深讯信科</p>
 * <p>版本: 1.0</p>
 * @程序 sxit
 * @日期 2005-12-15
 * @修改纪录
 */
public class TpushImpl
{
     public TpushImpl()
     {
          super();
     }
     private int id;
     private String frommdn;
     private String tomdn;
     private String title;
     private String url;
     private int status;
     private String result;
     private String channelid;
     private java.sql.Timestamp systime;
     private long corporationid;
     private String channelname;
     public void setId(int id)
     {
          this.id = id;
     }
     public int getId()
     {
          return id;
     }
     public void setChannelname(String channelname)
     {
          this.channelname = channelname;
     }
     public String getChannelname()
     {
          return channelname;
     }

     public void setFrommdn(String frommdn)
     {
          this.frommdn = frommdn;
     }
     public String getFrommdn()
     {
          return frommdn;
     }
     public void setTomdn(String tomdn)
     {
          this.tomdn = tomdn;
     }
     public String getTomdn()
     {
          return tomdn;
     }
     public void setTitle(String title)
     {
          this.title = title;
     }
     public String getTitle()
     {
          return title;
     }
     public void setUrl(String url)
     {
          this.url = url;
     }
     public String getUrl()
     {
          return url;
     }
     public void setStatus(int status)
     {
          this.status = status;
     }
     public int getStatus()
     {
          return status;
     }
     public void setResult(String result)
     {
          this.result = result;
     }
     public String getResult()
     {
          return result;
     }
     public void setChannelid(String channelid)
     {
          this.channelid = channelid;
     }
     public String getChannelid()
     {
          return channelid;
     }
     public void setSystime(java.sql.Timestamp systime)
     {
          this.systime = systime;
     }
     public java.sql.Timestamp getSystime()
     {
          return systime;
     }
     public void setCorporationid(long corporationid)
     {
          this.corporationid = corporationid;
     }
     public long getCorporationid()
     {
          return corporationid;
     }
     /**
      * 创建数据，需要初始化类
      */
     public void create(Connection con,int id) throws SQLException
     {
          PreparedStatement stmt=null;
          ResultSet rs=null;
          String sql="";
          try{
               sql="select id,frommdn,tomdn,title,url,status,result,channelid,systime,corporationid from tpush where id=?";
               stmt=con.prepareStatement(sql);
               stmt.setInt(1,id);
               rs=stmt.executeQuery();
               if(rs.next()){
                    this.id = rs.getInt("id");
                    frommdn = rs.getString("frommdn");
                    tomdn = rs.getString("tomdn");
                    title = rs.getString("title");
                    url = rs.getString("url");
                    status = rs.getInt("status");
                    result = rs.getString("result");
                    channelid = rs.getString("channelid");
                    systime = rs.getTimestamp("systime");
                    corporationid = rs.getLong("corporationid");
               }
               stmt.close();
          }
          finally{
               if(stmt!=null) stmt.close();
          }
     }
     /**
      * 插入数据，无需要初始化类
      */
     public static int insert(Connection con,int id,String frommdn,String tomdn,String title,String url,int status,String result,String channelid,String transid,long corporationid) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          try
          {
               sql="insert into tpush "+
                   "(id,frommdn,tomdn,title,url,status,result,channelid,systime,transid,corporationid) "+
                   "values (?,?,?,?,?,?,?,?,sysdate,?,?)";
               stmt=con.prepareStatement(sql);
               stmt.setInt(1, id);
               stmt.setString(2, frommdn);
               stmt.setString(3, tomdn);
               stmt.setString(4, title);
               stmt.setString(5, url);
               stmt.setInt(6, status);
               stmt.setString(7, result);
               stmt.setString(8, channelid);
               stmt.setString(9,transid);
              stmt.setLong(10, corporationid);
                cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally
          {
               if(stmt!=null) stmt=null;
          }
          return cnt;
     }
     public static int insert1(Connection con,int id,String frommdn,String tomdn,String title,String url,int status,String result,String channelid,String transid,long corporationid) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          try
          {
               sql="insert into tpush "+
                   "(id,frommdn,tomdn,title,url,status,result,channelid,systime,transid,corporationid) "+
                   "values (?,?,?,?,?,?,?,?,sysdate,?,?)";

               stmt=con.prepareStatement(sql);
               stmt.setInt(1, id);
               stmt.setString(2, frommdn);
               stmt.setString(3, tomdn);
               stmt.setString(4, title);
               stmt.setString(5, url);
               stmt.setInt(6, status);
               stmt.setString(7, result);
               stmt.setString(8, channelid);
               stmt.setString(9,transid);
              stmt.setLong(10, corporationid);
                cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally
          {
               if(stmt!=null) stmt=null;
          }
          return cnt;
     }


     /**
      * 插入数据，需要初始化类，并将设置类的域
      */
     public int insert(Connection con) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          try
          {
               sql="insert into tpush "+
                   "(id,frommdn,tomdn,title,url,status,result,channelid,systime,corporationid) "+
                   "values (?,?,?,?,?,?,?,?,?,?)";
               stmt=con.prepareStatement(sql);
               stmt.setInt(1, id);
               stmt.setString(2, frommdn);
               stmt.setString(3, tomdn);
               stmt.setString(4, title);
               stmt.setString(5, url);
               stmt.setInt(6, status);
               stmt.setString(7, result);
               stmt.setString(8, channelid);
               stmt.setTimestamp(9, systime);
               stmt.setLong(10, corporationid);
               cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally
          {
               if(stmt!=null) stmt=null;
          }
          return cnt;
     }
     /**
      * 更新数据，无需要初始化类
      */
     public static int update(Connection con,int id,String frommdn,String tomdn,String title,String url,int status,String result,int channelid,java.sql.Timestamp systime,long corporationid) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          try
          {
               sql="update tpush set frommdn=?,tomdn=?,title=?,url=?,status=?,result=?,channelid=?,systime=?,corporationid=? where id=?";
               stmt=con.prepareStatement(sql);
               stmt.setString(1, frommdn);
               stmt.setString(2, tomdn);
               stmt.setString(3, title);
               stmt.setString(4, url);
               stmt.setInt(5, status);
               stmt.setString(6, result);
               stmt.setInt(7, channelid);
               stmt.setTimestamp(8, systime);
               stmt.setLong(9, corporationid);
               stmt.setInt(10, id);
               cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally
          {
               if(stmt!=null) stmt=null;
          }
          return cnt;
     }
     /**
      * 更新数据，需要初始化类，并将设置类的域
      */
     public int update(Connection con) throws SQLException
     {