在 Dapper 中执行带参数的存储过程

Question

我正在使用Dapper（感谢Sam，伟大的项目。）带有 DAL 的微型 ORM，由于某种原因，我无法使用输入参数执行存储过程。

在示例服务中，我有以下代码：

public void GetSomething(int somethingId)
{
    IRepository<Something, SomethingEnum> repository = UnitOfWork.GetRepository<Something, SomethingEnum>();

    var param = new DynamicParameters();
    param.Add("@somethingId", dbType: DbType.Int32, value:somethingId, direction: ParameterDirection.Input);

    var result = repository.Exec<Something>(SomethingEnum.spMyStoredProcedure, param);

    ...

}

当触发存储过程的执行时，会抛出一个 SqlException，说明我需要提供 'somethingId'

过程或函数“spMyStoredProcedure”需要参数“@somethingId”，但未提供。

我的DAL是基于Pencroff的这个github项目类似的。

我错过了什么吗？

更新：我实际上是通过 SomethingEnum 传递 commandType：

 public class SomethingEnum : EnumBase<SomethingEnum, string>
 {
    public static readonly SomethingEnum spMyStoredProcedure = new SomethingEnum("spMyStoredProcedure", "[dbo].[spMyStoredProcedure]", CommandType.StoredProcedure);

    public SomethingEnum(string Name, string EnumValue, CommandType? cmdType): base(Name, EnumValue, cmdType)
    {
    }
}

Answer 1

您需要告诉它命令类型：确保在 dapper 调用中有 commandType: CommandType.StoredProcedure。否则，它只是执行 text 命令：

spMyStoredProcedure

（在环境上下文中带有一些未使用的参数）。这是合法的 TSQL，并尝试在不传递参数的情况下调用 spMyStoredProcedure - 就像将 spMyStoredProcedure 放入 SSMS 并按 f5 一样。

另外，如果你的参数是固定的，我实际上建议只使用：

var param = new { somethingId };

甚至完全内联：

var result = repository.Exec<Something>(SomethingEnum.spMyStoredProcedure,
    new { somethingId }, commandType: CommandType.StoredProcedure);

（注意：如果您的 Exec<T> 方法只处理存储过程，您可以将 commandType 内部移动到方法中 - 或者您可以将其设为默认为 CommandType.StoredProcedure 的可选参数）

Answer 2

var queryParameters = new DynamicParameters();
queryParameters.Add("@parameter1", valueOfparameter1);
queryParameters.Add("@parameter2", valueOfparameter2);

await db.QueryAsync<YourReturnType>(
    "{NameOfStoredProcedure}",
    queryParameters,
    commandType: CommandType.StoredProcedure)

Answer 3

因为这对我来说是最好的结果，但是没有解决带有表值参数的 ExecuteNonQuery 的答案，这里是代码：

var queryParameters = new DynamicParameters();
queryParameters.Add("@Param0", datatable0.AsTableValuedParameter());
queryParameters.Add("@Param1", datatable1.AsTableValuedParameter());
var result = await ExecuteStoredProc("usp_InsertUpdateTest", queryParameters);

private async Task<Result<int>> ExecuteStoredProc(string sqlStatement, DynamicParameters parameters)
    {
        try
        {
            using (SqlConnection conn = new SqlConnection(connectionString))
            {
                await conn.OpenAsync();
                var affectedRows = await conn.ExecuteAsync(
                    sql: sqlStatement,
                    param: parameters,
                    commandType: CommandType.StoredProcedure);
                return Result.Ok(affectedRows);
            }
        }
        catch (Exception e)
        {
            //do logging
            return Result.Fail<int>(e.Message);
        }
    }

Answer 4

您需要对其进行扩展以支持出站参数和返回结果，但它包含用于创建 Dapper 动态参数的部分。

internal static bool ExecuteProc(string sql, List<SqlParameter> paramList = null)
{
    try
    {
        using (SqlConnection conn = new SqlConnection (GetConnectionString()))
        {                    
           DynamicParameters dp = new DynamicParameters();
           if(paramList != null)
               foreach (SqlParameter sp in paramList)
                   dp.Add(sp.ParameterName, sp.SqlValue, sp.DbType);
           conn.Open();
           return conn.Execute(sql, dp, commandType: CommandType.StoredProcedure) > 0;
        }
    }
    catch (Exception e)
    {
        //do logging
        return false;
    }

}

Answer 5

这对我有用。请注意，执行此操作的方法是异步的，因此需要等待和 QueryAsync。另请注意，创建了一个匿名类型以方便发送“Id”参数。

await dbConnection.QueryAsync<Something>("StoredProcedureNameGoesHere @Id", new { Id = id });