srequsers.java

windows系统下用java开发的网络入侵检测程序

import java.sql.*;
import java.io.*;
/**
 * 
 * Transact searching registered users.<p>
 * 2005.8.18<p>
 * @version 0.1.2
 * @author Daxin Tian
 *
 */
public class Srequsers {

	/**
	 * Search whom, if null means search all users.
	 */
	String users_name;
	/**
	 * Server's DataInputStream.
	 */
	DataInputStream s_dis=null;
	/**
	 * Server's DataOutputStream.
	 */
	DataOutputStream s_dos=null;
	/**
	 * Contain some information about the search request.
	 */
	String info=null;
	/**
	 * How many users are found.
	 */
	int num=0;
	/**
	 * Founded user's name.
	 */
	String rsname=null;
	/**
	 * Founded user's signature.
	 */
	String rsinfo=null;
	/**
	 * Founded user's state.
	 */
	int rsstate=0;
	/**
	 * Founded user's IP address.
	 */
	String rsips=null;
	
	Connection con;
	Statement sql;
	ResultSet rs;
	/**
	 * 
	 * @param users Search whom, if null means search all users.
	 * @param dis Server's DataInputStream.
	 * @param dos Server's DataOutputStream.
	 */
	Srequsers(String users,DataInputStream dis,DataOutputStream dos)
	{
		users_name=users;
	    s_dis=dis;
	    s_dos=dos;
	}
	/**
	 * Search one registered user or all users.
	 *
	 */
	public void req()
	{
		StringBuffer s_sb=null;
		
		try
		{
			Class.forName("com.mysql.jdbc.Driver");
			//Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
		}
		catch(ClassNotFoundException e)
		{
			info="db driver wrong";
			
		}
		try
		{
			con=DriverManager.getConnection("jdbc:mysql://localhost/jidx");
			//con=DriverManager.getConnection("jdbc:odbc:jidxdb","","");
			sql=con.createStatement();
			if(users_name==null)
			{
				rs=sql.executeQuery("select * from register");
			}
			else
			{
				rs=sql.executeQuery("select * from register where username='"+users_name+"'");
			}
			
			while(rs.next())
			{
				num++;
			}
			info="found users";
			s_sb=new StringBuffer();
			s_sb.append("<msg><ack_users_num><num>"+num+"</num><info>"+info+"</info></ack_users_num></msg>");
			try
			{
				//System.out.println("send num"+num);
				s_dos.writeUTF(s_sb.toString());
			}
			catch(IOException e)
			{
				
			}
			if(num>0)
			{
				
				rs.beforeFirst();
				while(rs.next())
				{
					s_sb=new StringBuffer();
					rsname=rs.getString(1);
					rsinfo=rs.getString(3);
					rsstate=rs.getInt(4);
					rsips=rs.getString(5);
					s_sb.append("<msg><ack_users><name>"+rsname+"</name><info>"+rsinfo+"</info><state>"+rsstate+"</state><ips>"+rsips+"</ips></ack_users></msg>");
					try
					{
						s_dos.writeUTF(s_sb.toString());
					}
					catch(IOException e)
					{
						
					}
					
				}
				con.close();
			}
			
			
			
			
		}
		catch(SQLException e)
		{
			info="find users wrong";
			s_sb=new StringBuffer();
			s_sb.append("<msg><ack_users_num><num>"+num+"</num><info>"+info+"</info></ack_users_num></msg>");
			try
			{
				s_dos.writeUTF(s_sb.toString());
			}
			catch(IOException ee)
			{
				
			}
		}
		
	}
}