Fix mysql.

u-less · u-less · commit 9435a2ce6ca3 · 2020-02-26T11:23:58.000+08:00
diff --git a/Test/RayCore.Tests/RayCore.Tests.csproj b/Test/RayCore.Tests/RayCore.Tests.csproj
@@ -1,7 +1,7 @@
 ﻿<Project Sdk="Microsoft.NET.Sdk">
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="3.1.1" />
-    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.4.0" />
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.5.0" />
     <PackageReference Include="Microsoft.Orleans.TestingHost" Version="3.0.2" />
     <PackageReference Include="xunit" Version="2.4.1" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.4.1">
diff --git a/src/Ray.Storage.MySQL/Storage/EventStorage.cs b/src/Ray.Storage.MySQL/Storage/EventStorage.cs
@@ -30,6 +30,7 @@ public EventStorage(IServiceProvider serviceProvider, StorageOptions config)
             serializer = serviceProvider.GetService<ISerializer>();
             typeFinder = serviceProvider.GetService<ITypeFinder>();
             mpscChannel = serviceProvider.GetService<IMpscChannel<AsyncInputEvent<BatchAppendTransport<PrimaryKey>, bool>>>();
+            mpscChannel.BindConsumer(BatchInsertExecuter);
             this.config = config;
         }
         static readonly ConcurrentDictionary<string, string> getListSqlDict = new ConcurrentDictionary<string, string>();
diff --git a/src/Ray.Storage.PostgreSQL/Ray.Storage.PostgreSQL.csproj b/src/Ray.Storage.PostgreSQL/Ray.Storage.PostgreSQL.csproj
@@ -1,7 +1,7 @@
 ﻿<Project Sdk="Microsoft.NET.Sdk">
   <ItemGroup>
     <PackageReference Include="Dapper" Version="2.0.30" />
-    <PackageReference Include="Npgsql" Version="4.1.2" />
+    <PackageReference Include="Npgsql" Version="4.1.3" />
   </ItemGroup>
 
   <ItemGroup>

Original file line number	Diff line number	Diff line change
`@@ -30,6 +30,7 @@ public EventStorage(IServiceProvider serviceProvider, StorageOptions config)`
`30`	`30`	`serializer = serviceProvider.GetService<ISerializer>();`
`31`	`31`	`typeFinder = serviceProvider.GetService<ITypeFinder>();`
`32`	`32`	`mpscChannel = serviceProvider.GetService<IMpscChannel<AsyncInputEvent<BatchAppendTransport<PrimaryKey>, bool>>>();`
	`33`	`+ mpscChannel.BindConsumer(BatchInsertExecuter);`
`33`	`34`	`this.config = config;`
`34`	`35`	`}`
`35`	`36`	`static readonly ConcurrentDictionary<string, string> getListSqlDict = new ConcurrentDictionary<string, string>();`