databaseserver.java

图书管理（负责监听客户端的呼叫）

import java.io.*;
import java.net.*;
import java.sql.*;
import java.util.StringTokenizer;
public class DatabaseServer
{
	public static void main(String args[])
	{ServerSocket server=null;
	 Server_thread thread;
	 Socket you=null;
	
	while(true)
	{ 
	try{
		server=new ServerSocket(6666);
	}
	catch(IOException el)
	{
		System.out.println("正在监听");
	}
	try{
		you=server.accept();
	}
	catch(IOException e)
	{
	}
	if(you!=null)
	{new Server_thread(you).start();
	}
	else{
		continue;
	    }
	}
}
}
class Server_thread extends Thread
{
 Socket socket;
 Connection con=null;
 Statement stmt=null;
 ResultSet rs;
 DataOutputStream out=null;
 DataInputStream in=null;
 String s=null;
 int number=0;
 Server_thread(Socket t)
  {
  	socket=t;
  	try{in=new DataInputStream(socket.getInputStream());
  	    out=new DataOutputStream(socket.getOutputStream());
  	}
  	catch(IOException e)
  	{
  	}
  	try{Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
  	}
  	catch(ClassNotFoundException e)
  	{
  	}
  	try{
  		con=DriverManager.getConnection("jdbc:odbc:moon","","");
  		stmt=con.createStatement();
  	}
  	catch(SQLException ee)
  	{
  	}
  }
  
  public void run()
  {
  	while(true)
  	{try{
  		s=in.readUTF();
  		System.out.println(s);
  		String sqlCondition=null;
  		String 查询内容=".",查询范畴="",查询条件="";
  		StringTokenizer fenxi=new StringTokenizer(s,":");
  		if(fenxi.hasMoreTokens())
  	   {
  	   	查询内容=fenxi.nextToken();
  	   }
  	   if(fenxi.hasMoreTokens())
  	   {
  	   	查询范畴=fenxi.nextToken();
  	   }
  	   if(fenxi.hasMoreTokens())
  	   {
  	   	查询条件=fenxi.nextToken();
  	   }
  	   if(查询条件.equals("完全一致"))
  	   {sqlCondition=
  	      "SELECT * FROM bookform WHERE"+查询范畴+"="+"'"+查询内容+"'"; 	 
  	    }
  	   else if(查询条件.equals("前方一致"))
  	   {
  	   	sqlCondition=
  	   	"SELECT * FROM bookform WHERE"+查询范畴+"LIKE"+"'%"+查询内容+"%'";
  	   }
  	   try{
  	   	rs=stmt.executeQuery(sqlCondition);
  	   	number=0;
  	   	while(rs.next())
  	   	{number++;
  	   	 String 书名=rs.getString("书名");
  	   	 String 作者=rs.getString("作者");
  	   	 String 出版社=rs.getString("出版社");
  	   	 String 价格=rs.getString("价格");
  	   	 Date 日期=rs.getDate("日期");
  	   	 out.writeUTF("\n"+number+""+书名+","+作者+","+出版社+","+价格+","+日期);
  	   	 }
  	   	 if(number==0)
  	   	 {out.writeUTF("没有查询到任何记录\n");
  	   	 }
  	   	}
  	   	catch(SQLException ee)
  	   	{
  	   	}
  	   }
  	   catch(IOException e)
  	   {
  	   	try
  	   	  {
  	   	  	socket.close();
  	   	  	con.close();
  	   	  }
  	   catch(Exception eee)
  	    {
  	    }
  	    System.out.println("客户离开了");
  	    break;	  
  	   }
  	}
  	}
  }