feat: add product mysql storage

Galaxy.Product.GrpcHost/Startup.cs

@@ -20,6 +20,8 @@ public void ConfigureServices(IServiceCollection services)
             services.AddCodeFirstGrpc(config => {
                 config.ResponseCompressionLevel = System.IO.Compression.CompressionLevel.Optimal;
             });
+
+            services.AddProductService();
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.

Galaxy.Product/Configuration/ServiceCollectionExtensions.cs

@@ -1,6 +1,8 @@
 using Galaxy.Product;
 using Galaxy.Product.Abstraction;
+using Galaxy.Product.Entity;
 using Grpc.Net.Client;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.DependencyInjection;
 using ProtoBuf.Grpc.Client;
 using System;
@@ -14,6 +16,8 @@ public static class ServiceCollectionExtensions
         public static IServiceCollection AddProductService(this IServiceCollection services)
         {
             services.AddScoped<IProductService, ProductService>();
+            services.AddDbContext();
+
             return services;
         }
 
@@ -33,5 +37,11 @@ public static IServiceCollection AddProductServiceAsGrpc(this IServiceCollection
 
             return services;
         }
+
+        private static IServiceCollection AddDbContext(this IServiceCollection services)
+        {
+            services.AddDbContext<ProductContext>(option => option.UseMySql("server=mysql.zzhong.me;userid=lims;password=Dev@2017;database=Galaxy;"));
+            return services;
+        }
     }
 }

Galaxy.Product/Entity/ProductContext.cs

@@ -0,0 +1,22 @@
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Galaxy.Product.Entity
+{
+    public class ProductContext : DbContext
+    {
+        public ProductContext(DbContextOptions<ProductContext> options)
+            : base(options)
+        {
+        }
+
+        protected override void OnModelCreating(ModelBuilder builder)
+        {
+            builder.Entity<ProductEntity>();
+
+            base.OnModelCreating(builder);
+        }
+    }
+}

Galaxy.Product/Entity/ProductEntity.cs

@@ -1,10 +1,15 @@
 using System;
 using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
 using System.Text;
 
 namespace Galaxy.Product.Entity
 {
+    [Table("Product")]
     public class ProductEntity
-    {
+    {
+        public string Id { get; set; }
+
+        public string Name { get; set; }
     }
 }

Galaxy.Product/Galaxy.Product.csproj

@@ -6,6 +6,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="3.0.0" />
+    <PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="2.2.6" />
     <PackageReference Include="System.Threading.Tasks" Version="4.3.0" />
     <PackageReference Include="Grpc.Net.Client" Version="2.24.0" />
   </ItemGroup>

Galaxy.Product/ProductService.cs

@@ -1,5 +1,7 @@
 using Galaxy.Product.Abstraction;
 using Galaxy.Product.Abstraction.Models.Dtos;
+using Galaxy.Product.Entity;
+using Microsoft.EntityFrameworkCore;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -10,13 +12,11 @@ namespace Galaxy.Product
 {
     public class ProductService : IProductService
     {
-        private List<ProductDto> products { get; set; }
+        private ProductContext context { get; set; }
 
-        public ProductService()
+        public ProductService(ProductContext context)
         {
-            products = new List<ProductDto>();
-            products.Add(new ProductDto() { Id = "1", Name = "Apple" });
-            products.Add(new ProductDto() { Id = "2", Name = "Orange" });
+            this.context = context;
         }
 
         public Task<ProductDto> CreateAsync(ProductDto product)
@@ -26,12 +26,10 @@ public Task<ProductDto> CreateAsync(ProductDto product)
 
         public async Task<IEnumerable<ProductDto>> GetListAsync(ProductQueryDto query)
         {
-            var task = await Task.Run(() =>
-            {
-                Thread.Sleep(100);
-                return products.AsEnumerable();
-            });
-            return task;
+            var entities = await this.context.Set<ProductEntity>().ToListAsync();
+            var products = new List<ProductDto>();
+            entities.ForEach(entity => products.Add(new ProductDto() { Id = entity.Id, Name = entity.Name }));
+            return products;
         }
     }
 }