database_server.java

书中的例题

//(2) 服务器端程序：
import java.io.*;import java.net.*;
import java.util.*;import java.sql.*;
public class Database_server 
{   public static void main(String args[])
    {   ServerSocket server=null;
	    Server_thread thread;
         Socket you=null;
         while(true) 
         { try{ server=new ServerSocket(4331);
               }
             catch(IOException e1) {System.out.println("正在监听");} 
             try{ you=server.accept();
                }
             catch (IOException e)
                {System.out.println("正在等待客户");
                }
             if(you!=null) 
                {new Server_thread(you).start();   
                }
             else {continue;}
         }
    }
}


class Server_thread extends Thread
{  Socket socket;
   Connection Con=null;
   Statement Stmt=null;
   DataOutputStream out=null;
   DataInputStream  in=null;
   String s=null;
   String conURL="jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)};DBQ=TestDB.mdb";
   Server_thread(Socket t)
      { socket=t;
        try {
			  in=new DataInputStream(socket.getInputStream());
              out=new DataOutputStream(socket.getOutputStream());
            }
        catch (IOException e) {System.out.println(e.getMessage());}
        try { 
			  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            }
        catch(ClassNotFoundException e){System.out.println(e.getMessage()); }
        try {
			  Con=DriverManager.getConnection(conURL);
              Stmt=Con.createStatement();
            }
        catch(SQLException ee) {System.out.println(ee.getMessage());}
      }  
   public void run()        
   {  while(true)
       {try{ s=in.readUTF();
             int n=0;
             ResultSet rs=
             Stmt.executeQuery("SELECT * FROM 商品表 WHERE 品名 ="+"'"+s+"'" );
             while (rs.next())
                 { String 英语单词=rs.getString("品名");
                   if(s.equals(英语单词))
                       { out.writeUTF(rs.getString("单价"));
				         n=1;break; 
                       }
                    if(n==0) {out.writeUTF("没有此商品");}
                 }
              sleep(45);
            }
        catch(Exception ee) 
            {
			  System.out.println(ee.getMessage());
			  break;
            }
       } 
   }
}