修改

Net6Demo_Api.Business/BaseBusiness.cs

@@ -9,7 +9,6 @@ using System.Linq;
 using System.Reflection;
 using System.ComponentModel.DataAnnotations;
 using System.Data.Common;
-using MySqlConnector;
 using Net6Demo_Api.Entity;
 
 namespace Net6Demo_Api.Business
@@ -513,46 +512,6 @@ namespace Net6Demo_Api.Business
             return await _db.ExecuteSqlAsync(sql, paras);
         }
 
-        /// <summary>
-        /// 通过Sql语句查询返回DataSet,参数化查询
-        /// </summary>
-        /// <param name="sql">Sql语句</param>
-        /// <param name="parameters">参数</param>
-        /// <returns></returns>
-        public DataSet GetDataSetWithSql(string sql, List<DbParameter> parameters = null)
-        {
-            DbProviderFactory dbProviderFactory = MySqlConnectorFactory.Instance;
-            using (DbConnection conn = dbProviderFactory.CreateConnection())
-            {
-                conn.ConnectionString = _db.ConnectionString;
-                if (conn.State != ConnectionState.Open)
-                {
-                    conn.Open();
-                }
-
-                using (DbCommand cmd = conn.CreateCommand())
-                {
-                    cmd.Connection = conn;
-                    cmd.CommandText = sql;
-                    if (parameters != null && parameters.Count > 0)
-                    {
-                        foreach (var item in parameters)
-                        {
-                            cmd.Parameters.Add(item);
-                        }
-                    }
-
-                    DbDataAdapter adapter = dbProviderFactory.CreateDataAdapter();
-                    adapter.SelectCommand = cmd;
-                    DataSet ds = new DataSet();
-                    adapter.Fill(ds);
-                    cmd.Parameters.Clear();
-
-                    return ds;
-                }
-            }
-        }
-
         #endregion
 
         #region 缓存数据

Net6Demo_Api.Business/Net6Demo_Api.Business.csproj

@@ -7,10 +7,6 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="EFCore.Sharding.MySql" Version="6.0.7" />
-  </ItemGroup>
-
-  <ItemGroup>
     <ProjectReference Include="..\Net6Demo_Api.Entity\Net6Demo_Api.Entity.csproj" />
     <ProjectReference Include="..\Net6Demo_Api.IBusiness\Net6Demo_Api.IBusiness.csproj" />
     <ProjectReference Include="..\Net6Demo_Api.Util\Net6Demo_Api.Util.csproj" />

Net6Demo_Api.Entity/Input/HomeInput.cs

@@ -0,0 +1,40 @@
+using System.ComponentModel;
+
+namespace Net6Demo_Api.Entity
+{
+    /// <summary>
+    /// 代码配置输入
+    /// </summary>
+    public class CodeInput
+    {
+        /// <summary>
+        /// 模块名
+        /// </summary>
+        [DefaultValue("")]
+        public string modulename { get; set; } = "";
+        /// <summary>
+        /// 控制器名
+        /// </summary>
+        [DefaultValue("")]
+        public string controllername { get; set; } = "";
+        /// <summary>
+        /// 表名
+        /// </summary>
+        [DefaultValue("")]
+        public string tablename { get; set; } = "";
+    }
+
+    public class LoginInput
+    {
+        /// <summary>
+        /// 账号
+        /// </summary>
+        [DefaultValue("")]
+        public string usercode { get; set; } = "";
+        /// <summary>
+        /// 密码
+        /// </summary>
+        [DefaultValue("")]
+        public string password { get; set; } = "";
+    }
+}

Net6Demo_Api.Entity/Input/LoginInput.cs

@@ -1,18 +0,0 @@
-using System.ComponentModel;
-
-namespace Net6Demo_Api.Entity
-{
-    public class LoginInput
-    {
-        /// <summary>
-        /// 账号
-        /// </summary>
-        [DefaultValue("")]
-        public string usercode { get; set; } = "";
-        /// <summary>
-        /// 密码
-        /// </summary>
-        [DefaultValue("")]
-        public string password { get; set; } = "";
-    }
-}

Net6Demo_Api.IBusiness/IBaseBusiness.cs

@@ -234,14 +234,6 @@ namespace Net6Demo_Api.IBusiness
         /// <returns></returns>
         Task<int> ExecuteSqlAsync(string sql, params (string, object)[] paras);
 
-        /// <summary>
-        /// 通过Sql语句查询返回DataSet,参数化查询
-        /// </summary>
-        /// <param name="sql">Sql语句</param>
-        /// <param name="parameters">参数</param>
-        /// <returns></returns>
-        DataSet GetDataSetWithSql(string sql, List<DbParameter> parameters = null);
-
         #endregion
     }
 }

Net6Demo_Api.Util/Extention/Services.cs

@@ -64,6 +64,7 @@ namespace Net6Demo_Api.Util
                         {
                             services.Add(new ServiceDescriptor(i, aType, aMap.Value));
                         });
+                        services.Add(new ServiceDescriptor(aType, aType, aMap.Value));
                     }
                 });
             });

Net6Demo_Api.Util/Helper/CreateCodeFileHelper.cs

@@ -0,0 +1,698 @@
+using EFCore.Sharding;
+using Microsoft.Data.SqlClient;
+using Microsoft.Extensions.Hosting;
+using MySqlConnector;
+using Npgsql;
+using Oracle.ManagedDataAccess.Client;
+using System.Data;
+using System.Data.Common;
+using System.Net;
+using System.Text;
+
+namespace Net6Demo_Api.Util
+{
+    public class CreateCodeFileHelper: ITransientDependency
+    {
+        private readonly IDbAccessor _db;
+        private readonly IHostEnvironment _env;
+        private readonly DbProviderFactory _factory;
+        private string _key;
+        public CreateCodeFileHelper(IDbAccessor db, IHostEnvironment env)
+        {
+            _db = db;
+            _env = env;
+
+            switch (db.DbType)
+            {
+                case DatabaseType.SqlServer: _factory = SqlClientFactory.Instance; break;
+                case DatabaseType.MySql: _factory = MySqlConnectorFactory.Instance; break;
+                case DatabaseType.PostgreSql: _factory = NpgsqlFactory.Instance; break;
+                case DatabaseType.Oracle: _factory = OracleClientFactory.Instance; break;
+
+                default: throw new Exception("此数据库不支持！");
+            }
+        }
+
+        /// <summary>
+        /// 生成代码文件
+        /// </summary>
+        /// <param name="tableName"></param>
+        public void CreateCodeFile(string tableName, string controllerName, string moduleName)
+        {
+            var list= GetDataTableWithSql(DbTableSqlDic[_db.DbType]).ToJson().ToObject<List<TableInfo>>();
+            if (!string.IsNullOrEmpty(tableName)) list = list.Where(p => p.Name.ToLower() == tableName.ToLower()).ToList();
+            foreach (var item in list)
+            {
+                CreateEntityFile(item.Name,item.Description, controllerName, moduleName);
+                CreateBusinessFile(item.Name, controllerName, moduleName);
+                CreateControllerFile(item.Name, controllerName, moduleName);
+            }
+        }
+
+        /// <summary>
+        /// 生成实体文件
+        /// </summary>
+        public void CreateEntityFile(string tableName, string tableDescription, string controllerName, string moduleName)
+        {
+            moduleName = string.IsNullOrEmpty(moduleName) ? "" : moduleName + "\\";
+            string path = Directory.GetParent(_env.ContentRootPath).Parent.FullName;
+            string pname = _env.ApplicationName;
+
+            var dbtype = _db.DbType;
+            var columns = GetDataTableWithSql(DbTableColumnSqlDic[dbtype], new Dictionary<string, string>() { { "@tablename" , tableName } } ).ToJson().ToObject<List<TableColumn>>();
+            int index = 0;
+            string properties = string.Empty;
+            string inputproperties = string.Empty;
+            string viewproperties = string.Empty;
+            foreach (var column in columns)
+            {
+                string key = string.Empty;
+                if (column.IsKey)
+                {
+                    key = $@"
+        [Key, Column(Order = {index + 1})]";
+                    _key = column.Name;
+                }
+
+                Type type = DbTypeToCsharpType(column.Type);
+                string isNullable = column.IsNullable && type.IsValueType ? "?" : "";
+                string description =string.IsNullOrEmpty(column.Description) ? column.Name : column.Description;
+                properties += $@"
+        /// <summary>{description}</summary>{key}
+        public {type.Name}{isNullable} {column.Name} {{ get; set; }}
+";
+                inputproperties += $@"
+        /// <summary>{description}</summary>
+        public {type.Name}{isNullable} {(column.Name.StartsWith("F_")? column.Name.Substring(2) : column.Name)} {{ get; set; }}
+";
+                viewproperties += $@"
+        /// <summary>{description}</summary>
+        public {type.Name}{isNullable} {(column.Name.StartsWith("F_") ? column.Name.Substring(2) : column.Name)} {{ get; set; }}
+";
+                index++;
+            }
+
+            string entityContent = $@"
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+namespace {pname}.Entity
+{{
+    /// <summary>
+    /// {tableDescription}
+    /// </summary>
+    [Table(""{tableName}"")]
+    public class {tableName}
+    {{
+        {properties}
+    }}
+}}";
+            CreateFile($@"{path}\{pname}.Entity\DataBase\{moduleName}\{tableName}.cs", entityContent);
+
+            string inputEntityContent = $@"
+using Net6Demo_Api.Util;
+namespace {pname}.Entity
+{{
+    /// <summary>
+    /// {tableDescription}
+    /// </summary>
+    [Map(typeof({tableName}))]
+    public class {controllerName}Input
+    {{
+        {inputproperties}
+    }}
+}}";
+            CreateFile($@"{path}\{pname}.Entity\Input\{moduleName}\{controllerName}Input.cs", inputEntityContent);
+
+            string viewEntityContent = $@"
+using Net6Demo_Api.Util;
+namespace {pname}.Entity
+{{
+    /// <summary>
+    /// {tableDescription}
+    /// </summary>
+    [Map(typeof({tableName}))]
+    public class {controllerName}View
+    {{
+        {viewproperties}
+    }}
+}}";
+            CreateFile($@"{path}\{pname}.Entity\View\{moduleName}\{controllerName}View.cs", viewEntityContent);
+
+            //数据库类型转C#类型
+            Type DbTypeToCsharpType(string dbTypeStr)
+            {
+                string _dbTypeStr = dbTypeStr.ToLower();
+                Type type = null;
+                if (DbTypeDic[dbtype].ContainsKey(_dbTypeStr))
+                    type = DbTypeDic[dbtype][_dbTypeStr];
+                else
+                    type = typeof(string);
+
+                return type;
+            }
+        }
+
+        /// <summary>
+        /// 生成控制器文件
+        /// </summary>
+        /// <param name="tableName"></param>
+        /// <param name="controllerName"></param>
+        /// <param name="moduleName"></param>
+        public void CreateControllerFile(string tableName, string controllerName, string moduleName)
+        {
+            moduleName = string.IsNullOrEmpty(moduleName) ? "" : moduleName + "\\";
+            string path = _env.ContentRootPath + "\\Controllers\\" + moduleName;
+            string pname = _env.ApplicationName;
+
+            string controllerContent = $@"
+using AutoMapper;
+using LinqKit;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore;
+using {pname}.Entity;
+using {pname}.IBusiness;
+namespace {pname}.Controllers
+{{
+    public class {controllerName}Controller : BaseController
+    {{
+        private readonly I{controllerName}Business _{controllerName}Bus;
+        private readonly IMapper _mapper;
+        public {controllerName}Controller(I{controllerName}Business {controllerName}Bus,  IMapper mapper)
+        {{
+            _{controllerName}Bus = {controllerName}Bus;
+            _mapper = mapper;
+        }}
+        /// <summary>
+        /// 获取分页列表
+        /// </summary>
+        /// <param name=""input""></param>
+        /// <returns></returns>
+        [HttpPost]
+        public async Task<ActionResult> GetDataListPage(PageInput<{controllerName}Input> input)
+        {{
+            var q = PredicateBuilder.New<{tableName}>(true);
+            var data = await _{controllerName}Bus.GetListPageAsync(input, q, p => p.OrderByDescending(q => q.{_key}));
+            return Success(""成功"", _mapper.Map<List<{controllerName}View>>(data.Item1), data.Item2);
+        }}
+        /// <summary>
+        /// 获取单个
+        /// </summary>
+        /// <param name=""id"">主键ID</param>
+        /// <returns></returns>
+        [HttpGet]
+        public async Task<ActionResult> GetData(int id)
+        {{
+            var data = await _{controllerName}Bus.GetEntityAsync(id);
+            if (data != null) return Success(""成功"", _mapper.Map<{controllerName}View>(data));
+            else return Error(""获取失败"");
+        }}
+        /// <summary>
+        /// 新增
+        /// </summary>
+        /// <param name=""input"" ></param>
+        /// <returns></returns>
+        [HttpPost]
+        public async Task<ActionResult> AddData({controllerName}Input input)
+        {{
+            {tableName} model = _mapper.Map<{tableName}>(input);
+            int result = await _{controllerName}Bus.InsertAsync(model);
+            if (result > 0) return Success(""成功"");
+            else return Error(""失败"");
+        }}
+        /// <summary>
+        /// 编辑
+        /// </summary>
+        /// <param name=""input"" ></param>
+        /// <returns></returns>
+        [HttpPost]
+        public async Task<ActionResult> EditData({controllerName}Input input)
+        {{
+            int result = 0;
+            var oldData = await _{controllerName}Bus.GetEntityAsync(input.{(_key.StartsWith("F_") ? _key.Substring(2) : _key)});
+            if (oldData != null)
+            {{
+                _mapper.Map(input, oldData);
+                result = await _{controllerName}Bus.UpdateAsync(oldData);
+            }}
+            if (result > 0) return Success(""成功"");
+            else return Error(""失败""); 
+        }}
+        /// <summary>
+        /// 删除
+        /// </summary>
+        /// <param name=""ids"" ></param>
+        /// <returns></returns>
+        [HttpPost]
+        public async Task<ActionResult> DeleteData(List<string> ids)
+        {{
+            if (await _{controllerName}Bus.DeleteAsync(ids) > 0) return Success(""删除成功"");
+            else return Error(""删除失败"");
+        }}
+        
+    }}
+}}
+";
+            CreateFile($@"{path}\{controllerName}Controller.cs", controllerContent);
+        }
+
+        /// <summary>
+        /// 生成业务文件
+        /// </summary>
+        /// <param name="tableName"></param>
+        /// <param name="controllerName"></param>
+        /// <param name="moduleName"></param>
+        public void CreateBusinessFile(string tableName, string controllerName, string moduleName)
+        {
+            moduleName = string.IsNullOrEmpty(moduleName) ? "" : moduleName + "\\";
+            string path = Directory.GetParent(_env.ContentRootPath).Parent.FullName;
+            string pname = _env.ApplicationName;
+
+            string iBusinessContent = $@"
+using {pname}.Entity;
+namespace {pname}.IBusiness
+{{
+    public interface I{controllerName}Business : IBaseBusiness<{tableName}>
+    {{
+        
+    }}
+}}
+";
+            CreateFile($@"{path}\{pname}.IBusiness\{moduleName}I{controllerName}Business.cs", iBusinessContent);
+
+            string businessContent = $@"
+using EFCore.Sharding;
+using Microsoft.Extensions.Caching.Distributed;
+using {pname}.Entity;
+using {pname}.IBusiness;
+using {pname}.Util;
+namespace {pname}.Business
+{{
+    public class {controllerName}Business : BaseBusiness<{tableName}>, I{controllerName}Business, ITransientDependency
+    {{
+        public {controllerName}Business(IDbAccessor db, IDistributedCache cache) : base(db, cache, true)
+        {{
+        }}
+    }}
+}}
+";
+            CreateFile($@"{path}\{pname}.Business\{moduleName}{controllerName}Business.cs", businessContent);
+        }
+
+        /// <summary>
+        /// 创建文件
+        /// </summary>
+        /// <param name="filepath"></param>
+        /// <param name="content"></param>
+        private void CreateFile(string filepath, string content)
+        {
+            string path = filepath.Substring(0, filepath.LastIndexOf("\\"));
+            if (!Directory.Exists(path)) Directory.CreateDirectory(path);
+            if (!File.Exists(filepath))
+            {
+                FileInfo file = new FileInfo(filepath);
+                using (FileStream stream = file.Create())
+                {
+                    using (StreamWriter writer = new StreamWriter(stream, Encoding.UTF8))
+                    {
+                        writer.Write(content);
+                        writer.Flush();
+                    }
+                }
+            }
+        }
+
+        /// <summary>
+        /// 根据sql获取DataTable
+        /// </summary>
+        /// <param name="sql"></param>
+        /// <param name="parameters"></param>
+        /// <returns></returns>
+        private DataTable GetDataTableWithSql(string sql, Dictionary<string, string> paras = null)
+        {
+            using (DbConnection conn = _factory.CreateConnection())
+            {
+                conn.ConnectionString = _db.ConnectionString;
+                if (conn.State != ConnectionState.Open)
+                {
+                    conn.Open();
+                }
+
+                using (DbCommand cmd = conn.CreateCommand())
+                {
+
+                    cmd.Connection = conn;
+                    cmd.CommandText = sql;
+
+                    if (paras != null)
+                    {
+                        foreach (KeyValuePair<string, string> kvp in paras)
+                        {
+                            switch (_db.DbType)
+                            {
+                                case DatabaseType.SqlServer: cmd.Parameters.Add(new SqlParameter(kvp.Key, kvp.Value)); break;
+                                case DatabaseType.MySql: cmd.Parameters.Add(new MySqlParameter(kvp.Key, kvp.Value)); break;
+                                case DatabaseType.PostgreSql: cmd.Parameters.Add(new NpgsqlParameter(kvp.Key, kvp.Value)); break;
+                                case DatabaseType.Oracle: cmd.Parameters.Add(new OracleParameter(kvp.Key, kvp.Value)); break;
+                            }
+                        }
+                    }
+
+                    DbDataAdapter adapter = _factory.CreateDataAdapter();
+                    adapter.SelectCommand = cmd;
+                    DataSet table = new DataSet();
+                    adapter.Fill(table);
+                    cmd.Parameters.Clear();
+
+                    return table.Tables[0];
+                }
+            }
+        }
+
+        /// <summary>
+        /// 数据库类型和C#类型字典
+        /// </summary>
+        private Dictionary<DatabaseType, Dictionary<string, Type>> DbTypeDic = new Dictionary<DatabaseType, Dictionary<string, Type>>()
+        {
+            { DatabaseType.SqlServer,new Dictionary<string, Type>()
+                {
+                    { "int", typeof(Int32) },
+                    { "text", typeof(string) },
+                    { "bigint", typeof(Int64) },
+                    { "binary", typeof(byte[]) },
+                    { "bit", typeof(bool) },
+                    { "char", typeof(string) },
+                    { "date", typeof(DateTime) },
+                    { "datetime", typeof(DateTime) },
+                    { "datetime2", typeof(DateTime) },
+                    { "datetimeoffset", typeof(DateTimeOffset) },
+                    { "decimal", typeof(decimal) },
+                    { "float", typeof(double) },
+                    { "image", typeof(byte[]) },
+                    { "money", typeof(decimal) },
+                    { "nchar", typeof(string) },
+                    { "ntext", typeof(string) },
+                    { "numeric", typeof(decimal) },
+                    { "nvarchar", typeof(string) },
+                    { "real", typeof(Single) },
+                    { "smalldatetime", typeof(DateTime) },
+                    { "smallint", typeof(Int16) },
+                    { "smallmoney", typeof(decimal) },
+                    { "time", typeof(TimeSpan) },
+                    { "timestamp", typeof(DateTime) },
+                    { "tinyint", typeof(byte) },
+                    { "varbinary", typeof(byte[]) },
+                    { "varchar", typeof(string) },
+                    { "variant", typeof(object) },
+                    { "uniqueidentifier", typeof(Guid) }
+                }
+            },
+            { DatabaseType.MySql,new Dictionary<string, Type>()
+                {
+                    { "bool",typeof(bool)},
+                    { "boolean",typeof(bool)},
+                    { "bit(1)",typeof(bool)},
+                    { "binary",typeof(byte[])},
+                    { "varbinary",typeof(byte[])},
+                    { "blob",typeof(byte[])},
+                    { "longblob",typeof(byte[])},
+                    { "date",typeof(DateTime)},
+                    { "datetime",typeof(DateTime)},
+                    { "timestamp",typeof(DateTime)},
+                    { "datetimeoffset", typeof(DateTimeOffset) },
+                    { "time", typeof(TimeSpan) },
+                    { "double",typeof(double)},
+                    { "smallint",typeof(Int16)},
+                    { "int",typeof(Int32)},
+                    { "bigint",typeof(Int64)},
+                    { "tinyint",typeof(bool)},
+                    { "float",typeof(float)},
+                    { "decimal",typeof(decimal)},
+                    { "numeric",typeof(decimal)},
+                    { "char",typeof(string)},
+                    { "nchar",typeof(string)},
+                    { "varchar",typeof(string)},
+                    { "nvarchar",typeof(string)},
+                    { "text",typeof(string)},
+                    { "longtext",typeof(string)}
+                }
+            },
+            { DatabaseType.PostgreSql,new Dictionary<string, Type>()
+                {
+                    { "bool", typeof(bool) },
+                    { "boolean",typeof(bool)},
+                    { "int2", typeof(Int16) },
+                    { "smallint", typeof(Int16) },
+                    { "int4", typeof(Int32) },
+                    { "bigint", typeof(Int64) },
+                    { "int8", typeof(Int64) },
+                    { "integer", typeof(Int32) },
+                    { "float4", typeof(float) },
+                    { "float8", typeof(decimal) },
+                    { "decimal", typeof(decimal) },
+                    { "numeric", typeof(decimal) },
+                    { "money", typeof(decimal) },
+                    { "text", typeof(string) },
+                    { "varchar", typeof(string) },
+                    { "bpchar", typeof(string) },
+                    { "citext", typeof(string) },
+                    { "json", typeof(string) },
+                    { "jsonb", typeof(string) },
+                    { "xml", typeof(string) },
+                    { "bit(1)", typeof(bool) },
+                    { "uuid", typeof(Guid) },
+                    { "inet", typeof(IPAddress) },
+                    { "date", typeof(DateTime) },
+                    { "interval", typeof(TimeSpan) },
+                    { "timestamp", typeof(DateTime) },
+                    { "timestamptz", typeof(DateTime) },
+                    { "time", typeof(TimeSpan) },
+                    { "timetz", typeof(DateTimeOffset) },
+                    { "bytea", typeof(byte[]) },
+                    { "oid", typeof(uint) },
+                    { "xid", typeof(uint) },
+                    { "cid", typeof(uint) },
+                    { "name", typeof(string) }
+                }
+            },
+            { DatabaseType.Oracle,new Dictionary<string, Type>()
+                {
+                    { "boolean",typeof(bool)},
+                    { "bfile", typeof(byte[]) },
+                    { "blob", typeof(byte[]) },
+                    { "char", typeof(string) },
+                    { "clob", typeof(string) },
+                    { "date", typeof(DateTime) },
+                    { "float", typeof(decimal) },
+                    { "integer", typeof(decimal) },
+                    { "long", typeof(string) },
+                    { "long raw", typeof(string[]) },
+                    { "nchar", typeof(string) },
+                    { "nclob", typeof(string) },
+                    { "number", typeof(decimal) },
+                    { "nvarchar2", typeof(string) },
+                    { "raw", typeof(byte[]) },
+                    { "rowid", typeof(string) },
+                    { "timestamp", typeof(DateTime) },
+                    { "unsigned integer", typeof(decimal) },
+                    { "varchar2", typeof(string) }
+                }
+            },
+            { DatabaseType.SQLite,new Dictionary<string, Type>()
+                {
+                    { "tinyint", typeof(byte) },
+                    { "bool", typeof(bool) },
+                    { "boolean",typeof(bool)},
+                    { "int16", typeof(Int16) },
+                    { "smallint", typeof(Int16) },
+                    { "int32", typeof(Int32) },
+                    { "int", typeof(Int32) },
+                    { "int64", typeof(Int64) },
+                    { "integer", typeof(Int64) },
+                    { "text", typeof(string) },
+                    { "bigint", typeof(Int64) },
+                    { "real", typeof(double) },
+                    { "numeric", typeof(decimal) },
+                    { "decimal", typeof(decimal) },
+                    { "money", typeof(decimal) },
+                    { "currency", typeof(decimal) },
+                    { "date", typeof(DateTime) },
+                    { "smalldate", typeof(DateTime) },
+                    { "datetime", typeof(DateTime) },
+                    { "time", typeof(TimeSpan) },
+                    { "ntext", typeof(string) },
+                    { "char", typeof(string) },
+                    { "nchar", typeof(string) },
+                    { "varchar", typeof(string) },
+                    { "nvarchar", typeof(string) },
+                    { "string", typeof(string) },
+                    { "binary", typeof(byte[]) },
+                    { "blob", typeof(byte[]) },
+                    { "varbinary", typeof(byte[]) },
+                    { "image", typeof(byte[]) },
+                    { "general", typeof(byte[]) },
+                    { "datetimeoffset", typeof(DateTimeOffset) },
+                    { "guid", typeof(Guid) }
+                }
+            }
+        };
+
+        /// <summary>
+        /// 数据库类型表sql字典
+        /// </summary>
+        private Dictionary<DatabaseType, string> DbTableSqlDic=new Dictionary<DatabaseType, string>()
+        {
+            { DatabaseType.SqlServer,
+                "select [Name] = a.name, [Description] = g.value from sys.tables a left join sys.extended_properties g on (a.object_id = g.major_id AND g.minor_id = 0 AND g.name= 'MS_Description')"
+            },
+            { DatabaseType.MySql,
+                "SELECT TABLE_NAME as Name,table_comment as Description FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA =(select database())"
+            },
+            { DatabaseType.Oracle,
+                "SELECT A.TABLE_NAME AS NAME, B.comments AS DESCRIPTION FROM USER_TABLES A, USER_TAB_COMMENTS B WHERE A.table_name = B.table_name(+)"
+            },
+            { DatabaseType.PostgreSql,
+                "select relname as Name, cast(obj_description(relfilenode,'pg_class') as varchar) as Description from pg_class c where relkind = 'r' and relname not like 'pg_%' and relname not order by relname"
+            },
+            { DatabaseType.SQLite,""},
+        };
+
+        /// <summary>
+        /// 数据库类型表字段sql字典
+        /// </summary>
+        private Dictionary<DatabaseType, string> DbTableColumnSqlDic = new Dictionary<DatabaseType, string>()
+        {
+            { DatabaseType.SqlServer,
+                @"
+select
+sys.columns.name as [Name],
+sys.types.name as [Type], 
+sys.columns.is_nullable [IsNullable], 
+[IsIdentity]=CONVERT(BIT, (select count(*) from sys.identity_columns where sys.identity_columns.object_id = sys.columns.object_id and sys.columns.column_id = sys.identity_columns.column_id)),
+(select value from sys.extended_properties where sys.extended_properties.major_id = sys.columns.object_id and sys.extended_properties.minor_id = sys.columns.column_id and name='MS_Description') as [Description],
+[IsKey] =CONVERT(bit,(case when sys.columns.name in (select b.column_name
+from information_schema.table_constraints a
+inner join information_schema.constraint_column_usage b
+on a.constraint_name = b.constraint_name
+where a.constraint_type = 'PRIMARY KEY' and a.table_name = @tablename) then 1 else 0 end))
+from sys.columns, sys.tables, sys.types where sys.columns.object_id = sys.tables.object_id and sys.columns.system_type_id=sys.types.system_type_id and sys.tables.name=@tablename and sys.types.name !='sysname' 
+order by sys.columns.column_id asc;"
+            },
+            { DatabaseType.MySql,
+                @"
+select DISTINCT
+a.COLUMN_NAME as Name,
+a.DATA_TYPE as Type,
+(a.COLUMN_KEY = 'PRI') as IsKey,
+(a.IS_NULLABLE = 'YES') as IsNullable,
+a.COLUMN_COMMENT as Description,
+a.ORDINAL_POSITION
+from information_schema.columns a 
+where table_name=@tableName and table_schema=(select database())
+ORDER BY a.ORDINAL_POSITION;"
+            },
+            { DatabaseType.Oracle,
+                @"
+SELECT 
+A.COLUMN_NAME AS NAME,
+A.DATA_TYPE   AS TYPE,
+NVL2(D.CONSTRAINT_TYPE,1,0) AS ISKEY,
+DECODE(A.NULLABLE,'Y',1,0) AS ISNULLABLE,
+B.COMMENTS AS DESCRIPTION
+FROM USER_TAB_COLUMNS A, USER_COL_COMMENTS B, USER_IND_COLUMNS C, USER_CONSTRAINTS D
+WHERE A.TABLE_NAME = B.TABLE_NAME(+)
+AND A.COLUMN_NAME = B.COLUMN_NAME(+)
+AND A.TABLE_NAME = C.TABLE_NAME(+)
+AND A.COLUMN_NAME = C.COLUMN_NAME(+)
+AND C.INDEX_NAME = D.INDEX_NAME(+)
+AND 'P' = D.CONSTRAINT_TYPE(+)
+AND A.TABLE_NAME= :tableName
+ORDER BY A.COLUMN_ID;"
+            },
+            { DatabaseType.PostgreSql,
+                @"
+SELECT 
+a.attname as Name,
+pg_type.typname as Type,
+(SELECT count(1) from(SELECT ic.column_name as ColumnName FROM information_schema.table_constraints tc JOIN information_schema.constraint_column_usage AS ccu USING(constraint_schema, constraint_name) JOIN information_schema.columns AS ic ON ic.table_schema = tc.constraint_schema AND tc.table_name = ic.table_name AND ccu.column_name = ic.column_name
+where constraint_type = 'PRIMARY KEY' and tc.table_name = @tablename) KeyA WHERE KeyA.ColumnName = a.attname)> 0 as IsKey,
+a.attnotnull<> True as IsNullable,
+col_description(a.attrelid, a.attnum) as Description
+FROM pg_class as c,pg_attribute as a inner join pg_type on pg_type.oid = a.atttypid
+where c.relname = @tablename and a.attrelid = c.oid and a.attnum > 0
+order by a.attnum asc;"
+            }
+        };
+
+        /// <summary>
+        /// 表信息
+        /// </summary>
+        private class TableInfo
+        {
+            /// <summary>
+            /// 表名
+            /// </summary>
+            public string Name { get; set; }
+
+            /// <summary>
+            /// 表描述说明
+            /// </summary>
+            public string Description
+            {
+                get
+                {
+                    return string.IsNullOrEmpty(_description) ? Name : _description;
+                }
+                set
+                {
+                    _description = value;
+                }
+            }
+
+            private string _description { get; set; }
+        }
+
+        /// <summary>
+        /// 表结构信息
+        /// </summary>
+        private class TableColumn
+        {
+            /// <summary>
+            /// 字段名
+            /// </summary>
+            public string Name { get; set; }
+
+            /// <summary>
+            /// 字段类型
+            /// </summary>
+            public string Type { get; set; }
+
+            /// <summary>
+            /// 是否为主键
+            /// </summary>
+            public bool IsKey { get; set; }
+
+            /// <summary>
+            /// 是否为空
+            /// </summary>
+            public bool IsNullable { get; set; }
+
+            /// <summary>
+            /// 字段描述说明
+            /// </summary>
+            public string Description
+            {
+                get
+                {
+                    return string.IsNullOrEmpty(_description) ? Name : _description;
+                }
+                set
+                {
+                    _description = value;
+                }
+            }
+
+            private string _description { get; set; }
+        }
+    }
+}

Net6Demo_Api.Util/Net6Demo_Api.Util.csproj

@@ -8,6 +8,10 @@
 
   <ItemGroup>
     <PackageReference Include="AutoMapper" Version="11.0.1" />
+    <PackageReference Include="EFCore.Sharding.MySql" Version="6.0.7" />
+    <PackageReference Include="EFCore.Sharding.Oracle" Version="6.0.7" />
+    <PackageReference Include="EFCore.Sharding.PostgreSql" Version="6.0.7" />
+    <PackageReference Include="EFCore.Sharding.SqlServer" Version="6.0.7" />
     <PackageReference Include="Microsoft.Extensions.Http" Version="6.0.0" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
     <PackageReference Include="NLog.Web.AspNetCore" Version="5.1.0" />

Net6Demo_Api/Controllers/HomeController.cs

@@ -22,13 +22,15 @@ namespace Net6Demo_Api.Controllers
         private readonly IUserAccountBusiness _userBus;
         private readonly HttpHelper _httpHelper;
         private readonly IWebHostEnvironment _env;
+        private readonly CreateCodeFileHelper _createHelper;
         private readonly ILogger _logger;
-        public HomeController(IUserAccountBusiness userBus, IConfiguration config, HttpHelper httpHelper, IWebHostEnvironment env,ILogger<HomeController> logger)
+        public HomeController(IUserAccountBusiness userBus, IConfiguration config, HttpHelper httpHelper, IWebHostEnvironment env, CreateCodeFileHelper createHelper,ILogger<HomeController> logger)
         {
             _userBus = userBus;
             _config = config;
             _httpHelper = httpHelper;
             _env = env;
+            _createHelper=createHelper;
             _logger = logger;
         }
 
@@ -86,6 +88,18 @@ namespace Net6Demo_Api.Controllers
         }
 
         /// <summary>
+        /// 生成代码文件(只支持SqlServer,MySql,Oracle,PostgreSql)
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost]
+        public ActionResult BulidCodeFile(CodeInput input)
+        {
+            _createHelper.CreateCodeFile(input.tablename, input.controllername, input.modulename);
+            return Success("成功");
+        }
+
+        /// <summary>
         /// 登录
         /// </summary>
         /// <param name="input">登录信息</param>