afmaptable.java

一个java编写的拓扑自动发现程序

package com.sitech.net.topo.table;

import java.util.List;

import sitech.www.frame.jdbc.SqlDelete;
import sitech.www.frame.jdbc.SqlInsert;
import sitech.www.frame.jdbc.SqlQuery;

public class AFMapTable {

	public void init() {
		String sql = "delete from tb_topo_afmaptable";
		SqlDelete.delete(sql);
	}

	public void saveToDB() {
		String sql = "select distinct(nodeid) from tb_topo_dot1dtpfdbtable";
		List list = SqlQuery.findList(sql);
		for (int i = 0; i < list.size(); i++) {
			String[] item = (String[]) list.get(i);
			String nodeid = item[0];
			insertFAMapTable(nodeid);
		}
	}

	private void insertFAMapTable(String nodeid) {
		String sql_insert = "insert into tb_topo_afmaptable"
				+ "(select tdbtable.nodeid," + "porttable.baseportifindex,"
				+ "iftable.ifdesc,iftable.ifphyaddr," + "iftable1.nodeid,"
				+ "iftable1.ifindex," + "iftable1.ifdesc,"
				+ "tdbtable.fdbaddr,"
				+ "to_char(sysdate,'yyyy-mm-dd hh24:mi:ss') "
				+ "from tb_topo_dot1dtpfdbtable tdbtable,"
				+ "tb_topo_dot1dbaseporttable porttable,"
				+ "tb_topo_iftable iftable," + "tb_topo_iftable iftable1 "
				+ "where tdbtable.nodeid = '" + nodeid
				+ "' and tdbtable.nodeid = porttable.nodeid "
				+ "and tdbtable.fdbport = porttable.baseport "
				+ "and iftable.nodeid = tdbtable.nodeid "
				+ "and iftable.ifindex = porttable.baseportifindex "
				+ "and tdbtable.fdbstatus <> '4' "
				+ "and tdbtable.fdbaddr = iftable1.ifphyaddr)";
		
		/////////////////////////////////////////////////////////////////////////
		String sql_insert1 = "insert into tb_topo_afmaptable"
			+ "(select tdbtable.nodeid," + "porttable.baseportifindex,"
			+ "iftable.ifdesc,iftable.ifphyaddr," + "iftable1.nodeid,"
			+ "iftable1.ifindex," + "iftable1.ifdesc,"
			+ "tdbtable.fdbaddr,"
			+ "to_char(sysdate,'yyyy-mm-dd hh24:mi:ss') "
			+ "from tb_topo_dot1dtpfdbtable tdbtable,"
			+ "tb_topo_dot1dbaseporttable porttable,"
			+ "tb_topo_iftable iftable," + "tb_topo_iftable iftable1 "
			+ "where tdbtable.nodeid = '" + nodeid
			+ "' and tdbtable.nodeid = porttable.nodeid "
			+ "and tdbtable.fdbport = porttable.baseport "
			+ "and iftable.nodeid = tdbtable.nodeid "
			+ "and iftable.ifindex = porttable.baseportifindex "
			+ "and tdbtable.fdbaddr = iftable1.ifphyaddr)";
		SqlInsert.insert(sql_insert1);
	}

	public static void main(String args[]) {
		AFMapTable afMapTable = new AFMapTable();
		afMapTable.init();
		afMapTable.saveToDB();
	}
}