serverthread.java

个人编写的即时网络通信软件

                                out.println(rs.getString(3));
                                out.println(rs.getString(4));
                                out.println(rs.getString(5));
                                out.println(rs.getString(6));
                                out.println(rs.getString(7));
                                out.println(rs.getString(8));
                                out.println(rs.getString(9));
                                out.println(rs.getString(10));
                                out.println("over");
                             }
                            else
                            {
                                out.println("not_found");
                          //      rs.close();
                          //      aConnection.close();
                            }
                        }
                        
                    }
                    catch(SQLException e)
                    {  System.out.println("数据库连接有错3");       }
      //              socket.close();
               }
               else if(str.equals("get_my_friend"))
               {
                   try
                   {
                       String myno=in.readLine().trim();
                       String sql5="select * from friend where yourno='"+myno+"'";
                       Vector aVector=new Vector();
                       ResultSet rs=aStatement.executeQuery(sql5);
                       boolean gotIt=rs.next();
                       if(!gotIt)
                           out.println("no_friend");
                       else
                       {
                           out.println("have_found");
                            while(gotIt)
                               {
                                    aVector.add(rs.getString("friendno"));
                                    gotIt=rs.next();
                                }                   
                            for(int i=0;i<aVector.size();i++)
                            {
                                String findfriend="select * from qq where qqno='"+
                                   (String)aVector.elementAt(i)+"'";
                                ResultSet rs1=aStatement.executeQuery(findfriend);
                                boolean gotIt1=rs1.next();
                                if(gotIt1) 
                                {       
                                     out.println(rs1.getString(1));
                                     out.println(rs1.getString(2));
                                     out.println(rs1.getString(3));
                                     out.println(rs1.getString(4));
                                     out.println(rs1.getString(5));
                                     out.println(rs1.getString(6));
                                     out.println(rs1.getString(7));
                                     out.println(rs1.getString(8));
                                     out.println(rs1.getString(9));
                                     out.println(rs1.getString(10));
                                     if(i==aVector.size()-1)
                                         out.println("over");
                                 }
                                else
                                {
                                     out.println("not_found");
                                }                     
                             }
                        }
                   }
                   catch(SQLException e)
                   {    System.out.println("数据库连接有错4"); }
     //              socket.close();
               }
               else if(str.equals("add_friend"))
               {
                   try
                   {
                       String myno=in.readLine();
                       String friendno=in.readLine();
                       String sql6="select * from friend where yourno='"+myno+"' and friendno='"+friendno+"'";
                       String sql7="insert into friend(yourno,friendno) values('"+myno+"','"+friendno+"')";
                       ResultSet rs=aStatement.executeQuery(sql6);
                       boolean gotIt=rs.next();
                       if(gotIt)
                       {
                           out.println("friend_have_existed_false");
                       }
                       else
                       {
                           int result=0;
                           result=aStatement.executeUpdate(sql7);
                           if(result==1)
                                out.println("add_friend_succeed");
                           else 
                               out.println("add_friend_false");
                       }
                       
                   }
                   catch(SQLException e)
                   {    System.out.println("数据库有错5");   }
        //           socket.close();
               }
               else if(str.equals("delete_friend"))
               {
                   try
                   {
                       String myno=in.readLine();
                       String friendno=in.readLine();
                       String sql8="delete from friend where yourno='"+myno+"' and friendno='"
                               +friendno+"'";
                       int result=0;
                       result=aStatement.executeUpdate(sql8);
                       if(result==1)
                           out.println("delete_friend_ok");
                       else
                           out.println("delete_friend_false");                       
                   }
                   catch(SQLException e)
                   {    System.out.println("数据库有错6");   }
               }
               else if(str.equals("hide_me"))
               {
                   try
                   {
                       String yourstatus="离线";
                   //    String yourip="未知";
                       String myqqno=in.readLine().trim();
                   //    String sql11="Update qq set status='"+yourstatus+"',ip='"+yourip+"' where qqno='"+myqqno+"'";
                       String sql11="Update qq set status='"+yourstatus+"' where qqno='"+myqqno+"'";
                       int result=0;
                       result=aStatement.executeUpdate(sql11);
                       if(result==1)
                           out.println("hide_me_succeed");
                       else
                           out.println("hide_me_false");
         
                   }
                   catch(SQLException e)
                   {    System.out.println("数据库有错7");   }
               }
               else if(str.equals("express_me"))
               {
                   try
                   {
                       String yourstatus="在线";
                   //    String yourip="未知";
                       String myqqno=in.readLine().trim();
                   //    String sql11="Update qq set status='"+yourstatus+"',ip='"+yourip+"' where qqno='"+myqqno+"'";
                       String sql12="Update qq set status='"+yourstatus+"' where qqno='"+myqqno+"'";
                       int result=0;
                       result=aStatement.executeUpdate(sql12);
                       if(result==1)
                           out.println("express_me_succeed");
                       else
                           out.println("express_me_false");
         
                   }
                   catch(SQLException e)
                   {    System.out.println("数据库有错8");   }
               }
               else if(str.equals("logout"))
               {
                   try
                   {
                       String yourstatus="离线";
                       String yourip="未知";
                       String myqqno=in.readLine().trim();
                       String sql13="Update qq set status='"+yourstatus+"',ip='"+yourip+"' where qqno='"+myqqno+"'";                       
                       int result=0;
                       result=aStatement.executeUpdate(sql13);
                       if(result==1)
                           out.println("logout_succeed");
                       else
                           out.println("logout_false");
         
                   }
                   catch(SQLException e)
                   {    System.out.println("数据库有错9");   }
               }
            }
        }
        catch(IOException e)
                   {    System.out.println("数据库有错10");   }
        catch(SQLException e)
                   {    System.out.println("数据库有错11");   }
    }
}