MongoDb 相关

本文内容纲要：

本文地址:http://www.cnblogs.com/vnii/archive/2012/08/23/2652891.html

1.C#下对MongoDB中的数据分组Group

IMongoQueryquery=null; query=Query.And( Query.EQ("CityCode","hangzhou"), Query.EQ("LT_IsBDT",1), Query.EQ("LT_Checked",1) ); Dictionary<string,int>dictionary=newDictionary<string,int>(); dictionary["num"]=0; //IMongoGroupBygroupBy=null; //groupBy=GroupBy.Keys("LTT_ID"); GroupByBuildergroupByBuilder=newGroupByBuilder(newstring[]{"LTT_ID","LTT_TypeName","LTT_ParentID"}); vartSmall=_mongoCollection.Group(query,groupByBuilder,BsonDocument.Create(dictionary), BsonJavaScript.Create("function(doc,prev){prev.num++;}"), BsonJavaScript.Create("function(doc){doc.count=doc.num;deletedoc.num;}")).ToList();

2.C#操作MongoDB的部分代码示例

MongoServer_mongoServer=MongoServer.Create("mongodb://192.168.90.245:10008/?safe=true");//连接数据库 MongoDatabase_mongoDatabase=_mongoServer.GetDatabase("MYDB");//选择数据库名 MongoCollectionMongoCt=_mongoDatabase.GetCollection("MyCollection");//选择集合，相当于表 //获取数据 publicList<InfoModel>GetTopicListByType(stringsKeyWord,intiPageSize,intiCurrPageIndex) { IMongoQueryquery=null; query=Query.And( Query.EQ("LT_IsBDT",1), Query.EQ("LT_Checked",1), Query.Or(Query.EQ("LT_Status",0),Query.EQ("LT_Status",1)), Query.GTE("LT_CreateDate",DateTime.Now), Query.Matches("LT_Title",BsonRegularExpression.Create("/.*"+sKeyWord+".*/")) ); SortByDocumentsort=newSortByDocument{{"LT_CreateDate",-1}}; returnMongoCt.FindAs<InfoModel>(query).SetLimit(iPageSize).SetSkip(iPageSize*iCurrPageIndex).SetSortOrder(sort).ToList(); } //更新+1 publicboolIncViewCount(intiLtId,intiInc) { IMongoQueryquery; query=Query.And( Query.EQ("LT_ID",iLtId) ); UpdateBuilderupdate=newUpdateBuilder(); SafeModeResultr=MongoCt.Update(query,update.Inc("LT_ViewCount",iInc)); returnr!=null&&r.Ok; } //插入数据 publicboolInsertBatch<T>(IEnumerable<T>document) { List<SafeModeResult>result=(List<SafeModeResult>)this.MongoCt.InsertBatch<T>(document); returnresult!=null&&result[0]!=null&&result[0].Ok; } //根据ID删除数据 publicboolRemoveBatchById(List<int>list) { IMongoQueryquery=null; query=Query.And( Query.In("IA_ID",BsonArray.Create(list)) ); SafeModeResultresult=this.MongoCt.Remove(query); returnresult!=null&&result.Ok; } //根据ID更新数据 publicboolUpdateSingleByLtid(InfoModelmodel) { IMongoQueryquery; query=Query.And( Query.EQ("IA_ID",model.IA_ID) ); BsonDocumentbsonDocument=model.ToBsonDocument<InfoModel>(); bsonDocument.Remove("_id"); bsonDocument.Remove("IA_ID"); varupdate=newUpdateDocument { {"$set",bsonDocument} }; SafeModeResultresult=this.MongoCt.Update(query,update); returnresult!=null&&result.Ok; } //删除所有数据 publicboolRemoveAll() { SafeModeResultr=this.MongoCt.Remove(null); returnr!=null&&r.Ok; } //创建索引 publicboolCreateIndex1() { SafeModeResultr=this.MongoCt.CreateIndex( newIndexKeysBuilder().Ascending("IA_CityCode","IT_Key").Descending("IA_CreateDate") ); returnr!=null&&r.Ok; } //获取表索引 publicGetIndexesResultGetIndex() { returnthis.MongoCt.GetIndexes(); } //删除表索引 publicboolDropIndex() { returnthis.MongoCt.DropAllIndexes().Ok; }

3.命令行下语法

db.collection.update(criteria,objNew,upsert,multi) criteria:update的查询条件，类似sqlupdate查询内where后面的 objNew:update的对象和一些更新的操作符（如$,$inc...）等，也可以理解为sqlupdate查询内set后面的 upsert:这个参数的意思是，如果不存在update的记录，是否插入objNew,true为插入，默认是false，不插入。 multi:mongodb默认是false,只更新找到的第一条记录，如果这个参数为true,就把按条件查出来多条记录全部更新。 //用法：{$inc:{field:value}} //意思对一个数字字段field增加value,如SQL-“updatetest0setcount=count+1where_id=15” db.test0.update({"_id":15},{$inc:{"count":1}}); //用法：{$unset:{field:1}} //顾名思义，就是删除字段了,删除某条件下的文档中的某个列，如： db.test0.update({"_id":15},{$unset:{"Age":1}}); //添加字段赋值 db.test0.find().forEach( function(item){ db.test0.update({},{"$set":{"CreateDate":item.UpdateDate}},false,true) } ) db.test0.find({CityCode:"hz","CreateDate":{$exists:false}}).forEach( function(item){ db.test0.update({CityCode:"hz","CreateDate":{$exists:false}},{"$set":{"CreateDate":item.UpdateDate}},false,true) } ) //查询指定字段 db.test0.find({},{"CreateDate":1,_id:0}) //查找不存在字段FName的记录 db.test0.find({CityCode:"hz","FName":{$exists:false}}) //创建索引 db.test0.ensureIndex({"CityCode":1,"LT_ID":-1},{"name":"test0ByLtId"}) //删除索引 db.runCommand({deleteIndexes:"表名",index:"索引名"})//删除指定索引 db.test0.dropIndexes()//删除所有索引 //查看索引 db.test0.getIndexes() //列重命名 db.test0.update({},{$rename:{"BigTypeName":"ParentTypeName"}},false,true) db.test0.remove({});//删除things中的所有数据 db.test0.remove({n:1});//删除things中n=1的所有数据类似deletewheren=1 //链接字符串 Servers=IP:27017;ConnectTimeout=30000;ConnectionLifetime=300000;MinimumPoolSize=8;MaximumPoolSize=256;Pooled=true

本文内容总结：

原文链接：https://www.cnblogs.com/vnii/archive/2012/08/23/2652891.html