Devlooped.TableStorage.Bson 5.2.0

用于文档型存储库的BSON二进制序列化程序。

使用方法

  var repo = DocumentRepository.Create<Product>(..., serializer: BsonDocumentSerializer.Default);

文档存储

DocumentRepository.Create 和 DocumentPartition.Create 工厂方法提供对基于文档的存储的访问权限，公开类似列存储的API。

文档存储库将实体持久化为一个单一的文档列，同时附带类型和版本信息以处理应用程序级别的版本控制系统。

API与基于列的存储库（文档存储库实现了相同的底层 ITableStorage 接口）大致相同。

public record Product(string Category, string Id) 
{
  public string? Title { get; init; }
  public double Price { get; init; }
  public DateOnly CreatedAt { get; init; }
}

var book = new Product("book", "9781473217386")
{
    Title = "Neuromancer",
    Price = 7.32
};

// Column-based storage
var repo = TableRepository.Create<Product>(
    CloudStorageAccount.DevelopmentStorageAccount,
    tableName: "Products",
    partitionKey: p => p.Category,
    rowKey: p => p.Id);

await repo.PutAsync(book);

// Document-based storage
var docs = DocumentRepository.Create<Product>(
    CloudStorageAccount.DevelopmentStorageAccount,
    tableName: "Documents",
    partitionKey: p => p.Category,
    rowKey: p => p.Id
    serializer: [SERIALIZER]);

await docs.PutAsync(book);

如果没有提供，序列化程序默认为基于 System.Text.Json 的 DocumentSerializer.Default。

以下为Azure Storage Explorer中的存储截图，可看到存储结果的不同。

文档表中的 Type 列表示持久化实体的 Type.FullName，而 Version 则表示其程序集的 [主版本].[次版本]，这可以在高级数据迁移场景中使用。主版本和次版本组件也作为单独的列提供，以便通过 IDocumentRepository.EnumerateAsync(predicate) 方便地对各种版本范围进行查询。

赞助商

了解更多关于 GitHub 赞助信息