c# 仿QQ程序(2)

添加新类 opDate 数据库操作类



using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;



public static bool qUserLogin(string uid, string pwd) //用户登陆验证
{
if (uid == "-1" || pwd == "-1")
{
return (false);
}
else
{
string sql = string.Format("select * from UserInf where cQQNum='{0}' and vcQuserPwd='{1}'", uid, pwd);
SqlConnection Conn = SqlConnectionTest.GetConnection();
if (Conn != null)
{
Conn.Open();
SqlCommand Com = new SqlCommand(sql, Conn);
SqlDataReader dr;
dr = Com.ExecuteReader();
if (dr.Read())
{
Com.Dispose();
Conn.Close();
return (true);
}
else
{
Com.Dispose();
Conn.Close();
return (false);
}
}
else
{
return (false);
}
}
}


public static DataSet GetFriendLsit(string uid)// 通过用户ｉｄ获取好友列表
{
DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("GetFriendLsit", Con);
da.SelectCommand.CommandType = CommandType.StoredProcedure; //存储过程
SqlParameter cQQNum = da.SelectCommand.Parameters.Add("@cQQNum", SqlDbType.Char, 8);
cQQNum.Direction = ParameterDirection.Input;
cQQNum.Value = uid;
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}


public static DataSet GetGroupInfByUserId(string uid,int model)

// 根据用户id获取该用户的好友分组消息
{
DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("GetGroupInf", Con);
da.SelectCommand.CommandType = CommandType.StoredProcedure;
SqlParameter cQQNum = da.SelectCommand.Parameters.Add("@UserId", SqlDbType.Char, 8);
SqlParameter Model = da.SelectCommand.Parameters.Add("@Model", SqlDbType.Int);
cQQNum.Direction = ParameterDirection.Input;
Model.Value = model;
cQQNum.Value = uid;
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}

public static string GetUserNameByNumber(string number)
{// 通过用户号码获取用户名称

SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("GetUserNameByNumber",Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter UserNumber = cmd.Parameters.Add("@UserNumber", SqlDbType.Char, 8);
UserNumber.Direction = ParameterDirection.Input;
UserNumber.Value = number;
return (cmd.ExecuteScalar().ToString());
}

public static string AddNewUser(string uid,string pwd)
{ // 添加新用户,返回QQ号码
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("RegUser", Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter UserName = cmd.Parameters.Add("@UserName", SqlDbType.Char, 10);
SqlParameter UserPwd = cmd.Parameters.Add("@UserPwd", SqlDbType.Char, 50);
SqlParameter UserNumber = cmd.Parameters.Add("@UserNumber", SqlDbType.Char, 8);
UserName.Direction = ParameterDirection.Input;
UserPwd.Direction = ParameterDirection.Input;
UserNumber.Direction = ParameterDirection.Output;
UserName.Value = uid;
UserPwd.Value = pwd;
cmd.ExecuteNonQuery();
return (UserNumber.Value.ToString());
}

public static DataSet SelectUserByName(string Name)
{ // 通过用户名查询用户
DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("SelectUserByName", Con);
da.SelectCommand.CommandType = CommandType.StoredProcedure;
SqlParameter UserName = da.SelectCommand.Parameters.Add("@UserName", SqlDbType.Char, 10);
UserName.Direction = ParameterDirection.Input;
UserName.Value = Name;
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}

public static DataSet SelectUserByNum(string Num)
{// 通过用户号码查询用户

DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("SelectUserByNum", Con);
da.SelectCommand.CommandType = CommandType.StoredProcedure;
SqlParameter UserNum = da.SelectCommand.Parameters.Add("@UserNum", SqlDbType.Char, 8);
UserNum.Direction = ParameterDirection.Input;
UserNum.Value = Num;
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}
public static string AddFriend(string Ow, string FNumber)
{// 添加好友
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("AddFriend", Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter Owner = cmd.Parameters.Add("@Owner", SqlDbType.Char, 8);
SqlParameter FriendNumber = cmd.Parameters.Add("@FriendNumber", SqlDbType.Char, 8);
SqlParameter GroupId = cmd.Parameters.Add("@GroupId", SqlDbType.Int);
SqlParameter result = cmd.Parameters.Add("@result", SqlDbType.Int);
Owner.Direction = ParameterDirection.Input;
FriendNumber.Direction = ParameterDirection.Input;
GroupId.Direction = ParameterDirection.Input;
result.Direction = ParameterDirection.Output;
Owner.Value = Ow;
FriendNumber.Value = FNumber;
GroupId.Value = "-1";
cmd.ExecuteNonQuery();
Con.Close();
return (result.Value.ToString());
}
public static string AddNewGroup(string Owner,string groupname)
{/// 添加新用户分组

SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("AddNewGroup", Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter GroupOwner = cmd.Parameters.Add("@GroupOwner", SqlDbType.Char, 8);
SqlParameter GroupName = cmd.Parameters.Add("@GroupName", SqlDbType.Char, 8);
SqlParameter Result = cmd.Parameters.Add("@Result", SqlDbType.Int);
GroupName.Direction = ParameterDirection.Input;
GroupOwner.Direction = ParameterDirection.Input;
Result.Direction = ParameterDirection.Output;
GroupName.Value = groupname;
GroupOwner.Value = Owner;
cmd.ExecuteNonQuery();
Con.Close();
if (Result.Value.ToString().Trim() == "-1")
{
return ("该分组名称已经存在！");
}
else if (Result.Value.ToString().Trim() == "1")
{
return ("恭喜！添加分组成功！");
}
else
{
return ("未知错误！");
}
}

public static string UpDateGroupInf(string NewName, string uid,string groupid)
{ // 更新用户分组名称
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("UpDateGroupInf", Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter newName = cmd.Parameters.Add("@newName", SqlDbType.Char, 10);
SqlParameter User = cmd.Parameters.Add("@User", SqlDbType.Char, 8);
SqlParameter GroupId = cmd.Parameters.Add("@GroupId", SqlDbType.Int);
SqlParameter Result = cmd.Parameters.Add("@Result", SqlDbType.Int);
newName.Direction = ParameterDirection.Input;
User.Direction = ParameterDirection.Input;
GroupId.Direction = ParameterDirection.Input;
Result.Direction = ParameterDirection.Output;
newName.Value = NewName;
User.Value = uid;
GroupId.Value = groupid;
cmd.ExecuteNonQuery();
Con.Close();
switch (Result.Value.ToString().Trim())
{
case "0":
return ("该分组名称已经存在！不能修改为此名称！");
case "1":
return ("修改名称成功！");
case "2":
return ("不能修改默认分组\"我的好友\"的名称！");
default:
return ("未知错误！");
}
}
public static bool DelGroup(string groupId)
{// 删除用户分组

try
{
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("DelGroupName", Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter GroupId = cmd.Parameters.Add("@GroupId", SqlDbType.Int);
GroupId.Direction = ParameterDirection.Input;
GroupId.Value = groupId;
cmd.ExecuteNonQuery();
Con.Close();
return (true);
}
catch
{
return (false);
}
}

public static DataSet GetFriendByGroupId(string groupId)
{// 根据分组id返回该分组的所有好友列表

DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("GetFriendByGroupId", Con);
da.SelectCommand.CommandType = CommandType.StoredProcedure;
SqlParameter GroupId = da.SelectCommand.Parameters.Add("@GroupId", SqlDbType.Int);
GroupId.Direction = ParameterDirection.Input;
GroupId.Value = groupId;
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}

public static DataSet GetDefaultGroupFriend(string uid)
{// 根据用户id获取所有默认分组的好友名单
DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("GetFriendListDefault", Con);
da.SelectCommand.CommandType = CommandType.StoredProcedure;
SqlParameter UserId = da.SelectCommand.Parameters.Add("@UserId", SqlDbType.Char,8);
UserId.Direction = ParameterDirection.Input;
UserId.Value = uid;
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}

public static bool ChangeFriGroup(string friendId, string DesGroup)
{// 更改好友所属于分组

SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("ChangeFriGroup", Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter FriendId = cmd.Parameters.Add("@FriendId", SqlDbType.Int);
SqlParameter DestiGroup = cmd.Parameters.Add("@DestiGroup", SqlDbType.Int);
FriendId.Direction = ParameterDirection.Input;
DestiGroup.Direction = ParameterDirection.Input;
FriendId.Value = friendId.Trim();
DestiGroup.Value = DesGroup.Trim();
cmd.ExecuteNonQuery();
Con.Close();
return (true);
}

public static bool DelThisFriend(string friendId)
{ // 删除指定好友

SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlCommand cmd = new SqlCommand("DelThisFriend", Con);
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter FriendId = cmd.Parameters.Add("@FriendId", SqlDbType.Int);
FriendId.Direction = ParameterDirection.Input;
FriendId.Value = friendId.Trim();
cmd.ExecuteNonQuery();
Con.Close();
return (true);
}

public static DataSet GetAllUser()
{ // 返回所有用户

DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("select * from GetAllUser", Con);
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}

public static DataSet GetZoneInf(string owner)
{ // 根据id获取空间资料
DataSet ds = new DataSet();
SqlConnection Con = SqlConnectionTest.GetConnection();
Con.Open();
SqlDataAdapter da = new SqlDataAdapter("GetZoneInf", Con);
da.SelectCommand.CommandType = CommandType.StoredProcedure;
SqlParameter Owner = da.SelectCommand.Parameters.Add("@Owner", SqlDbType.Char, 8);
Owner.Direction = ParameterDirection.Input;
Owner.Value = owner;
da.Fill(ds);
da.Dispose();
Con.Close();
return (ds);
}