- 增加 MySql 特有功能 Insert Ignore Into；

Author: 28810

Examples/base_entity/Program.cs

@@ -26,24 +26,41 @@ public class S_SysConfig<T> : BaseEntity<S_SysConfig<T>>
             public T Config { get; set; }
         }
 
+        public class Products : BaseEntity<Products, int>
+        {
+            public string title { get; set; }
+        }
+
         static void Main(string[] args)
         {
             #region 初始化 IFreeSql
-            BaseEntity.Initialization(new FreeSql.FreeSqlBuilder()
+            var fsql = new FreeSql.FreeSqlBuilder()
                 .UseAutoSyncStructure(true)
                 .UseNoneCommandParameter(true)
                 .UseConnectionString(FreeSql.DataType.Sqlite, "data source=test.db;max pool size=5")
-                .UseConnectionString(FreeSql.DataType.MySql, "Data Source=127.0.0.1;Port=3306;User ID=root;Password=root;Initial Catalog=cccddd;Charset=utf8;SslMode=none;Max pool size=2")
-                .Build());
+                //.UseConnectionString(FreeSql.DataType.MySql, "Data Source=127.0.0.1;Port=3306;User ID=root;Password=root;Initial Catalog=cccddd;Charset=utf8;SslMode=none;Max pool size=2")
+                .Build();
+            BaseEntity.Initialization(fsql);
             #endregion
 
+            new Products { title = "product-1" }.Save();
+            new Products { title = "product-2" }.Save();
+            new Products { title = "product-3" }.Save();
+            new Products { title = "product-4" }.Save();
+            new Products { title = "product-5" }.Save();
+
+            var items1 = Products.Select.Limit(10).OrderByDescending(a => a.CreateTime).ToList();
+            var items2 = fsql.Select<Products>().Limit(10).OrderByDescending(a => a.CreateTime).ToList();
+
             BaseEntity.Orm.UseJsonMap();
 
             new S_SysConfig<TestConfig> { Name = "testkey11", Config = new TestConfig { clicks = 11, title = "testtitle11" } }.Save();
             new S_SysConfig<TestConfig> { Name = "testkey22", Config = new TestConfig { clicks = 22, title = "testtitle22" } }.Save();
             new S_SysConfig<TestConfig> { Name = "testkey33", Config = new TestConfig { clicks = 33, title = "testtitle33" } }.Save();
             var testconfigs11 = S_SysConfig<TestConfig>.Select.ToList();
 
+            var repo = BaseEntity.Orm.Select<TestConfig>().Limit(10).ToList();
+
             Task.Run(async () =>
             {
                 using (var uow = BaseEntity.Begin())
@@ -111,6 +128,8 @@ static void Main(string[] args)
 
             }).Wait();
 
+            
+
             Console.WriteLine("按任意键结束。。。");
             Console.ReadKey();
         }

FreeSql.DbContext/FreeSql.DbContext.xml

@@ -18,6 +18,7 @@ public class g
 
     static Lazy<IFreeSql> sqlserverLazy = new Lazy<IFreeSql>(() => new FreeSql.FreeSqlBuilder()
         .UseConnectionString(FreeSql.DataType.OdbcSqlServer, "Driver={SQL Server};Server=.;Persist Security Info=False;Trusted_Connection=Yes;Integrated Security=True;DATABASE=freesqlTest_odbc;Pooling=true;Max pool size=3")
+        //.UseConnectionString(FreeSql.DataType.OdbcSqlServer, "Driver={SQL Server};Server=192.168.164.129;Persist Security Info=False;Trusted_Connection=Yes;UID=sa;PWD=123456;DATABASE=ds_shop;")
         .UseAutoSyncStructure(true)
         .UseMonitorCommand(
             cmd => Trace.WriteLine(cmd.CommandText), //监听SQL命令对象，在执行前

FreeSql.Tests/FreeSql.Tests.Provider.Odbc/g.cs

@@ -129,6 +129,29 @@ public void ExecuteInserted()
             //insert.AppendData(items.First()).ExecuteInserted();
         }
 
+        [Fact]
+        public void MySqlIgnoreInto()
+        {
+            var items = new List<Topic>();
+            for (var a = 0; a < 10; a++) items.Add(new Topic { Id = a + 1, Title = $"newtitle{a}", Clicks = a * 100, CreateTime = DateTime.Now });
+
+            Assert.Equal(1, insert.MySqlIgnoreInto().AppendData(items.First()).ExecuteAffrows());
+            Assert.Equal(10, insert.MySqlIgnoreInto().AppendData(items).ExecuteAffrows());
+
+            Assert.Equal(1, g.mysql.Insert<TestEnumInsertTb>().MySqlIgnoreInto().AppendData(new TestEnumInsertTb { type = TestEnumInserTbType.sum211 }).ExecuteAffrows());
+            Assert.Equal(1, g.mysql.Insert<TestEnumInsertTb>().MySqlIgnoreInto().AppendData(new TestEnumInsertTb { type = TestEnumInserTbType.sum211 }).NoneParameter().ExecuteAffrows());
+
+            items = new List<Topic>();
+            for (var a = 0; a < 10; a++) items.Add(new Topic { Id = a + 1, Title = $"newtitle{a}", Clicks = a * 100 });
+
+            Assert.NotEqual(0, insert.MySqlIgnoreInto().AppendData(items.First()).ExecuteIdentity());
+
+            var id = g.mysql.Insert<TestEnumInsertTb>().MySqlIgnoreInto().AppendData(new TestEnumInsertTb { type = TestEnumInserTbType.sum211 }).ExecuteIdentity();
+            Assert.Equal(TestEnumInserTbType.sum211, g.mysql.Select<TestEnumInsertTb>().Where(a => a.id == id).First()?.type);
+            id = g.mysql.Insert<TestEnumInsertTb>().MySqlIgnoreInto().AppendData(new TestEnumInsertTb { type = TestEnumInserTbType.sum211 }).NoneParameter().ExecuteIdentity();
+            Assert.Equal(TestEnumInserTbType.sum211, g.mysql.Select<TestEnumInsertTb>().Where(a => a.id == id).First()?.type);
+        }
+
         [Fact]
         public void AsTable()
         {

FreeSql.Tests/FreeSql.Tests/MySql/Curd/MySqlInsertTest.cs

@@ -35,6 +35,7 @@ public class g
 
     static Lazy<IFreeSql> sqlserverLazy = new Lazy<IFreeSql>(() => new FreeSql.FreeSqlBuilder()
         .UseConnectionString(FreeSql.DataType.SqlServer, "Data Source=.;Integrated Security=True;Initial Catalog=freesqlTest;Pooling=true;Max Pool Size=3")
+        //.UseConnectionString(FreeSql.DataType.SqlServer, "Data Source=192.168.164.129;uid=sa;pwd=123456;Initial Catalog=ds_shop;Pooling=true;Max Pool Size=3")
         .UseAutoSyncStructure(true)
         .UseMonitorCommand(
             cmd => Trace.WriteLine(cmd.CommandText), //监听SQL命令对象，在执行前

FreeSql.Tests/FreeSql.Tests/g.cs

@@ -17,6 +17,7 @@ public MySqlInsert(IFreeSql orm, CommonUtils commonUtils, CommonExpression commo
         {
         }
 
+        internal bool InternalIsIgnoreInto = false;
         internal IFreeSql InternalOrm => _orm;
         internal TableInfo InternalTable => _table;
         internal DbParameter[] InternalParams => _params;
@@ -33,6 +34,13 @@ public MySqlInsert(IFreeSql orm, CommonUtils commonUtils, CommonExpression commo
         public override List<T1> ExecuteInserted() => base.SplitExecuteInserted(5000, 3000);
 
 
+        public override string ToSql()
+        {
+            if (InternalIsIgnoreInto == false) return base.ToSqlValuesOrSelectUnionAll();
+            var sql = base.ToSqlValuesOrSelectUnionAll();
+            return $"INSERT IGNORE INTO {sql.Substring(12)}";
+        }
+
         protected override long RawExecuteIdentity()
         {
             var sql = this.ToSql();

FreeSql/FreeSql.xml

@@ -1,5 +1,6 @@
 using FreeSql;
 using FreeSql.MySql.Curd;
+using System;
 
 public static partial class FreeSqlMySqlGlobalExtensions
 {
@@ -22,4 +23,17 @@ public static partial class FreeSqlMySqlGlobalExtensions
     /// <returns></returns>
     public static OnDuplicateKeyUpdate<T1> OnDuplicateKeyUpdate<T1>(this IInsert<T1> that) where T1 : class => new FreeSql.MySql.Curd.OnDuplicateKeyUpdate<T1>(that.InsertIdentity());
 
+    /// <summary>
+    /// MySql 特有的功能，Insert Ignore Into
+    /// </summary>
+    /// <typeparam name="T1"></typeparam>
+    /// <param name="that"></param>
+    /// <returns></returns>
+    public static IInsert<T1> MySqlIgnoreInto<T1>(this IInsert<T1> that) where T1 : class
+    {
+        var _mysqlInsert = that as MySqlInsert<T1>;
+        if (_mysqlInsert == null) throw new Exception("MySqlIgnoreInto 是 FreeSql.Provider.MySql/FreeSql.Provider.MySqlConnector 特有的功能");
+        _mysqlInsert.InternalIsIgnoreInto = true;
+        return that;
+    }
 }