2

我有几种像下面这样的Dapper查询，结果有几种不同的类型。这是其中一个特定的，它产生例如 List<ClassA> ：

string anSql = GetSqlQueryText("query_name");
SqlConnection connection = GetSqlConnection();

List<ClassA> result = null;
try
{
    connection.Open();
    result = connection.Query<ClassA>(anSql, new    //want to move this part from here
    {
        param1 = "value1",
        param2 = "value2"
    }).ToList();                                    //to here out, to an outer call
}
catch //more error handling and retry logic omitted and this is a simplified version
{
    result = new List<ClassA>();       //this good to be filled up by the generic type
}
finally
{
    connection.Close();
}

我想将这种查询加入到 GenDapperQuery<T> 通用方法中，可以在委托（或 Func/Action 或其他任何东西）的帮助下调用它（T 将是 ClassA 或 ClassB 等）最终代码）：

List<T> result = GenDapperQuery<T>(() =>
{
    result = connection.Query<T>(anSql, new
    {
        param1 = "value1",
        param2 = "value2"
    }).ToList();
}
//and I want to use the result then as a specific type e.g. ClassA
//either immediately or after a cast
result[0].Id = 3; //or
(result as List<ClassA>)[0].Id = 3;

所以我的目的是多次使用连接、我的错误处理/重试逻辑，当然还有 Dapper 查询（因为我不想像我拥有的​​查询和类型那样把它们写下来），但我想要以某种方式对这个（想要的）通用方法说，用 dapper 查询什么以及创建和填充什么类型的（通用）列表。

（这个（想要的）泛型方法将在同一个类中，我可以在其中创建一次连接。错误处理部分会更复杂，但每种类型总是相同的，这就是为什么我不想多次写下它们. 参数可以像输入的 sql 字符串一样自由变化。）

我现在的问题是，我无法围绕自己的代码编写通用的 Dapper 查询，而是使用来自此（想要的）方法之外的特定注入函数。

这在 C# 中可能吗？任何建议将不胜感激。

4

2 回答 2

3

有很多方法可以做到这一点。一种机制是为 Execute/ErrorHandler 创建一个方法：

public TResult ExecuteWrapper<TResult>(SqlConnection connection, Func<TResult, SqlConnection> func)
{
    TResult result;
    try
    {
        connection.Open();
        // Query will be wrapped in a function or lambda
        result = func(connection);
    }
    catch //more error handling and retry logic omitted and this is a simplified version
    {
        // Specifying a new TResult may be more difficult. You could either:
        // 1. Pass a default value in the method parameter
        //    result = defaultValue; // defaultValue is method parameter
        // 2. Use System.Activator to create a default instance
        //    result = (TResult)System.Activator(typeof(TResult));

        // Original: result = new List<ClassA>(); // this good to be filled up by the generic type
    }
    finally
    {
        connection.Close();
    }
    return result;
}

然后你会像这样使用它：

List<ClassA> result = ExecuteWrapper(connection, (cn) =>
    {
        string anSql = GetSqlQueryText("query_name");
        return cn.Query<ClassA>(anSql, new
            {
                param1 = "value1",
                param2 = "value2"
            }).ToList();        
    });
于 2013-07-19T19:38:21.507 回答
2

我发布了我的改进——基于 Ryan 的好答案——也是为了将这些解决方案结合在一起。这个包装函数不仅请求 SQL 连接，还请求查询的名称。所以这个解决方案更短，在调用方只有一行，可能更优雅一点。
修改后的包装函数：

public TResult ExecuteWrapper<TResult>(SqlConnection connection, string queryName, Func<SqlConnection, string, TResult> func)
{
   string anSql = GetSqlText(queryName);
   TResult result;
   try
   {
      connection.Open();
      result = func(connection, anSql);
   }
   catch
   {
      result = System.Activator.CreateInstance<TResult>(); //this is working in .NET 4.5 environment
   }
   finally
   {
      connection.Close();
   }
   return result;
}

而这个调用方：

List<ClassA> result = ExecuteWrapper(connection, "query_name", (conn, sql) =>
    {
        return conn.Query<ClassA>(sql, new
            {
                param1 = "value1",
                param2 = "value2"
            }).ToList();        
    });

再次感谢瑞恩的回答。

于 2013-07-23T09:08:11.807 回答