using?System;
using?System.Collections.Generic;
using?System.Linq.expressions;
using?System.Threading.Tasks;
using?framework.MongoDB.Extension;
using?framework.MongoDB.Model;
using?frameWork.Extension;
using?frameWork.MongoDB.MongoDbConfig;
using?MongoDB.Bson.Serialization.Conventions;
using?MongoDB.Driver;

namespace?frameWork.MongoDB
{
????#region?MongoDb操作封裝
????///?

????///?MongoDb操作封裝
????///?

????public?class?MongoDbService
????{
????????#region?初始化

????????private?readonly?string?_connString?=?“MongoDb“.ValueOfAppSetting（）;
????????private?readonly?MongoClient?_mongoClient;

????????public?MongoDbService（）
????????{
????????????ConventionRegistry.Register（“IgnoreExtraElements“?new?ConventionPack?{?new?IgnoreExtraElementsConvention（true）?}?type?=>?true）;
????????????_mongoClient?=?new?MongoClient（_connString）;
????????}

????????#endregion

????????#region?增

????????#region?增（同步）

????????///?

????????///?新增數據
????????///?

????????///?
????????///?se“>庫
????????///?集合（表）
????????///?實體（文檔）
????????public?void?Add（string?database?string?collection?T?entity）?where?T?:?MongoEntity
????????{
????????????AddAsync（database?collection?entity）.Wait（）;
????????}

????????///?

????????///?新增數據
????????///?

????????///?
????????///?實體（文檔）
????????public?void?Add（T?entity）?where?T?:?MongoEntity
????????{
????????????AddAsync（entity）.Wait（）;
????????}

????????#endregion

????????#region?增（異步）

????????///?

????????///?增（異步）
????????///?

????????///?
????????///?se“>庫
????????///?集合（表）
????????///?實體（文檔）
????????///?
????????public?async?Task?AddAsync（string?database?string?collection?T?entity）?where?T?:?MongoEntity
????????{
????????????var?db?=?_mongoClient.GetDatabase（database）;
????????????var?coll?=?db.GetCollection（collection）;
????????????await?coll.InsertOneAsync（entity）.ConfigureAwait（false）;
????????}

????????///?

????????///?增（異步）
????????///?

????????///?
????????///?實體（文檔）
????????///?
????????public?Task?AddAsync（T?entity）?where?T?:?MongoEntity
????????{
????????????var?mongoAttribute?=?typeof（T）.GetMongoAttribute（）;
????????????if?（mongoAttribute.IsNull（））
????????????????throw?new?ArgumentException（“MongoAttribute不能為空“）;

????????????return?AddAsync（mongoAttribute.Database?mongoAttribute.Collection?entity）;
????????}

????????#endregion

????????#endregion

????????#region?批量增

????????#region?批量增（異步）

????????///?

????????///?批量增（異步）
????????///?

????????///?
????????///?