{"MongoConnection": {"ConnectionString": "mongodb://admin:abc123!@localhost","Database": "NotesDb"},"Logging": {"IncludeScopes": false,"Debug": {"LogLevel": {"Default": "Warning"}},"Console": {"LogLevel": {"Default": "Warning"}}}
}

依赖注入和选项模型

namespace NotebookAppApi.Model
{public class Settings{public string ConnectionString;public string Database;}
}

这是我们修改Startup.cs以便在Options访问器模型中注入设置的方法：

public void ConfigureServices(IServiceCollection services)
{// Add framework services.services.AddMvc();services.Configure<Settings>(options =>{options.ConnectionString = Configuration.GetSection("MongoConnection:ConnectionString").Value;options.Database = Configuration.GetSection("MongoConnection:Database").Value;});
}

此外，在项目中，可以通过IOptions接口访问设置：

IOptions<Settings>

MongoDB配置

systemLog:destination: filepath: "C:\\tools\\mongodb\\db\\log\\mongo.log"logAppend: true
storage:dbPath: "C:\\tools\\mongodb\\db\\data"

在命令提示符下运行。这将启动MongoDB服务器，指向已经创建的配置文件（如果服务器安装在自定义文件夹中，请首先更新命令）

"C:\Program Files\MongoDB\Server\3.2\bin\mongod.exe" --config C:\Dev\Data.Config\mongod.cfg

服务器启动后（您可以在日志文件中看到详细信息），在命令提示符下运行mongo.exe 。下一步是将管理员用户添加到数据库中。使用完整路径运行mongodb（例如：“C:\Program Files\MongoDB\Server\3.2\bin\mongo.exe”）。

use admin
db.createUser({user: "admin",pwd: "abc123!",roles: [ { role: "root", db: "admin" } ]}
);
exit;

然后停止服务器并更新配置文件，包括安全选项。

systemLog:destination: filepath: "C:\\tools\\mongodb\\db\\log\\mongo.log"logAppend: true
storage:dbPath: "C:\\tools\\mongodb\\db\\data"
security:authorization: enabled

从现在开始，我们将使用管理员用户连接到MongoDb 。有一个很好的做法，就是不要在正常操作中使用超级用户角色（在我们的案例中为Administrator），但是为了使事情变得简单，我们将继续只有一个用户。

using System;
using MongoDB.Bson.Serialization.Attributes;namespace NotebookAppApi.Model
{public class Note{[BsonId]// standard BSonId generated by MongoDbpublic ObjectId InternalId { get; set; }// external Id, easier to reference: 1,2,3 or A, B, C etc.public string Id { get; set; }                          public string Body { get; set; } = string.Empty;[BsonDateTimeOptions]// attribute to gain control on datetime serializationpublic DateTime UpdatedOn { get; set; } = DateTime.Now;public NoteImage HeaderImage { get; set; }public int UserId { get; set; } = 0;}
}

注意：默认情况下，使用参数 BsonDateTimeOptions，Bson序列化程序尝试将序列化为DateTime和UTC。如下添加特性[BsonDateTimeOptions(Kind = DateTimeKind.Local)]，我们允许保存本地时间：

public class NoteImage
{public string Url { get; set; } = string.Empty;public string ThumbnailUrl { get; set; } = string.Empty;public long ImageSize { get; set; } = 0L;
}

定义数据库上下文

public class NoteContext
{private readonly IMongoDatabase _database = null;public NoteContext(IOptions<Settings> settings){var client = new MongoClient(settings.Value.ConnectionString);if (client != null)_database = client.GetDatabase(settings.Value.Database);}public IMongoCollection<Note> Notes{get{return _database.GetCollection<Note>("Note");}}
}

添加存储库

public interface INoteRepository
{Task<IEnumerable<Note>> GetAllNotes();Task<Note> GetNote(string id);// query after multiple parametersTask<IEnumerable<Note>> GetNote(string bodyText, DateTime updatedFrom, long headerSizeLimit);// add new note documentTask AddNote(Note item);// remove a single document / noteTask<bool> RemoveNote(string id);// update just a single document / noteTask<bool> UpdateNote(string id, string body);// demo interface - full document updateTask<bool> UpdateNoteDocument(string id, string body);// should be used with high cautious, only in relation with demo setupTask<bool> RemoveAllNotes();
}

对数据库的访问将是异步的。我们在这里使用新的驱动程序，它提供了完整的异步堆栈。

public async Task<IEnumerable<Note>> GetAllNotes()
{var documents = await _context.Notes.Find(_ => true).ToListAsync();return documents;
}

这是所有基本CRUD操作的完整实现：

public class NoteRepository : INoteRepository
{private readonly NoteContext _context = null;public NoteRepository(IOptions<Settings> settings){_context = new NoteContext(settings);}public async Task<IEnumerable<Note>> GetAllNotes(){try{return await _context.Notes.Find(_ => true).ToListAsync();}catch (Exception ex){// log or manage the exceptionthrow ex;}}// query after Id or InternalId (BSonId value)//public async Task<Note> GetNote(string id){try{ObjectId internalId = GetInternalId(id);return await _context.Notes.Find(note => note.Id == id || note.InternalId == internalId).FirstOrDefaultAsync();}catch (Exception ex){// log or manage the exceptionthrow ex;}}// query after body text, updated time, and header image size//public async Task<IEnumerable<Note>> GetNote(string bodyText, DateTime updatedFrom, long headerSizeLimit){try{var query = _context.Notes.Find(note => note.Body.Contains(bodyText) &&note.UpdatedOn >= updatedFrom &&note.HeaderImage.ImageSize <= headerSizeLimit);return await query.ToListAsync();}catch (Exception ex){// log or manage the exceptionthrow ex;}}private ObjectId GetInternalId(string id){ObjectId internalId;if (!ObjectId.TryParse(id, out internalId))internalId = ObjectId.Empty;return internalId;}public async Task AddNote(Note item){try{await _context.Notes.InsertOneAsync(item);}catch (Exception ex){// log or manage the exceptionthrow ex;}}public async Task<bool> RemoveNote(string id){try{DeleteResult actionResult = await _context.Notes.DeleteOneAsync(Builders<Note>.Filter.Eq("Id", id));return actionResult.IsAcknowledged && actionResult.DeletedCount > 0;}catch (Exception ex){// log or manage the exceptionthrow ex;}}public async Task<bool> UpdateNote(string id, string body){var filter = Builders<Note>.Filter.Eq(s => s.Id, id);var update = Builders<Note>.Update.Set(s => s.Body, body).CurrentDate(s => s.UpdatedOn);try{UpdateResult actionResult = await _context.Notes.UpdateOneAsync(filter, update);return actionResult.IsAcknowledged&& actionResult.ModifiedCount > 0;}catch (Exception ex){// log or manage the exceptionthrow ex;}}public async Task<bool> UpdateNote(string id, Note item){try{ReplaceOneResult actionResult = await _context.Notes.ReplaceOneAsync(n => n.Id.Equals(id), item, new UpdateOptions { IsUpsert = true });return actionResult.IsAcknowledged&& actionResult.ModifiedCount > 0;}catch (Exception ex){// log or manage the exceptionthrow ex;}}// Demo function - full document updatepublic async Task<bool> UpdateNoteDocument(string id, string body){var item = await GetNote(id) ?? new Note();item.Body = body;item.UpdatedOn = DateTime.Now;return await UpdateNote(id, item);}public async Task<bool> RemoveAllNotes(){try{DeleteResult actionResult = await _context.Notes.DeleteManyAsync(new BsonDocument());return actionResult.IsAcknowledged&& actionResult.DeletedCount > 0;}catch (Exception ex){// log or manage the exceptionthrow ex;}}
}

为了使用DI模型访问NoteRepository，我们在ConfigureServices中添加了一行

services.AddTransient<INoteRepository, NoteRepository>();

其中：

[Produces("application/json")]
[Route("api/[controller]")]
public class NotesController : Controller
{private readonly INoteRepository _noteRepository;public NotesController(INoteRepository noteRepository){_noteRepository = noteRepository;}[NoCache][HttpGet]public async Task<IEnumerable<Note>> Get(){return await _noteRepository.GetAllNotes();}// GET api/notes/5 - retrieves a specific note using either Id or InternalId (BSonId)[HttpGet("{id}")]public async Task<Note> Get(string id){return await _noteRepository.GetNote(id) ?? new Note();}// GET api/notes/text/date/size// ex: http://localhost:53617/api/notes/Test/2018-01-01/10000[NoCache][HttpGet(template: "{bodyText}/{updatedFrom}/{headerSizeLimit}")]public async Task<IEnumerable<Note>> Get(string bodyText, DateTime updatedFrom, long headerSizeLimit){return await _noteRepository.GetNote(bodyText, updatedFrom, headerSizeLimit) ?? new List<Note>();}// POST api/notes - creates a new note[HttpPost]public void Post([FromBody] NoteParam newNote){_noteRepository.AddNote(new Note{Id = newNote.Id,Body = newNote.Body,CreatedOn = DateTime.Now,UpdatedOn = DateTime.Now,UserId = newNote.UserId});}// PUT api/notes/5 - updates a specific note[HttpPut("{id}")]public void Put(string id, [FromBody]string value){_noteRepository.UpdateNoteDocument(id, value);}// DELETE api/notes/5 - deletes a specific note[HttpDelete("{id}")]public void Delete(string id){_noteRepository.RemoveNote(id);}
}

添加管理员控制器

[Route("api/[controller]")]
public class SystemController : Controller
{private readonly INoteRepository _noteRepository;public SystemController(INoteRepository noteRepository){_noteRepository = noteRepository;}// Call an initialization - api/system/init[HttpGet("{setting}")]public string Get(string setting){if (setting == "init"){_noteRepository.RemoveAllNotes();var name = _noteRepository.CreateIndex();_noteRepository.AddNote(new Note(){Id = "1",Body = "Test note 1",UpdatedOn = DateTime.Now,UserId = 1,HeaderImage = new NoteImage{ImageSize = 10,Url = "http://localhost/image1.png",ThumbnailUrl = "http://localhost/image1_small.png"}});_noteRepository.AddNote(new Note(){Id = "2",Body = "Test note 2",UpdatedOn = DateTime.Now,UserId = 1,HeaderImage = new NoteImage{ImageSize = 13,Url = "http://localhost/image2.png",ThumbnailUrl = "http://localhost/image2_small.png"}});_noteRepository.AddNote(new Note(){Id = "3",Body = "Test note 3",UpdatedOn = DateTime.Now,UserId = 1,HeaderImage = new NoteImage{ImageSize = 14,Url = "http://localhost/image3.png",ThumbnailUrl = "http://localhost/image3_small.png"}});_noteRepository.AddNote(new Note(){Id = "4",Body = "Test note 4",UpdatedOn = DateTime.Now,UserId = 1,HeaderImage = new NoteImage{ImageSize = 15,Url = "http://localhost/image4.png",ThumbnailUrl = "http://localhost/image4_small.png"}});return "Database NotesDb was created, and collection 'Notes' was filled with 4 sample items";}return "Unknown";}
}

启动设定

{"iisSettings": {"windowsAuthentication": false,"anonymousAuthentication": true,"iisExpress": {"applicationUrl": "http://localhost:53617/","sslPort": 0}},"profiles": {"IIS Express": {"commandName": "IISExpress","launchBrowser": true,"launchUrl": "api/notes","environmentVariables": {"ASPNETCORE_ENVIRONMENT": "Development"}},"NotebookAppApi": {"commandName": "Project","launchBrowser": true,"launchUrl": "http://localhost:5000/api/notes","environmentVariables": {"ASPNETCORE_ENVIRONMENT": "Development"}}}
}

运行项目

public void ConfigureServices(IServiceCollection services)
{// Add service and create Policy with optionsservices.AddCors(options => { options.AddPolicy("CorsPolicy",builder => builder.AllowAnyOrigin().AllowAnyMethod().AllowAnyHeader().AllowCredentials());});// ....services.AddMvc();
}

public void Configure(IApplicationBuilder app)
{// ...// global policy, if assigned here (it could be defined individually for each controller)app.UseCors("CorsPolicy");// ...// We define UseCors() BEFORE UseMvc, below just a partial callapp.UseMvc(routes => {
}

即使可以更进一步，更有选择性地应用它，本文其余部分也保持不变。

public async Task<ReplaceOneResult> UpdateNote(string id, Note item)
{return await _context.Notes.ReplaceOneAsync(n => n.Id.Equals(id), item, new UpdateOptions { IsUpsert = true });
}

测试更新

public async Task<IEnumerable<Note>> GetAllNotes()
{try{return await _context.Notes.Find(_ => true).ToListAsync();}catch (Exception ex){// log or manage the exceptionthrow ex;}
}

通过这种方式，我们通过使用await异步地等待有故障的任务来完成它。这将重新引发原始存储的异常。

public async Task AddNote(Note item)
{try{await _context.Notes.InsertOneAsync(item);}catch (Exception ex){// log or manage the exceptionthrow ex;}
}

.NET Core中的JSON POST的模型绑定

[HttpPost]
public void Post([FromBody] NoteParam newNote)

要添加新的Note，我们首先需要将Content-Type设置为application/json。

note.UpdatedOn >= updatedFrom && note.HeaderImage.ImageSize <= headerSizeLimit

使用IIS Express访问应用程序，我们可以使用Get函数，该函数包含所有带有Test的注释，该注释在2018-01-01之后创建，并且大小小于10000。项目启动后，可以使用浏览器中的下一个URL调用此函数：http://localhost:53617/api/notes/Test/2018-01-01/10000。