MongoDB操作非结构化数据

转自：http://blog.csdn.net/han_yankun2009/article/details/17050959

Mongodb

 

一般指分布式文档存储数据介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。他支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型.

 我们这次项目中用到的就是它的这两个特点

 

特点：

使用高效的二进制数据存储，包括大型对象（如视频等）。

*自动处理碎片，以支持云计算层次的扩展性。

面向集合存储，易存储对象类型的数据。

 

关于mongdb的数据数据操作,攀比SQL Server ，mongodb的操作和它真是有的一比，几乎是如出一辙。增删改查，样样都有。

下面咱就看看它的连接和查询方式吧。

当然在使用mongodb数据库之前是要先引入它的一些驱动程序的，（我这里使用的是官方提供的两个驱动程序）所谓的就是两个Dll类库文件。分别是

 MongoDB.Driver.dll：顾名思义，驱动程序

 MongoDB.Bson.dll：序列化、Json相关。

之后我们在自己所用的程序中引入这两个dll文件和导入命名空间。

 

下列就是具体的实例代码了

1 链接数据库

 

///初始化Mongodb数据库链接

 

public void Init()
    {


//数据库连接字符串,207017是mongodb的数据库端口
ConnectionString="mongodb://Localhost:27017/?safe=true"/>
 //数据库名称
 conststring dbName ="ExamDB";
//创建数据库连接

 MongoServerSettingssettings= new MongoServerSettings();
 settings.MaxConnectionPoolSize = 1000;//设定最大连接池
//等待列队数量
  settings.WaitQueueSize = 50;
 MongoServer server=MongoServer.Create(settings)；//创建连接数据文件
 //获得数据库cnblogs
MongoDatabase db=server.GateDataBase(dbName);

}

 

 

通过我们先前的Sql链接数据库我们发现几乎没有什么不同，这是名字换了下而已。所以不同的数据库操作，只要认识了一种，熟悉后，对别的数据库操作，上手是很容易的。

         

string connStr =ConfigurationManager.AppSettings["connstr"]; //获取配置文件的连接
          conn = new SqlConnection(connStr);
  conn.open();

 

 

 

2插入数据

 

好了数据打开了，现在得添加数据了，由于mongodb没有表的概念，只有数据集合，所以我们插入数据，就要设定数据的集合名称。（但这里很类似表，只是存储的数据不再受表的限制，它是对象集合，所以可以存储任意的数据类型）：

 

 

 public static stringfileTable = "files";//设定查询的集合名称
//Httpcontext类是获取前台的数据
Public bool Insert（HttpContext contex）
{
            MongoDatabase db = Init();
// MongoGridFS fs = newMongoGridFS(db); //如果不设定查询的集合，则默认读取的集合表名是filse
//定义设定集合对象，设定查询的集合
            MongoGridFSSettings fsSetting = new MongoGridFSSettings() { Root = fileTable };
//定义文件的操作对象，可以执行文件的增加，删除和更新操作
    MongoGridFS fs = new MongoGridFS(DB, fsSetting);
 // 摘要:  public sealed class HttpPostedFile.ContentLength
 //    获取上载文件的大小（以字节为单位）。
 // 返回结果:
 // 文件长度（以字节为单位）。
//定义文件字节流对象
 HttpPostedFile file =context.Request.Files["Filedata"];
 int nFileLen = file.ContentLength;//     文件长度（以字节为单位）
byte[]myData = new Byte[nFileLen];
 file.InputStream.Read(myData, 0, nFileLen).//将文件以字节流的形式写入

//添加文件上传的附件信息，可以添加很多，这里只做个实例
 MongoGridFSCreateOptions option = new MongoGridFSCreateOptions();
 option.UploadDate = DateTime.Now;
//Using语句实现销毁链接方式
//MongoGirdFSStream可以实现文件的度和取得操作，
 //创建文件，文件并存储数据
using(MongoGridFSStream gfs = fs.Create(file.FileName, option))
                {
                    gfs.Write(myData, 0,nFileLen);
                    gfs.Close();
}

}

 

 

 

通过实例我们发现，Mongodb的操作和SQLServer的操作是很大程度上是相识的，包括增，删除，添加和修改等方式，只是名字不同。我们不必因为是一个新的东西而听着害怕这种感觉，只要肯联系和观察思考，就会发现和以往有很多联系之处的

以上只是一个简单的上传的实例，具体的更多的方法还等待大家继续去实践。后续继续说明Mongodb的一些配置。