C#:合并多数据库驱动接口(interface)

Question

我决定为两个不同的数据库驱动程序 MySQL 和 MongoDB 编写包装器。我打算单独使用它们，但后来决定为什么不让我的应用程序兼容多驱动程序？并行运行 MongoDB 和 MySQL，以及选择驱动程序的配置值。

后来我意识到过滤，更新，需要传递给这些方法的参数有很多不同，并且在一个接口(interface)(IDatabase)上运行它们会很困难，事实上这是不可能的我不知道怎么办..

我正在寻求一些帮助，以便在逻辑上将它们合并为一个界面，以便我可以在一个应用程序中同时使用它们(多驱动程序)？我写了下面的方法

MongoDB:
UpdateOneRecord(string collection, List<UpdateDefinition<BsonDocument>> updateDefinitions, List<FilterDefinition<BsonDocument>> filterDefinitions = null)
UpdateManyRecords(string collection, List<List<UpdateDefinition<BsonDocument>>> updateDefinitions, List<List<FilterDefinition<BsonDocument>>> filterDefinitions = null)
InsertOneRecord(string collection, TDocument insertDocument)
InsertManyRecords(string collection, List<TDocument> insertDocuments)
DeleteRecords(string collection, List<FilterDefinition<BsonDocument>> filterDefinitions = null)
GetTableCount(string collection, List<FilterDefinition<BsonDocument>> filterDefinitions = null)
GetDataTable(string collection, List<string> selectParts, List<FilterDefinition<BsonDocument>> filterDefinitions = null)
GetDataRow(string collection, List<string> selectParts, List<FilterDefinition<BsonDocument>> filterDefinitions = null)

MySQL:
UpdateOneRecord(string table, Dictionary<string, string> updateDefinitions, Dictionary<string, string> filterDefinitions = null, string customFilter = "")
UpdateManyRecords(string table, List<Dictionary<string, string>> updateDefinitions, List<Dictionary<string, string>> filterDefinitions = null, List<string> customFilters = null)
InsertOneRecord(string table, Dictionary<string, string> insertDefinitions)
InsertManyRecords(string table, List<Dictionary<string, string>> insertDefinitions)
DeleteRecords(string table, Dictionary<string, string> filterDefinitions = null, string customFilter = "")
GetTableCount(string table, Dictionary<string, string> filterDefinitions = null, string customFilter = "")
GetDataTable(string table, List<string> selectParts, Dictionary<string, string> filterDefinitions = null, string customFilter = "")
GetDataRow(string table, List<string> selectParts, Dictionary<string, string> filterDefinitions = null, string customFilter = "")

这就是整个问题，尽管我在下面包含了代码以进一步解释我的设置。

我有一个名为 DatabaseHandler 的类，它返回一个 IDatabaseConnection 接口(interface)(MongoDB 和 MySQL 都将继承该接口(interface))

public IDatabaseConnection GetNewConnection()
{
    if (_databaseDriver == "mysql") {
        return new MySqlDbConnection(_mysqlConnectionStr);
    }

    return new MongoDbConnection(_mongoClient, _mongoDatabase);
}

当然，MySqlDbConnection 和 MongoDbConnection 这两个类都继承了类上的 IDatabaseConnection 类以及上述所有方法。

问题是，接口(interface)将强制两个类具有相同的方法和相同的参数。

我看不出解决这个问题的方法，希望其他人可以提供帮助。在编程和创建好的系统方面，我真的没有“开启”或逻辑。

Answer 1

简短回答:不要尝试针对特定数据库引擎编写代码。

---

点IDatabaseConnection接口(interface)的优点在于它提供了一个一致的属性和方法列表，您可以合理地期望它们以类似的方式运行。这样您就不必担心编写针对特定数据库的代码，您只需编写适用于任何的代码IDatabaseConnection实现。

当然，现实可能有点不同。例如，MySQL 和 SQLServer 的查询语言略有不同。当我写 SELECT TOP <n>...对于 SQLServer，我知道我被锁定在一个特定的数据库中，并且该查询将在几乎所有其他方面失败。

解决方案通常是使用一个库来抽象掉这些问题。在 .NET 上，标准答案是 Entity Frameworks 6，但我发现它太笨拙和夸张了。使用 EF6 几次后，我确定它真的不适合我。 Linq to SQL (L2S) 更符合我的风格，您可以将它用于任何实现了一些基础知识的数据库，例如 IDatabaseConnection .

在 L2S(或 EF6，或...)中，您使用 LINQ 表达式编写查询，库会找出如何在服务器上运行查询。在TOP <n>的情况下对比LIMIT <n> LINQ 查询看起来是一样的:

var query = db.SomeTable.Take(10);

当我枚举该查询时，库会生成适当的 SQL 以仅获取 10 个结果。它为您处理各种类似的事情，就像一个好的图书馆应该做的那样。它确实如此 - 有时令我惊讶 - 非常好。

我偶尔会手动编写 SQL，但现在不像以前那么频繁了。当然，我想念 CTE 和 MERGE有时，但这就是我们拥有 View 和存储过程的原因。

---

我当前选择的数据库库是 linq2db .支持不同的数据库几乎都是在幕后完成的。他们有 T4 模板项目，可以根据您提供的连接信息为数据库生成代码，从而缩短启动和运行所需的时间。在 GitHub 上并且有一个活跃的社区致力于此。我什至设法获得了最新版本的拉取请求:)

我目前的一个项目使用 MySQL、SqlServer、SQLite 和——我没骗你——一个 Access 数据库连接到几个不同的数据库。添加其中最大的一个(具有 >300 个表和 idk 有多少 View 的供应商数据库)花了我大约 5 分钟。 Access 数据库是其中最小的，它花费的时间更长，因为在这种情况下，供应商构建了一个会让任何 DBA 哭泣的模式，包括添加单独的表来保存工作数据。那一个从开始到结束是半小时。

将其与我花费 100 多个小时构建 L2S 数据库以及我认为我需要的各种附加功能进行比较。完成后，我花了几天时间为新数据库构建一个变体。有趣，是的，但效率不高。

---

举个例子，比较这个(公认的坏)IDbConnection基于代码:

    List<(int ID, string FirstName, string LastName)> queryResults = new List<(int ID, string FirstName, string LastName)>();

    using (IDbConnection conn = new SqlConnection(myConnectionString))
    {
        conn.Open();
        using (IDbCommand cmd = conn.CreateCommand())
        {
            cmd.CommandType = System.Data.CommandType.Text;
            cmd.CommandText = "SELECT ID, FirstName, LastName FROM Users";
            using (IDataReader r = cmd.ExecuteReader())
            {
                while (r.NextResult())
                {
                    int id = r.GetInt32(0);
                    string firstname = r.GetString(1);
                    string lastname = r.GetString(2);
                    queryResults.Add((id, firstname, lastname));
                }
            }
        }
    }

... 使用此 LINQ 等效项:

List<(int ID, string FirstName, string LastName)> queryResults = new List<(int ID, string FirstName, string LastName)>();

using (var db = new MyDatabase())
{
    queryResults.AddRange(
        (
            from u in db.Users
            select new { u.ID, u.FirstName, u.LastName }
        )
        .AsEnumerable()
        .Select(r => (r.ID, r.FirstName, r.LastName))
    );
}

如果我使用结果类型而不是元组(LINQ 不理解)，那会更简单。