qqdbo.java

IO流的项目好

//服务器端数据库操作
package myQQ;

import java.util.*;

class QQDBO
{
	static DBWork dbw = new DBWork("QQmanager","QQ-2006");
		
	public static boolean chatInfoIn(MessType mt)
	{	//聊天信息录入数据库
		String sql = "";
		Object[] obj = null;
		Integer SI = new Integer(mt.Sendid);
		Integer RI = new Integer(mt.Readid);
		String T = mt.SendTime.getTime().toLocaleString();
		Boolean B = new Boolean(mt.HaseSend);
		if(mt.State==10)
		{	//聊天内容
			sql = "insert into ChatInfo(sendid,readid,sendtime,content,hasesend) values(?,?,?,?,?)";
			obj = new Object[]{SI,RI,T,mt.Content,B};
		}
		else if(mt.State==11)
		{	//聊天场景
			sql = "insert into ChatInfo(sendid,readid,sendtime,scene,hasesend) values(?,?,?,?,?)";
			obj = new Object[]{SI,RI,T,mt.Scene,B};
		}
		boolean f = dbw.Pexe(sql,obj);	//返回是否保存成功
		return f;
	}
	
	public static String logCheck(MessType mt)
	{	//登录验证
		String flag = "登录成功";
		String sql = "";
		Vector v = null;
		sql = "select * from State where QQid ='"+mt.Sendid+"'";
		v = dbw.exeQuery(sql);
		if(v.size()!=0)
		{
			sql = "select * from State where QQid ='"+mt.Sendid+"' and pw='"+mt.Sendpw+"'";
			v = dbw.exeQuery(sql);
			if(v.size()==0)
				flag = "密码有误！";
		}
		else
			flag = "此QQ号码不存在！";
		return flag;
	}
	
	public static boolean logIn(MessType mt)
	{	//注册
		String sql1 = "",sql2 = "";
		Object [] obj1 = null,obj2 = null;
		Integer In1 = new Integer(mt.Sendid);
		String s1 = mt.SendName;
		Integer A1 = new Integer(mt.SendAge);
		String s2 = mt.Sendpw;
		String s3 = mt.SendSex;
		String s4 = mt.Pro;
		String s5 = mt.City;
		String s6 = mt.SendHead;
		sql1 = "insert into Users(QQname,age,pw,sex,pro,city,head) values(?,?,?,?,?,?,?)";
		obj1 = new Object[]{s1,A1,s2,s3,s4,s5,s6};
		boolean f = dbw.Pexe(sql1,obj1);	//返回是否保存成功
		Integer In2 = new Integer(getLogId());
		sql2 = "insert into State(QQid,pw,State) values (?,?,?)";
		obj2 = new Object[]{In2,s2,new Integer(-1)};
		f = dbw.Pexe(sql2,obj2);	
		return f;
	}
	
	public static Vector getPlace(int f,MessType mt)
	{	//取得省市信息
		String sql = "";
		if(f==1)
			sql = "select distinct province from place";
		else
			sql = "select city from place where province='"+mt.Pro+"'";
		Vector v = dbw.exeQuery(sql);
		Vector x = new Vector();
		for (int i = 0; i<v.size(); i++)
		{
			String s = ((Vector)v.elementAt(i)).elementAt(0).toString();
			x.addElement(s);
		}
		return x;
	}
	
	public static String getLogId()
	{	//取得注册号
		String sql = "select max(QQid) from Users";
		Vector v = dbw.exeQuery(sql);
		String sId = ((Vector)v.elementAt(0)).elementAt(0).toString();
		return sId;
	}
	
	public static Vector getFriend(MessType mt)
	{	//取得好友列表信息
		String sql = "select head,QQname,QQid from Users where QQid in(select fid from friend where sid='"+mt.Sendid+"')";
		Vector v = dbw.exeQuery(sql);
		return v;
	}	
	
	public int stateChangeIn()
	{	//状态变化录入数据库
		return 0;	
	}
}