C#中GraphQL的搭建与实战详解

using hotchocolate; // 核心命名空间
using hotchocolate.aspnetcore; // web集成
using hotchocolate.data; // 数据查询扩展
using microsoft.entityframeworkcore; // 若结合ef core

var builder = webapplication.createbuilder(args);

// 1. 注册ef core（若需操作数据库）
builder.services.adddbcontext<appdbcontext>(opt => 
    opt.usesqlserver(builder.configuration.getconnectionstring("defaultconnection")));

// 2. 注册graphql服务，配置schema、查询/突变类型
builder.services
    .addgraphqlserver() // 注册graphql服务器
    .addquerytype<query>() // 注册查询类型（获取数据）
    .addmutationtype<mutation>() // 注册突变类型（新增/修改/删除数据）
    .addprojections() // 支持字段投影（按需取数核心）
    .addfiltering() // 支持查询过滤
    .addsorting(); // 支持查询排序

var app = builder.build();

// 3. 启用graphql中间件，配置访问路径（默认/graphql）
app.usegraphql();
// 4. 启用graphql playground（调试工具，生产环境关闭）
app.usegraphqlplayground();

app.run();

// 实体类（示例：商品实体）
public class product
{
    public int id { get; set; }
    public string name { get; set; }
    public decimal price { get; set; }
    public string description { get; set; }
    public int categoryid { get; set; }
    // 关联导航属性
    public category category { get; set; }
}

public class category
{
    public int id { get; set; }
    public string name { get; set; }
    public list<product> products { get; set; } = new();
}

// 数据库上下文
public class appdbcontext : dbcontext
{
    public appdbcontext(dbcontextoptions<appdbcontext> options) : base(options) { }
    public dbset<product> products { get; set; }
    public dbset<category> categories { get; set; }
}

/// <summary>
/// 查询类型（获取数据，只读操作）
/// </summary>
public class query
{
    /// <summary>
    /// 查询所有商品（支持过滤、排序、投影）
    /// </summary>
    [useprojection] // 启用投影（按需取数）
    [usefiltering] // 启用过滤（如按价格、名称筛选）
    [usesorting] // 启用排序（如按价格升序/降序）
    public iqueryable<product> getproducts([service] appdbcontext dbcontext)
    {
        return dbcontext.products.include(p => p.category); // 关联查询
    }

    /// <summary>
    /// 根据id查询单个商品
    /// </summary>
    public async task<product> getproductbyid(int id, [service] appdbcontext dbcontext)
    {
        return await dbcontext.products.include(p => p.category).firstordefaultasync(p => p.id == id);
    }
}

/// <summary>
/// 突变类型（新增/修改/删除数据，写操作）
/// </summary>
public class mutation
{
    /// <summary>
    /// 新增商品
    /// </summary>
    public async task<product> createproduct(productinput input, [service] appdbcontext dbcontext)
    {
        var product = new product
        {
            name = input.name,
            price = input.price,
            description = input.description,
            categoryid = input.categoryid
        };
        dbcontext.products.add(product);
        await dbcontext.savechangesasync();
        return product;
    }

    /// <summary>
    /// 修改商品
    /// </summary>
    public async task<product> updateproduct(int id, productinput input, [service] appdbcontext dbcontext)
    {
        var product = await dbcontext.products.findasync(id);
        if (product == null) throw new exception("商品不存在");
        
        product.name = input.name;
        product.price = input.price;
        product.description = input.description;
        product.categoryid = input.categoryid;
        
        await dbcontext.savechangesasync();
        return product;
    }

    /// <summary>
    /// 输入类型（用于接收客户端提交的参数，类型安全）
    /// </summary>
    public class productinput
    {
        public string name { get; set; }
        public decimal price { get; set; }
        public string description { get; set; }
        public int categoryid { get; set; }
    }
}

# 1. 查询单个商品（仅获取id、名称、价格，无需description和category）
query getproductbyid {
  productbyid(id: 1) {
    id
    name
    price
  }
}

# 2. 查询所有商品（过滤价格>100，按价格降序，获取商品信息及所属分类）
query getproducts {
  products(where: { price: { gt: 100 } }, order: { price: desc }) {
    id
    name
    price
    category {
      id
      name
    }
  }
}

# 3. 新增商品（突变操作）
mutation createproduct {
  createproduct(input: {
    name: "测试商品"
    price: 199.99
    description: "测试描述"
    categoryid: 1
  }) {
    id
    name
  }
}