connectsql.java

网络聊天程序

               else 
              	   friendclass.friendStatus="0";
               friendclass.friendPic=rslt.getInt("pic");
               friendclass.friendPlace= rslt.getString("place");
               friendclass.friendEmail=rslt.getString("email");
               friendclass.picInfo=rslt.getString("info");
               System.out.println(friendclass.friendNickname);
               System.out.println(friendclass.friendIcqno);
               System.out.println(friendclass.friendIp);
               System.out.println(friendclass.friendStatus);
               System.out.println(friendclass.friendPic);
               System.out.println(friendclass.friendEmail);
               System.out.println(friendclass.picInfo);
               vector.add(friendclass);
              }
              
           }
          
        } 
        catch(Exception e)
        {
          	System.out.println("查询失败!");
        }
        finally
        {
          	closeSQL();
        }
        return  vector;
	}
	 //以下处理用户添加好友
	public String addfriend(int myicqno,int friendicqno)
	{
		String sql="select * from friend where Icqno=? and Friend=?";
		 String addfriend="insert into friend values(?,?)";
		 String variable="alreadyadd";
		 try
		 {
		 	prepare = con.prepareStatement(sql);
            prepare.clearParameters();
            prepare.setInt(1,myicqno);
            prepare.setInt(2,friendicqno);
            rslt=prepare.executeQuery();
            if(rslt.next())
            {
            	variable="alreadyadd";
            }
            else
            {
            prepare = con.prepareStatement(addfriend);
            prepare.clearParameters();
            prepare.setInt(1,myicqno);
            prepare.setInt(2,friendicqno);
            int  r6=0;
            r6=prepare.executeUpdate();
            if(r6==1) 
               variable="addSucceed";
            else 
               variable="addLost";
           }
           }
           catch(Exception e)
           {
           	  	System.out.println("插入数据失败!");
           }
           finally
           {
           	closeSQL();
           }
           return variable;    
	}
	//以下处理其他用户如果加我，我就加他
	public Vector addnewfriend(int myicqno,int friendicqno)
	{
		 //String addfriend="insert into friend values(?,?)";
         String sql="select * from icq where icqno=?";
         Vector rsAddnew = new Vector();
          //如果成功，就向用户传递好友的基本信息，比如呢称等
         try
         {   
                 prepare = con.prepareStatement(sql);
                 prepare.clearParameters();
                 prepare.setObject(1,friendicqno);
                 rslt=prepare.executeQuery();
                 boolean status;
                 while(rslt.next())
                 {
              	  Friend friendclass= new Friend();
                  friendclass.friendNickname=rslt.getString("nickname");
                  friendclass.friendSex=rslt.getString("sex");
                  friendclass.friendIcqno=rslt.getInt("icqno");
                  friendclass.friendIp=rslt.getString("ip");
                  status=rslt.getBoolean("status");
                  if (status)
                    friendclass.friendStatus="1";
                  else 
              	  friendclass.friendStatus="0";
                  friendclass.friendPic=rslt.getInt("pic");
                  friendclass.friendPlace= rslt.getString("place");
                  friendclass.friendEmail=rslt.getString("email");
                  friendclass.picInfo=rslt.getString("info");
                  System.out.println(friendclass.friendNickname);
                  System.out.println(friendclass.friendIcqno);
                  System.out.println(friendclass.friendIp);
                  System.out.println(friendclass.friendStatus);
                  System.out.println(friendclass.friendPic);
                  System.out.println(friendclass.friendEmail);
                  System.out.println(friendclass.picInfo);
                  rsAddnew.add(friendclass);
                 
                  } 
          }
          catch(Exception e)
          {
           	 System.out.println("查询好友失败!");
           }
          finally
          {
              closeSQL();
          }
          return rsAddnew;
	}
    //以下执行用户删除好友
	public String delfriend(int myicqno,int friendicqno)
	{
	   String delfriend="delete from friend where icqno=? and friend=?";
	   String rs = "delLost";
	   try
	   {
        prepare = con.prepareStatement(delfriend);
        prepare.clearParameters();
        prepare.setInt(1,myicqno);
        prepare.setInt(2,friendicqno);
        int  r7=0;
        r7=prepare.executeUpdate();
        if(r7==1) 
           rs = "delSucceed";//成功
        else  
            rs = "delLost";//失败
        }
        catch(Exception e)
        {
          	System.out.println("查询失败!");
        }
        finally
        {
          	closeSQL();
        }
        return rs;
        
	}
	//以下处理用户退出程序
	public String logout(int myicqno)
	{
		String status="update icq set status=0 , ip=' ' where icqno=?";
		String rslogout="updatelost";
		try
		{
             prepare = con.prepareStatement(status);
             prepare.clearParameters();
             prepare.setInt(1,myicqno);
             int r8=prepare.executeUpdate();
             if(r8==1) 
                 rslogout="updatesucceed";
              else  
                 rslogout="updatelost";
          }
          catch(Exception e)
          {
          	System.out.println("查询失败!");
          }
          finally
          {
          	closeSQL();
          }
          return rslogout;
	}
	//以下处理那些人加了我为好友，以便上线通知他们
	public void getwhoaddme(int myicqno)
	{
	    String getwhoaddme="select icqno from friend where friend=?";
	    try
	    {
	    	prepare=con.prepareCall(getwhoaddme);
	    	prepare.clearParameters();
	    	prepare.setInt(1,myicqno);
	    	rslt=prepare.executeQuery();
            Vector who=new Vector();
            while(rslt.next())
            {
                who.add(new Integer(rslt.getInt(1)));
            }
            //然后告诉这些好友的ip地址，然后发给用户以便告诉其他客户我上线了
            for(int i=0;i<who.size();i++)
            {
              String whoinfo="select ip from icq where icqno=? and status=1";
              prepare=con.prepareCall(whoinfo);
              prepare.clearParameters();
              prepare.setObject(1,who.get(i));
              rslt=prepare.executeQuery();
              while(rslt.next())
              {
                System.out.println(rslt.getString("ip"));
              } 
             }  
             System.out.println("over");
             System.out.println("over");
          }
          catch(Exception e)
          {
               	System.out.println("查询失败!");
          }
          finally
          {
             	closeSQL();
          }
	}
	//关闭数据库的连接
	public void closeSQL()
	{
		try
		{
		//	rslt.close();
		    con.close();
		}
		catch(SQLException sqle)
		{
			System.out.println("关闭失败");
		}
		catch(Exception e)
		{
			System.out.println("数据库关闭失败");
		}
	}
	
}