c# mongodb 增删改查 实例源码下载

【实例简介】实例基本实现了 增删改查询功能，mongodb c#驱动程序 用的是官方版本(从nuget引用的)

安装Mongo数据库：
　　在发布本文的时间官方提供的最新版本是：1.6.5 ，如果不做特殊声明，本教程所用的版本将会是这个版本。
第一步：下载安装包：官方下载地址 ←单击此处,如果是win系统，注意是64位还是32位版本的，请选择正确的版本。
第二步：新建目录“D:\MongoDB”，解压下载到的安装包，找到bin目录下面全部.exe文件，拷贝到刚创建的目录下。
第三步：在“D:\MongoDB”目录下新建“data”文件夹，它将会作为数据存放的根文件夹。
配置Mongo服务端：
　　打开CMD窗口，按照如下方式输入命令：
　　> d:
　　> cd D:\MongoDB
　　> mongod --dbpath D:\MongoDB\data
　　配置成功后会看到如下画面：

在浏览器输入：http://localhost:27017/，可以看到如下提示：
It looks like you are trying to access MongoDB over HTTP on the native driver port.

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;

namespace MongoDBWinDemo
{




    public partial class Form1 : Form
    {

        public Form1()
        {
            InitializeComponent();
        }

        public class Entity
        {
            public ObjectId Id { get; set; }
            public string Name { get; set; }
        }
        public MongoCollection<T> GetCollection<T>()
        {

            //var connectionString = "mongodb://localhost";
            //var client = new MongoClient(connectionString);
            //var server = client.GetServer();
            //var database = server.GetDatabase("test");
            //var collection = database.GetCollection<Entity>("entities");

            var connectionString = "mongodb://localhost";
            var client = new MongoClient(connectionString);
            var server = client.GetServer();
            var database = server.GetDatabase("test");
            var collection = database.GetCollection<T>("entities");
            return collection;
        }




        private void btnAdd_Click(object sender, EventArgs e)
        {
            var collection = this.GetCollection<Entity>();
            var entity = new Entity { Name = "Tom" };
            collection.Insert(entity);
            var id = entity.Id;
            MessageBox.Show(id.ToString());
        }

        private void btnDel_Click(object sender, EventArgs e)
        {
            var collection = this.GetCollection<Entity>();
            var name = "Tom";
            var query = Query<Entity>.EQ(ex => ex.Name, name);
            var entity = collection.FindOne(query);
            collection.Remove(query);
            MessageBox.Show("result:delSucess");
        }

        private void btnUpdate_Click(object sender, EventArgs e)
        {
            var collection = this.GetCollection<Entity>();
            var name = "Tom";
            var query = Query<Entity>.EQ(ex => ex.Name, name);
            var update = Update<Entity>.Set(ex => ex.Name, "Harry");
            collection.Update(query, update);
            MessageBox.Show("result:toHarry" );
        }

        private void btnQuery_Click(object sender, EventArgs e)
        {
            var collection = this.GetCollection<Entity>();
            var name = "Tom";
            var query = Query<Entity>.EQ(ex => ex.Name, name);
            var entity = collection.FindOne(query);
            if (entity != null)
                MessageBox.Show("result:"   entity.Name   "("   entity.Id.ToString()   ")");
            else MessageBox.Show("mongodb>没找到数据");
        }


    }
}