ASP.NET Core中使用GraphQL - 第九章 在GraphQL中處理多對多關係

ASP.NET Core中使用GraphQL

• ASP.NET Core中使用GraphQL - 第一章 Hello World
• ASP.NET Core中使用GraphQL - 第二章 中間件
• ASP.NET Core中使用GraphQL - 第三章 依賴注入
• ASP.NET Core中使用GraphQL - 第四章 GrahpiQL
• ASP.NET Core中使用GraphQL - 第五章 字段, 參數, 變量
• ASP.NET Core中使用GraphQL - 第六章 使用EF Core做爲持久化倉儲
• ASP.NET Core中使用GraphQL - 第七章 Mutation
• ASP.NET Core中使用GraphQL - 第八章 在GraphQL中處理一對多關係

---

上一章中，咱們介紹瞭如何在GraphQL中處理一對多關係，這一章，咱們來介紹一下GraphQL中如何處理多對多關係。

咱們繼續延伸上一章的需求，上一章中咱們引入了客戶和訂單，可是咱們沒有涉及訂單中的物品。在實際需求中，一個訂單能夠包含多個物品，一個物品也能夠屬於多個訂單，因此訂單和物品之間是一個多對多關係。

爲了建立訂單和物品之間的關係，這裏咱們首先建立一個訂單物品實體。

OrderItem

[Table("OrderItems")]
public class OrderItem
{
    public int Id { get; set; }

    public string Barcode { get; set; }

    [ForeignKey("Barcode")]
    public virtual Item Item { get; set; }

    public int Quantity { get; set; }

    public int OrderId { get; set; }

    [ForeignKey("OrderId")]
    public virtual Order Order { get; set; }
}

建立完成以後，咱們還須要修改Order和Item實體, 添加他們與OrderItem之間的關係

Order

public class Order
{
    public int OrderId { get; set; }
    public string Tag { get; set; }
    public DateTime CreatedAt { get; set; }

    public Customer Customer { get; set; }
    public int CustomerId { get; set; }

    public virtual ICollection<OrderItem> OrderItems { get; set; }
}

Item

[Table("Items")]
public class Item
{
    [Key]
    public string Barcode { get; set; }

    public string Title { get; set; }

    public decimal SellingPrice { get; set; }

    public virtual ICollection<OrderItem> OrderItems { get; set; }
}

修改完成以後，咱們使用以下命令建立數據庫遷移腳本，並更新數據庫

dotnet ef migrations add AddOrderItemTable
dotnet ef database update

遷移成功以後，咱們能夠添加一個新的GraphQL節點，使用這個新節點，咱們能夠向訂單中添加物品。爲了實現這個功能，咱們首先須要爲OrderItem實體添加它在GraphQL中對應的類型OrderItemType

OrderItemType

public class OrderItemType : ObjectGraphType<OrderItem>  
{
    public OrderItemType(IDataStore dateStore)
    {   
        Field(i => i.ItemId);      

        Field<ItemType, Item>().Name("Item").ResolveAsync(ctx =>
        {
            return dateStore.GetItemByIdAsync(ctx.Source.ItemId);
        });         

        Field(i => i.Quantity);

        Field(i => i.OrderId);

        Field<OrderType, Order>().Name("Order").ResolveAsync(ctx =>
        {
            return dateStore.GetOrderByIdAsync(ctx.Source.OrderId);
        });

    }
}

第二步，咱們還須要建立一個OrderItemInputType來定義添加OrderItem須要哪些字段。

OrderItemInputType

public class OrderItemInputType : InputObjectGraphType  
{
    public OrderItemInputType()
    {
        Name = "OrderItemInput";
        Field<NonNullGraphType<IntGraphType>>("quantity");
        Field<NonNullGraphType<IntGraphType>>("itemId");
        Field<NonNullGraphType<IntGraphType>>("orderId");
    }
}

第三步，咱們須要在InventoryMutation類中針對OrderItem添加新的mutation。

InventoryMutation

Field<OrderItemType, OrderItem>()  
    .Name("addOrderItem")
    .Argument<NonNullGraphType<OrderItemInputType>>("orderitem", "orderitem input")
    .ResolveAsync(ctx =>
    {
        var orderItem = ctx.GetArgument<OrderItem>("orderitem");
        return dataStore.AddOrderItemAsync(orderItem);
    });

第四步，咱們須要在IDataStore接口中定義幾個新的方法，並在DataStore類中實現他們

IDataStore

Task<OrderItem> AddOrderItemAsync(OrderItem orderItem);

Task<Order> GetOrderByIdAsync(int orderId);

Task<IEnumerable<OrderItem>> GetOrderItemByOrderIdAsync(int orderId);

DataStore

public async Task<OrderItem> AddOrderItemAsync(OrderItem orderItem)
{
    var addedOrderItem = await _context.OrderItems.AddAsync(orderItem);
    await _context.SaveChangesAsync();
    return addedOrderItem.Entity;
}

public async Task<Order> GetOrderByIdAsync(int orderId)
{
    return await _context.Orders.FindAsync(orderId);
}

public async Task<IEnumerable<OrderItem>> GetOrderItemByOrderIdAsync(int orderId)
{
    return await _context.OrderItems
        .Where(o => o.OrderId == orderId)
        .ToListAsync();
}

第五步，咱們來修改OrderType類，咱們但願查詢訂單的時候，能夠返回訂單中的全部物品

public class OrderType : ObjectGraphType<Order>
{
    public OrderType(IDataStore dataStore)
    {
        Field(o => o.Tag);
        Field(o => o.CreatedAt);
        Field<CustomerType, Customer>()
        .Name("Customer")
        .ResolveAsync(ctx =>
        {
            return dataStore.GetCustomerByIdAsync(ctx.Source.CustomerId);
        });

        Field<OrderItemType, OrderItem>()
        .Name("Items")
        .ResolveAsync(ctx =>
        {
            return dataStore.GetOrderItemByOrderIdAsync(ctx.Source.OrderId);
        });
        }
    }
}

最後咱們還須要在Startup類中註冊咱們剛定義的2個新類型

services.AddScoped<OrderItemType>();  
services.AddScoped<OrderItemInputType>();

以上就是全部的代碼修改。如今咱們啓動項目

首先咱們先爲以前添加的訂單1, 添加兩個物品

而後咱們來調用查詢Order的query, 結果中訂單中物品正確顯示了。

本文源代碼： https://github.com/lamondlu/GraphQL_Blogs/tree/master/Part%20IX