accountsafetydal.cs

guan yu pai ke xi tong de ruan jian

using System;
using System.Collections.Generic;
using System.Text;

using System.Data;
using System.Data.SqlClient;

using Y2T03.CourseScheduler.CourseModel;
using Y2T03.CourseScheduler.IDAL;

namespace Y2T03.CourseScheduler.CourseDAL
{
    /// <summary>
    /// AccountSafetyDAL 的数据访问层
    /// </summary>
    public class AccountSafetyDAL : IAccountSafety
    {
        public AccountSafetyDAL()
        { }

        #region 添加用户
        /// <summary>
        /// 添加用户
        /// </summary>
        /// <param name="account">用户实体对象</param>
        /// <returns>true = 成功, false = 失败</returns>
        public bool Create(Account account)
        {
            string sql = "INSERT INTO Accounts(LoginName, Password) VALUES(@LoginName, @Password)";

            SqlParameter[] parms = new SqlParameter[]
            {
                new SqlParameter("@LoginName", account.LoginName),
                new SqlParameter("@Password", account.Password)
            };

            int rows = 0;

            try
            {
                rows = SQLDBHelper.ExecuteNonQuery(sql, parms);
            }
            catch (Exception ex)
            {
                string err = ex.Message;
            }

            return (rows > 0) ? true : false;
        }
        #endregion

        #region 获取用户
        /// <summary>
        /// 获取用户
        /// </summary>
        /// <param name="loginName">用户名</param>
        /// <returns>用户实体对象</returns>
        public Account GetAccount(string loginName)
        {
            string sql = "SELECT LoginName, Password FROM Accounts WHERE LoginName = @LoginName";

            SqlParameter[] parms = new SqlParameter[]
            {
                new SqlParameter("@LoginName", loginName)
            };

            Account account = null;
            try
            {
                using (SqlDataReader reader = SQLDBHelper.ExecuteReader(sql, parms))
                {
                    if (reader.Read())
                    {
                        account = new Account();

                        account.LoginName = reader.GetString(0);
                        account.Password = reader.GetString(1);
                    }
                    reader.Close();
                }
            }
            catch (Exception ex)
            {
                string err = ex.Message;
            }

            return account;
        }
        #endregion

        #region 登陆判断
        /// <summary>
        /// 登陆判断
        /// </summary>
        /// <param name="loginName">用户名</param>
        /// <param name="password">密码</param>
        /// <returns>true = 成功, false = 失败</returns>
        public bool Login(string loginName, string password)
        {
            string sql = "SELECT LoginName, Password FROM Accounts WHERE LoginName = @LoginName AND Password = @Password";

            SqlParameter[] parms = new SqlParameter[]
            {
                new SqlParameter("@LoginName", loginName),
                new SqlParameter("@Password", password)
            };

            Account account = new Account();
            try
            {
                using (SqlDataReader reader = SQLDBHelper.ExecuteReader(sql, parms))
                {
                    if (reader.Read())
                    {
                        account.LoginName = reader.GetString(0);
                        account.Password = reader.GetString(1);

                        return true;
                    }
                    reader.Close();
                }
            }
            catch (Exception ex)
            {
                string err = ex.Message;
            }

            return false;
        }
        #endregion

        #region 获取用户列表
        /// <summary>
        /// 获取用户列表
        /// </summary>
        /// <returns>用户实体对象列表</returns>
        public IList<Account> GetAccounts()
        {
            string sql = "SELECT LoginName, Password FROM Accounts";

            IList<Account> list = new List<Account>();
            try
            {
                using (SqlDataReader reader = SQLDBHelper.ExecuteReader(sql))
                {
                    while (reader.Read())
                    {
                        Account account = new Account();
                        account.LoginName = reader.GetString(0);
                        account.Password = reader.GetString(1);

                        list.Add(account);
                    }
                    reader.Close();
                }
            }
            catch (Exception ex)
            {
                string err = ex.Message;
            }

            return list;
        }
        #endregion

        #region 更新用户
        /// <summary>
        /// 更新用户
        /// </summary>
        /// <param name="account">用户实体对象</param>
        /// <returns>true = 成功, false = 失败</returns>
        public bool Update(Account account)
        {
            string sql = "UPDATE Accounts SET Password = @Password WHERE LoginName = @LoginName";

            SqlParameter[] parms = new SqlParameter[]
            {
                new SqlParameter("@Password", account.Password),
                new SqlParameter("@LoginName", account.LoginName)
            };

            int rows = 0;

            try
            {
                rows = SQLDBHelper.ExecuteNonQuery(sql, parms);
            }
            catch (Exception ex)
            {
                string err = ex.Message;
            }

            return (rows > 0) ? true : false;
        }
        #endregion

        #region 删除用户
        /// <summary>
        /// 删除用户
        /// </summary>
        /// <param name="loginName">用户名</param>
        /// <returns>true = 成功, false = 失败</returns>
        public bool Delete(string loginName)
        {
            string sql = "DELETE FROM Accounts WHERE LoginName = @LoginName";

            SqlParameter[] parms = new SqlParameter[]
            {
                new SqlParameter("@LoginName", loginName)
            };

            int rows = 0;

            try
            {
                rows = SQLDBHelper.ExecuteNonQuery(sql, parms);
            }
            catch (Exception ex)
            {
                string err = ex.Message;
            }

            return (rows > 0) ? true : false;
        }
        #endregion
    }
}