Add DM Database support.

Author: SeriaWei

Database/DM/README.md

@@ -0,0 +1,19 @@
+# 这是用于达梦数据库（DM8, dameng）的数据库初始化脚本
+
+右键“模式”，选择导入dmp，然后添加导入文件，点确定即可。
+
+## 数据库配置
+
+使用达梦数据库的时候需要注意，由于达梦数据库的表名和字段名都是大写的，所以请配置表名和字段名为大写`"TableNaming": "UpperCase"`, `"ColumnNaming": "UpperCase"`。
+
+appsettings.json
+``` json
+{
+  "Database": {
+    "DbType": "DM",
+    "ConnectionString": "Server=localhost;Port=5236;SCHEMA=ZKEACMS;User Id=SYSDBA;Password=SYSDBA001;",
+    "TableNaming": "UpperCase",
+    "ColumnNaming": "UpperCase"
+  }
+}
+```

Database/DM/dump.dmp

@@ -7,6 +7,7 @@
   <ItemGroup>
     <PackageVersion Include="Alipay.AopSdk.F2FPay.AspnetCore" Version="2.2.7" />
     <PackageVersion Include="CommonMark.NET" Version="0.15.1" />
+    <PackageVersion Include="DM.Microsoft.EntityFrameworkCore" Version="9.0.0.37033" />
     <PackageVersion Include="DocumentFormat.OpenXml" Version="3.3.0" />
     <PackageVersion Include="FastExpressionCompiler" Version="5.3.0" />
     <PackageVersion Include="Fluid.Core" Version="2.25.0" />

Directory.Packages.props

@@ -33,4 +33,14 @@ public enum UserType
         Administrator = 1,
         Customer = 2
     }
+    public enum NameCaseStrategy
+    {
+        None = 0,
+        LowerCase = 1,
+        UpperCase = 2,
+        CamelCase = 3,      // userName
+        PascalCase = 4,     // UserName
+        SnakeCase = 5,      // user_name
+        KebabCase = 6       // user-name
+    }
 }

src/EasyFrameWork/Constant/DataEnumerate.cs

@@ -29,6 +29,10 @@ public enum DbTypes
         /// <summary>
         /// Oracle
         /// </summary>
-        Oracle = 5
+        Oracle = 5,
+        /// <summary>
+        /// Dameng DB
+        /// </summary>
+        DM = 6
     }
 }

src/EasyFrameWork/DbTypes.cs

@@ -0,0 +1,84 @@
+using Easy.Constant;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Easy
+{
+    public class NamingConverter
+    {
+        public NamingConverter(NameCaseStrategy strategy)
+        {
+            Strategy = strategy;
+        }
+
+        public NameCaseStrategy Strategy { get; set; }
+
+        public string Prefix { get; set; }
+
+        public string Suffix { get; set; }
+
+        public string ConvertName(string name)
+        {
+            if (string.IsNullOrEmpty(name)) return name;
+
+            var result = name;
+
+            result = Strategy switch
+            {
+                NameCaseStrategy.LowerCase => result.ToLower(),
+                NameCaseStrategy.UpperCase => result.ToUpper(),
+                NameCaseStrategy.CamelCase => ToCamelCase(result),
+                NameCaseStrategy.PascalCase => ToPascalCase(result),
+                NameCaseStrategy.SnakeCase => ToSnakeCase(result),
+                NameCaseStrategy.KebabCase => ToKebabCase(result),
+                _ => result
+            };
+
+            if (!string.IsNullOrEmpty(Prefix)) result = Prefix + result;
+            if (!string.IsNullOrEmpty(Suffix)) result = result + Suffix;
+
+            return result;
+        }
+
+        private static string ToCamelCase(string name)
+        {
+            if (string.IsNullOrEmpty(name)) return name;
+            return char.ToLower(name[0]) + name.Substring(1);
+        }
+
+        private static string ToPascalCase(string name)
+        {
+            if (string.IsNullOrEmpty(name)) return name;
+            return char.ToUpper(name[0]) + name.Substring(1);
+        }
+
+        private static string ToSnakeCase(string name)
+        {
+            var result = new StringBuilder();
+            result.Append(char.ToLower(name[0]));
+
+            for (int i = 1; i < name.Length; i++)
+            {
+                if (char.IsUpper(name[i]))
+                {
+                    result.Append('_');
+                    result.Append(char.ToLower(name[i]));
+                }
+                else
+                {
+                    result.Append(name[i]);
+                }
+            }
+
+            return result.ToString();
+        }
+
+        private static string ToKebabCase(string name)
+        {
+            return ToSnakeCase(name).Replace('_', '-');
+        }
+    }
+}

src/EasyFrameWork/NamingConverter.cs

@@ -11,8 +11,7 @@ namespace Easy.RepositoryPattern
 {
     public class DataTableAttribute : TableAttribute
     {
-        public static bool IsLowerCaseTableNames { get; set; }
-        public DataTableAttribute(string name) : base(IsLowerCaseTableNames ? name.ToLowerInvariant() : name)
+        public DataTableAttribute(string name) : base(name)
         {
 
         }

src/EasyFrameWork/RepositoryPattern/DataTableAttribute.cs

@@ -6,6 +6,10 @@
     //"ConnectionString": "Data Source=App_Data/Database.sqlite"
     //"DbType": "MySql",
     //"ConnectionString": "Server=localhost;Database=ZKEACMS;User Id=root;Password=root;"
+    //"DbType": "DM",
+    //"ConnectionString": "Server=localhost;Port=5236;SCHEMA=ZKEACMS;User Id=SYSDBA;Password=SYSDBA001;",
+    //"TableNaming": "UpperCase",
+    //"ColumnNaming": "UpperCase"
   },
   "Logging": {
     "LogLevel": {

src/ZKEACMS.WebHost/appsettings.json

@@ -38,7 +38,6 @@ public static void ConfigDatabase(this IServiceCollection services, IConfigurati
             services.AddScoped<DbContext>((provider) => provider.GetService<CMSDbContext>());
             services.AddScoped<EasyDbContext>((provider) => provider.GetService<CMSDbContext>());
             DatabaseOption databaseOption = configuration.GetSection("Database").Get<DatabaseOption>();
-            DataTableAttribute.IsLowerCaseTableNames = databaseOption.IsLowerCaseTableNames;
             services.AddSingleton(databaseOption);
             #endregion
         }

src/ZKEACMS/BuilderDatabase.cs

@@ -2,14 +2,16 @@
  * Copyright (c) ZKEASOFT. All rights reserved. 
  * http://www.zkea.net/licenses */
 
-using System.Collections.Generic;
 using Easy;
+using Easy.Constant;
 using Easy.RepositoryPattern;
 using Microsoft.EntityFrameworkCore;
+using System.Collections.Generic;
 using ZKEACMS.Common.Models;
 using ZKEACMS.ExtendField;
 using ZKEACMS.Layout;
 using ZKEACMS.Media;
+using ZKEACMS.Options;
 using ZKEACMS.Page;
 using ZKEACMS.PendingTask;
 using ZKEACMS.Setting;
@@ -22,9 +24,14 @@ namespace ZKEACMS
 {
     public class CMSDbContext : EasyDbContext
     {
-        public CMSDbContext(DbContextOptions<CMSDbContext> dbContextOptions, IEnumerable<IOnModelCreating> modelCreatings) : base(dbContextOptions)
+        private readonly DatabaseOption _databaseOption;
+        public CMSDbContext(DbContextOptions<CMSDbContext> dbContextOptions,
+            IEnumerable<IOnModelCreating> modelCreatings,
+            DatabaseOption databaseOption)
+            : base(dbContextOptions)
         {
             ModelCreatings = modelCreatings;
+            _databaseOption = databaseOption;
         }
 
         public DbSet<WidgetBasePart> WidgetBasePart { get; set; }
@@ -48,5 +55,27 @@ public CMSDbContext(DbContextOptions<CMSDbContext> dbContextOptions, IEnumerable
         public DbSet<StyleSheetWidget> StyleSheetWidget { get; set; }
         public DbSet<VideoWidget> VideoWidget { get; set; }
         public DbSet<BreadcrumbWidget> BreadcrumbWidget { get; set; }
+
+        protected override void OnModelCreating(ModelBuilder modelBuilder)
+        {
+            base.OnModelCreating(modelBuilder);
+
+            var tableNamingConverter = new NamingConverter(_databaseOption.TableNaming);
+            var columnNamingConverter = new NamingConverter(_databaseOption.ColumnNaming);
+            foreach (var entity in modelBuilder.Model.GetEntityTypes())
+            {
+                if (tableNamingConverter.Strategy != NameCaseStrategy.None)
+                {
+                    entity.SetTableName(tableNamingConverter.ConvertName(entity.GetTableName()));
+                }
+                foreach (var property in entity.GetProperties())
+                {
+                    if (columnNamingConverter.Strategy != NameCaseStrategy.None)
+                    {
+                        property.SetColumnName(columnNamingConverter.ConvertName(property.GetColumnName()));
+                    }
+                }
+            }
+        }
     }
 }