Master.CanYinWu.DAL/FriendshipLinkDAL.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Dapper;
using Master.CanYinWu.Entity;
using Master.CanYinWu.Utility;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Master.CanYinWu.DAL
{
    public class FriendshipLinkDAL
    {
        private IDbConnection conn;

        #region 友情链接分页列表
        /// <summary>
        /// 友情链接分页列表
        /// </summary>
        /// <param name="pageIndex">当前页</param>
        /// <param name="pageSize">每页显示数据行数</param>
        /// <param name="key">关键字搜索</param>
        /// <returns></returns>
        public async Task<Tuple<IEnumerable<FriendshipLink>, int>> GetFriendshipLinkPageListAsync(int pageIndex, int pageSize, string key)
        {
            StringBuilder sb = new StringBuilder(@"select * from(
									                    select *,ROW_NUMBER() over (order by FriendshipLinkId desc) as  rownumber  from  FriendshipLink 
                                                             where IsDelete =0 ");
            DynamicParameters dp = new DynamicParameters();
            dp.Add("PageIndex", pageIndex);
            dp.Add("PageSize", pageSize);
            StringBuilder sqlTotal = new StringBuilder(@"select count(1)  from FriendshipLink where IsDelete =0");
            DynamicParameters dpTotal = new DynamicParameters();
            if (!string.IsNullOrEmpty(key))
            {
                sb.Append(" and LinkName like '%'+@Key+'%' ");
                sqlTotal.Append(" and LinkName like '%'+@Key+'%' ");
                dp.Add("Key", key);
                dpTotal.Add("Key", key);
            }
            sb.Append(" )as tab where rownumber BETWEEN(((@PageIndex - 1) * @PageSize) + 1) and @PageIndex * @PageSize ");
            using (conn = ConnectionFactory.Connection())
            {
                var query = await conn.QueryAsync<FriendshipLink>(sb.ToString(), dp);
                var total = await conn.ExecuteScalarAsync<int>(sqlTotal.ToString(), dpTotal);
                return new Tuple<IEnumerable<FriendshipLink>, int>(query, total);
            }
        }
        #endregion

        #region 查询所有友情链接列表
        /// <summary>
        /// 查询所有友情链接列表
        /// </summary>
        /// <returns></returns>
        public async Task<IList<FriendshipLink>> GetAllFriendshipLinkListAsync()
        {
            string sql = "select * from FriendshipLink where IsDelete =0  order by Sort asc";
            using (conn = ConnectionFactory.Connection())