SqlSugar/Src/Asp.Net/SqlServerTest/Demo/Demo2_Updateable.cs

using SqlSugar;
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace OrmTest
{
    public class Demo2_Updateable
    {
        public static void Init()
        {
            Console.WriteLine("");
            Console.WriteLine("#### Updateable Start ####");

            SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
            {
                DbType = DbType.SqlServer,
                ConnectionString = Config.ConnectionString,
                InitKeyType = InitKeyType.Attribute,
                IsAutoCloseConnection = true,
                AopEvents = new AopEvents
                {
                    OnLogExecuting = (sql, p) =>
                    {
                        Console.WriteLine(sql);
                        Console.WriteLine(string.Join(",", p?.Select(it => it.ParameterName + ":" + it.Value)));
                    }
                }
            });



            /*** 1.entity or List ***/

            var updateObj = new Order() { Id = 1, Name = "order1" };
            var updateObjs = new List<Order> {
                 new Order() { Id = 11, Name = "order11" },
                 new Order() { Id = 12, Name = "order12" }
            };

            //update all columns by primary key
            var result = db.Updateable(updateObj).ExecuteCommand();//update single
            var result2 = db.Updateable(updateObjs).ExecuteCommand();//update List<Class>

            //Ignore  Name and Price
            var result3 = db.Updateable(updateObj).IgnoreColumns(it => new { it.CreateTime, it.Price }).ExecuteCommand();

            //only update Name and CreateTime 
            var result4 = db.Updateable(updateObj).UpdateColumns(it => new { it.Name, it.CreateTime }).ExecuteCommand();

            //If there is no primary key
            var result5 = db.Updateable(updateObj).WhereColumns(it => new { it.Id }).ExecuteCommand();//update single by id
            var result6 = db.Updateable(updateObjs).WhereColumns(it => new { it.Id }).ExecuteCommand();//update List<Class> by id

            //Re set value
            var result66 = db.Updateable(new List<Order> { updateObj }).ReSetValue(it => it.Id = 112).IgnoreColumns(it => new { it.CreateTime, it.Price }).ExecuteCommand();

            var result67 =
              db.Updateable(updateObjs)
              .PublicSetColumns(it => it.Price, it => it.Price + 1)
              .ExecuteCommand();

            var result68 =
             db.Updateable(updateObjs.First())
             .PublicSetColumns(it => it.Price, it => it.Price + 1)
             .ExecuteCommand();

            var list = db.Queryable<Order>().OrderBy(it=>it.Id).Take(2).ToList();
            if (list.Count >= 2)
            {
                list[0].Price = 10;
                list[1].Price = 2;
                var result69 =
                db.Updateable(list)
                .PublicSetColumns(it => it.Price, "+")
                .ExecuteCommand();
            }

            //Update by track
            Console.WriteLine(" Tracking 1:");
            db.Tracking(updateObj);
            //Update set name
            updateObj.Name = "a1" + Guid.NewGuid();
            db.Updateable(updateObj).ExecuteCommand();
            db.TempItems = null;

            Console.WriteLine(" Tracking 2:");
            db.Tracking(updateObj);
            //No Update
            db.Updateable(updateObj).ExecuteCommand();
            db.TempItems = null;

            /*** 2.by expression ***/

            //update  name,createtime
            var result7 = db.Updateable<Order>(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand();
            var result71 = db.Updateable<Order>().SetColumns(it => new Order() { Name = "a", CreateTime = DateTime.Now }).Where(it => it.Id == 11).ExecuteCommand();
            //only update name
            var result8 = db.Updateable<Order>(it => it.Name == "Name" + "1").Where(it => it.Id == 1).ExecuteCommand();
            var result81 = db.Updateable<Order>().SetColumns(it => it.Name == "Name" + "1").Where(it => it.Id == 1).ExecuteCommand();
            var array = new string[] { "1" };
            var result82 = db.Updateable<Order>().SetColumns(it => it.Name == array[0]).Where(it => it.Id == 1).ExecuteCommand();
            var result61 = db.Updateable<Order>()
                      .InnerJoin<Custom>((x, y) => x.CustomId == y.Id)
                      .SetColumns((x, y) => new Order() { Name = y.Name, Price = y.Id })
                      .Where((x, y) => x.Id == 1)
                      .ExecuteCommand();

            /*** 3.by Dictionary ***/
            var dt = new Dictionary<string, object>();
            dt.Add("id", 1);
            dt.Add("name", "abc");
            dt.Add("createTime", DateTime.Now);
            var dtList = new List<Dictionary<string, object>>();
            dtList.Add(dt);

            var t66 = db.Updateable(dt).AS("[Order]").WhereColumns("id").ExecuteCommand();
            var t666 = db.Updateable(dtList).AS("[Order]").WhereColumns("id").ExecuteCommand();



            /*** 4.Other instructions ***/

            var caseValue = "1";
            //Do not update NULL columns
            db.Updateable(updateObj).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand();

            //if 1 update name else if 2 update name,createtime
            db.Updateable(updateObj)
                            .UpdateColumnsIF(caseValue == "1", it => new { it.Name })
                            .UpdateColumnsIF(caseValue == "2", it => new { it.Name, it.CreateTime })
                            .ExecuteCommand();
            //Use Lock
            db.Updateable(updateObj).With(SqlWith.UpdLock).ExecuteCommand();

            //Where Sql
            //db.Updateable(updateObj).Where("id=@x", new { x = "1" }).ExecuteCommand();


            var levelCode = "123213123131321";
            db.Updateable<Order>(a => a.Name == "a")
               .Where(a => SqlFunc.StartsWith(a.Name, levelCode))
               .AddQueue();
            db.SaveQueues();

            var dataTable = db.Queryable<Order>().Select("id,name,1 as price").Take(2).ToDataTable();
            db.Fastest<Order>().BulkUpdate("Order", dataTable,new string[] {"id" },new string[] {"name" });
           
            db.Updateable<object>()
             .AS("[Order]")
             .SetColumns("name", 1)
             .Where("id=1").ExecuteCommand();

            db.Updateable<object>()
              .AS("[Order]")
              .SetColumns("name", 1)
              .SetColumns("price", 1)
              .Where("id=1").ExecuteCommand();

            db.Updateable<object>()
            .AS("[Order]")
            .SetColumns(it => SqlFunc.MappingColumn<string>("name"), it => SqlFunc.MappingColumn<string>("(case when id>0 then name else '' end) "))
            .SetColumns("price", 1)
            .Where("id=1").ExecuteCommand();

            db.Updateable<object>()
            .AS("[Order]")
            .SetColumns(it => SqlFunc.MappingColumn<string>("name"), it => SqlFunc.MappingColumn<string>("(case when id>0 then name else '' end) "))
            //.SetColumns("price", 1)
            .Where("id=1").ExecuteCommand();

            db.Updateable<Custom>()
             .AS("order")
             .SetColumns(it=>it.Name=="a")
             .Where(it => SqlFunc.Subqueryable<Custom>().AS("order").Where(s => s.Id == it.Id).NotAny()).ExecuteCommand();


            db.Updateable<Order>()
             .AS("order")
             .SetColumns(it => it.Price == 1+SqlFunc.Subqueryable<Custom>().AS("order").Where(s => s.Id == it.Id).Select(s=>s.Id))
             .Where(it => 1==2).ExecuteCommand();

            db.Updateable<Order>() 
             .SetColumns(it => it.Price == 1 + SqlFunc.Subqueryable<Custom>().Where(s => s.Id == it.Id).Select(s => s.Id))
             .Where(it => 1 == 2).ExecuteCommand();

            object o = db.Queryable<Order>().First();
            db.UpdateableByObject(o).ExecuteCommandAsync().GetAwaiter().GetResult();
            object os = db.Queryable<Order>().Take(2).ToList();
            db.UpdateableByObject(os).ExecuteCommand();
            db.UpdateableByObject(os).IgnoreColumns("name","price").ExecuteCommand();
            Console.WriteLine("#### Updateable End ####");
        }

    }
}