Added Support for MySql

Author: manishtiwari25

Readme.md

@@ -231,3 +231,8 @@ Note the ConnectionString format of SQL Server needs to be consistent:
 ```
 "ConnectionString": "Data Source=sql;Initial Catalog=master;User ID=sa;Password=<YOURPASSWORD>;TrustServerCertificate=True;MultiSubnetFailover=True"
 ```
+For MySql Change following
+```
+"PersistenceProvider": "MySql"
+"ConnectionString": "Server=YOURSERVER;User ID=YOURUSERID;Password=YOURPASSWORD;Database=YOURDATABAS"
+```

src/LinkDotNet.Blog.Infrastructure/LinkDotNet.Blog.Infrastructure.csproj

@@ -8,6 +8,7 @@
 
     <ItemGroup>
       <PackageReference Include="Microsoft.EntityFrameworkCore" Version="7.0.4" />
+      <PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="7.0.0" />
       <PackageReference Include="RavenDB.Client" Version="5.4.103" />
     </ItemGroup>
 

src/LinkDotNet.Blog.Infrastructure/Persistence/PersistenceProvider.cs

@@ -1,4 +1,4 @@
-using LinkDotNet.Blog.Domain;
+using LinkDotNet.Blog.Domain;
 
 namespace LinkDotNet.Blog.Infrastructure.Persistence;
 
@@ -8,6 +8,7 @@ public class PersistenceProvider : Enumeration<PersistenceProvider>
     public static readonly PersistenceProvider Sqlite = new(nameof(Sqlite));
     public static readonly PersistenceProvider RavenDb = new(nameof(RavenDb));
     public static readonly PersistenceProvider InMemory = new(nameof(InMemory));
+    public static readonly PersistenceProvider MySql = new(nameof(MySql));
 
     protected PersistenceProvider(string key)
         : base(key)

src/LinkDotNet.Blog.Web/RegistrationExtensions/SqlRegistrationExtensions.cs

@@ -1,4 +1,4 @@
-using LinkDotNet.Blog.Infrastructure.Persistence;
+using LinkDotNet.Blog.Infrastructure.Persistence;
 using LinkDotNet.Blog.Infrastructure.Persistence.Sql;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.DependencyInjection;
@@ -38,6 +38,24 @@ public static void UseSqliteAsStorageProvider(this IServiceCollection services)
             builder.UseSqlite(connectionString)
 #if DEBUG
                 .EnableDetailedErrors()
+#endif
+                ;
+        });
+        services.AddScoped(typeof(IRepository<>), typeof(Repository<>));
+    }
+
+    public static void UseMySqlAsStorageProvider(this IServiceCollection services)
+    {
+        services.AssertNotAlreadyRegistered(typeof(IRepository<>));
+
+        services.AddPooledDbContextFactory<BlogDbContext>(
+        (s, builder) =>
+        {
+            var configuration = s.GetRequiredService<AppConfiguration>();
+            var connectionString = configuration.ConnectionString;
+            builder.UseMySql(connectionString, ServerVersion.AutoDetect(connectionString))
+#if DEBUG
+                .EnableDetailedErrors()
 #endif
                 ;
         });

src/LinkDotNet.Blog.Web/RegistrationExtensions/StorageProviderExtensions.cs

@@ -1,4 +1,4 @@
-using LinkDotNet.Blog.Domain;
+using LinkDotNet.Blog.Domain;
 using LinkDotNet.Blog.Infrastructure.Persistence;
 using Microsoft.Extensions.Caching.Memory;
 using Microsoft.Extensions.Configuration;
@@ -34,6 +34,11 @@ public static void AddStorageProvider(this IServiceCollection services, IConfigu
             services.UseSqlAsStorageProvider();
             services.RegisterCachedRepository<Infrastructure.Persistence.Sql.Repository<BlogPost>>();
         }
+        else if (persistenceProvider == PersistenceProvider.MySql)
+        {
+            services.UseMySqlAsStorageProvider();
+            services.RegisterCachedRepository<Infrastructure.Persistence.Sql.Repository<BlogPost>>();
+        }
     }
 
     private static void RegisterCachedRepository<TRepo>(this IServiceCollection services)

tests/LinkDotNet.Blog.UnitTests/StorageProviderRegistrationExtensionsTests.cs

@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Collections.Generic;
 using LinkDotNet.Blog.Web.RegistrationExtensions;
 using Microsoft.Extensions.DependencyInjection;
@@ -13,6 +13,7 @@ public class StorageProviderRegistrationExtensionsTests
             new object[] { new Action<IServiceCollection>(services => services.UseSqlAsStorageProvider()) },
             new object[] { new Action<IServiceCollection>(services => services.UseInMemoryAsStorageProvider()) },
             new object[] { new Action<IServiceCollection>(services => services.UseRavenDbAsStorageProvider()) },
+            new object[] { new Action<IServiceCollection>(services => services.UseMySqlAsStorageProvider()) },
         };
 
     [Theory]
@@ -26,4 +27,4 @@ public void GivenAlreadyRegisteredRepository_WhenTryingToAddAnotherStorage_ThenE
 
         actualAct.Should().Throw<NotSupportedException>();
     }
-}
+}