一、Mongodb的基本概念
1.Mongodb的數(shù)據(jù)結(jié)構(gòu)
2.Mongodb數(shù)據(jù)類型
MongoDB的最小存儲單位就是文檔(document)對象。文檔(document)對象對應(yīng)于關(guān)系型數(shù)據(jù)庫的行。數(shù)據(jù)在MongoDB中以BSON（Binary-JSON）文檔的格式存儲在磁盤上。
BSON（Binary Serialized Document Format）是一種類json的一種二進(jìn)制形式的存儲格式，簡稱Binary JSON。BSON和JSON一樣，支持內(nèi)嵌的文檔對象和數(shù)組對象，但是BSON有JSON沒有的一些數(shù)據(jù)類型，如Date和BinData類型。
二、Mongodb的代碼封裝
1.配置文件
{ "Logging": { "LogLevel": { "Default": "Information", "Microsoft": "Warning", "Microsoft.Hosting.Lifetime": "Information" } }, "ProductMongoDBOptions": { "ConnectionString": "mongodb://localhost:27017", "DatabaseName": "ProductDb_3", "ProductCollectionName": "Product_3" }, "AllowedHosts": "*" }
2.擴(kuò)展類
/// /// MongoDB擴(kuò)展方法 /// public static class MongoDBServiceCollectionExtensions { public static IServiceCollection AddMongoDB(this IServiceCollection services, IConfiguration Configuration) { // 1、獲取配置文件數(shù)據(jù) ProductMongoDBOptions productMongoDBOptions = (ProductMongoDBOptions)Configuration.GetSection(nameof(ProductMongoDBOptions)); // 1、建立MongoDB連接 var client = new MongoClient(productMongoDBOptions.ConnectionString); // 2、獲取商品庫 var database = client.GetDatabase(productMongoDBOptions.DatabaseName); // 3、獲取商品表(集合) var _products = database.GetCollection(productMongoDBOptions.ProductCollectionName); services.AddSingleton(_products); return services; } }
3.注入擴(kuò)展類
services.AddMongoDB();
4.使用
4.1 相關(guān)依賴
public class Product { [BsonId] [BsonRepresentation(BsonType.ObjectId)] public string Id { set; get; } public string ProductCode { set; get; } //商品編碼 public string ProductUrl { set; get; } // 商品主圖 public string ProductTitle { set; get; } //商品標(biāo)題 public string ProductDescription { set; get; } // 圖文描述 public decimal ProductVirtualprice { set; get; } // 商品虛擬價格 public decimal ProductPrice { set; get; } //價格 public int ProductSort { set; get; } //商品序號 public int ProductSold { set; get; } //已售件數(shù) public int ProductStock { set; get; } //商品庫存 public string ProductStatus { set; get; } // 商品狀態(tài) public int score { set; get; } //商品級別 }
public interface IProductService { void Create(Product Product); public void CreateList(List Products); IEnumerable GetProducts(); Product GetProductById(string id); public IEnumerable GetProductsByPage(int Page, int PageSize); public IEnumerable GetProductsBySort(Product product, int Page, int PageSize); public IEnumerable GetProductsByAggregation(Product product); void Update(string id,Product Product); public void UpdateList(string id, Product Product); // 更新字段 public void UpdateFiled(string id, ProductUpdateFiledDto productUpdateFiledDto); void Delete(Product Product); public void DeleteList(Product Product); bool ProductExists(string id); // 字段修改 public void Replace(string id, Product Product); // 創(chuàng)建索引 public string CreateIndex(); }
/// /// 商品服務(wù)實(shí)現(xiàn) /// public class ProductService : IProductService { private readonly IMongoCollection _products; public ProductService( /* IMongoCollection products,*/ IConfiguration configuration/*,IOptions options*/) { // 1、建立MongoDB連接 //var client = new MongoClient("mongodb://localhost:27018,localhost:27019,localhost:27020"); var client = new MongoClient("mongodb://localhost:27000,localhost:27100"); // 2、獲取商品庫(自己創(chuàng)建商品數(shù)據(jù)) var database = client.GetDatabase("ProductDb"); // 3、獲取商品表(自己創(chuàng)建商品數(shù)) _products = database.GetCollection("Product"); // _products = products; } public void Create(Product Product) { _products.InsertOne(Product); } public void CreateList(List Products) { _products.InsertMany(Products); } public void Delete(Product Product) { _products.DeleteOne(product => product.Id == Product.Id); } public void DeleteList(Product Product) { _products.DeleteMany(product => product.Id == Product.Id); } public Product GetProductById(string id) { return _products.Find(product => product.Id == id).FirstOrDefault(); } public IEnumerable GetProducts() { return _products.Find(product => true).ToList(); } /// /// 商品不同字段獲取 /// /// public IEnumerable GetProductsFiled() { var filter = Builders.Filter; /* BsonDocument filter = new BsonDocument(); var collection = _mongoDatabase.GetCollection("ProductDb"); var s = collection.Find(filter).ToList(); using (var cursor = collection.FindAsync(filter).Result) { while (cursor.MoveNextAsync().Result) { var batch = cursor.Current; foreach (BsonDocument document in batch) { Console.WriteLine(document.ToJson()); } } }*/ return _products.Find(product => true).ToList(); } /*/// /// 商品數(shù)量查詢 /// /// /// public long GetCount(int Page, int PageSize) { var skip = (Page - 1) * PageSize; return _products.Count(); }*/ /// /// 商品分頁查詢 /// /// /// public IEnumerable GetProductsByPage(int Page,int PageSize) { var skip = (Page - 1) * PageSize; return _products.Find(x => true).Skip(skip).Limit(PageSize).ToList(); } /// /// 商品排序 /// /// /// public IEnumerable GetProductsBySort(Product product, int Page, int PageSize) { var skip = (Page - 1) * PageSize; return _products.Find(product => true).SortBy(product => product.ProductSort).ToList(); } /// /// 商品價格聚合查詢 /// /// /// public IEnumerable GetProductsByAggregation(Product product) { var filter = Builders.Filter; PipelineDefinition pipelineDefinitions = PipelineDefinition.Create("ProductPrice"); var ints = _products.Aggregate(pipelineDefinitions); while (ints.MoveNext()) { var test = ints.Current; return test; } return null; } /// /// 更新 /// /// /// public void Update(string id, Product Product) { var update = Builders.Update; _products.UpdateOne(product => product.Id == id, update.Set("ProductTitle", Product.ProductTitle)); } /// /// 更新字段(增加字段) /// /// /// public void UpdateFiled(string id, ProductUpdateFiledDto productUpdateFiledDto) { var update = Builders.Update; _products.UpdateOne(product => product.Id == id, update.AddToSet("ProductTest", productUpdateFiledDto.ProductLike)); } /// /// 批量更新 /// /// /// public void UpdateList(string id, Product Product) { var filter = Builders.Filter; var update = Builders.Update; _products.UpdateMany(product => product.ProductCode == Product.ProductCode, update.Set("ProductTitle", Product.ProductTitle)); } /// /// 創(chuàng)建索引 /// /// public string CreateIndex() { var indexKeys = Builders.IndexKeys; return _products.Indexes.CreateOne(indexKeys.Descending("ProductCode")); } // 原理 // 分片集群 // 分片復(fù)制集群 /// /// 替換 /// /// /// public void Replace(string id, Product Product) { _products.ReplaceOneAsync(x => x.Id == id, Product); } public bool ProductExists(string id) { Product product = _products.Find(product => product.Id == id).FirstOrDefault(); if (product != null) { return true; } return false; } }
4.使用
/// /// 商品控制器 /// [ApiController] [Route("Product")] public class ProductController : ControllerBase { private readonly ILogger _logger; private readonly IProductService _productService; public ProductController(ILogger logger, IProductService productService) { _logger = logger; _productService = productService; } /// /// 添加商品 /// /// /// [HttpPost] public ActionResult CreateProduct(Product product) { _productService.Create(product); return CreatedAtAction("GetProduct", new { id = product.Id }, product); } /// /// 批量添加商品 /// /// /// [HttpPost("ProductList")] public ActionResult CreateProductList(Product[] Products) { _productService.CreateList(Products.ToList()); return CreatedAtAction("GetProduct", Products); } /// /// 查詢商品列表 /// /// [HttpGet] public ActionResult> GetProducts() { return _productService.GetProducts().ToList(); } /// /// 商品單個商品 /// /// /// [HttpGet("{id}")] public ActionResult GetProduct(string id) { var product = _productService.GetProductById(id); if (product == null) { return NotFound(); } return product; } /// /// 商品分頁查詢 /// /// /// /// [HttpGet("Page")] public ActionResult> GetProductsByPage(int Page ,int PageSize) { return _productService.GetProductsByPage(Page, PageSize).ToList(); } [HttpGet("Aggregation")] public ActionResult> GetProductsByAggregation(Product product) { return _productService.GetProductsByAggregation(product).ToList(); } /// /// 修改商品 /// /// /// /// [HttpPut("{id}")] public IActionResult PutProduct(string id, Product product) { try { _productService.Update(id,product); } catch (Exception) { throw; } return NoContent(); } /// /// 修改商品 /// /// /// /// [HttpPut("UpdateField")] public IActionResult PutFieldProduct(string id, ProductUpdateFiledDto productUpdateFiledDto) { try { _productService.UpdateFiled(id, productUpdateFiledDto); } catch (Exception) { throw; } return NoContent(); } /// /// 商品文檔批量修改 /// /// /// /// [HttpPut("UpdateList")] public IActionResult PutProductList(string id, Product product) { try { _productService.UpdateList(id, product); } catch (Exception) { throw; } return NoContent(); } /// /// 刪除商品 /// /// /// [HttpDelete] public IActionResult DeletetProduct(Product product) { try { _productService.Delete(product); } catch (Exception) { throw; } return NoContent(); } // PUT: api/Products/5 [HttpPost("CreateIndex")] public IActionResult CreateIndex() { try { _productService.CreateIndex(); } catch (Exception) { throw; } return NoContent(); } }
.NET MongoDB 分布式
版權(quán)聲明：本文內(nèi)容由網(wǎng)絡(luò)用戶投稿，版權(quán)歸原作者所有，本站不擁有其著作權(quán)，亦不承擔(dān)相應(yīng)法律責(zé)任。如果您發(fā)現(xiàn)本站中有涉嫌抄襲或描述失實(shí)的內(nèi)容，請聯(lián)系我們jiasou666@gmail.com 處理，核實(shí)后本網(wǎng)站將在24小時內(nèi)刪除侵權(quán)內(nèi)容。
