MySoft.Data從入門到精通系列(五)【數據更新】

前一章講了如何利用MySoft.Data進行數據的插入，利用DbSession可以實現各種數據增、刪、改、查等各種復雜的處理，本章著重講解一下數據的更新：

數據更新在日常開發中占據中非常重要的地位，盡次於查詢。下面就講解一下如何利用DbSession來進行數據的更新。

繼續引用前面的DbSession配置，如下：

/// <summary>
    /// 數據庫訪問類
    /// </summary>
    public static class DataAccess
    {
        /// <summary>
        /// 通過配置節來實例化DbSession
        /// </summary>
        public static readonly DbSession DefaultSession = new DbSession("DataExample");
        /// <summary>
        /// 通過自定義類來實例化DbSession
        /// </summary>
        public static readonly DataExample ExampleSession = new DataExample();
    }
    /// <summary>
    /// DataExample會話類
    /// </summary>
    public class DataExample : DbSession
    {
        public DataExample()
            : base("DataExample")
        {
#if DEBUG
            this.RegisterSqlLogger(log =>
                {
                    System.IO.File.WriteAllText("c:\\log.txt", log);
                });
#endif
        }
    }

下面還是利用DataAccess.ExampleSession來進行操作：

一、強類型的數據更新

下面的操作以Products實體為例進行操作：

1、單個實體數據更新

//實例化一個Products對象
Products product = new Products()
{
   ProductID = 1,
   ProductName = "測試產品1"
};
//更新單個對象
product.Attach();
DataAccess.ExampleSession.Save(product);

2、批量實體數據更新

//實例化一組Products對象
List<Products> list = new List<Products>();
for (int index = 0; index < 10; index++)
{
  list.Add(new Products()
  {
     ProductID = index,
     ProductName = "測試產品" + index
  });
}
//批量更新數據
DbBatch batch = DataAccess.ExampleSession.BeginBatch(10);
list.ForEach(item =>
{
   item.Attach();
    batch.Save(item);
});
batch.Process();

3、帶事務單個實體更新(MySoft.Data內置實現DbTrans)

//實例化一個Products對象
Products product = new Products()
{
  ProductID = 1,
  ProductName = "測試產品1"
};
//使用事務進行數據插入
using (DbTrans trans = DataAccess.ExampleSession.BeginTrans())
{
  try
  {
    product.Attach();
    trans.Save(product);
    trans.Commit();
  }
  catch
  {
    trans.Rollback();
  }
}

4、帶事務批量實體更新(MySoft.Data內置實現DbTrans)

//實例化一組Products對象
            List<Products> list = new List<Products>();
            for (int index = 0; index < 10; index++)
            {
                list.Add(new Products()
                {
                    ProductID = index,
                    ProductName = "測試產品" + index
                });
            }
            //使用事務進行批量數據插入
            using (DbTrans trans = DataAccess.ExampleSession.BeginTrans())
            {
                try
                {
                    DbBatch batch = trans.BeginBatch(10);
                    list.ForEach(item =>
                    {
                        item.Attach();
                        batch.Save(item);
                    });
                    batch.Process();
                    trans.Commit();
                }
                catch
                {
                    trans.Rollback();
                }
            }

5、創建外部數據庫鏈接方式更新

//實例化一個Products對象
Products product = new Products()
{
   ProductID = 1,
   ProductName = "測試產品1"
};
using (System.Data.Common.DbConnection conn = DataAccess.ExampleSession.CreateConnection())
{
   //更新單個對象
   product.Attach();
   DataAccess.ExampleSession.SetConnection(conn).Save(product);
}

注：批量插入可以采用同樣的方法處理！

6、創建外部數據庫事務方式更新

//實例化一個Products對象
            Products product = new Products()
            {
                ProductID = 1,
                ProductName = "測試產品1"
            };
            using (System.Data.Common.DbTransaction trans = DataAccess.ExampleSession.BeginTransaction())
            {
                try
                {
                    //更新單個對象
                    product.Attach();
                    DataAccess.ExampleSession.SetTransaction(trans).Save(product);
                    trans.Commit();
                }
                catch
                {
                    trans.Rollback();
                }
            }

注：批量更新可以采用同樣的方法處理！

當實體存在時更新，否則插入的處理方式：

Products product = new Products()
{
   ProductID = 1,
   ProductName = "測試產品"
};
DataAccess.ExampleSession.InsertOrUpdate(product);

以上操作相應的都可以使用事務來處理

二、UpdateCreator數據更新

通過更新創建器同樣也可以達到上面的效果，也可以進行泛型方式進行數據插入，一般情況下創建器用於沒有建立對象實體時直接對表和字段的操作。

1、通過實體更新實體

UpdateCreator uc = UpdateCreator.NewCreator()
.From<Products>()
.SetEntity<Products>(product, true);
DataAccess.ExampleSession.Excute(uc);

2、通過字符串表與字段更新數據

UpdateCreator uc = UpdateCreator.NewCreator()
.From("Products")
.AddUpdate("ProductName", "測試產品")
.AddWhere("ProductID", 1);
DataAccess.ExampleSession.Excute(uc);

三、用戶自定義更新方式

DataAccess.ExampleSession.Update<Products>(Products._.ProductName, "測試產品", Products._.ProductID == 1);

條件可以多個組件產生，如下：

WhereClip where = Where.All;

if(條件一) where = where && Products._.ProductID == 1;

if(條件二) where = where && Products._.ProductID == 2;

//ProductID為1和2(相當於In操作)

if(條件三) where = where || Products._.ProductID.In(1,2);

//ProductID不為1和2(相當於Not In操作)

if(條件四) where = where || !Products._.ProductID.In(1,2);

……

DataAccess.ExampleSession.Update<Products>(Products._.ProductName, "測試產品", where);

以上通過創建器的方式同樣可以用事務來操作 trans.Excute(uc);

這裡只是簡單的介紹了一下，還有更多的功能需要用戶使用時才能體會到。

數據的更新操作就講解到這裡，下一章將講解數據的刪除(Delete)操作