【C#/.NET】Dapper使用QueryMultipleAsync執行多條SQL

 目錄

背景

解決方案

總結

背景

        對於查詢數據列表的功能，需要分頁已經查詢總數。這裡涉及兩句SQL,一個是查詢分頁對應的數據，第二個是Count(*); 會導致部分重覆代碼和兩次的資料庫查詢。

解決方案

        Dapper有封裝QueryMultipleAsync的非同步方法支持執行多條SQL,來減少資料庫查詢次數。

使用方法

 public async Task<(IEnumerable<Log> list,int total)> GetListAsync()
    {
        string sql = @"SELECT sql_calc_found_rows id, mark1, mark2, mark3  
                       FROM logs ORDER BY id ASC  LIMIT @Offset, @PageSize;
                       SELECT FOUND_ROWS()  ";
        DynamicParameters parameters = new DynamicParameters();
        parameters.Add("@Offset", 0);
        parameters.Add("@PageSize", 2);

        using var connection = _dapperContext.CreateConnection();
        using var multi = await connection.QueryMultipleAsync(sql, parameters);
        var list = await multi.ReadAsync<Log>();
        var total = await multi.ReadSingleAsync<int>();
        return (list, total);
    }

        這裡是查詢MYSQL，使用了sql_calc_found_rows在第一個查詢分頁數據的SQL中，第二條是SELECT FOUND_ROWS()來獲取Limit之外的行數。

        使用QueryMultipleAsync方法返回的是一個GridReader對象。這個對象提供了一些方法讀取數據，比如

        示例中使用ReadAsync讀取數據，ReadSingleAsync讀取count然後返回元組

var list = await multi.ReadAsync<Log>();
var total = await multi.ReadSingleAsync<int>();
return (list, total);

總結

        通過使用Dapper的QueryMultipleAsync一次性查詢多個結果，減少了與資料庫伺服器的請求次數。減少了代碼量。