runserver.java

学生资料管理系统 基于c/s模式开发 用户可以运行用户端登陆服务器 然后通过客户端来进行服务器端的数据库操作

import java.io.IOException;
import java.sql.SQLException;
import java.util.Calendar;


/**
 * author sunringove
 * data 2007-01-17
 * 
 */
public class RunServer {

	/**
	 * @param args
	 * @throws ClassNotFoundException 
	 * @throws IOException 
	 * @throws SQLException 
	 */
	
	
	
	public static void main(String[] args) throws IOException, ClassNotFoundException, SQLException {
		
		String string;
		String userName="sunringove";
		String passWord="000000";
		String uName=new String();
		String pWord=new String();
		String query = null;
		String searchKey;
		String searchValue;
		Calendar calendar=Calendar.getInstance();
		ConsoleFrame consoleFrame=new ConsoleFrame();
		consoleFrame.setVisible(true);
		Server server=new Server();
		consoleFrame.appendString(calendar.getTime()+" Server Ready!");
       
		String operate;
		int index=0;
		Member member[]=new Member[1024];
		SqlOperator sql;
				
		server.sendString("request userName and passWord");
		
		string=server.receiveString().toString();
		
		try{	
		
		while(!string.equals("Legel user")){
											
			uName=server.receiveString().toString();
			pWord=server.receiveString().toString();
									
			if(uName.equals(userName)&&pWord.equals(passWord)){
					server.sendString("vertify");
					
					consoleFrame.appendString(calendar.getTime()+" leagel user");
					System.out.println( calendar.getTime()+" leagel user");
					consoleFrame.appendString(calendar.getTime()+" sunringove log in!");
					System.out.println(calendar.getTime()+" sunringove log in!");
			}
			else{
					server.sendString("erre");
					
					consoleFrame.appendString(calendar.getTime()+" unleagel user="+uName);
					System.out.println(calendar.getTime()+" unleagel user="+uName);
			}
			
			string=server.receiveString();
			
		}
		
		sql=new SqlOperator();
		member=sql.selectAll();
		
		server.sendString(sql.getIndex()+"");
		server.sendObject(member);
		
		while(true){
						
			operate=server.receiveString();
						
			if(operate.equals("刷新")){
				sql=new SqlOperator();
				member=sql.selectAll();
				query=sql.getQuery();
				index=sql.getIndex();
			}
			
			if(operate.equals("修改")){
				sql=new SqlOperator();
				sql.Delete("学号",server.receiveString());
				consoleFrame.appendString(sql.getQuery());
				sql.Insert(server.receiveSingleObject());
				query=sql.getQuery();
				member=sql.selectAll();
				index=sql.getIndex();
			}
						
			if(operate.equals("添加")){
					sql=new SqlOperator();
					sql.Insert(server.receiveSingleObject());
					query=sql.getQuery();
					member=sql.selectAll();
					index=sql.getIndex();
			}
			
			if(operate.equals("删除")){
					sql=new SqlOperator();
					sql.Delete("学号",server.receiveSingleObject().getID());
					query=sql.getQuery();
					member=sql.selectAll();
					index=sql.getIndex();
					
			}
			
			if(operate.equals("查找")){
					sql=new SqlOperator();
					
					searchKey=server.receiveString();
					searchValue=server.receiveString();
					member=sql.select(searchKey,searchValue);
					query=sql.getQuery();
					index=sql.getIndex();
					
					
			}
					
			
			consoleFrame.appendString(query);
			server.sendObject(member);
			server.sendString(index+"");	
					
				
		}
	}catch(Exception e){
		
		consoleFrame.appendString(calendar.getTime()+" 客户端断开");
		System.out.println(calendar.getTime()+" 客户端断开");
	}
		
	}

}