mongodb for Linq(T)操作和Json操作BsonDocument

using MongoDB.Driver;
using MongoDB.Driver.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;

namespace Core.DBContext
{
public class MongoDBbase<T> where T : class, new()
{
MongoClient client;
IMongoDatabase database;
public IMongoCollection<T> collection;
public MongoDBbase()
{
//var client = new MongoClient("mongodb://host:27017,host2:27017/?replicaSet=rs0");
client = new MongoClient("mongodb://39.96.34.12:27017");
database = client.GetDatabase("test");
Type type = typeof(T);
collection = database.GetCollection<T>(type.Name.ToLower());
}

public void traTest()
{
var session = client.StartSession();
try
{
var database = session.Client.GetDatabase("test");
session.StartTransaction(new TransactionOptions(
readConcern: ReadConcern.Snapshot,
writeConcern: WriteConcern.WMajority));
//IMongoCollection<Userinfo> collection = database.GetCollection<Userinfo>("userinfo");
// 切记，使用事务的时候，记得要给需要事务的指令里面吧当前会话的对象传入进去
// 因为事务的完整性是通过sessionid来做的
//collection.InsertOne(session, daqiao);
//throw new Exception("取消事务");
session.CommitTransaction();
}
catch (Exception ex)
{
//回滚
session.AbortTransaction();
}

}
public void DropDatabase()
{
client.DropDatabase("test");
}
public void InsertOne(T model)
{
collection.InsertOne(model);
}
public void InsertMany(params T[] modes)
{
collection.InsertMany(modes);
}
public IMongoQueryable<T> Select()
{
return collection.AsQueryable<T>();
}
public IMongoQueryable<T> Select(int pageIndex, int pageSize)
{
return collection.AsQueryable<T>().Skip(pageSize * (pageIndex - 1)).Take(pageSize);
}
public IMongoQueryable<T> Select(Expression<Func<T, bool>> predicate, Expression<Func<T, object>> keySelector, int pageIndex, int pageSize)
{
return collection.AsQueryable<T>().Where(predicate).OrderBy(keySelector).Skip(pageSize * (pageIndex - 1)).Take(pageSize);
}
public void UpdateMany(Expression<Func<T, bool>> filter, UpdateDefinition<T> update)
{
collection.UpdateMany(filter, update);
}

public void UpdateOne(Expression<Func<T, bool>> filter, T update)
{
collection.ReplaceOne(filter, update);
}

public void DeleteMany(Expression<Func<T, bool>> filter)
{
collection.DeleteMany(filter);
}

}
}

-----------------------------json操作  BsonDocument--------------------------

using MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Collections.Generic;
using System.Text;

namespace Zhaoxi.MongodbApp
{
public class JsonOperation
{
public static void Show()
{
var client = new MongoClient("mongodb://192.168.1.14:27017");
var database = client.GetDatabase("test");
var document = BsonDocument.Parse("{ a: 1, b: [{ c: 1 }],c: 'ff'}");
var document1 = BsonDocument.Parse("{ a: 6666}");
database.GetCollection<BsonDocument>("userinfo").InsertOne(document1);

database.GetCollection<BsonDocument>("userinfo").InsertOne(document);
}
}
}