add SyncCacheManager to sample

Author: Ahoo-Wang

sample/SmartSql.Sample.AspNetCore/Controllers/UserController.cs

@@ -18,20 +18,22 @@ public class UserController : ControllerBase
         private readonly UserService _userService;
 
         public UserController(IUserRepository userRepository
-        ,UserService userService)
+            , UserService userService)
         {
             _userRepository = userRepository;
             _userService = userService;
         }
+
         // GET api/values
         [HttpPost]
-        public long AddWithTranWrap([FromBody]User user)
+        public long AddWithTranWrap([FromBody] User user)
         {
             var id = _userService.AddWithTranWrap(user);
             return id;
         }
+
         [HttpPost]
-        public long AddWithTran([FromBody]User user)
+        public long AddWithTran([FromBody] User user)
         {
             var id = _userService.AddWithTran(user);
             return id;
@@ -46,6 +48,12 @@ public User GetById(long id)
             return user;
         }
 
+        [HttpPost]
+        public int Update(User user)
+        {
+            return _userRepository.Update(user);
+        }
+
         [HttpGet]
         public GetByPageResponse<User> GetByPage(int pageIndex = 1)
         {
@@ -55,16 +63,19 @@ public GetByPageResponse<User> GetByPage(int pageIndex = 1)
                 PageIndex = pageIndex
             });
         }
+
         [HttpGet]
         public IEnumerable<User> Query(int taken = 10)
         {
             return _userRepository.Query(taken);
         }
+
         [HttpGet]
         public async Task<IEnumerable<User>> QueryAsync(int taken = 10)
         {
             return await _userRepository.QueryAsync(taken);
         }
+
         [HttpGet]
         public async Task Mt(int id)
         {
@@ -86,7 +97,6 @@ await _userRepository.InsertAsync(new User
                 _userRepository.SqlMapper.RollbackTransaction();
                 throw;
             }
-            
         }
     }
-}
+}

sample/SmartSql.Sample.AspNetCore/DyRepositories/IUserRepository.cs

@@ -19,5 +19,6 @@ public interface IUserRepository
         [Statement(Id = "QueryByPage")]
         TPageResult GetByPage<TPageResult>(object request);
         Task<IEnumerable<User>> QueryAsync([Param("Taken")]int taken);
+        int Update(User entity);
     }
 }

sample/SmartSql.Sample.AspNetCore/SmartSql.Sample.AspNetCore.csproj

@@ -28,6 +28,7 @@
     <ProjectReference Include="..\..\src\SmartSql.Bulk.SqlServer\SmartSql.Bulk.SqlServer.csproj" />
     <ProjectReference Include="..\..\src\SmartSql.Bulk\SmartSql.Bulk.csproj" />
     <ProjectReference Include="..\..\src\SmartSql.Cache.Redis\SmartSql.Cache.Redis.csproj" />
+    <ProjectReference Include="..\..\src\SmartSql.Cache.Sync\SmartSql.Cache.Sync.csproj" />
     <ProjectReference Include="..\..\src\SmartSql.DIExtension\SmartSql.DIExtension.csproj" />
     <ProjectReference Include="..\..\src\SmartSql.DyRepository\SmartSql.DyRepository.csproj" />
     <ProjectReference Include="..\..\src\SmartSql.InvokeSync.Kafka\SmartSql.InvokeSync.Kafka.csproj" />

sample/SmartSql.Sample.AspNetCore/Startup.cs

@@ -6,8 +6,10 @@
 using Microsoft.EntityFrameworkCore.Metadata;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
+using SmartSql.Cache.Sync;
 using SmartSql.ConfigBuilder;
 using SmartSql.DIExtension;
+using SmartSql.InvokeSync;
 using SmartSql.InvokeSync.Kafka;
 using SmartSql.Sample.AspNetCore.Service;
 using Swashbuckle.AspNetCore.Swagger;
@@ -28,18 +30,23 @@ public IServiceProvider ConfigureServices(IServiceCollection services)
         {
             services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
             services
-                .AddSmartSql((builder) => { builder.UseProperties(Configuration); })
+                .AddSmartSql((sp, builder) =>
+                {
+                    builder.UseProperties(Configuration);
+                    var subscriber = sp.GetRequiredService<ISubscriber>();
+                    builder.UseCacheManager(new SyncCacheManager(subscriber));
+                })
                 .AddRepositoryFromAssembly(o =>
                 {
                     o.AssemblyString = "SmartSql.Sample.AspNetCore";
                     o.Filter = (type) => type.Namespace == "SmartSql.Sample.AspNetCore.DyRepositories";
                 })
-                .AddInvokeSync(options => {  })
+                .AddInvokeSync(options => { })
                 .AddKafkaPublisher(options =>
                 {
                     options.Servers = "localhost:9092";
                     options.Topic = "smartsql.sync";
-                    options.Config.Add("group.id","SmartSql");
+                    options.Config.Add("group.id", "SmartSql");
                 });
             services.AddSingleton<UserService>();
             RegisterConfigureSwagger(services);

src/SmartSql.Test/Maps/User.xml

@@ -9,10 +9,7 @@
 
 <SmartSqlMap Scope="User" xmlns="http://SmartSql.net/schemas/SmartSqlMap.xsd">
   <Caches >
-    <Cache Id="RedisCache" Type="${RedisCacheProvider}">
-      <Property Name="DatabaseId" Value="3"/>
-      <Property Name="ConnectionString" Value="${Redis}"/>
-      <FlushOnExecute Statement="Insert"/>
+    <Cache Id="UserCache" Type="Lru">
       <FlushOnExecute Statement="Update"/>
       <FlushOnExecute Statement="Delete"/>
     </Cache>
@@ -106,7 +103,7 @@
     </Statement>
 
     <!--获取表映射实体-->
-    <Statement Id="GetEntity" >
+    <Statement Id="GetEntity" Cache="UserCache" >
       Select Top 1 T.* From T_User T With(NoLock)
       <Where Min="1">
         <IsNotEmpty Prepend="And" Property="Id">