MongoDB八天课程之：第八天驱动实践

作者：ys2011一号_139 | 来源：互联网 | 2014-05-28 16:53

作为系列的最后一篇，得要说说C#驱动对mongodb的操作，目前驱动有两种：官方驱动和samus驱动，不过我个人还是喜欢后者，
因为提供了丰富的linq操作，相当方便。
官方驱动：https://github.com/mongodb/mongo-csharp-driver/downloads。下载后，还提供了一个酷似msdn的帮助文档。
samus驱动：https://github.com/samus/mongodb-csharp/downloads。
下面就具体看看samus驱动，https://github.com/samus/mongodb-csharp/blob/master/examples/Simple/Main.cs上面提供了
一个简单的demo，大体上看看我们就知道怎么玩了。
一：实践
1：我们建立一个Person实体，MongoAlias特性表示取别名，这里的ID值将会覆盖掉数据库自动生成的_id。
#region 数据实体
///

/// 数据实体
///

     public class Person
     {
         [MongoAlias("_id")]
         public string ID { get; set; }

         public string Name { get; set; }

         public int Age { get; set; }

         public DateTime CreateTime { get; set; }
     }
     #endregion
2：初始化一些变量
         string connectionString = string.Empty;

         string databaseName = string.Empty;

         string collectionName = string.Empty;

         static MongodbHelper mongodb;

         #region 初始化操作
///

/// 初始化操作
///

         public MongodbHelper()
         {
             connectionString = "Server=127.0.0.1:2222";
             databaseName = "shopex";
             collectionName = "person";
         }
         #endregion
3：为了方便T的继承类使用linq功能，我们还需要映射一下。
#region 实现linq查询的映射配置
         ///

/// 实现linq查询的映射配置
///

         public MongoConfiguration configuration
         {
             get
             {
                 var config = new MongoConfigurationBuilder();

                 config.Mapping(mapping =>
                 {
                     mapping.DefaultProfile(profile =>
                     {
                         profile.SubClassesAre(t => t.IsSubclassOf(typeof(T)));
                     });
                     mapping.Map();
                     mapping.Map();
                 });

                 config.ConnectionString(connectionString);

                 return config.BuildConfiguration();
             }
         }
         #endregion
4：下面是一些基本的CURD的代码，跟写EF代码很类似，写起来好舒服。
     #region 插入操作
         ///

/// 插入操作
///

///
///
         public void Insert(T t)
         {
             using (Mongo mongo = new Mongo(configuration))
             {
                 try
                 {
                     mongo.Connect();

                     var db = mongo.GetDatabase(databaseName);

                     var collection = db.GetCollection(collectionName);

                     collection.Insert(t, true);

                     mongo.Disconnect();

                 }
                 catch (Exception)
                 {
                     mongo.Disconnect();
                     throw;
                 }
             }
         }
         #endregion

         #region 更新操作
         ///

/// 更新操作
///

///
///
         public void Update(T t, Expression> func)
         {
             using (Mongo mongo = new Mongo(configuration))
             {
                 try
                 {
                     mongo.Connect();

                     var db = mongo.GetDatabase(databaseName);

                     var collection = db.GetCollection(collectionName);

                     collection.Update(t, func, true);

                     mongo.Disconnect();

                 }
                 catch (Exception)
                 {
                     mongo.Disconnect();
                     throw;
                 }
             }
         }
         #endregion

         #region 获取集合
         ///

///获取集合
///

///
///
         public List List(int pageIndex, int pageSize, Expression> func, out int pageCount)
         {
             pageCount = ;

             using (Mongo mongo = new Mongo(configuration))
             {
                 try
                 {
                     mongo.Connect();

                     var db = mongo.GetDatabase(databaseName);

                     var collection = db.GetCollection(collectionName);

                     pageCount = Convert.ToInt32(collection.Count());

                     var personList = collection.Linq().Where(func).Skip(pageSize * (pageIndex - ))
                                                    .Take(pageSize).Select(i => i).ToList();

                     mongo.Disconnect();

                     return personList;

                 }
                 catch (Exception)
                 {
                     mongo.Disconnect();
                     throw;
                 }
             }
         }
         #endregion

         #region 读取单条记录
         ///

///读取单条记录
///

///
///
         public T Single(Expression> func)
         {
             using (Mongo mongo = new Mongo(configuration))
             {
                 try
                 {
                     mongo.Connect();

                     var db = mongo.GetDatabase(databaseName);

                     var collection = db.GetCollection(collectionName);

                     var single = collection.Linq().FirstOrDefault(func);

                     mongo.Disconnect();

                     return single;

                 }
                 catch (Exception)
                 {
                     mongo.Disconnect();
                     throw;
                 }
             }
         }
         #endregion

         #region 删除操作
         ///

/// 删除操作
///

///
///
         public void Delete(Expression> func)
         {
             using (Mongo mongo = new Mongo(configuration))
             {
                 try
                 {
                     mongo.Connect();

                     var db = mongo.GetDatabase(databaseName);

                     var collection = db.GetCollection(collectionName);

                     //这个地方要注意，一定要加上T参数，否则会当作object类型处理
//导致删除失败
                     collection.Remove(func);

                     mongo.Disconnect();

                 }
                 catch (Exception)
                 {
                     mongo.Disconnect();
                     throw;
                 }
             }
         }
         #endregion
5. 好，我们开一下2222端口，由于前前篇我已经把这个mongodb做成了服务，现在就直接连过去了，并做一下对Name的索引。

6. 一切准备妥当，我们做下基本的操作，比如这里我添加一千条数据，注意我开启的是安全模式，如果插入不成功，将会抛出异常。
<1> Add:
    static void Main(string[] args)
         {
             MongodbHelper helper = new MongodbHelper();

             //插入1000条数据
             for (int i = ; i < ; i++)
             {
                 helper.Insert(new Person()
                 {
                     ID = Guid.NewGuid().ToString(),
                     Name = "jack" + i,
                     Age = i,
                     CreateTime = DateTime.Now
                 });
             }

             Console.WriteLine("插入成功");

             Console.Read();
         }

乍一看显示的数据以为有问题，为什么没有出现jack0或者jack999，不过find的一下后心情舒坦了。
<2> update: 这里就把jack941的名字改掉“mary”
  static void Main(string[] args)
         {
             MongodbHelper helper = new MongodbHelper();

             //修改jack941改成mary
             var single = helper.Single(i => i.Name == "jack941");
             single.Name = "mary";
             helper.Update(single, i => i.ID == single.ID);

             Console.WriteLine("修改成功");
             Console.Read();
         }

<3>Delete：删除mary这条记录
      static void Main(string[] args)
         {
             MongodbHelper helper = new MongodbHelper();

             //删除mary这个记录
             helper.Delete(i => i.Name == "mary");

             Console.WriteLine("删除成功");
             Console.Read();
         }

<4> list操作：这里我获取一下名字里面带9的人数列表    static void Main(string[] args)
         {
             MongodbHelper helper = new MongodbHelper();

             int pagecount;

             //获取名字里面带9的人数
             var list = helper.List(, , i => i.Name.Contains(""), out pagecount);

            Console.Read();
         }

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Configuration;
using System.Linq.Expressions;

using MongoDB.Configuration;
using MongoDB.Linq;
using MongoDB.Attributes;

namespace MongoDB.Test
{
     public class MongodbHelper where T : class
     {
         string connectionString = string.Empty;

         string databaseName = string.Empty;

         string collectionName = string.Empty;

         static MongodbHelper mongodb;

         #region 初始化操作
         ///

/// 初始化操作
///

         public MongodbHelper()
         {
             connectionString = "Server=127.0.0.1:2222";
             databaseName = "shopex";
             collectionName = "person";
         }
         #endregion

         #region 实现linq查询的映射配置
         ///

/// 实现linq查询的映射配置
///

/// 插入操作
///

/// 更新操作
///

///获取集合
///

///读取单条记录
///

/// 删除操作
///

/// 数据实体
///

     public class Person
     {
         [MongoAlias("_id")]
         public string ID { get; set; }

         public string Name { get; set; }

         public int Age { get; set; }

         public DateTime CreateTime { get; set; }
     }
     #endregion
}
wow，趁着3天的休假，不断的努力终于把这个系列写完了，很感谢一直关注此系列的朋友。

推荐阅读

sum
H5技术实现经典游戏《贪吃蛇》

本文将分享一个使用HTML5技术实现的经典小游戏——《贪吃蛇》。通过H5技术，我们将探讨如何构建这款游戏的两种主要玩法：积分闯关和无尽模式。 ... [详细]

蜡笔小新 2024-11-21 20:16:59
email
2023年7月7日网络安全动态

汇总了2023年7月7日最新的网络安全新闻和技术更新，包括最新的漏洞披露、工具发布及安全事件。 ... [详细]

蜡笔小新 2024-11-23 13:35:48
bit
2023年1月28日网络安全热点

涵盖最新的网络安全动态，包括OpenSSH和WordPress的安全更新、VirtualBox提权漏洞、以及谷歌推出的新证书验证机制等内容。 ... [详细]

蜡笔小新 2024-11-24 10:29:06
main
Singleton单例模式和DoubleChecked Locking双重检查锁定模式

问题描述现在，不管开发一个多大的系统（至少我现在的部门是这样的），都会带一个日志功能；在实际开发过程中 ... [详细]

蜡笔小新 2024-11-21 15:14:45
main
使用Caffe执行ResNet网络

本文介绍如何在Caffe框架中运行ResNet模型，包括通过Caffe内置工具创建LMDB数据集的方法，以及相关参数的详细说明。 ... [详细]

蜡笔小新 2024-11-25 13:18:25
js
使用IntelliJ IDEA高效开发与运行Shell脚本

本文介绍了如何利用IntelliJ IDEA中的BashSupport插件来增强Shell脚本的开发体验，包括插件的安装、配置以及脚本的运行方法。 ... [详细]

蜡笔小新 2024-11-25 11:20:34
plugins
Android 开发框架整合：MVP + Retrofit + Dagger2 + RxAndroid 配置指南

本文将详细介绍如何配置并整合MVP架构、Retrofit网络请求库、Dagger2依赖注入框架以及RxAndroid响应式编程库，构建高效、模块化的Android应用。 ... [详细]

蜡笔小新 2024-11-24 20:16:02
window
在Windows 10上安装Python 3和Scrapy的详细步骤

本文档提供了在Windows 10操作系统中安装Python 3及Scrapy框架的完整指南，包括必要的依赖库如wheel、lxml、pyOpenSSL、Twisted和pywin32的安装方法。 ... [详细]

蜡笔小新 2024-11-24 12:05:49
header
Python3爬虫入门：pyspider的基本使用[python爬虫入门]

Python学习网有大量免费的Python入门教程，欢迎大家来学习。本文主要通过爬取去哪儿网的旅游攻略来给大家介绍pyspid ... [详细]

蜡笔小新 2024-11-22 18:00:41
header
Python 领跑！2019年2月编程语言排名更新

根据最新的编程语言流行指数（PYPL）排行榜，Python 在2019年2月的份额达到了26.42%，稳坐榜首位置。 ... [详细]

蜡笔小新 2024-11-21 09:18:39
require
MongoDB 高可用集群搭建指南：分片、读写分离与负载均衡

本文详细介绍了如何搭建一个高可用的MongoDB集群，包括环境准备、用户配置、目录创建、MongoDB安装、配置文件设置、集群组件部署等步骤。特别关注分片、读写分离及负载均衡的实现。 ... [详细]

蜡笔小新 2024-11-20 18:28:16
js
实践指南：使用Express、Create React App与MongoDB搭建React开发环境

本文详细介绍了如何利用Express、Create React App和MongoDB构建一个高效的React应用开发环境，旨在为开发者提供一套完整的解决方案，包括环境搭建、数据模拟及前后端交互。 ... [详细]

蜡笔小新 2024-11-20 10:05:15
main
Git配置及常用命令详解

本文介绍了如何在不同操作系统上安装Git，以及一些基本和高级的Git操作，包括项目初始化、文件状态检查、版本控制、分支管理、标签处理、版本回退等，并简要提及了开源许可协议的选择。 ... [详细]

蜡笔小新 2024-11-19 19:52:34
main
APP及其接口测试全面解析

本文深入探讨了移动应用（APP）及其接口测试的关键点，包括安装与卸载、功能一致性、系统兼容性、权限管理等多个方面的测试策略，以及针对接口的功能、边界值、参数组合等专业测试方法。同时，介绍了几款常用的测试工具，帮助开发者提高测试效率和质量。 ... [详细]

蜡笔小新 2024-11-25 11:35:36
main
如何在U8系统中连接服务器并获取数据

本文介绍了如何在U8系统中通过不同的方法连接服务器并获取数据，包括使用MySQL客户端连接实例的方法，如非SSL连接和SSL连接，并提供了详细的步骤和注意事项。 ... [详细]

蜡笔小新 2024-11-19 12:08:19

ys2011一号_139

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章