.Net下MoongoDB的简单调用

显示全部楼层 · 2019-10-17 09:44:19

1、安装.Net 驱动:Install-Package MongoDB.Driver

2、数据插入，链接数据库

复制代码

MongoClient client = new MongoClient("mongodb://127.0.0.1");
IMongoDatabase database = client.GetDatabase("TestDb");//相称于数据库
IMongoCollection<Person> collection = database.GetCollection<Person>("Persons");//大抵相称于表
Person p1 = new Person()
{
Id = 2,
Name = "test1",
Age = 29,
Height=130
};
collection.InsertOne(p1);//单条插入也支持异步方法，反面建议都用异步的!风俗成天然!

复制代码

[/code]
<p>回到客户端工具革新一下，就能看到新插入的数据，MongoDB 会主动创建“数据库” 以及 Collection(约便是“表”)。MongoDB 默认用 id 做主键，因此不用显式指定 id 是主键。</p>
<p><div align="center"> </div></p>
<p>MongoDB 中没有内置“自增字段”，可以把 Id 声明为 ObjectId 类型(using MongoDB.Bson) 这样插入以后就主动给字段赋值。</p>
[code] //多条插入
IMongoCollection<ObjectPerson> collection1 = database.GetCollection<ObjectPerson>("ObjectPersons");//大抵相称于表
List<ObjectPerson> persons = new List<ObjectPerson>() { new ObjectPerson() { Name = "test2", Age = 30, Height = 135 }, new ObjectPerson() { Name = "test3", Age = 31, Height = 140 } };
collection1.InsertMany(persons);//多条插入

复制代码

MongoDB 是用 json 生存的，因此也可以直接以 json 格式插入，用 BsonDocument 来代表:

IMongoCollection<BsonDocument> dogs = database.GetCollection<BsonDocument>("Dogs");
string jsondata = "{id:8999,Age:81,Name:'japan',gender:true}";
BsonDocument p2 = BsonDocument.Parse(jsondata);
dogs.InsertOne(p2);

复制代码

还可以插入有嵌套关系的对象，好比弟子和老师，注意不会有表间关系，都是存到一个聚集中，注意和关系库不一样。

IMongoCollection<Person> collection = database.GetCollection<Person>("Persons");//大抵相称于表
Person p1 = new Person()
{
Id = 2,
Name = "test1",
Age = 29,
Height=130,
t1=new TestPerson() { Name="222"}
};
collection.InsertOne(p1);//单条插入

复制代码

3、MongoDB查询

IMongoCollection<Person> collection = database.GetCollection<Person>("Persons");
var filter = Builders<Person>.Filter.Gt(p => p.Age,5);
var filter1 = Builders<Person>.Filter.And(Builders<Person>.Filter.Gt(p => p.Age, 5), Builders<Person>.Filter.Eq(p => p.Id, 1));// And 并且还有or方法
var filter2 = Builders<Person>.Filter.Where(p => p.Age > 5 && p.Id == 1);//和上面的写法是一样的但是，建议用Where方法
//普通查询
var result= collection.Find(filter).ToList();
foreach (var item in result)
{
Console.WriteLine(item.Age + item.Name);
}

复制代码

除了 Gt，还有 Gte、In、Lt、Lte、Ne、Nin、Near、NearSphere、Or、Where、And、Not。固然最常用的照旧 Where 利用:

异步查询

//异步查询
using (IAsyncCursor<Person> personsCursor = await collection.FindAsync<Person>(filter)) {
while (personsCursor.MoveNextAsync().Result)//获取下一组数据，相称于是否有指针，MongoDB其实是返回一个组，不像sql每次是一次次取
{
IEnumerable<Person> items = personsCursor.Current;//返回当前组的数据
foreach (var item in items)
{
Console.WriteLine(item.Age + item.Name);
}
}
//假如数据量不大,可以直接tolist
var results = personsCursor.ToList();
}

复制代码

为什么 FindAsync 不直接返回聚集，而是要 MoveNext 之后返回一个聚集呢?因为返回的数据量可能很大，因此 MongoDB 是分批下载，下载一批之后执行 GET_More 利用返回下一批。可以通过 FindOptions 参数的 BatchSize 设置每一批的巨细。

假如确认返回的数据量不大，可以 var ps = await personsCursor.ToListAsync()(或者 ToEnumerable()等)一下子返回全部数据。还有 Any、First、FirstOrDefault 等以及异步利用。必要注意 MongoDB 中查询区分巨细写。

4、分页查询

//分页
FindOptions<Person, Person> findop = new FindOptions<Person, Person>();
findop.Limit = 3;//取最多几条
findop.Skip = 2;//跳过几条
findop.Sort = Builders<Person>.Sort.Ascending(p => p.Age).Ascending(p => p.Name);//排序
using (var cursor = collection.FindAsync(filter, findop).Result)
{
var items = cursor.ToList();
foreach (var item in items)
{
Console.WriteLine(item.Age + item.Name);
}
}

复制代码

指定排序规则 findop.Sort = Builders.Sort.Ascending(p => p.Age).Ascending(p => p.Name);

5、Json格式取法

//json格式取法
IMongoCollection<BsonDocument> bsonDoc = database.GetCollection<BsonDocument>("Persons");
var filter4 = Builders<BsonDocument>.Filter.Gt("Age", 5);
using (var persons=await bsonDoc.FindAsync(filter4)) <br />{
foreach (var item in await persons.ToListAsync())
{
Console.WriteLine(item.GetValue("Name").AsString);
}
}

复制代码

6、Update更新利用

IMongoCollection<Person> upPersons = database.GetCollection<Person>("Persons");
var upFilter = Builders<Person>.Filter.Where(p => p.Age>20);//筛选条件
var update = Builders<Person>.Update.Set(c => c.Name, "test2");//更新条件，将Name更新成test2
upPersons.UpdateMany(filter, update);

复制代码

7、Delete删除利用