Dapper 调用存储过程并将结果映射到类

问题描述 投票:0回答:3

我有一个 T-SQL 存储过程:

CREATE PROCEDURE [dbo].[GetRequestTest] 
        @RequestId UNIQUEIDENTIFIER
AS
BEGIN
    SELECT 
        Request.Amount,
        Request.Checksum 
    FROM 
        Request 
    WHERE
        RequestId = @RequestId
END

C# 映射类:

public class CustomTest : Itest
{
    public decimal Amount {get;set;}
    public string Checksum { get; set; }
}

我正在尝试使用 Dapper 调用存储过程:

public void Load(CustomTest obj, Guid RequestId)
{
    using (var con = base.GetClosedConnection())
    {
        con.Open();

        var p = new DynamicParameters();
        p.Add("@RequestId", dbType: DbType.Guid, direction: ParameterDirection.Input);               

        var result = con.ExecuteReader("[dbo].[GetRequestTest]", param: p, commandType: CommandType.StoredProcedure);

        while (result.Read())
             obj.Amount = (decimal)result["Amount"];
    }            
}

但结果为空

我尝试调用将存储过程中的 SQL 语句直接放入 C# 代码中 - 它工作正常,但不适用于存储过程。

有什么想法 - 如何让它发挥作用吗?

c# sql-server stored-procedures dapper
3个回答
22
投票

您调用了错误的方法:

public void Load(CustomTest obj, Guid RequestId)
{
    using (var con = base.GetClosedConnection())
    {
        con.Open();                

        //result is list of CustomTest
        var result = db.Query<CustomTest>("GetRequestTest", new {RequestId},
                         commandType: CommandType.StoredProcedure);
    }            
}

如何使用 dapper:https://github.com/StackExchange/dapper-dot-net


3
投票
using (var con = base.GetClosedConnection())
{
    var result = conn.Query<CustomTest>("exec [dbo].[GetRequestTest] @id", new {Id = RequestId});
}

存储过程或查询返回的列名称应与 CustomTest 的属性名称相同(例如 Amount、Checksum)。结果,您将收到填充了适当数据的 IEnumerable。


0
投票

如果你像我一样,你从 Google 来到这里,因为你需要调用一个 SPROC 并且你无法更改该 sproc,你只需要将返回结果映射到一个正常的 POCO。

Query 和 QuerySingle/First 均返回动态。所以大多数时候你可以像这样手动映射:

using(var connection = new SqlConnection(connectionString))
{
    //Set up DynamicParameters object to pass parameters  
    DynamicParameters parameters = new DynamicParameters();   
    parameters.Add("id", 1);  
    
    //Execute stored procedure and map the returned result to a Customer object  
    var res = conn.QuerySingleOrDefault("GetCustomerById", parameters, commandType: CommandType.StoredProcedure);

    var customer = new Customer()
    {
        MyProperty = res.my_prop,
    };
}
© www.soinside.com 2019 - 2024. All rights reserved.