dboperation.java

以IP地址为例

//package ipstatistic;
import java.sql.*;
import java.util.*;

/**
 * <p>Title: </p>
 * <p>Description:
 *SQL测试语句
 * SELECT MAX(NUM) FROM IPTEST/LINKTEST
 * SELECT MIN(IP_ID),MAX(IP_ID) FROM IPTEST
 * SELECT MIN(LINK_ID),MAX(LINK_ID) FROM LINKTEST
 * SELECT MIN(PATH_ID),MAX(PATH_ID) FROM PATH
 * DELETE FROM IPTEST
 * DELETE FROM LINKTEST</p>
 * <p>Copyright: Copyright (c) 2006</p>
 * <p>Company: </p>
 * @author liangwen
 * @version 1.0
 */

public class DBOperation {
  private Connection conn;
  private Statement stmt;

  /*连接数据库
   */
  boolean OpenConnection()
  {
      String url
        = "jdbc:odbc:AccessServer";
      String userName = "sa";
      String password = "";
      try {
            //DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
            //conn=DriverManager.getConnection (url, userName, password);
            //加载数据库驱动程序
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            //根据用户名和密码,建立与数据库的连接
            conn=DriverManager.getConnection (url, userName, password);
            return true;
            }
            catch (Exception ex) {
                return false;
            }
  }

/*更新IP地址表，ID从1开始，依次递增
 */
 boolean UpdateIPTable(Hashtable inforHashTable){
  //
  Enumeration inforEnumeration;
  String tableName="ipstatistic";
  String sqlStr,ipStr,numStr;
  //记录数据库操作是否成功
  try {
    stmt = conn.createStatement();
    sqlStr="delete from "+tableName;
    stmt.executeUpdate(sqlStr);
   //插入新记录
    inforEnumeration=inforHashTable.keys();
    while (inforEnumeration.hasMoreElements()) {
        ipStr = inforEnumeration.nextElement().toString();
        numStr= inforHashTable.get(ipStr).toString();

        sqlStr="insert into "+tableName+"(IP,NUM) values('"
               + ipStr+"',"+numStr+")";

      System.out.print("插入：" + ipStr+"、"+numStr);
      stmt.executeUpdate(sqlStr);
      System.out.println(",成功");
    }
    IPStatisticFrame.inforOutJTA.append(tableName+"表更新成功！\n");
    return true;
  }
  catch (Exception ex) {
      System.out.println ("In DBOperation.InsertIPorLinkTable(),"
                          +ex.toString());
      DBClose();
      return false;
  }
}

/*关闭数据库
 */
 void DBClose(){
   try {
     conn.close();
   }
   catch (Exception ex) {
     System.out.println ("In DBOperation.DBClose(),"+ex.toString());
   }
 }
}