datauser.cs

聊天系统的经

using System;
using System.Windows.Forms;
using System.Data;
using System.Data.SqlClient;

namespace WindowsApplication1
{
	/// <summary>
	/// DataUser 的摘要说明。
	/// </summary>
	public class DataUser
	{
		private SqlConnection conn;
		private SqlCommand cmd;
		private SqlDataAdapter da;

		public DataUser()
		{
			conn=new SqlConnection("server=.;uid=sa;pwd=;database=Students");
			cmd=conn.CreateCommand();
			da=new SqlDataAdapter();
		}
		public DataSet GetAllUser()
		{
			DataSet ds=new DataSet();
			cmd.CommandText="select * from t_user";
			cmd.CommandType=CommandType.Text;
			da.SelectCommand=cmd;
			da.Fill(ds,"t_user");
			return ds;
		}
		public void InsertUser(DataSet ds)
		{
			cmd.CommandText="dbo_InsertUser";
			cmd.CommandType=CommandType.StoredProcedure;

			cmd.Parameters.Add("@uname",SqlDbType.NVarChar,50);
			cmd.Parameters.Add("@uage",SqlDbType.Int);
			cmd.Parameters.Add("@ustat",SqlDbType.NVarChar,50);

			cmd.Parameters[0].SourceColumn="uname";
			cmd.Parameters[1].SourceColumn="uage";
			cmd.Parameters[2].SourceColumn="ustat";

			da.InsertCommand=cmd;
			try
			{
				da.Update(ds,"t_user");
				MessageBox.Show("插入记录成功!");
			}
			catch(SqlException ex)
			{
				MessageBox.Show(ex.Message);
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message);
			}
			finally
			{
			}
		}
		public void UpdateUser(DataSet ds)
		{
			cmd.CommandText="dbo_UpdateUser";
			cmd.CommandType=CommandType.StoredProcedure;

			cmd.Parameters.Add("@uname",SqlDbType.NVarChar,50);
			cmd.Parameters.Add("@uage",SqlDbType.Int);
			cmd.Parameters.Add("@ustat",SqlDbType.NVarChar,50);

			cmd.Parameters[0].SourceColumn="uname";
			cmd.Parameters[0].SourceVersion=DataRowVersion.Original;

			cmd.Parameters[1].SourceColumn="uage";
			cmd.Parameters[1].SourceVersion=DataRowVersion.Current;

			cmd.Parameters[2].SourceColumn="ustat";
			cmd.Parameters[2].SourceVersion=DataRowVersion.Current;

			da.UpdateCommand=cmd;

			try
			{
				da.Update(ds,"t_user");
				MessageBox.Show("修改记录成功!");
			}
			catch(SqlException ex)
			{
				MessageBox.Show(ex.Message);
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message);
			}
			finally
			{
			}
		}
		public void DeleteUser(DataSet ds)
		{
			cmd.CommandText="dbo_DeleteUser";
			cmd.CommandType=CommandType.StoredProcedure;

			cmd.Parameters.Add("@uname",SqlDbType.NVarChar,50);
			cmd.Parameters[0].SourceColumn="uname";
			cmd.Parameters[0].SourceVersion=DataRowVersion.Original;

			da.DeleteCommand=cmd;

			try
			{
				da.Update(ds,"t_user");
				MessageBox.Show("删除记录成功！");
			}
			catch(SqlException ex)
			{
				MessageBox.Show(ex.Message);
			}
			catch(Exception ex)
			{
				MessageBox.Show(ex.Message);
			}
			finally
			{

			}
		}
	}
}