C# | 大中华官方唯一支持 - mongodb - 官方

Your browser does not seem to support JavaScript. As a result, your viewing experience will be diminished, and you have been placed in read-only mode.

Please download a browser that supports JavaScript, or enable it if it's disabled (i.e. NoScript).

登录后发表

C#使用Mongodb帮助类来注册及登录，欢迎吐槽，肯定有需要修改及优化的地方，不吝赐教
• 做自己

1

1
帖子

32
浏览



#region 登录的模块
protected void butlogin_Click(object sender, EventArgs e)
{
string uname = Request["uname"]; string upswd = Request["upswd"]; string ckme = Request["ckme"];
string script = string.Empty;
if (uname.IsNotEmptOrNull() && upswd.IsNotEmptOrNull())
{
UserInfo info = new UserInfo();
info.name = uname; info.pswd = upswd;
string sessionId = Guid.NewGuid().ToString();//cookid cp2
HttpCookie cp1 = new HttpCookie("cp1", sessionId);
HttpCookie cp2 = new HttpCookie("cp2", uname + "**" + Md5Helper.Md5Str(Md5Helper.Md5Str(upswd)));
DateTime loginDay ;
if (ckme.IsNotEmptOrNull())
{
cp1.Expires = DateTime.Now.AddDays(7);
cp2.Expires = DateTime.Now.AddDays(7);
loginDay = DateTime.Now.AddDays(7);
}
else
{
loginDay = DateTime.Now.AddMinutes(30);
}
MemecacheHelper.Set(sessionId, NewtonSoftHelper.ObjectToJsonStr(info), loginDay);
Response.Cookies.Add(cp1); Response.Cookies.Add(cp2);
script = DoLogin(info);
}
else
{
script = BootBoxDialog.Error();
}
ScriptManager.RegisterStartupScript(this.Page, this.GetType(), "", script, true);
}

private string DoLogin(UserInfo info)
{
UserInfo uinf = MongoDbHelper.FindOneByCondition<UserInfo>(MyenumHelper.DBChose.myfirstmog.ToString(), MyenumHelper.TableChose.person.ToString(), Query.And(Query<UserInfo>.EQ(c => c.name, info.name), Query<UserInfo>.EQ(c => c.pswd, info.pswd)));
if (uinf != null)
{
return BootBoxDialog.Succeed("登录成功 !");
}
else { return BootBoxDialog.Failure(); }
}
#endregion

#region 注册的模块
protected void butregister_Click(object sender, EventArgs e)
{
string uname = Request.Params["uname"]; string upswd = Request.Params["upswd"];
string script = string.Empty;
if (uname.IsNotEmptOrNull() && upswd.IsNotEmptOrNull())
{
UserInfo info = new UserInfo();
info.name = uname; info.pswd = upswd;
if (MongoDbHelper.Insert<UserInfo>(MyenumHelper.DBChose.myfirstmog.ToString(), MyenumHelper.TableChose.person.ToString(),info))
{
script = BootBoxDialog.Succeed("恭喜，注册成功 !");
}
else
{
script = BootBoxDialog.Failure("注册失败！");
}
}
else
{
script = BootBoxDialog.Warning("账号密码必填项写 !");
}
ScriptManager.RegisterStartupScript(this.Page, this.GetType(), "", script, true);
}

#endregion
C#操作mongodb帮助类，WriteConcernResult result= collection.Insert<T>(model)这个方法返回为null,不理解
• 做自己

1

1
帖子

23
浏览



using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using MongoDB.Bson;
using MongoDB.Driver.Builders;
using MongoDB.Driver;
using System.Configuration;
/// <summary>
/// MongoDbHelper 的摘要说明
/// </summary>
public class MongoDbHelper
{
public static readonly string mongodbStr = ConfigurationManager.ConnectionStrings["mongodbStr"].ConnectionString;
public MongoDbHelper()
{
//
// TODO: 在此处添加构造函数逻辑
//
}

#region MyRegion 获取collection对象
public static MongoCollection GetMongoCollection(string dbName, string collectionName)
{
MongoClient client = new MongoClient(mongodbStr);
MongoServer servcer = client.GetServer();
MongoCollection collection = servcer.GetDatabase(MyenumHelper.DBChose.myfirstmog.ToString()).GetCollection(MyenumHelper.TableChose.person.ToString());

//MongoServer server = MongoServer.Create(mongodbStr); //这个方法为否决的方法，还是使用上面的链接方法
//MongoDatabase db = server.GetDatabase(dbName);
//MongoCollection collection = db.GetCollection(collectionName);
return collection;
}
#endregion

#region MyRegion 获取collection对象泛型
public static MongoCollection GetMongoCollection<T>(string dbName, string collectionName) where T : BaseMongo
{
MongoServer server = MongoServer.Create(mongodbStr);
MongoDatabase db = server.GetDatabase(dbName);
MongoCollection collection = db.GetCollection<T>(collectionName);
return collection;
}
#endregion

#region MyRegion 新增的操作 ok
public static bool Insert<T>(string dbName, string collectionName, T model) where T : BaseMongo
{
try
{
if (model == null)
{
throw new ArgumentNullException("model", "待插入数据不能为空");
}
var collection = GetMongoCollection(MyenumHelper.DBChose.myfirstmog.ToString(), MyenumHelper.TableChose.person.ToString());
collection.Insert(model);//直接插入对象就是ok的
//WriteConcernResult result= collection.Insert<T>(model);//不可以这样使用，下面两句有bug 调试时发现返回为null,不理解，实际新增到数据库是成功的？why?why?why?
// return result.HasLastErrorMessage; result.Ok;
return true;
}
catch (Exception)
{
return false;
}
}
#endregion

#region MyRegion 删除collection 中所有的数据，不可以回滚慎重！！！ ok
public static bool DeleteAll(string dbName, string collectionName)
{
try
{
MongoCollection collection = GetMongoCollection(dbName, collectionName);
collection.RemoveAll();
return true;
}
catch (Exception)
{
return false;
}
}
#endregion

#region MyRegion 查找所有的列表信息 ok
public static List<T> FindAll<T>(string dbName, string collectionName) where T : BaseMongo
{
var collection = GetMongoCollection<T>(dbName, collectionName);
return collection.FindAllAs<T>().ToList();
}
#endregion

#region 根据Query的条件来获取一个对象 ok
public static T FindOneByCondition<T>(string dbName, string collectionName, IMongoQuery query) where T : BaseMongo
{
MongoCollection collection = GetMongoCollection(dbName, collectionName);
return collection.FindOneAs<T>(query);
}
#endregion

#region 根据Query的条件来获取一个对象 ok
public static T FindOneById<T>(string dbName, string collectionName, string objid) where T : BaseMongo
{
MongoCollection collection = GetMongoCollection(dbName, collectionName);
return collection.FindOneByIdAs<T>(new ObjectId(objid));
}
#endregion
}
(转)C#开发Mongo笔记第一篇
• x4_965be

2

2
帖子

414
浏览



创建了User 类，在User类里面有一个Chengji的类属性，然后将实体使用 mongodb的collection.Insert()方法都插入到数据库中，楼主的意思是这样的吧
MongoDB的连接池和连接管理
• F3218466

2

2
帖子

313
浏览



主要的调整在于2.10.0版本中引入了MongoClient类，同时在其API中也说明了Mongo类会在将来的版本中被MongoClient替换（Note: This class has been superseded by MongoClient, and may be deprecated in a future release.）。故在这次调整中，也对原先的本帖下載内容已隐藏，请登入以查看隐藏内容！集群的应用只需要一个实例，所以这次调整我们设计成单例形式。如果出于某些原因，你决定使用多个实例，请注意：所有资源使用限制（最大连接数等等）对每个MongoClient都适用；销毁一个实例时，请确认调用MongoClient.close()方法来清理资源。

下面给出相关的代码：
/** * 项目名：SpiderCrawler * 文件名：MongoDBDao.java * 作者：zhouyh * 时间：2014-8-30 下午03:46:55 * 描述：TODO(用一句话描述该文件做什么) */ package com.newsTest.dao; import java.util.ArrayList; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBObject; /** * 类名： MongoDBDao * 包名： com.newsTest.dao * 作者： zhouyh * 时间： 2014-8-30 下午03:46:55 * 描述： TODO(这里用一句话描述这个类的作用) */ public interface MongoDBDao { /** * * 方法名：getDb * 作者：zhouyh * 创建时间：2014-8-30 下午03:53:40 * 描述：获取指定的mongodb数据库 * @param dbName * @return */ public DB getDb(String dbName); /** * * 方法名：getCollection * 作者：zhouyh * 创建时间：2014-8-30 下午03:54:43 * 描述：获取指定mongodb数据库的collection集合 * @param dbName 数据库名 * @param collectionName 数据库集合 * @return */ public DBCollection getCollection(String dbName, String collectionName); /** * * 方法名：inSert * 作者：zhouyh * 创建时间：2014-8-30 下午04:07:35 * 描述：向指定的数据库中添加给定的keys和相应的values * @param dbName * @param collectionName * @param keys * @param values * @return */ public boolean inSert(String dbName, String collectionName, String[] keys, Object[] values); /** * * 方法名：delete * 作者：zhouyh * 创建时间：2014-8-30 下午04:09:00 * 描述：删除数据库dbName中，指定keys和相应values的值 * @param dbName * @param collectionName * @param keys * @param values * @return */ public boolean delete(String dbName, String collectionName, String[] keys, Object[] values); /** * * 方法名：find * 作者：zhouyh * 创建时间：2014-8-30 下午04:11:11 * 描述：从数据库dbName中查找指定keys和相应values的值 * @param dbName * @param collectionName * @param keys * @param values * @param num * @return */ public ArrayList<DBObject> find(String dbName, String collectionName, String[] keys, Object[] values, int num); /** * * 方法名：update * 作者：zhouyh * 创建时间：2014-8-30 下午04:17:54 * 描述：更新数据库dbName，用指定的newValue更新oldValue * @param dbName * @param collectionName * @param oldValue * @param newValue * @return */ public boolean update(String dbName, String collectionName, DBObject oldValue, DBObject newValue); /** * * 方法名：isExit * 作者：zhouyh * 创建时间：2014-8-30 下午04:19:21 * 描述：判断给定的keys和相应的values在指定的dbName的collectionName集合中是否存在 * @param dbName * @param collectionName * @param keys * @param values * @return */ public boolean isExit(String dbName, String collectionName, String key, Object value); } 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 /** * 项目名：SpiderCrawler * 文件名：MongoDBDaoImpl.java * 作者：zhouyh * 时间：2014-8-30 下午04:21:11 * 描述：TODO(用一句话描述该文件做什么) */ package com.newsTest.dao.impl; import java.net.UnknownHostException; import java.util.ArrayList; import com.newsTest.dao.MongoDBDao; import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.DBObject; import com.mongodb.MongoClient; import com.mongodb.MongoClientOptions; import com.mongodb.MongoException; import com.mongodb.WriteResult; /** * 类名： MongoDBDaoImpl * 包名： com.newsTest.dao.impl * 作者： zhouyh * 时间： 2014-8-30 下午04:21:11 * 描述： TODO(这里用一句话描述这个类的作用) */ public class MongoDBDaoImpl implements MongoDBDao{ /** * MongoClient的实例代表数据库连接池，是线程安全的，可以被多线程共享，客户端在多线程条件下仅维持一个实例即可 * Mongo是非线程安全的，目前mongodb API中已经建议用MongoClient替代Mongo */ private MongoClient mongoClient = null; /** * * 私有的构造函数 * 作者：zhouyh */ private MongoDBDaoImpl(){ if(mongoClient == null){ MongoClientOptions.Builder build = new MongoClientOptions.Builder(); build.connectionsPerHost(50); //与目标数据库能够建立的最大connection数量为50 build.autoConnectRetry(true); //自动重连数据库启动 build.threadsAllowedToBlockForConnectionMultiplier(50); //如果当前所有的connection都在使用中，则每个connection上可以有50个线程排队等待 /* * 一个线程访问数据库的时候，在成功获取到一个可用数据库连接之前的最长等待时间为2分钟 * 这里比较危险，如果超过maxWaitTime都没有获取到这个连接的话，该线程就会抛出Exception * 故这里设置的maxWaitTime应该足够大，以免由于排队线程过多造成的数据库访问失败 */ build.maxWaitTime(1000*60*2); build.connectTimeout(1000*60*1); //与数据库建立连接的timeout设置为1分钟 MongoClientOptions myOptions = build.build(); try { //数据库连接实例 mongoClient = new MongoClient("127.0.0.1", myOptions); } catch (UnknownHostException e) { // TODO 这里写异常处理的代码 e.printStackTrace(); } catch (MongoException e){ e.printStackTrace(); } } } /********单例模式声明开始，采用饿汉式方式生成，保证线程安全********************/ //类初始化时，自行实例化，饿汉式单例模式 private static final MongoDBDaoImpl mongoDBDaoImpl = new MongoDBDaoImpl(); /** * * 方法名：getMongoDBDaoImplInstance * 作者：zhouyh * 创建时间：2014-8-30 下午04:29:26 * 描述：单例的静态工厂方法 * @return */ public static MongoDBDaoImpl getMongoDBDaoImplInstance(){ return mongoDBDaoImpl; } /************************单例模式声明结束*************************************/ @Override public boolean delete(String dbName, String collectionName, String[] keys, Object[] values) { DB db = null; DBCollection dbCollection = null; if(keys!=null && values!=null){ if(keys.length != values.length){ //如果keys和values不对等，直接返回false return false; }else{ try { db = mongoClient.getDB(dbName); //获取指定的数据库 dbCollection = db.getCollection(collectionName); //获取指定的collectionName集合 BasicDBObject doc = new BasicDBObject(); //构建删除条件 WriteResult result = null; //删除返回结果 String resultString = null; for(int i=0; i<keys.length; i++){ doc.put(keys[i], values[i]); //添加删除的条件 } result = dbCollection.remove(doc); //执行删除操作 resultString = result.getError(); if(null != db){ try { db.requestDone(); //请求结束后关闭db db = null; } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } } return (resultString!=null) ? false : true; //根据删除执行结果进行判断后返回结果 } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } finally{ if(null != db){ db.requestDone(); //关闭db db = null; } } } } return false; } @Override public ArrayList<DBObject> find(String dbName, String collectionName, String[] keys, Object[] values, int num) { ArrayList<DBObject> resultList = new ArrayList<DBObject>(); //创建返回的结果集 DB db = null; DBCollection dbCollection = null; DBCursor cursor = null; if(keys!=null && values!=null){ if(keys.length != values.length){ return resultList; //如果传来的查询参数对不对，直接返回空的结果集 }else{ try { db = mongoClient.getDB(dbName); //获取数据库实例 dbCollection = db.getCollection(collectionName); //获取数据库中指定的collection集合 BasicDBObject queryObj = new BasicDBObject(); //构建查询条件 for(int i=0; i<keys.length; i++){ //填充查询条件 queryObj.put(keys[i], values[i]); } cursor = dbCollection.find(queryObj); //查询获取数据 int count = 0; if(num != -1){ //判断是否是返回全部数据，num=-1返回查询全部数据，num!=-1则返回指定的num数据 while(count<num && cursor.hasNext()){ resultList.add(cursor.next()); count++; } return resultList; }else{ while(cursor.hasNext()){ resultList.add(cursor.next()); } return resultList; } } catch (Exception e) { // TODO: handle exception } finally{ if(null != cursor){ cursor.close(); } if(null != db){ db.requestDone(); //关闭数据库请求 } } } } return resultList; } @Override public DBCollection getCollection(String dbName, String collectionName) { // TODO Auto-generated method stub return mongoClient.getDB(dbName).getCollection(collectionName); } @Override public DB getDb(String dbName) { // TODO Auto-generated method stub return mongoClient.getDB(dbName); } @Override public boolean inSert(String dbName, String collectionName, String[] keys, Object[] values) { DB db = null; DBCollection dbCollection = null; WriteResult result = null; String resultString = null; if(keys!=null && values!=null){ if(keys.length != values.length){ return false; }else{ db = mongoClient.getDB(dbName); //获取数据库实例 dbCollection = db.getCollection(collectionName); //获取数据库中指定的collection集合 BasicDBObject insertObj = new BasicDBObject(); for(int i=0; i<keys.length; i++){ //构建添加条件 insertObj.put(keys[i], values[i]); } try { result = dbCollection.insert(insertObj); resultString = result.getError(); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); }finally{ if(null != db){ db.requestDone(); //请求结束后关闭db } } return (resultString != null) ? false : true; } } return false; } @Override public boolean isExit(String dbName, String collectionName, String key, Object value) { // TODO Auto-generated method stub DB db = null; DBCollection dbCollection = null; if(key!=null && value!=null){ try { db = mongoClient.getDB(dbName); //获取数据库实例 dbCollection = db.getCollection(collectionName); //获取数据库中指定的collection集合 BasicDBObject obj = new BasicDBObject(); //构建查询条件 obj.put(key, value); if(dbCollection.count(obj) > 0) { return true; }else{ return false; } } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } finally{ if(null != db){ db.requestDone(); //关闭db db = null; } } } return false; } @Override public boolean update(String dbName, String collectionName, DBObject oldValue, DBObject newValue) { DB db = null; DBCollection dbCollection = null; WriteResult result = null; String resultString = null; if(oldValue.equals(newValue)){ return true; }else{ try { db = mongoClient.getDB(dbName); //获取数据库实例 dbCollection = db.getCollection(collectionName); //获取数据库中指定的collection集合 result = dbCollection.update(oldValue, newValue); resultString = result.getError(); return (resultString!=null) ? false : true; } catch (Exception e) { // TODO: handle exception e.printStackTrace(); } finally{ if(null != db){ db.requestDone(); //关闭db db = null; } } } return false; } /** * 方法名：main * 作者：zhouyh * 创建时间：2014-8-30 下午04:21:11 * 描述：TODO(这里用一句话描述这个方法的作用) * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub } } 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316
.NET C#操作MongoDB异常
• oughl0007

2

2
帖子

193
浏览



@oughl0007 說：

PersonEntity user2 = mongoCollection.FindAs(query).FirstOrDefault(); textBox1.Text += user2.name; //到這行報錯了，提示未將對象引用到對象實例

應該是沒查找到資料. user2 返回 null
C#操作MongoDB返回的数据集怎么反射为对象模型
• oughl0007

1

1
帖子

145
浏览



有个c#项目中使用到了MongoDB，比如有一个简单的查询，然后使用

var filter = Builders.Filter.Eq("_id", new ObjectId(rid));
var collection = MongoManager.getSingleton().getCollection(MongoManager.cycleCollect);
var queryResult = collection.Find(filter).ToJson();

var jsonObj = JsonConvert.DeserializeObject(queryResult); ```

怎么样把通过find方法找到的数据反射成为对象好方便后续操作，
使用.toJson()方法出来的并不是数据，求指教！
S

Upsert方法
• seal

3

3
帖子

784
浏览



@尖尖角
結果跳過去又要跳回來
S

Slice沒有效果
• seal

2

2
帖子

194
浏览



@seal
試看看
.Project(BsonDocument.Parse("{ x: {$slice: ['$comments', 2,3]} } "))
1

MS SQL 轉換MongoDB軟件推薦
• 15816

4

4
帖子

214
浏览



楼上看起来是蛮好用的工具，

不过，我觉得RDB和mongoDB整体是不太一样概念，直接这样转很方便，但或许再使用数据就不是那么方便了
M

Command findAndModify failed: The _id field cannot be changed from {_id: ObjectId('58e8d0749c10fd28e48d7211')} to {_id: ObjectId('000000000000000000000000')}..
• machao

4

4
帖子

275
浏览



用法看起來沒錯，先看看傳進來的參數 item 資料是不是含有 _id，有的話把他拿掉試試
.NET C# 下調用MongoDB連結的方法
• Fredyang

4

4
帖子

1527
浏览



這篇應該是舊了... 新版應該是用 MongoClient 建立連線
mongodb Server instance {0} is no longer connected
• jesseshi

1

1
帖子

168
浏览



C# 连接MongoDB 一段时间后报mongodb Server instance {0} is no longer connected 是怎么回事呢？
C#指定mongoid问题
• x4_965be

2

2
帖子

315
浏览



这个东西其实自己根据业务需求自定义生成，只要不冲突即可。但是要达到不冲突又淡何容易，尤其是分布式的资料库。所以，既然mongo已提供了此方法，那就直接用吧。没必要重新做轮子。
S

Solved 新增/更新數據後取得ObjectId
• seal

3

3
帖子

301
浏览

S

@22265
可以了，非常感謝
MongoDB aggregate 运用以及在C#对应方法
• F3218466

7

7
帖子

4154
浏览



@JasonChen 说：

查出的結果差過16M就無法查詢

請教這句話的意思是?
J

C# 連結 MongoDB 說明
• JasonChen

2

2
帖子

555
浏览

S

如果要用到GridFS的話，要記得一起安裝喔
Install-Package MongoDB.Driver.GridFS
S

MongoDB .NET Driver 2.4.2 C# 連接方式
• seal

9

9
帖子

2064
浏览

J

範例很多啊

本帖下載内容已隐藏，请登入以查看隐藏内容！

都是
请问在C#中使用MapReduce时如何定义查询过滤条件
• Silence_wen

2

2
帖子

567
浏览

J

@Silence_wen 姐针对时间日期范围类的查询如何编写？
可以使用下列語句：代表在runtime的那個參數，挑選出後面兩個時間點內的結果集。
{ RunTime: {$gt: ISODate("2017-02-07T00:00:04.989Z"), $lte: ISODate("2017-02-07T00:00:06.000Z")} }
(转)C#开发Mongo笔记第三篇
• x4_965be

1

1
帖子

389
浏览



本文转自www.cnblogs.com，作者为晨冬之雪。
今天主要测试了一下查询功能了，当然了主要还是为了让查询可以和我们平时使用的实体对象关联起来，并且那些BsonDocument和Collection我们操作起来不是太方便的。

还是首先定义了一个用户类，注意这个类需要和mongo中的对象的字段完全匹配，包括大小写，不然查询的时候会出现字段无法匹配的错误。
public class User
{
     public ObjectId Id { get; set; }
     public string Name { get; set; }
     public int Age { get; set; }
}
有了实体类就是怎么让查询结果和实体类关联起来了，

   var list=     collection.FindAllAs<User>();

主要是在findAllAs的时候查出来一个泛型集合，但是这个集合无法转成List集合（当然了，是我不会转，还希望会转的拍砖），它返回的集合是MongoCurror类型的，操作起来也不方便，干脆就用弱类型接收吧。

值得欣慰的是这个集合在遍历的时候可以转换成User对象。

最大的好消息是在对这个集合查询的时候支持linq查询，是不是太强大了，让我们一起欢呼吧！！
MongoDatabase db = MongoHelper.GetConnection();
MongoCollection collection = db.GetCollection<User>("user");
User user = new User();
user.Name = "lisi";
user.Age = 20;
collection.Insert<User>(user);
var list= collection.FindAllAs<User>();
foreach (User item in list.Where(u=>u.Name=="lisi"))
{
     Response.Write(item.Name);
}
//删除
// collection.Remove(new QueryDocument());代码都很简单，主要是测试了一个把查询结果转成对象和一个linq条件查询。
S

Solved BsonDocument可以存放List嗎
• seal

2

2
帖子

590
浏览



MongoDB的C# driver其实有实现类似于ORM的功能。即可以在BsonDocument和你自定义的Class之间做mapping，本帖下載内容已隐藏，请登入以查看隐藏内容！。
编码过程中使用Class比BsonDocument通常要来得方便，建议为常用的document定义成class，这样可避免你的问题。

1 / 2

C#使用Mongodb帮助类来注册及登录，欢迎吐槽，肯定有需要修改及优化的地方，不吝赐教 • 做自己

C#操作mongodb帮助类，WriteConcernResult result= collection.Insert<T>(model)这个方法返回为null,不理解 • 做自己

(转)C#开发Mongo笔记第一篇 • x4_965be

MongoDB的连接池和连接管理 • F3218466

.NET C#操作MongoDB异常 • oughl0007

C#操作MongoDB返回的数据集怎么反射为对象模型 • oughl0007

Upsert方法 • seal

Slice沒有效果 • seal

MS SQL 轉換MongoDB軟件推薦 • 15816

Command findAndModify failed: The _id field cannot be changed from {_id: ObjectId('58e8d0749c10fd28e48d7211')} to {_id: ObjectId('000000000000000000000000')}.. • machao

.NET C# 下調用MongoDB連結的方法 • Fredyang

mongodb Server instance {0} is no longer connected • jesseshi

C#指定mongoid问题 • x4_965be

Solved 新增/更新數據後取得ObjectId • seal

MongoDB aggregate 运用以及在C#对应方法 • F3218466

​C# 連結 MongoDB 說明 • JasonChen

MongoDB .NET Driver 2.4.2 C#​ 連接方式 • seal

请问在C#中使用MapReduce时如何定义查询过滤条件 • Silence_wen

(转)C#开发Mongo笔记第三篇 • x4_965be

Solved BsonDocument可以存放List嗎 • seal

C#使用Mongodb帮助类来注册及登录，欢迎吐槽，肯定有需要修改及优化的地方，不吝赐教
• 做自己

C#操作mongodb帮助类，WriteConcernResult result= collection.Insert<T>(model)这个方法返回为null,不理解
• 做自己

(转)C#开发Mongo笔记第一篇
• x4_965be

MongoDB的连接池和连接管理
• F3218466

.NET C#操作MongoDB异常
• oughl0007

C#操作MongoDB返回的数据集怎么反射为对象模型
• oughl0007

Upsert方法
• seal

Slice沒有效果
• seal

MS SQL 轉換MongoDB軟件推薦
• 15816

Command findAndModify failed: The _id field cannot be changed from {_id: ObjectId('58e8d0749c10fd28e48d7211')} to {_id: ObjectId('000000000000000000000000')}..
• machao

.NET C# 下調用MongoDB連結的方法
• Fredyang

mongodb Server instance {0} is no longer connected
• jesseshi

C#指定mongoid问题
• x4_965be

Solved 新增/更新數據後取得ObjectId
• seal

MongoDB aggregate 运用以及在C#对应方法
• F3218466

C# 連結 MongoDB 說明
• JasonChen

MongoDB .NET Driver 2.4.2 C# 連接方式
• seal

请问在C#中使用MapReduce时如何定义查询过滤条件
• Silence_wen

(转)C#开发Mongo笔记第三篇
• x4_965be

Solved BsonDocument可以存放List嗎
• seal