feat: support sql repository

Author: ikesnowy

src/Cnblogs.Architecture.Ddd.Domain.Abstractions/ISqlRepository.cs

@@ -0,0 +1,36 @@
+namespace Cnblogs.Architecture.Ddd.Domain.Abstractions;
+
+/// <summary>
+///     Repository that support raw sql execution.
+/// </summary>
+/// <typeparam name="TEntity">The type of entity.</typeparam>
+/// <typeparam name="TKey">The type of key.</typeparam>
+public interface ISqlRepository<TEntity, TKey> : IRepository<TEntity, TKey>
+    where TEntity : EntityBase, IAggregateRoot
+    where TKey : IComparable<TKey>
+{
+    /// <summary>
+    ///     Query entity with raw sql.
+    /// </summary>
+    /// <param name="sql">The sql string.</param>
+    /// <param name="parameters">The parameters</param>
+    /// <returns></returns>
+    IQueryable<TEntity> SqlQuery(string sql, params object[] parameters);
+
+    /// <summary>
+    ///     Query with raw sql.
+    /// </summary>
+    /// <param name="sql">The sql string.</param>
+    /// <param name="parameters">The parameters.</param>
+    /// <typeparam name="T">The type of query result.</typeparam>
+    /// <returns></returns>
+    IQueryable<T> SqlQuery<T>(string sql, params object[] parameters);
+
+    /// <summary>
+    ///     Execute raw sql.
+    /// </summary>
+    /// <param name="sql">The sql string.</param>
+    /// <param name="parameters">The parameters.</param>
+    /// <returns>The number of rows affected.</returns>
+    Task<int> ExecuteSqlAsync(string sql, params object[] parameters);
+}

src/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework/BaseRepository.cs

@@ -12,7 +12,7 @@ namespace Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework;
 /// <typeparam name="TEntity">该类管理的实体。</typeparam>
 /// <typeparam name="TKey"><typeparamref name="TEntity" /> 的主键。</typeparam>
 public abstract class BaseRepository<TContext, TEntity, TKey>
-    : INavigationRepository<TEntity, TKey>, IUnitOfWork<TEntity, TKey>
+    : INavigationRepository<TEntity, TKey>, IUnitOfWork<TEntity, TKey>, ISqlRepository<TEntity, TKey>
     where TContext : DbContext
     where TEntity : EntityBase, IEntity<TKey>, IAggregateRoot
     where TKey : IComparable<TKey>
@@ -185,4 +185,22 @@ private void CallBeforeUpdate()
             .ToList();
         domainEntities.ForEach(x => x.Entity.BeforeUpdate());
     }
+
+    /// <inheritdoc />
+    public IQueryable<TEntity> SqlQuery(string sql, params object[] parameters)
+    {
+        return Context.Set<TEntity>().FromSqlRaw(sql, parameters);
+    }
+
+    /// <inheritdoc />
+    public IQueryable<T> SqlQuery<T>(string sql, params object[] parameters)
+    {
+        return Context.Database.SqlQueryRaw<T>(sql, parameters);
+    }
+
+    /// <inheritdoc />
+    public Task<int> ExecuteSqlAsync(string sql, params object[] parameters)
+    {
+        return Context.Database.ExecuteSqlRawAsync(sql, parameters);
+    }
 }

src/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework/Cnblogs.Architecture.Ddd.Infrastructure.EntityFramework.csproj

@@ -9,7 +9,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="7.0.12" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="7.0.13" />
   </ItemGroup>
 
   <ItemGroup>