机房重构---C#七层登陆

「爱情、让人受尽委屈。」 2022-03-30 15:54 238阅读 0赞

using System;
    using System.Collections.Generic;
    using System.ComponentModel;
    using System.Data;
    using System.Drawing;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Windows.Forms;
    
    namespace LoginUI
    {
        public partial class Login : Form
        {
            public Login()
            {
                InitializeComponent();//初始化窗体上的控件
            }
    
            private void Login_Load(object sender, EventArgs e)
            {
             
              
            }
            private void btnLogin_Click_1(object sender, EventArgs e)
            {
                //判断输入不能为空
                if (txtUserID.Text.Trim() == "")
                {
                    MessageBox.Show("用户名不能为空", "温馨提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                }
                if (txtPWD.Text == "")
                {
                    MessageBox.Show("密码不能为空", "温馨提示", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                }
                try
                {
                    Entity.User user = new Entity.User();//实例化实体
                    user.UserID = Convert.ToInt32(txtUserID.Text.Trim());//将用户输入的用户名和密码传给实体
                    user.Password = txtPWD.Text;
    
                    Boolean flag = false;
                    Facade.LoginFacade FLogin = new Facade.LoginFacade();//实例化外观
    
                    flag = FLogin.SelectUser(user);//调用外观的SelectUser方法，返回给user
    
                    if (flag != false)
                    {
                        this.Hide(); 
                        this.DialogResult = System.Windows.Forms.DialogResult.OK;
                        frmMain frmMain = new frmMain();//实例化一个窗体
                        frmMain.Show();//显示实例化的窗体
    
                    }
                    else
                    {
                        MessageBox.Show("密码或者用户名错误");
                    }
                }
                catch (Exception)
                {
                    throw;
                }
            }
            private void btncancel_Click(object sender, EventArgs e)
            {
    
                System.Environment.Exit(0);
    
            }
    
            
        }
    }

Entity

namespace Entity
    {
        public class User
        {
            //定义用户ID 字段
            private int userid;
            public int UserID
            {
                get { return userid; }
                set { userid = value; }
            }
    
            //定义用户名 字段
            private string userName;
            public string UserName
            {
                get { return userName; }
                set { userName = value; }
            }
    
            //定义密码 字段
            private string password;
            public string Password
            {
                get { return password; }
                set { password = value; }
            }
        }
    }

Facade

using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    
    namespace Facade
    {
        public class LoginFacade
        {
            public Boolean SelectUser(Entity.User user)
            {
                bool flag;
                BLL.LoginBLL userBLL = new BLL.LoginBLL();//实例化B层
                flag = userBLL.UserBLL(user);//调用B层的UserBLL方法
                return flag;
            }
        }
    }

BLL

using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Data;
    
    namespace BLL
    {
        public class LoginBLL
        {
            public bool UserBLL(Entity.User user)
            {
                Factory.LoginFactory fact = new Factory.LoginFactory();//实例化工厂
                IDAL.LoginIDAL idal = fact.CreateUser();//调用工厂方法创建接口  
                DataTable table = idal.SelectUser(user);//调用D层的SelectUser方法，接受D层的返回值  
                bool flag;
                if (table.Rows.Count == 0)//返回的DataTable类型，如果它的行数等于0，说明没有符合该帐号密码的用户  
                { flag = false; }
                else
                {
                    flag = true;
                }
                return flag;
            }
        }
    }

Factory

using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Configuration;
    using System.Reflection;//增加反射的引用
    using System.IO;
    
    namespace Factory
    {
        public class LoginFactory
        {
            //string StrDB = System.Configuration.ConfigurationManager.AppSettings["DB"];
            String StrDB = "DAL";
    
            public IDAL.LoginIDAL CreateUser()
            {
                string ClassName = StrDB + "." + "LoginDAL";//DAL层的类名
                return (IDAL.LoginIDAL)Assembly.Load(StrDB).CreateInstance(ClassName);
            }
        }
    }

IDAL

namespace IDAL
    {
        public interface LoginIDAL
        {
            DataTable SelectUser(Entity.User UserInfo);
        }
    }

DAL

using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.Configuration;
    using System.Data;
    using System.Data.SqlClient;
    
    namespace DAL
    {
        public class LoginDAL:IDAL.LoginIDAL
        {
            public DataTable SelectUser(Entity.User user)
            {
                SQLHelper sqlHelper = new SQLHelper(); //实例化SQLHelper
                 SqlParameter[] sqlParams = { new SqlParameter("@userID", user.UserID), new SqlParameter("@Password", user.Password) };//防止sql注入
                string sql = @"SELECT*FROM [User]WHERE UserId=@UserId and Password=@Password";//sql语句
                DataTable table = sqlHelper.ExecuteQuery(sql, sqlParams, CommandType.Text);
                return table;
            }
            public DataTable addUser(Entity.User user)
            {
                SQLHelper sqlHelper = new SQLHelper();
                SqlParameter[] sqlParams =
                {   new SqlParameter("@UserID",user.UserID),
                    //new SqlParameter ("@Phone",UserInfo.Phone),
                    new SqlParameter("@PassWord",user.Password),
                    //new SqlParameter("@Balance",UserInfo.Balance)
                };
    
                string sql = "Insert into [User](UserID,Phone,PassWord,Balance)values(@UserID,@Phone,@PassWord,@Balance)";
    
                DataTable table = sqlHelper.ExecuteQuery(sql, sqlParams, CommandType.Text);
                return table;
            }
        }
    }

SqlHelper

using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using System.IO;
    using System.Configuration;
    using System.Data;
    using System.Data.SqlClient;
    using System.Reflection;
    
    namespace DAL
    {
        public class SQLHelper
        {
            private SqlConnection conn = null;
            private SqlCommand cmd = null;
            private SqlDataReader sdr = null;
    
    
    
            public SQLHelper()
            {
                string connStr = ConfigurationManager.AppSettings["connstr"];//连接数据库，connstr是从web.config配置文件里面连接数据库的关键字，在每个.cs页面引用这一句就可以连接数据库
                conn = new SqlConnection(connStr);
            }
    
            private SqlConnection GetConn()
            {
                if (conn.State == ConnectionState.Closed)
                {
                    conn.Open();
                }
                return conn;
            }
    
            /// <summary>
            /// 执行不带参数的的增删改SQL语句或者存储过程
            /// </summary>
            /// <param name="cmdText">增删改查SQL</param>
            /// <param name="ct">命令类型</param>
            /// <returns>返回受影响的行数</returns>
            /// 
            public int ExecuteNonQuery(string cmdText, CommandType ct)
            {
                int res;
                try
                {
                    cmd = new SqlCommand(cmdText, GetConn());
                    cmd.CommandType = ct;
                    res = cmd.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    throw ex;
                }
                finally
                {
                    if (conn.State == ConnectionState.Open)
                    {
                        conn.Close();
                    }
                }
                return res;
            }
    
            /// <summary>
            /// 执行带参数的的增删改SQL语句或者存储过程
            /// </summary>
            /// <param name="cmdText">增删改查SQL</param>
            /// <param name="paras">要查询的参数</param>
            /// <param name="ct">命令类型</param>
            /// <returns>返回受影响的行数</returns>
            /// 
            public int ExecuteNonQuery(string cmdText, SqlParameter[] paras, CommandType ct)
            {
                int res;
                using (cmd = new SqlCommand(cmdText, GetConn()))
                {
                    cmd.CommandType = ct;
                    cmd.Parameters.AddRange(paras);
                    res = cmd.ExecuteNonQuery();
                }
                return res;
            }
    
            /// <summary>
            ///  执行不带参数的查询SQL语句或存储过程
            /// </summary>
            /// <param name="cmdText">查询SQL语句或存储过程</param>
            /// <param name="ct">命令类型</param>
            /// <returns></returns>
            /// 
    
            public DataTable ExecuteQuery(string cmdText, CommandType ct)
            {
                DataTable dt = new DataTable();
                cmd = new SqlCommand(cmdText, GetConn());
                cmd.CommandType = ct;
                using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))
                {
                    dt.Load(sdr);
                }
                return dt;
    
            }
            /// <summary>
            /// 执行带参数的查询SQL语句或存储过程
            /// </summary>
            /// <param name="cmdText">查询SQL语句或存储过程</param>
            /// <param name="paras">参数集合</param>
            /// <param name="ct">命令类型</param>
            /// <returns></returns>
            /// 
            public DataTable ExecuteQuery(string cmdText, SqlParameter[] paras, CommandType ct)
            {
                DataTable dt = new DataTable();
                cmd = new SqlCommand(cmdText, GetConn());
    
                cmd.CommandType = ct;
                cmd.Parameters.AddRange(paras);
                using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))
                {
                    dt.Load(sdr);
                }
                return dt;
            }
        }
    }

APP.config

<?xml version="1.0" encoding="utf-8" ?>
    <configuration>
        <startup> 
            <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />
        </startup>
    <appSettings>
        <add key ="ConnStr" value="server=Sarahhjf; database=Login;user ID = sa ; pwd=1"/>
        
        <add key ="DB" value="DAL" />
      </appSettings>
    </configuration>