sqldataaccess.cs

使用工具为.net2003

/*****************************************************************************************************
*
* 作    者: 夏竹青
*
* 创建日期：2006-10-18
*
* 功能描述：数据层，与Account表相关的操作，如：添加新成员、显示成员所有信息、登陆取密码等。
*
*
* 处理过程：SignIn：通过 SqlHelper.ExecuteDataset方法，使用存储过程“usps_proSelectPwdRole”取密码与权限的数据。
*			AddnewMember：通过SqlHelper.ExecuteNonQuery方法，使用存储过程“usps_proInsAccount”来将用户信息添加进数据库。
*			MemberList：调用SqlHelper.ExecuteDataset方法，使用存储过程“usps_proSelectAccount”来将用户信息选择出来。
*
* 调用说明：实例化DataLayer.SqlDataAccess类以后，便可调用其中的方法。
*			SignIn：传入参数为_userId，返回值为DataSet，其中就是一张含有权限以及密码的表。
*			AddnewMember：传入参数为_userId，返回值为int。返回值如果大于0则表示添加成功。
*			MemberList：无传入参数，返回值为DataSet，其中含有所有用户的信息。
*************************************************************************************************/
using System;
using Microsoft.ApplicationBlocks.Data;//导入SqlHelper类
using AbstractLayer;
using System.Data;
using System.Data.SqlClient;

namespace DataLayer
{
	/// <summary>
	/// Summary description for sqlDataAccess.
	/// </summary>
	public class SqlDataAccess : IdataAccess
	{
		// All the implementation of signatures goes here 
		string m_Connection_String = "server=219.219.221.30; UID=sa; Password=; Database=test";
		//System.Configuration.ConfigurationSettings.AppSettings["ConnectionString"].ToString();


		#region SqlDataAccess构造函数
		/// <summary>
		/// 将接受的_connectionString赋给m_Connection_String
		/// </summary>
		/// <param name="string">_connectionString</param>
		/// <returns></returns>
		public SqlDataAccess(string _connectionString)
		{
			m_Connection_String=_connectionString;	
		}
		#endregion

		#region 登陆方法
		/// <summary>
		/// 登陆方法
		/// </summary>
		/// <param name="string">_userId</param>
		/// <returns>包含密码以及权限的数据集</returns>
		public DataSet SignIn(string _userId)
		{
			DataSet dtStPwd;
			//signOnParms参数，用于传给存储过程参数
			SqlParameter[] signOnParms={
										   new SqlParameter("@_userId",_userId)
									   };
			//dtStPwd = SqlHelper.ExecuteDataset(m_Connection_String,CommandType.StoredProcedure,"usps_proSelectPwd",signOnParms);
			//调用SqlHelper.ExecuteDataset方法获取密码及权限
			dtStPwd = SqlHelper.ExecuteDataset(m_Connection_String,CommandType.StoredProcedure,"usps_proSelectPwdRole",signOnParms);
			return dtStPwd;
		}
		#endregion

		#region 添加新用户
		/// <summary>
		/// 添加新用户
		/// </summary>
		/// <param name="AbstractLayer.baseMember">objMember</param>
		/// <returns>-1表示插入失败，1表示插入成功</returns>
		public int AddnewMember(AbstractLayer.baseMember  objMember)
		{
			//实例化事务
			SqlTransaction objTrans=null;
			//实例化链接字符串			
			SqlConnection myConnection =  new SqlConnection(m_Connection_String);
			try
			{
				// Insert Member Personal details only
				//打开数据库连接
				myConnection.Open();
				//开始事务
				objTrans= myConnection.BeginTransaction();
				//给arrParam参数赋值
				SqlParameter [] arrParam=new SqlParameter[9];
//
//				arrParam[0]=new SqlParameter("@fName", objMember.userId); 
//				arrParam[1]=new SqlParameter("@lName",objMember.passWord);
//				arrParam[2]=new SqlParameter("@coNo",objMember.contactNo);
//				arrParam[3]=new SqlParameter("@emailAddr",objMember.emailAddress);
//				//pass connection string, storedprocedure name and parameter array
//				SqlHelper.ExecuteNonQuery(m_Connection_String,CommandType.StoredProcedure,"usps_proInsMember",arrParam);
				
				arrParam[0]=new SqlParameter("@userId", objMember.userId); 
				arrParam[1]=new SqlParameter("@passWord",objMember.passWord);
				arrParam[2]=new SqlParameter("@role",objMember.role);
				arrParam[3]=new SqlParameter("@userName", objMember.userName); 
				arrParam[4]=new SqlParameter("@job",objMember.job);
				arrParam[5]=new SqlParameter("@contactNo",objMember.contactNo);
				arrParam[6]=new SqlParameter("@emailAddress",objMember.emailAddress);
				arrParam[7]=new SqlParameter("@homeAddress",objMember.homeAddress);
				arrParam[8]=new SqlParameter("@specify",objMember.specify);
				//pass connection string, storedprocedure name and parameter array
				//调用SqlHelper.ExecuteNonQuery方法，并使用usps_proInsAccount存储过程
				SqlHelper.ExecuteNonQuery(m_Connection_String,CommandType.StoredProcedure,"usps_proInsAccount",arrParam);
			}
			catch(Exception Ex)
			{	
				//参数失败，则返回－1
				objTrans.Rollback();
				string sError=Ex.Message.ToString();  
				return -1;
			}
			finally
			{
				myConnection.Close(); 
			}
			//插入成功则返回1
			return 1;
		}
		#endregion

		#region 显示用户所有信息
		/// <summary>
		/// 显示用户所有信息
		/// </summary>
		/// <param name=""></param>
		/// <returns>用户所有信息的数据集</returns>
		public DataSet ListAllMembers()
		{
			DataSet dtStMembers;
//			dtStMembers = SqlHelper.ExecuteDataset(m_Connection_String,CommandType.StoredProcedure,"usps_proSelectMember");
			//调用SqlHelper.ExecuteDataset方法，并使用usps_proSelectAccount存储过程
			dtStMembers = SqlHelper.ExecuteDataset(m_Connection_String,CommandType.StoredProcedure,"usps_proSelectAccount");
			return dtStMembers;
		}
		#endregion
	}
}