最近在弄有关MongoDB存储查询订单的功能,再此做个记录
这里使用的是 MongoDB.Driver
1.连接数据库:
var strconn = "mongodb://帐号:密码@数据库链接:端口";
var mongoUrl = MongoUrl.Create(strconn);
var MongoClient client = new MongoClient(mongoUrl);
var db = client.GetDatabase("dbName");//获取数据库
var table = db.GetCollection<T>("tableName");//获取集合(泛型)
2.先介绍几个东西
Builders<Publisher_Order_Dto_MongoDB>.Filter:筛选数据用到,查询或者更新数据等会用到,有很多 操作符
Builders<Publisher_Order_Dto_MongoDB>.Update:更新数据用到
Builders<Publisher_Order_Dto_MongoDB>.Projection:指定查询字段或者不要查询某个字段时用到,这里主要用于过滤掉 _id
3.插入数据
table.InsertMany(List);//批量插入数据
table.InsertOne(item);//插入一条
4.更新数据
A.批量查询已有的数据再更新(目前只找到这种方式来更新)
var filter = Builders<T>.Filter;//查询条件用到
var Update = Builders<T>.Update;//更新数据用到
var Id_List = List.Select(x => x.trade_id).ToList();//订单id
var where = filter.And(filter.Eq("userId", userId), filter.In("trade_id",Id_List));//查询(这里 类似 select * from table where userId=userId and trade_id in(xxx,xxx,xxx) )
//指定查询字段
var fieldList = new List<ProjectionDefinition<T>>();
fieldList.Add(Builders<T>.Projection.Exclude("_id"));//不包含_id
var projection = Builders<T>.Projection.Combine(fieldList);
//更新操作-先查询出已有的数据,再循环更新
var data_update = table.Find(where).Project<T>(projection);//插入设置的条件进行查询
data_update.ForEachAsync((item) =>
{
var updateItem = List.Where(x => x.trade_id == item.trade_id).FirstOrDefault();
if (updateItem != null)
{
//更新操作
var query = filter.And(filter.Eq("userId", userId), filter.Eq("trade_id", item.trade_id));
var updateSet = Update
.Set("tk_status", updateItem.tk_status)//设置要更新的字段和数据
.Set("tk_status_name", updateItem.tk_status_name)
.Set("tk_earning_time", updateItem.tk_earning_time);
table.UpdateOne(query, updateSet);//更新一条数据
}
});
B.直接按条件来批量更新数据
table.UpdateMany(query, updateSet);//批量
5.删除数据
var filter = Builders<T>.Filter;//查询条件用到:可以根据各个操作符组合
table.DeleteMany(filter);//批量
table.DeleteOne(filter);//一条
6.查询数据
7.索引