- 增加 FreeSqlBuilder UseSeedData 设定 CodeFirst 种子数据；

Author: 28810

Examples/base_entity/Program.cs

@@ -65,7 +65,24 @@ static void Main(string[] args)
                 //.UseConnectionString(FreeSql.DataType.OdbcOracle, "Driver={Oracle in XE};Server=//127.0.0.1:1521/XE;Persist Security Info=False;Trusted_Connection=Yes;UID=odbc1;PWD=123456")
                 //.UseNameConvert(FreeSql.Internal.NameConvertType.ToUpper)
 
-                .UseConnectionString(FreeSql.DataType.OdbcDameng, "Driver={DM8 ODBC DRIVER};Server=127.0.0.1:5236;Persist Security Info=False;Trusted_Connection=Yes;UID=USER1;PWD=123456789")
+                //.UseConnectionString(FreeSql.DataType.OdbcDameng, "Driver={DM8 ODBC DRIVER};Server=127.0.0.1:5236;Persist Security Info=False;Trusted_Connection=Yes;UID=USER1;PWD=123456789")
+
+                .UseMonitorCommand(cmd => Console.Write(cmd.CommandText))
+                .UseSeedData(sd => sd
+                    .Apply(new[]
+                    {
+                        new Products { Id = 1, title = "product-1" },
+                        new Products { Id = 2, title = "product-2" },
+                        new Products { Id = 3, title = "product-3" },
+                        new Products { Id = 4, title = "product-4" }
+                    })
+                    .Apply(new[]
+                    {
+                        new S_SysConfig<TestConfig> { Name = "testkey11", Config = new TestConfig { clicks = 11, title = "testtitle11" } },
+                        new S_SysConfig<TestConfig> { Name = "testkey22", Config = new TestConfig { clicks = 22, title = "testtitle22" } },
+                        new S_SysConfig<TestConfig> { Name = "testkey33", Config = new TestConfig { clicks = 33, title = "testtitle33" } }
+                    })
+                 )
 
                 .UseLazyLoading(true)
                 .Build();

Extensions/FreeSql.Extensions.BaseEntity/BaseEntity.cs

@@ -25,8 +25,7 @@ static BaseEntity()
         {
             var tkeyType = typeof(TKey)?.NullableTypeOrThis();
             if (tkeyType == typeof(int) || tkeyType == typeof(long))
-                Orm.CodeFirst.ConfigEntity(typeof(TEntity),
-                    t => t.Property("Id").IsIdentity(true));
+                BaseEntity.ConfigEntity(typeof(TEntity), t => t.Property("Id").IsIdentity(true));
         }
 
         /// <summary>

Extensions/FreeSql.Extensions.BaseEntity/BaseEntityAsync.cs

@@ -21,8 +21,7 @@ static BaseEntityAsync()
         {
             var tkeyType = typeof(TKey)?.NullableTypeOrThis();
             if (tkeyType == typeof(int) || tkeyType == typeof(long))
-                Orm.CodeFirst.ConfigEntity(typeof(TEntity),
-                    t => t.Property("Id").IsIdentity(true));
+                BaseEntity.ConfigEntity(typeof(TEntity), t => t.Property("Id").IsIdentity(true));
         }
 
         /// <summary>

Extensions/FreeSql.Extensions.BaseEntity/BaseEntityReadOnly.cs

@@ -4,6 +4,7 @@
 using System;
 using System.Collections;
 using System.Collections.Generic;
+using System.Collections.Concurrent;
 using System.Data;
 using System.Diagnostics;
 using System.Linq;
@@ -18,7 +19,7 @@ namespace FreeSql
     [Table(DisableSyncStructure = true)]
     public abstract class BaseEntity
     {
-        static IFreeSql _ormPriv;
+        internal static IFreeSql _ormPriv;
         /// <summary>
         /// 全局 IFreeSql orm 对象
         /// </summary>
@@ -42,6 +43,32 @@ public static void Initialization(IFreeSql fsql)
         {
             _ormPriv = fsql;
             _ormPriv.Aop.CurdBefore += (s, e) => Trace.WriteLine($"\r\n线程{Thread.CurrentThread.ManagedThreadId}: {e.Sql}\r\n");
+            if (_configEntityQueues.Any())
+            {
+                lock (_configEntityLock)
+                {
+                    while (_configEntityQueues.TryDequeue(out var cei))
+                        _ormPriv.CodeFirst.ConfigEntity(cei.EntityType, cei.Fluent);
+                }
+            }
+        }
+        
+        class ConfigEntityInfo
+        {
+            public Type EntityType;
+            public Action<TableFluent> Fluent;
+        }
+        static ConcurrentQueue<ConfigEntityInfo> _configEntityQueues = new ConcurrentQueue<ConfigEntityInfo>();
+        static object _configEntityLock = new object();
+        internal static void ConfigEntity(Type entityType, Action<TableFluent> fluent)
+        {
+            lock (_configEntityLock)
+            {
+                if (_ormPriv == null)
+                    _configEntityQueues.Enqueue(new ConfigEntityInfo { EntityType = entityType, Fluent = fluent });
+                else
+                    _ormPriv.CodeFirst.ConfigEntity(entityType, fluent);
+            }
         }
 
         /// <summary>