scheme_itemasmatrix.java

接收网络设备上NetFlow工具导出的NetFlow数据

package cai.flow.collector;

import java.sql.PreparedStatement;
import java.sql.SQLException;

import cai.flow.struct.Scheme_Data;
import cai.flow.struct.Scheme_DataASMatrix;
import cai.utils.Params;

public class Scheme_ItemASMatrix implements Scheme_Item {
	Scheme_DataASMatrix data;

	public Scheme_ItemASMatrix(Scheme_DataASMatrix data) {
		this.data = data;
	}

	public Scheme_Data getData() {
		return (Scheme_Data) data;
	}

	public boolean equals(Object oi) {
		if (oi == this)
			return true;

		Scheme_ItemASMatrix o = (Scheme_ItemASMatrix) oi;

		if (!data.equals(o.data))
			return false;

		if (!data.Src_As.equals(o.data.Src_As))
			return false;

		if (!data.Dst_As.equals(o.data.Dst_As))
			return false;

		return true;
	}

	public String toString() {
		return "ASMatrix: " + data.RouterIP + " " + data.Src_As + " -> "
				+ data.Dst_As + " " + data.dPkts + " pkts, " + data.dOctets
				+ " octets, " + data.Flows + " flows";
	}

	public int hashCode() {
		return new String(data.RouterIP + data.Src_As + data.Dst_As).hashCode();
	}

	public void add(Object o) {
		data.add(((Scheme_ItemASMatrix) o).data);
	}

	public int fill(PreparedStatement stm, int numi) throws SQLException {
		int num = data.fill(stm, numi);

		stm.setString(num++, data.Src_As);
		stm.setString(num++, data.Dst_As);
		stm.setString(num++, Params.getCurrentTime());

		return num;
	}

}