ASP.NET6 + Mongo + OData
准备工作[*]Docker环境
[*]Mongo数据库
[*]配置Mongo数据库
ASP.NET6 集成Mongo
安装MongoDB.Driver
https://cdn.nlark.com/yuque/0/2023/png/359374/1676126308713-cc93b0e1-4146-4399-85b9-7d202e8d0454.png#averageHue=%232a2827&clientId=ue5b8b7ba-894d-4&from=ui&id=udac72e12&name=QQ%E6%88%AA%E5%9B%BE20230211223816.png&originHeight=528&originWidth=496&originalType=binary&ratio=1.25&rotation=0&showTitle=false&size=40188&status=done&style=none&taskId=u2b8ea11d-f720-448c-9577-28c95bc5de3&title=
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"BookStoreDatabase": {
"ConnectionString": "mongodb://localhost",
"DatabaseName": "BookStore",
"BooksCollectionName": "Books"
},
"AllowedHosts": "*"
}public class BookStoreDatabaseSettings
{
public string ConnectionString { get; set; } = null!;
public string DatabaseName { get; set; } = null!;
public string BooksCollectionName { get; set; } = null!;
}using MongoDB.Bson;
using MongoDB.Bson.Serialization.Attributes;
namespace MongoExample.Models;
public class Book
{
public string? Id { get; set; }
public string BookName { get; set; } = null!;
public decimal Price { get; set; }
public string Category { get; set; } = null!;
public string Author { get; set; } = null!;
}using MongoDB.Driver;
using MongoExample.Models;
using Microsoft.Extensions.Options;
namespace MongoExample.Services;
public class BookService
{
private readonly IMongoCollection<Book> _bookCollection;
public BookService(IOptions<BookStoreDatabaseSettings> bookStoreDatabaseSettings)
{
var mongoClient = new MongoClient("mongodb://admin:000000@localhost:27017");
var mongoDatabase = mongoClient.GetDatabase(bookStoreDatabaseSettings.Value.DatabaseName);
_bookCollection = mongoDatabase.GetCollection<Book>(bookStoreDatabaseSettings.Value.BooksCollectionName);
}
public async Task<List<Book>> GetBooksAsync() => await _bookCollection.Find(_ => true).ToListAsync();
public async Task<Book> GetBookAsync(string id) => await _bookCollection.Find(x=>x.Id == id).FirstOrDefaultAsync();
public async Task CreateAsync(Book book) => await _bookCollection.InsertOneAsync(book);
public async Task UpdateAsync(string id, Book updatedBook) => await _bookCollection.ReplaceOneAsync(x=>x.Id == id, updatedBook);
public async Task RemoveAsync(string id) => await _bookCollection.DeleteOneAsync(x=>x.Id ==id);
}using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.OData.Query;
using MongoExample.Models;
using MongoExample.Services;
namespace MongoExample.Controllers;
")]
public class BooksController : ControllerBase
{
private readonly BookService _bookService;
public BooksController(BookService bookService)
{
this._bookService = bookService;
}
public async Task<List<Book>> Get() => await _bookService.GetBooksAsync();
public async Task<ActionResult<Book>> GetBook(string id)
{
var book = await _bookService.GetBookAsync(id);
if (book == null)
{
return NotFound();
}
return book;
}
public async Task<ActionResult> Create(Book book)
{
await _bookService.CreateAsync(book);
return CreatedAtAction("Get", new { id = book.Id }, book);
}
public async Task<IActionResult> Update(string id, Book updatedBook)
{
var book = await _bookService.GetBookAsync(id);
if (book == null)
{
return NotFound();
}
updatedBook.Id = book.Id;
await _bookService.UpdateAsync(id, updatedBook);
return NoContent();
}
public async Task<IActionResult> Delete(string id)
{
var book = await _bookService.GetBookAsync(id);
if (book == null)
{
return NotFound();
}
await _bookService.RemoveAsync(id);
return NoContent();
}
}ASP.NET6 集成OData
VS22022基于.NET6基础上创建的asp.net core web api模板已经合并了Startup和Program类， 所有的服务注入，中间件注入都合并在了Program类中， 好久没写C#了，这个类这次变化有点大。
安装OData
https://cdn.nlark.com/yuque/0/2023/png/359374/1676126245318-faf975d4-abde-4400-9891-2a6f4feae553.png#averageHue=%232b2827&clientId=ue5b8b7ba-894d-4&from=ui&id=uee3aafee&name=QQ%E6%88%AA%E5%9B%BE20230211223710.png&originHeight=495&originWidth=492&originalType=binary&ratio=1.25&rotation=0&showTitle=false&size=37676&status=done&style=none&taskId=u2dccbf15-49f8-41ca-97aa-c550f6aa612&title=
合并后的模板只有Program.cs类，没有了Startup类，也就是之前的服务注入都是通过ConfigServices方法，IServiceCollection实现。 如果不习惯的话也可以自己手动创建一个Startup类，然后在Program类中调用该类。
using Microsoft.AspNetCore.OData;
using MongoExample.Models;
using MongoExample.Services;
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddControllers();
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();
builder.Services.Configure<BookStoreDatabaseSettings>(builder.Configuration.GetSection("BookStoreDatabase"));
builder.Services.AddSingleton<BookService>();
//这里注入OData查询方法
builder.Services.AddControllers().AddOData(options => options.Select().Filter().OrderBy());
var app = builder.Build();
if (app.Environment.IsDevelopment())
{
app.UseSwagger();
app.UseSwaggerUI();
}
app.UseAuthorization();
app.MapControllers();
app.Run();测试OData Query
查询Category和BookName字段
http://localhost:5220/api/books?$select=Category,BookName
响应JSON值
[{"Category":"Computer","BookName":"Design Patters"},{"Category":"Software","BookName":"Java In Action"},{"Category":"Software","BookName":"C# In Action"}]查询Category和BookName字段并且用Category倒叙排列
[{"Category":"Software","BookName":"Java In Action"},{"Category":"Software","BookName":"C# In Action"},{"Category":"Computer","BookName":"Design Patters"}]
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！
页:
[1]