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

/**
 * <p>Title: </p>
 * <p>Description:
 *SQL測(cè)試語(yǔ)句
 * 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;

  /*連接數(shù)據(jù)庫(kù)
   */
  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);
            //加載數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            //根據(jù)用戶名和密碼,建立與數(shù)據(jù)庫(kù)的連接
            conn=DriverManager.getConnection (url, userName, password);
            return true;
            }
            catch (Exception ex) {
                return false;
            }
  }

/*更新IP地址表，ID從1開(kāi)始，依次遞增
 */
 boolean UpdateIPTable(Hashtable inforHashTable){
  //
  Enumeration inforEnumeration;
  String tableName="ipstatistic";
  String sqlStr,ipStr,numStr;
  //記錄數(shù)據(jù)庫(kù)操作是否成功
  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(tableName+"表插入：" + 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;
  }
}

/*關(guān)閉數(shù)據(jù)庫(kù)
 */
 void DBClose(){
   try {
     conn.close();
   }
   catch (Exception ex) {
     System.out.println ("In DBOperation.DBClose(),"+ex.toString());
   }
 }
}