namedhao 发表于 2015-11-10 14:32:16

MongoDB 安装及C#开发测试

MongoDB安装及C#开发测试
(一)MongoDB简介
MongoDB是一个介于关系数据库和非关系数据库之间的产品,是非关系数据库当中功能最丰富,最像关系数据库的。他支持的数据结构非常松散,是类似json的bjson格式,因此可以存储比较复杂的数据类型。Mongo最大的特点是他支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。
它的特点是高性能、易部署、易使用,存储数据非常方便。主要功能特性有:

[*]面向集合存储,易存储对象类型的数据。
[*]模式自由。
[*]支持动态查询。
[*]支持完全索引,包含内部对象。
[*]支持查询。
[*]支持复制和故障恢复。
[*]使用高效的二进制数据存储,包括大型对象(如视频等)。
[*]自动处理碎片,以支持云计算层次的扩展性
[*]支持RUBY,PYTHON,JAVA,C++,PHP等多种语言。
[*]文件存储格式为BSON(一种JSON的扩展)
[*]可通过网络访问
所谓“面向集合”(Collenction-Orented),意思是数据被分组存储在数据集中,被称为一个集合(Collenction)。每个 集合在数据库中都有一个唯一的标识名,并且可以包含无限数目的文档。集合的概念类似关系型数据库(RDBMS)里的表(table),不同的是它不需要定 义任何模式(schema)。
模式自由(schema-free),意味着对于存储在mongodb数据库中的文件,我们不需要知道它的任何结构定义。如果需要的话,你完全可以把不同结构的文件存储在同一个数据库里。
存储在集合中的文档,被存储为键-值对的形式。键用于唯一标识一个文档,为字符串类型,而值则可以是各中复杂的文件类型。我们称这种存储形式为BSON(Binary Serialized dOcument Format)。
MongoDB服务端可运行在Linux、Windows或OS X平台,支持32位和64位应用,默认端口为27017。推荐运行在64位平台,因为MongoDB
在32位模式运行时支持的最大文件尺寸为2GB。
MongoDB把数据存储在文件中(默认路径为:/data/db),为提高效率使用内存映射文件进行管理。

(二) MongoDB下载
下载地址为:http://www.mongodb.org/downloads
可选择window         32位mongodb,也可以选择window 64位mongodb,
32-bit mongodb window 下载地址:http://downloads.mongodb.org/win32/mongodb-win32-i386-2.0.2.zip

64-bit mongodb window 下载地址:http://downloads.mongodb.org/win32/mongodb-win32-x86_64-2.0.2.zip

其它:Linux 32-bit,Linux 64-bit,etc...
本文主要针对window操作系统上安装mongodb分布式文档数据库系统,
下载后为zip压缩文件,然后解压后,在里面有一个bin目录,里面就是运行的系统文件
注意:32位的mongodb数据库最多只能为2G的限制,这是由32位操作系统的内存寻址空间能力确定的,所在要存储海量数据库数据必须选择64位操作系统安装64位mongodb数据库(三) MongoDB安装
建立启动的批处理文件:1.命令行方式启动服务器端echo "bat_setupService.bat"mongod.exe -dbpath D:\Mongo_Service\db\

2 命令行方式启动客户端echo "bat_setupClient.bat"mongo.exe cclove

3安装为window服务方式echo "bat_installService.bat"mongod --install --serviceName MongoDB--logpath D:\MongoDB_Service\MongoDB.Log --dbpath D:\MongoDB_Service\db --directoryperdb
然后启动window服务MongoDB就开始运行了
(四)MongoDB C#测试代码查看源码打印?001public class TestClass:IDisposable002    { 003      privatestring connectionstring =&quot;&quot;; 004      privateMongoServer mserver = null;005      publicTestClass() 006      {007            stringhost = &quot;&quot;;008            host =&quot;192.168.1.221&quot;;//64位mongodb 009            //host = &quot;192.168.1.232&quot;;   //32位mongodb010            intport = 27017; 011            //connectionstring=&quot;Servers=IP:27017;ConnectTimeout=30000;ConnectionLifetime=300000;MinimumPoolSize=8;MaximumPoolSize=2000&quot;;012            MongoConnectionStringBuilder mcsb =new MongoConnectionStringBuilder();013            mcsb.Server =new MongoServerAddress(host, port);014            mcsb.ConnectTimeout =newTimeSpan(30000); 015            mcsb.MaxConnectionLifeTime =new TimeSpan(300000);016            mcsb.MinConnectionPoolSize = 8;017            mcsb.MaxConnectionPoolSize = 2000;018            //connectionstring=&quot;mongodb://192.168.3.10&quot;;019            //64位mongodb020            //connectionstring = &quot;mongodb://192.168.1.221&quot;;   021            //022            //32位mongodb023            //connectionstring = &quot;mongodb://192.168.1.232:27017&quot;;024025            //创建一个Mongo服务对象mserver026            this.mserver = MongoServer.Create(mcsb);//this.connectionstring);027      }028      //测试代码:029      //插入测试函数:030       publicint mongodbconn(intcouts)// test insert031       {032            try033            {034                //获取一个Mongo数据库对象db035                MongoDatabase db =this.mserver.GetDatabase(&quot;test&quot;);               036                //从Mongo数据库对象从获取Mongo集合(即表)名称为Test的集合(或叫表)037                MongoCollection<BsonDocument> mc = db.GetCollection<BsonDocument>(&quot;test&quot;);038                //删除原有数据039                mc.RemoveAll();040                //记录开始写入时间041                DateTime begintime = DateTime.Now;042                writefile(&quot;bgn: &quot;&#43;begintime.ToString());043                inti; 044                for( i = 1; i <= couts; i&#43;&#43;) 045                {046                  BsonDocument bd =new BsonDocument047                  {048                        {&quot;_id&quot;,i},049                        {&quot;id&quot;,i},050                        {&quot;name&quot;, &quot;c#&quot; }, 051                        {&quot;title&quot;, &quot;testing inert data &quot;&#43;i }               052                  };053                  mc.Insert(bd);054                  DateTime midtime = DateTime.Now;055                  if((i%10)==0)056                  {057                        writefile(&quot;row: &quot;&#43;i&#43;&quot; value=&quot;&#43;bd.ToString());058                        TimeSpan tso = midtime.Subtract(begintime);059                        stringstimeo = tso.TotalMilliseconds.ToString(); 060                        writefile(&quot;mid: &quot;&#43; stimeo&#43;&quot; ms&quot;);061                  }062                }063                //记录结束写入时间及用时多少ms064                DateTime endtime = DateTime.Now;065                writefile(&quot;end: &quot;&#43;endtime.ToString());066                TimeSpan ts = endtime.Subtract(begintime);067                stringstime=ts.TotalMilliseconds.ToString(); 068                writefile(&quot;use &quot;&#43; stime &#43; &quot; ms to insert &quot;&#43;i&#43;&quot; rows&quot;);069                return1; 070            }071            catch(Exception ex)072            {073                MessageBox.Show(ex.Message);074                return0;             075            }076         }077         078      //日志函数:079      publicstatic boolwritefile(stringstr) //logifile 080      {081            stringstartpath = Application.StartupPath; 082            stringlogpath=startpath&#43;&quot;\\mongodb.log&quot;;083            StreamWriter sw =new StreamWriter(logpath,true); 084            sw.WriteLine(str);085            sw.Close();086            returntrue; 087      }088089      //查询测试函数:090      publicbool query(inttype,stringtype1value,stringtypeothervalue) 091      {092            try093            {094                stringsql; 095                longcounts=0; 096                MongoDatabase db = mserver.GetDatabase(&quot;test&quot;);097                MongoCollection<BsonDocument> mc = db.GetCollection<BsonDocument>(&quot;test&quot;);098                if(type == 1) 099                {100                  sql = type1value;101                }102                else103                {104                  sql = typeothervalue;105                }106                DateTime qtime = DateTime.Now;107                var query =new QueryDocument(&quot;_id&quot;,Convert.ToInt32(sql));108               109                writefile(&quot;begin: &quot;&#43; qtime.ToString()); 110                foreach(BsonDocument emp inmc.Find(query).SetLimit(100)) 111                {112                  counts = counts &#43; 1;113                114                   stringrename = emp[&quot;name&quot;].AsString;115                   stringrevalue = emp[&quot;title&quot;].AsString;116                   writefile(rename &#43;&quot;&quot;&#43;revalue&#43;&quot; value=&quot;&#43;emp.ToString());117                }118                DateTime etime = DateTime.Now;119                TimeSpan ts = etime.Subtract(qtime);120                stringstime = ts.TotalMilliseconds.ToString(); 121                writefile(&quot;use &quot;&#43; stime &#43; &quot; ms to query &quot;&#43;counts&#43;&quot;data rows&quot;);122                returntrue; 123            }124            catch(Exception ex) 125            {126                MessageBox.Show(ex.Message);127                returnfalse; 128            }129      }130131132      #region IDisposable 成员133134      publicvoid Dispose() 135      {136            if(this.mserver !=null) 137            {138                this.mserver.Disconnect();139                this.mserver =null; 140            }141      }142143      #endregion144    }调用引类的方法查看源码打印?01public partial class Form1 : Form02    { 03      publicForm1() 04      {05            InitializeComponent();06      }0708      //连接mongoDb 服务器 事件09      privatevoid btn_ConnMongoDb_Click(object sender, EventArgs e)10      {11            TestClass test =new TestClass();12            test.mongodbconn(50);13            test.query(1,&quot;1&quot;, &quot;2&quot;);14            test.Dispose();15            MessageBox.<SPANclass=&quot;goog_qs-tidbit goog_qs-tidbit-1&quot;>Show(&quot;连接,插入,查询操作完毕!</SPAN>&quot;,&quot;提示&quot;); 16      }17    }需要在C#开发的项目工程中添加两个.Net的组件dllMongoDB.BsonMongoDB.Driver
这个需要安装MongoDB的C#驱动程序需到下面的网址去下载:http://www.mongodb.org/display/DOCS/Drivers
我下载的是这个版本:CSharpDriver-1.3.1.4349.msi下载下来安装后,就可以通过C#工程中的引用/Net组件引用这两个组件了MongoDB.BsonMongoDB.Driver------the----end-------create date:2012-02-22creater:hsg
页: [1]
查看完整版本: MongoDB 安装及C#开发测试