original_alarm.java

一个网络告警

package quanquanqi;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class Original_Alarm {
	/*
	 * private String ipaddress;// IP地址
	 * 
	 * private String alarm_type;// 告警类型
	 * 
	 * private String alarm_severity;// 告警严重程度
	 * 
	 * private String alarm_time;// 告警发生时间
	 */

	private final int Originalalarm_size=1000;

	int alarm_count = 0;

	public static int os =1000 ;

	GeneralDAO gdao = new GeneralDAO("mining1.mdb");

	public Original_Alarm() {
		
	}

	public void Generation_Alarm() { /*
										 * Alarm alarm=new Alarm();
										 * ipaddress=alarm.getipaddress();
										 * alarm_type=alarm.getalarm_type();
										 * alarm_severity=alarm.getalarm_severity();
										 * alarm_time=alarm.getalarm_time();
										 */
		try {
			gdao.stmt = gdao.con
					.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
							ResultSet.CONCUR_UPDATABLE);
			gdao.stmt.execute("Drop  TABLE alarm");
		} catch (SQLException e1) {
			// TODO 自动生成 catch 块
			e1.printStackTrace();
		}

		try {

			gdao.stmt
					.execute("CREATE TABLE alarm(alarm_number Integer,ipaddress varchar(30),alarm_type varchar(30),alarm_severity varchar(30),	alarm_time varchar(50));");
			gdao.executeQuery("select * from alarm");

		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		Alarm alarm = new Alarm();
		alarm_count++;
		writeToDatabase(gdao, alarm_count, alarm);
		while (alarm_count < Originalalarm_size)// 一种方法使其停止,如1000
		{
			alarm = new Alarm();
			alarm_count++;
			writeToDatabase(gdao, alarm_count, alarm);

		}
		try {
			gdao.applyUpdates();

			gdao.executeQuery("select * from alarm");			
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
	}
	
	public void resetAlarms()
	{
		os =1000;
		try {
			gdao.executeQuery("select * from alarm");

		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		for(int i=gdao.gvo.getRowCount()-1;i>=0;i--)
		{
			try {
				gdao.deleteRow(i);
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
		}
		
		try {
			gdao.executeQuery("select * from alarm");
		} catch (SQLException e1) {
			// TODO 自动生成 catch 块
			e1.printStackTrace();
		}
		alarm_count=0;
		Alarm alarm = new Alarm();
		alarm_count++;
		writeToDatabase(gdao, alarm_count, alarm);
		while (alarm_count < Originalalarm_size)// 一种方法使其停止,如1000
		{
			alarm = new Alarm();
			alarm_count++;
			writeToDatabase(gdao, alarm_count, alarm);

		}
		try {
			gdao.applyUpdates();

			gdao.executeQuery("select * from alarm");			
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
	}

	public void writeToDatabase(GeneralDAO gdao, int alarm_count, Alarm alarm) {
		gdao.gvo.appendRow();
		gdao.gvo.setObject("alarm_number", new Integer(alarm_count));
		gdao.gvo.setObject("ipaddress", alarm.getipaddress());
		gdao.gvo.setObject("alarm_type", alarm.getalarm_type());
		gdao.gvo.setObject("alarm_severity", alarm.getalarm_severity());
		gdao.gvo.setObject("alarm_time", alarm.getalarm_time());
		//System.out.println(alarm_count);
	}

	public void slidewindow_updating(int updatingsize) {
		int updatingcount = 0;
		
	/*	try {
			gdao.executeQuery("select * from alarm order by alarm_number");
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}*/
		
		gdao.gvo.absolute(gdao.gvo.getRowCount() - 1);
		//os = Originalalarm_size;
		Alarm alarm = new Alarm();
		updatingcount++;
		writeToDatabase(gdao, updatingcount + os, alarm);
		while (updatingcount < updatingsize) {
			alarm = new Alarm();
			updatingcount++;
			writeToDatabase(gdao, updatingcount + os, alarm);}

			os = os + updatingsize;
			System.out.println("os"+os);
		
		try {
			gdao.applyUpdates();
			gdao.executeQuery("select * from alarm order by alarm_number");
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
		gdao.gvo.absolute(0);
		updatingcount = 0;
		while (updatingcount < updatingsize) {
			gdao.gvo.adeleteRow();
			try {
				gdao.deleteRow(0);
				System.out.println("shangchu:"+updatingcount);
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			updatingcount++;
		}
		try {
			gdao.applyUpdates();
			gdao.executeQuery("select * from alarm order by alarm_number");
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}
	}
	public static void main(String[] args){
		Original_Alarm oa=new Original_Alarm();
		oa.Generation_Alarm();
	oa.slidewindow_updating(100);
	oa.Generation_Alarm();
		oa.slidewindow_updating(100);
	oa.slidewindow_updating(100);
	}
	
}