带有C＃驱动程序2.0的MongoDB（服务器v 2.6.7）：如何从InsertOneAsync获取结果

4 回答

• 0

  继@JonnyHK回复后，你可以在插入很多时做同样的事情 .

  collection.InsertManyAsync(doc, new InsertManyOptions { IsOrdered = false }).Wait();
  

  将被包装在try / catch中;

  try
  {
      collection.InsertManyAsync(doc, new InsertManyOptions { IsOrdered = false }).Wait();
  }
  catch (AggregateException aggEx)
  {
      aggEx.Handle(x =>
      {
          var mwx = x as MongoBulkWriteException;
          return mwx != null && mwx.WriteErrors.All(e => e.Category == ServerErrorCategory.DuplicateKey);
      });
  }
  

  回复于 2024-05-19T12:10:53+08:00
• 11

  如果您在 async 方法中执行此操作，那么Brduca的答案将起作用（并且是可取的），否则您可以在 InsertOneAsync 调用返回的 Task 上调用Wait()，以确保您的应用程序保持足够长的时间以查看重复的键异常：

  commandsCollection.InsertOneAsync(doc).Wait();
  

  如果插入因重复键而失败， Wait() 将抛出 AggregateException ，其中包含 MongoWriteException ，其中包含重复的键详细信息 .

  try
  {
      commandsCollection.InsertOneAsync(doc).Wait();
  }
  catch(AggregateException aggEx)
  {
      aggEx.Handle(x => 
      { 
          var mwx = x as MongoWriteException;
          if (mwx != null && mwx.WriteError.Category == ServerErrorCategory.DuplicateKey) 
          {
              // mwx.WriteError.Message contains the duplicate key error message
              return true; 
          }
          return false;
      });
  }
  

  同样，如果您使用 await ，那么也会抛出 AggregateException .

  为了避免包含mongo异常的 AggregateException 的复杂性，可以调用 GetAwaiter().GetResult() 而不是 Wait() ：

  try
  {
      commandsCollection.InsertOneAsync(doc).GetAwaiter().GetResult();
  }
  catch(MongoWriteException mwx)
  {
      if (mwx.WriteError.Category == ServerErrorCategory.DuplicateKey) 
      {
          // mwx.WriteError.Message contains the duplicate key error message
      }
  }
  

  回复于 2024-05-19T12:10:53+08:00
• 2

  这是一个异步任务，你错过了等待

  await commandsCollection.InsertOneAsync(bson);
  

  https://github.com/mongodb/mongo-csharp-driver/blob/master/README.md

  回复于 2024-05-19T12:10:53+08:00
• 1

  我正在使用VS 2015并尝试使用InsertOne / InsertOneAsync添加数据，但都没有工作 .

  代码在这里：//使用连接字符串_client = new MongoClient（）创建一个MongoClient对象;

  //Use the MongoClient to access the server
          _database = _client.GetDatabase("ratednext");
  
          //get mongodb collection
  
          var Collec = _database.GetCollection<BsonDocument>("computers");
          var documnt = new BsonDocument
          {
              {"Brand","Dell"},
              {"Price","400"},
              {"Ram","8GB"},
              {"HardDisk","1TB"},
              {"Screen","16inch"}
          };
          try
          {
              Collec.InsertOneAsync(documnt).GetAwaiter().GetResult();
          }
          catch (AggregateException aggEx)
          {
              aggEx.Handle(x =>
              {
                  var mwx = x as MongoWriteException;
                  if (mwx != null && mwx.WriteError.Category == ServerErrorCategory.DuplicateKey)
                  {
                      // mwx.WriteError.Message contains the duplicate key error message
                      return true;
                  }
                  return false;
              });
          }
  

  回复于 2024-05-19T12:10:53+08:00