tcpimpl.java

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

package com.sxit.pim.cp;
import java.util.*;
import java.sql.*;
/**
 * <p>类名: TcpImpl</p>
 * <p>功能: cp</p>
 * <p>公司: 深讯信科</p>
 * <p>版本: 1.0</p>
 * @程序 sxit
 * @日期 2005-12-14
 * @修改纪录
 */
public class TcpImpl
{
     public TcpImpl()
     {
          super();
     }
     private int id;
     private String cpid;
     private String cp_ip;
     private String cp_name;
     private long corporationid;
     public void setId(int id)
     {
          this.id = id;
     }
     public int getId()
     {
          return id;
     }
     public String getcpId()
    {
         return cpid;
    }
    public void setcpId(String cpid)
   {
        this.cpid = cpid;
   }

     public void setCp_ip(String cp_ip)
     {
          this.cp_ip = cp_ip;
     }
     public String getCp_ip()
     {
          return cp_ip;
     }
     public void setCp_name(String cp_name)
     {
          this.cp_name = cp_name;
     }
     public String getCp_name()
     {
          return cp_name;
     }
     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,cp_ip,cp_name,corporationid,cpid from tcp where id=?";
               stmt=con.prepareStatement(sql);
               stmt.setInt(1,id);
               rs=stmt.executeQuery();
               if(rs.next()){
                    this.id = rs.getInt("id");
                    cpid=rs.getString("cpid");
                    cp_ip = rs.getString("cp_ip");
                    cp_name = rs.getString("cp_name");
                    corporationid = rs.getInt("corporationid");
               }
               stmt.close();
          }
          finally{
               if(stmt!=null) stmt.close();
          }
     }
     /**
      * 插入数据，无需要初始化类
      */
     public static int insert(Connection con,int id,String cp_ip,String cp_name,long corporationid,String cpid) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          try
          {
               sql="insert into tcp "+
                   "(id,cp_ip,cp_name,corporationid,cpid) "+
                   "values (?,?,?,?,?)";
               stmt=con.prepareStatement(sql);
               stmt.setInt(1, id);
               stmt.setString(2, cp_ip);
               stmt.setString(3, cp_name);
               stmt.setLong(4, corporationid);
               stmt.setString(5,cpid);
               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 tcp "+
                   "(id,cp_ip,cp_name,corporationid) "+
                   "values (?,?,?,?)";
               stmt=con.prepareStatement(sql);
               stmt.setInt(1, id);
               stmt.setString(2, cp_ip);
               stmt.setString(3, cp_name);
               stmt.setLong(4, corporationid);
               cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally
          {
               if(stmt!=null) stmt=null;
          }
          return cnt;
     }
     /**
      * 更新数据，无需要初始化类
      */
     public static int update(Connection con,int id,String cp_ip,String cp_name,long corporationid) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          try
          {
               sql="update tcp set cp_ip=?,cp_name=?,corporationid=? where id=?";
               stmt=con.prepareStatement(sql);
               stmt.setString(1, cp_ip);
               stmt.setString(2, cp_name);
               stmt.setLong(3, corporationid);
               stmt.setInt(4, id);
               cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally
          {
               if(stmt!=null) stmt=null;
          }
          return cnt;
     }
     /**
      * 更新数据，需要初始化类，并将设置类的域
      */
     public int update(Connection con) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          try
          {
               sql="update tcp set cp_ip=?,cp_name=?,corporationid=?,cpid=? where id=?";
               stmt=con.prepareStatement(sql);
               stmt.setString(1, cp_ip);
               stmt.setString(2, cp_name);
               stmt.setLong(3, corporationid);
               stmt.setString(4,cpid);
               stmt.setInt(5, id);

               cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally
          {
               if(stmt!=null) stmt=null;
          }
          return cnt;
     }
     /**
      * 删除一条数据
      */
     public static int delete(Connection con,int id) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          String sql1="";
          int cnt=0;
          try{
            sql1="delete from tchannel where cp_id=?";
           stmt=con.prepareStatement(sql1);
           stmt.setLong(1,id);
           cnt=stmt.executeUpdate();
           stmt.close();

               sql="delete from tcp where id=?";
               stmt=con.prepareStatement(sql);
               stmt.setInt(1,id);
               cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally{
               if(stmt!=null) stmt.close();
          }
          return cnt;
     }
     /**
      * 删除多条数据
      */
     public static int delete(Connection con, String id[]) throws SQLException
     {
          PreparedStatement stmt=null;
          String sql="";
          int cnt=0;
          int i=0;
          try{
               sql="delete from tcp where id in (";
               for (i=0;i<id.length;i++ ) {
                    if(i==0) sql=sql+id[i];
                    else sql=sql+","+id[i];
               }
               sql=sql+")";
               stmt = con.prepareStatement(sql);
               cnt=stmt.executeUpdate();
               stmt.close();
          }
          finally{
               if(stmt!=null) stmt.close();
          }
          return cnt;
     }
}