C#/.NET 使用官方驱动操作MongoDB(一):插入、查询

时间:2022-09-04 13:07:25

概述

  想要在C#中使用MongoDB,首先得要有个MongoDB支持的C#版的驱动。

  C#版的驱动有很多,这里我们先用官方提供的 MongoDB.Driver(使用 Nuget 安装),当前版本为2.7.0。

  NuGet 会同时安装3个软件包,其中:

    MongoDB.Driver:顾名思义,驱动程序。(它几乎没有任何遗留代码,应该用于所有新项目)

    MongoDB.Bson:序列化、Json相关。(它是MongoDB.Driver.Core的依赖。它可以被自己使用)

    MongoDB.Driver.Core:驱动程序的核心和MongoDB.Driver的依赖。你可能不会直接使用这个包

  另外,在nuget上还有1个软件包:

    MongoDB.Driver.GridFS:GridFS包。更多文档可以在参考指南中找到。

  安装好驱动后,我们就可以开始撸代码了。

1.建立数据库连接

 // 使用连接字符串连接
var client = new MongoClient("mongodb://localhost:27017"); // 制定多个地址和端口,让程序自动选择一个进行连接。
var client = new MongoClient("mongodb://localhost:27017,localhost:27018,localhost:27019");

  该 MongoClient 实例实际上代表了一个到数据库的连接池; 即使有多个线程,也只需要一个 MongoClient 类的实例。

2.获取数据库

  我们可以使用client的GetDatabase方法获取数据库,即使数据库不存在,也没有关系,它会在首次使用数据库的时候进行自动创建。

var database = client.GetDatabase("foo");

3.获取数据集 Collection

  调用database的GetCollection<TDocument>方法可以获取数据集,其中如果数据是预先定义好的可以在<输入数据的类型>  ,如果是没有定义好的,可以使用BsonDocument类型,BsonDocument表示没有预定于的模式。

var collection = database.GetCollection<BsonDocument>("bar");

  此时,我们将获取到“foo”数据库中的“bar”集合,即使“bar”集合不存在也没有关系,同数据库一样,若数据集不存在,会自动创建该数据集。

4.插入数据

  获得了collection数据集后,就可以往数据集中插入数据了。

  我们可以使用BsonDocument来创建 document 文档对象。

 var document = new BsonDocument
{
{ "name", "MongoDB" },
{ "type", "Database" },
{ "count", },
{ "info", new BsonDocument
{
{ "x", },
{ "y", }
}}
};

  要将该document插入到collection中,我们可以使用InsertOne(同步插入)或InsertOneAsync(异步插入)方法。

InsertOne(同步插入):

collection.InsertOne(document);

InsertOneAsync(异步插入):

await collection.InsertOneAsync(document);

  如果想要插入多个数据,可以使用 InsertMany 或 InsertManyAsync 方法。

5.查询数据

  查询数据中,分三种进行叙述:

    第一种,获取第一条数据,

    第二种,获取所有数据,

    第三种,获取指定条件下的数据。

 5.1查找集合中的第一条数据

    查询集合中的第一条数据,需要用到的是FirstOrDefault方法或者FirstOrDefaultAsync方法,当有数据时,返回数据的第一条或者默认的那条,当没有数据时,返回null.

  同步查询并打印数据:

 var document = collection.Find(new BsonDocument()).FirstOrDefault();
Console.WriteLine(document.ToString());

  异步查询并打印数据:

var document = await collection.Find(new BsonDocument()).FirstOrDefaultAsync();
Console.WriteLine(document.ToString());

 5.2查询数数据集中的所有数据

    要查找数据集中的所有数据,可以使用ToList或者ToListAsync方法,需要注意的是,这种在预期返回数据较少的时候使用

  同步查询所有数据:

var documents = collection.Find(new BsonDocument()).ToList();

  异步查询所有数据:

var documents = await collection.Find(new BsonDocument()).ToListAsync();

  获取到了数据后,我们可以使用foreach的方法遍历得到每一个数据的值。

  如果返回的数据预期很大,建议采用以下异步的迭代的方法处理。

await collection.Find(new BsonDocument()).ForEachAsync(d => Console.WriteLine(d));

  如果实在要用同步的方法,那么可以使用ToEnumerable适配器方法。

 var cursor = collection.Find(new BsonDocument()).ToCursor();
foreach (var document in cursor.ToEnumerable())
{
Console.WriteLine(document);
}

 5.3用过滤器筛选获取单个文档

    可以通过创建一个过滤器来传递给Find方法来获取我们需要的的那个子集,然后用Fist方法,获取第一条数据。

  首先,创建一个筛选器:

var filter = Builders<BsonDocument>.Filter.Eq("i", );

  以上筛选器表示筛选i=71的数据。

  然后,通过同步或者异步的方法来查找符合该条件的数据:

var document = collection.Find(filter).First();
Console.WriteLine(document);

  或:

 var document = await collection.Find(filter).FirstAsync();
Console.WriteLine(document);

  因为我们在Find()后调用了Fist方法,所以获取的只是一条数据,如果不调用该函数,则获取的是一个数据集合。

 5.4使用过滤器获取一组文档

    如果我们要获取的是大于或者小于某值的数据集,那么就可以不用Fist()方法了。

  比如,获取i>50的数据,我们先设计一个这样的筛选器:

var filter = Builders<BsonDocument>.Filter.Gt("i", );

  然后,查找符合该条件的所有数据并输出。

  同步方法:

 var cursor = collection.Find(filter).ToCursor();
foreach (var document in cursor.ToEnumerable())
{
Console.WriteLine(document);
}

  异步方法:

await collection.Find(filter).ForEachAsync(document => Console.WriteLine(document));

  如果是50<i<=100,我们可以设计一个这样的筛选器

 var filterBuilder = Builders<BsonDocument>.Filter;
var filter = filterBuilder.Gt("i", ) & filterBuilder.Lte("i", );

1

C#/.NET 使用官方驱动操作MongoDB(一):插入、查询的更多相关文章

  1. &lbrack;转载&rsqb;在C&num;中使用官方驱动操作MongoDB

    在C#中使用官方驱动操作MongoDB 8.1)下载安装 想要在C#中使用MongoDB,首先得要有个MongoDB支持的C#版的驱动.C#版的驱动有很多种,如官方提供的,samus. 实现思路大都类 ...

  2. C&num;中使用官方驱动操作MongoDB

    想要在C#中使用MongoDB,首先得要有个MongoDB支持的C#版的驱动.C#版的驱动有很多种,如官方提供的,samus. 实现思路大都类似.这里我们先用官方提供的mongo-csharp-dri ...

  3. 在C&num;中使用官方驱动操作MongoDB

    MongoDB的官方驱动下载地址:https://github.com/mongodb/mongo-csharp-driver/releases 目前最新的版本是2.10,支持.NET 4.5以上.由 ...

  4. 使用MongoDB C&num;官方驱动操作MongoDB

    想要在C#中使用MongoDB,首先得要有个MongoDB支持的C#版的驱动.C#版的驱动有很多种,如官方提供的,samus. 实现思路大都类似.这里我们先用官方提供的mongo-csharp-dri ...

  5. 在C&num;中使用官方驱动操作MongoDB ---转载

    http://blog.csdn.net/dannywj1371/article/details/7440916

  6. MongoDB学习--&gt&semi;命令行增删改查&amp&semi;JAVA驱动操作Mongodb

    MongoDB 是一个基于分布式文件存储的数据库. 由 C++ 语言编写.旨在为 WEB 应用提供可扩展的高性能数据存储解决方案. MongoDB 是一个介于关系数据库和非关系数据库之间的产品,是非关 ...

  7. python操作mongodb根据&lowbar;id查询数据的实现方法

    python操作mongodb根据_id查询数据的实现方法   python操作mongodb根据_id查询数据的实现方法,实例分析了Python根据pymongo不同版本操作ObjectId的技巧, ...

  8. MongoDB基础入门003--使用官方驱动操作mongo&comma;C&num;

    本篇先简单介绍一下,使用官方驱动来操作MongoDB.至于MongoDB原生的增删改查语句,且等以后再慢慢学习. 一.操作MongoDB的驱动主要有两个 1.官方驱动:https://github.c ...

  9. MongoDB学习比较-07 C&num;驱动操作MongoDB

    下载驱动 驱动的下载有两种方式:一种是在C#项目中通过NuGet进行安装,另一种是通过下面的链接:https://github.com/mongodb/mongo-csharp-driver/rele ...

随机推荐

  1. C&num; IDisposable接口

    public class MyClass : IDisposable { public int a; public MyClass() { //构造 } public void Dispose() { ...

  2. WordPress &OpenCurlyQuote;crypt&lowbar;private&lpar;&rpar;’方法远程拒绝服务漏洞

    漏洞名称: WordPress ‘crypt_private()’方法远程拒绝服务漏洞 CNNVD编号: CNNVD-201306-250 发布时间: 2013-06-20 更新时间: 2013-06 ...

  3. python中的多线程和多进程编程

    注意:多线程和多线程编程是不同的!!! 第一点:一个进程相当于一个要执行的程序,它会开启一个主线程,多线程的话就会再开启多个子线程:而多进程的话就是一个进程同时在多个核上进行: 第二点:多线程是一种并 ...

  4. OpenSSL MD5 API

    #include <stdlib.h> #define _GNU_SOURCE /* for getline API */ #include <stdio.h> /* Open ...

  5. 绝对路径的表示方式为什么是&quot&semi;&sol;usr&quot&semi;而不是&quot&semi;&sol;&sol;usr&quot&semi;

    今天闲逛贴吧,竟然看到有个人问绝对路径的表示方式为什么不是//usr/local而是/usr/local.原文: 我想99%的人都没想过这个问题,都理所当然的认为:它不就是根"/" ...

  6. Java位运算符浅析

    在学习源码中,发现有大量使用位运算符,这样做的目的是为了节约内存开销和加快计算效率. 位运算符,这个”位”代表这什么? 位:二进制位简称“位”,是二进制记数系统中表示小于2的整数的符号,一般用1或 0 ...

  7. Java 几种showMessageDialog的表示

    最近在做swing程序中遇到使用消息提示框的,JOptionPane类其中封装了很多的方法. 很方便的,于是就简单的整理了一下. 1.1 showMessageDialog 显示一个带有OK 按钮的模 ...

  8. 将搬家至CSDN

    emmm,感觉没利用好博客,自己也弄了一个github上面的hexo博客https://clarkkun.github.io/,但是死活传不上去内容,尴尬 ̄□ ̄||,三个博客齐头并进吧

  9. JQuery中2个等号与3个等号的区别

    首先,== equality 等同,=== identity 恒等.==, 两边值类型不同的时候,要先进行类型转换,再比较.===,不做类型转换,类型不同的一定不等. 下面分别说明:先说 ===,这个 ...

  10. java实现文件的断点续传的下载

    java的断点续传是基于之前java文件下载基础上的功能拓展 首先设置一个以线程ID为名的下载进度文件, 每一次下载的进度会保存在这个文件中,下一次下载的时候,会根据进度文件里面的内容来判断下载的进度 ...