friendsmanager.java

jsp+oracle书记的源代码

package net.acai.forum;
/**
 * Title:        清清网络
 * Description:
 * Copyright:    Copyright (c) 2002
 * Company:      www.SuperSpace.com
 * @author:       SuperSpace
 * @version 1.0
 */
import net.acai.forum.*;
import net.acai.database.*;
import javax.servlet.http.*;
import java.sql.*;
import net.acai.util.*;
import java.util.Vector;
import net.acai.database.*;

public class FriendsManager
{
	String userName;
	String sql;
	public FriendsManager(HttpServletRequest request)throws Exception{
		userName=GCookie.getCookieValue(request,"UJBBUName","");
		userName = new String(userName.getBytes("ISO-8859-1"),"GBK");
	}
	public static Vector getFriendList(HttpServletRequest request) throws Exception{
		String userName=GCookie.getCookieValue(request,"UJBBUName","");
		String sql="select F_friend from  Friend where F_username='"+userName+"' order by F_addtime desc";
		DBConnect dbc=new DBConnect();
		dbc.prepareStatement(sql);
		//dbc.setBytes(1,().getBytes());
		ResultSet rs=dbc.executeQuery();
		Vector friendList=new Vector();
		while(rs.next()){
			Friend friend=new Friend();
			friend.setFriendFriend(rs.getString(1));

			friendList.add(friend);
		}
		dbc.close();
		return friendList;

	}

	public Vector getFriendInfo(HttpServletRequest request) throws Exception{
		sql="select F.*,U.useremail,U.homepage,U.oicq from  Friend F inner join myuser U on F.F_Friend=U.username where F.F_username='"+userName+"' order by F.f_addtime desc";
		//System.out.println("sql==========="+sql);
		DBConnect dbc=new DBConnect();
		dbc.prepareStatement(sql);
		//dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		ResultSet rs=dbc.executeQuery();
		Vector friendInfo=new Vector();
		while(rs.next()){

			Friend friend=new Friend();
			friend.setFriendID(rs.getInt(1));
			friend.setFriendUserName(rs.getString(2));
			friend.setFriendFriend(rs.getString(3));
			friend.setFriendAddTime(rs.getString(4));
			friend.setFriendEmail(rs.getString(5));
			friend.setFriendHomePage(rs.getString(6));
			friend.setFriendOicq(rs.getString(7));

			friendInfo.add(friend);
		}

		dbc.close();
		return friendInfo;
	}
	public void delFriend(HttpServletRequest request) throws Exception{
		int ID=0;
		try{
			ID=ParamUtil.getInt(request,"id");
		}
		catch(Exception e){
			throw new Exception("请指定相关参数。");
		}
		String userName=GCookie.getCookieValue(request,"UJBBUName","");

		DBConnect dbc=new DBConnect();
		sql="delete from  Friend where F_username='"+userName+"' and F_id="+ID;
		dbc.prepareStatement(sql);
		//dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
		dbc.executeUpdate();
		dbc.close();
	}
	public void allDelFriend() throws Exception{

		DBConnect dbc=new DBConnect();
		sql="delete from  Friend where F_username=? ";
		dbc.prepareStatement(sql);
		dbc.executeUpdate();
		dbc.close();
	}
	public void saveFriend(HttpServletRequest request) throws Exception{
		String touser=ParamUtil.getString(request,"touser");
		if(touser==null||"".equals(touser.trim()))
			throw new Exception("您忘记填写发送对象了吧。");
		String userName=GCookie.getCookieValue(request,"UJBBUName","");
		touser=touser.trim();
		String [] incept=touser.split(",");
		DBConnect dbc=new DBConnect();
		ResultSet rs;
		for(int i=0;i<incept.length;i++){
			if(i>4){
				dbc.close();
				throw new Exception("每次最多只能添加5位用户，您的名单5位以后的请重新填写");
			}
			String tempuser = new String(incept[i].getBytes("ISO-8859-1"),"GBK");
			sql="select username from  myuser where username='"+tempuser+"'";
			dbc.prepareStatement(sql);
			//dbc.setBytes(1,().getBytes());
			rs=dbc.executeQuery();
			if(!rs.next()){
				dbc.close();
				throw new Exception("系统没有这个用户，操作未成功。");
			}
			rs.close();
			sql="select F_friend from  friend where F_username='"+userName+"' and  F_friend='"+tempuser+"'";
			dbc.prepareStatement(sql);
			//dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
			//dbc.setBytes(2,(new String(incept[i].getBytes("ISO-8859-1"),"GBK")).getBytes());
			rs=dbc.executeQuery();
			String tempfid = MakeBean.makeID("FRIEND","F_ID");
			if(!rs.next()){
				sql="insert into  friend (F_ID,F_username,F_friend,F_addtime) values ('"+tempfid+"','"+userName+"','"+tempuser+"','2005-04-3')";
				dbc.prepareStatement(sql);
				//dbc.setBytes(1,(new String(userName.getBytes("ISO-8859-1"),"GBK")).getBytes());
				//dbc.setBytes(2,(new String(incept[i].getBytes("ISO-8859-1"),"GBK")).getBytes());
				dbc.executeUpdate();
			}
			rs.close();
		}
		dbc.close();
	}
}