.NET Framework中如何结合ADO.NET使用GraphQL并连接解析器？

完全可以实现GraphQL解析器与ADO.NET的集成，核心思路是在GraphQL的解析逻辑中直接调用ADO.NET的数据库操作API。以下是具体的实现步骤和示例：

1. 选择兼容.NET Framework的GraphQL库 #

使用GraphQL.NET（NuGet包：GraphQL），它支持.NET Framework 4.6.1及以上版本，是.NET生态中成熟的GraphQL实现库。

2. 定义实体与GraphQL类型 #

先定义业务实体类，再创建对应的GraphQL对象类型，映射实体的字段：

// 业务实体类
public class Product
{
    public int Id { get; set; }
    public string Name { get; set; }
    public decimal Price { get; set; }
}

// GraphQL对象类型，映射Product实体
public class ProductType : ObjectGraphType<Product>
{
    public ProductType()
    {
        Field(x => x.Id);
        Field(x => x.Name);
        Field(x => x.Price);
    }
}

3. 在GraphQL解析器中集成ADO.NET #

在GraphQL的Query类型中，编写解析方法，直接使用ADO.NET的SqlConnection、SqlCommand等类执行数据库查询，将结果返回给GraphQL：

public class MyQuery : ObjectGraphType
{
    public MyQuery()
    {
        // 查询所有产品
        Field<ListGraphType<ProductType>>("products", resolve: context =>
        {
            var productList = new List<Product>();
            // 替换为你的数据库连接字符串
            using (var conn = new SqlConnection("Server=.;Database=YourDb;Trusted_Connection=True;"))
            {
                conn.Open();
                using (var cmd = new SqlCommand("SELECT Id, Name, Price FROM Products", conn))
                using (var reader = cmd.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        productList.Add(new Product
                        {
                            Id = reader.GetInt32(0),
                            Name = reader.GetString(1),
                            Price = reader.GetDecimal(2)
                        });
                    }
                }
            }
            return productList;
        });

        // 根据ID查询单个产品
        Field<ProductType>("product",
            arguments: new QueryArguments(new QueryArgument<IntGraphType> { Name = "id" }),
            resolve: context =>
            {
                var productId = context.GetArgument<int>("id");
                Product targetProduct = null;

                using (var conn = new SqlConnection("Server=.;Database=YourDb;Trusted_Connection=True;"))
                {
                    conn.Open();
                    using (var cmd = new SqlCommand("SELECT Id, Name, Price FROM Products WHERE Id = @Id", conn))
                    {
                        cmd.Parameters.AddWithValue("@Id", productId);
                        using (var reader = cmd.ExecuteReader())
                        {
                            if (reader.Read())
                            {
                                targetProduct = new Product
                                {
                                    Id = reader.GetInt32(0),
                                    Name = reader.GetString(1),
                                    Price = reader.GetDecimal(2)
                                };
                            }
                        }
                    }
                }
                return targetProduct;
            });
    }
}

4. 初始化Schema并处理GraphQL请求 #

创建GraphQL Schema，执行查询请求并返回结果：

// 初始化Schema
var schema = new Schema { Query = new MyQuery() };

// 示例GraphQL查询语句
var query = @"
{
  products {
    id
    name
    price
  }
}";

// 执行查询
var result = await new DocumentExecuter().ExecuteAsync(options =>
{
    options.Schema = schema;
    options.Query = query;
}).ConfigureAwait(false);

// 将结果序列化为JSON
var jsonResult = new DocumentWriter().Write(result);

注意事项 #

• 连接字符串建议存储在配置文件（如web.config）中，避免硬编码
• 可将ADO.NET操作封装到独立的数据访问层，简化解析器代码，提升可维护性
• 处理动态条件查询时，务必使用参数化SQL防止注入风险
• 确保数据库连接通过using语句正确释放，避免连接泄漏

内容的提问来源于stack exchange，提问作者pratapsingh845