tcp.java

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

package com.sxit.pim.cp;

import java.util.*;
import java.sql.*;

/**
 * <p>类名: Tcp</p>
 * <p>功能: cp</p>
 * <p>公司: 深讯信科</p>
 * <p>版本: 1.0</p>
 * @程序 sxit
 * @日期 2005-12-14
 * @修改纪录
 */
public class Tcp
    extends TcpImpl {
    public Tcp() {
        super();
    }

    /**
     *  根据IP查找CP
     */
    public static int count_ip(Connection con, String ip) throws SQLException {
        PreparedStatement stmt = null;
        ResultSet rs = null;
        int cnt = 0;
        String sql = "";
        try {
            sql = "select count(*) as cnt from tcp where cp_ip='" + ip + "'";
            //System.out.println("sql="+sql);
            stmt = con.prepareStatement(sql);
            rs = stmt.executeQuery();
            if (rs.next()) {
                cnt = rs.getInt("cnt");
            }
            stmt.close();
        }
        finally {
            if (stmt != null)
                stmt.close();
        }
        return cnt;
    }

    /**
     * 创建数据，根据IP
     */
    public int create1(Connection con, String ip) throws SQLException {
        PreparedStatement stmt = null;
        ResultSet rs = null;
        String sql = "";
        int id=0;
        try {
            sql ="select id from tcp where cp_ip=?";
            stmt = con.prepareStatement(sql);
            stmt.setString(1, ip);
            rs = stmt.executeQuery();
            if (rs.next()) {
                id = rs.getInt("id");
            }
            stmt.close();
        }
        finally {
            if (stmt != null)
                stmt.close();
        }
        return id;
    }

}