如何在 ASP.Net 中创建必须是通用的数据访问层？

Question

我查看了几个站点 CodeProject、CSharpCorner、MSDN、CSharpPearls 等，包括一个 StackOverflow 链接：-

how to create single Data Access Layer to access two different data source in asp.net

但我对答案不满意。

我想在 ASP.net C# 中为我的网站创建一个 DAL，我在其中使用 Web.Config 来获取 ConnectionString。但事情是假设今天我连接到 SQLSERVER，我的 DAL 能够连接到 SQLSERVER。但是假设将来我再添加一个连接字符串，现在用一个连接字符串连接到 SQLSERVER，用另一个连接字符串连接到 MYSQL，我的 DAL 必须能够毫无问题地连接到所有类型的数据库。

到目前为止，我所做的是用于 SQLServer，它适用于 SQLServer，但我希望它是通用的，适用于 OLEDB、MYSQL、SQLCLIENT、（BIGTABLE & CASANDRA IF POSSIBLE）和所有其他提供商。

这是我到目前为止所尝试的：-

namespace MyDAL
{
namespace DB
{
    using System;
    using System.Configuration;
    using System.Data;
    using System.Data.SqlClient;
    /// <summary>
    /// BaseDataManager is used to connect to database
    /// </summary>
    [Serializable()]
    public class BaseDataManager : IDisposable
    {
        private bool _disposedValue = false;
        private SqlConnection _connectionObject = null;
        private SqlCommand _commandObject = null;
        public BaseDataManager()
        { }
        /// <summary>
        /// Provide ConnectionString
        /// </summary>
        public BaseDataManager(string connectionString)
        {
            this.SqlConnectionString = connectionString;
        }

        /// <summary>
        /// if config is true provide connectionstring name in Web.config
        /// else if config is false provide connectionstring rather than providing                     
        ///name
        /// </summary>
        public BaseDataManager(String connectionString_Name, Boolean config)
        {
            if (config == true)
            {
                this.SqlConnectionString = ConfigurationManager.ConnectionStrings[connectionString_Name].ConnectionString;
            }
            else if (config == false)
            {
                this.SqlConnectionString = connectionString_Name;
            }
            else
            {
                Console.Out.WriteLine("Error in Connection String, Check Web.Config ");
            }
        }
        /// <summary>
        /// Provide data source=; as connection string, username and password of
        /// database 
        /// </summary>
        public BaseDataManager(string DataSource, string InitialCatalog, bool IntegratedSecurity)
        {
            if (IntegratedSecurity == true)
            {
                this.SqlConnectionString += "Data Source=" + DataSource + "InitialCatalog=" + InitialCatalog + ";Integrated Security=" + IntegratedSecurity;
            }
        }

        /// <summary>
        /// Provide data source=; as connection string, username and password of
        /// database 
        /// </summary>
        public BaseDataManager(string DataSource,string InitialCatalog, string username, string password)
        {
            this.SqlConnectionString += "Data Source="+DataSource+"InitialCatalog="+InitialCatalog+";User ID=" + username + ";Password=" + password;
        }

        public string SqlConnectionString
        {
            get;
            set;
        }

        public virtual SqlConnection connection
        {
            get
            {
                if (_connectionObject == null && !String.IsNullOrEmpty (this.SqlConnectionString))
                    _connectionObject = new SqlConnection (this.SqlConnectionString);
                return _connectionObject;
            }
            set
            {
                _connectionObject = value;
            }
        }

        public virtual SqlCommand command
        {
            get
            {
                if (_commandObject == null)
                    _commandObject = new SqlCommand();
                return _commandObject;
            }
            set
            {
                _commandObject = value;
            }
        }

        public SqlConnection getOpenConnection()
        {
            if (connection.State == ConnectionState.Closed)
            {
                connection.Open();
            }
            return connection;
        }

        public SqlCommand getCommand()
        {
            return command;
        }

        protected virtual void Dispose(bool disposing)
        {
            if (!_disposedValue)
            {
                if (disposing)
                {


   //-------------------------------------------------------------------------
                    // Close the connection object prior to setting it to nothing


   //----------------------------------------------------------------------
                    if (_connectionObject != null)
                    {
                        _connectionObject.Close();
                        _connectionObject.Dispose();
                    }
                    if (_commandObject != null)
                    {
                        _commandObject.Cancel();
                        _commandObject.Dispose();
                    }
                }

                _disposedValue = true;
            }
        }
        public void Dispose()
        {
            Dispose(true);
            GC.SuppressFinalize(this);
    GC.Collect();
        }

        ~BaseDataManager()
        {
            Dispose(false);
        }

    }
 }
 }

请帮帮我..

Answer 1

我所看到的工作是在每个实体的基础上提供数据访问对象 (DAO)，而不是一个巨大的 DAO。

我会保持它非常简单，不要做太多抽象。假设您正在申请关于学校的申请。一些实体：

• 学校
• 老师
• 学生

然后你可以为每个DAO制作接口：

• ISschoolDAO
• ITeacherDAO
• 学生道

每个 DAO 都有特定于您的应用程序的功能。我不建议尝试使其通用。您可能对学校有这样的方法：

• 公共列表 GetSchools()
• 公立学校GetSchool(int id)

然后，当您为 DAO 实现接口时，它可以是您想要的任何技术。请记住，BigTable/Hadoop/SQL 之类的东西不符合相同的概念。一个是关系数据库，另一个不是关系数据库。

在整个代码中使用这些接口，然后您就可以编写单元测试并轻松更换底层技术。

（值得重复...不要尝试将 SQL 语句作为接口的一部分读取。请记住，这些语句在不同技术之间的映射是不同的。）