src/02_Data/Data.Core/Repository/RepositoryAbstract.cs

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

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

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Dapper;
using Mkh.Data.Abstractions;
using Mkh.Data.Abstractions.Adapter;
using Mkh.Data.Abstractions.Descriptors;
using Mkh.Data.Abstractions.Entities;
using Mkh.Data.Abstractions.Logger;

namespace Mkh.Data.Core.Repository;

public abstract partial class RepositoryAbstract<TEntity> : IRepository<TEntity> where TEntity : IEntity, new()
{
    #region ==字段==

    private IEntitySqlDescriptor _sql;
    private IDbAdapter _adapter;
    private DbLogger _logger;
    private IServiceProvider _sp;

    #endregion

    #region ==属性==

    public IDbContext DbContext { get; private set; }

    public IUnitOfWork Uow { get; private set; }

    public IEntityDescriptor EntityDescriptor { get; private set; }

    internal IDbTransaction Transaction => Uow?.Transaction;

    public IDbConnection Conn
    {
        get
        {
            //先从事务中获取连接
            if (Transaction != null)
                return Transaction.Connection;

            return DbContext.NewConnection();
        }
    }

    #endregion

    #region ==初始化==

    /// <summary>
    /// 初始化
    /// </summary>
    /// <param name="context"></param>
    /// <param name="sp"></param>
    internal void Init(IDbContext context, IServiceProvider sp)
    {
        DbContext = context;