飞雪团队

 找回密码
 立即注册
搜索
热搜: 活动 交友 discuz
查看: 13586|回复: 0

使用Hot Chocolate和.NET 6构建GraphQL应用(8) —— 实现Mutate添加数据 ...

[复制链接]

8242

主题

8330

帖子

2万

积分

管理员

Rank: 9Rank: 9Rank: 9

积分
27056
发表于 2022-2-12 14:35:41 | 显示全部楼层 |阅读模式
' [0 c* O, v- C3 f
<h2 id="系列导航">系列导航</h2>3 ]1 [2 E0 u# C
<p><a  href="https://www.cnblogs.com/code4nothing/p/graphql-net6-0.html">使用Hot Chocolate和.NET 6构建GraphQL应用文章索引</a></p>
5 u: B7 P# @' o<h2 id="需求">需求</h2>, p; D, K' n! @6 i2 R' O/ q
<p>在讨论完GraphQL中的查询需求后,这篇文章我们将演示如何实现GraphQL中的数据添加任务。</p>
% O6 i' i2 H( i0 J) {9 C+ g/ y, O<h2 id="思路">思路</h2>: k& M" {. Z; F2 T" A
<p>在GraphQL中,对数据进行查询使用<code>query</code>,而对于修改数据则需要使用<code>mutation</code>,包括新增和修改数据。Hot Chocolate在使用Mutation的逻辑上和使用Query的基本一致,但是需要根据需要定义用于创建或者更新的数据对象,所以我们直接进行实现。</p>
$ k# ?2 Q! f! i, Q<h2 id="实现">实现</h2>3 ?, R3 `5 f" C% L
<p>为了保持简单,我们先定义以下两个类型:</p>$ L% @% S! x) g5 O6 k7 |
<pre><code class="language-c#">// 定义新增Post的参数
2 O0 x% l, a( Q) V8 o. h. }: |public record AddPostInput(string Title, string Author);" f' l6 v& @; w2 Z1 {6 U
& y% Y, _, X  ^
// 定义新增Post的返回对象3 _0 g0 D& Q3 [+ x" H$ r- ~
public record AddPostPayload(Post Post);
$ Y, ~5 C0 J  Q& [</code></pre>3 Y/ W& ?+ q" m
<p>新建<code>Mutation.cs</code>用来定义相关接口:</p>
" Z2 r) Z4 n- D3 m<ul># y# B8 r8 q+ I9 Y
<li><code>Mutation.cs</code></li>
  }" G, U5 I4 k( p</ul>
6 p4 q* `- B. c. |6 o# K<pre><code class="language-c#">namespace PostGraphi.Api.GraphQL;' F) e+ `/ p* r, `2 R) a# u/ x

4 V* X* S2 l: tpublic class Mutation5 ]3 I9 I, H% E* b
{6 A+ d+ u+ |2 K0 U) f
    public async Task&lt;AddPostPayload&gt; AddPostAsync(AddPostInput input, [Service] IRepository&lt;Post&gt; repository)
5 ^2 L* }! q! n, Y- h' R/ d9 m    {
) T! L3 f( `# ~, A4 Z4 Y2 _        return new AddPostPayload(await repository.AddAsync(new Post
& {- L1 S4 z- [& @& r        {& f8 e( g' [; x1 U" Y. I- H% u2 E
            Title = input.Title," C/ @" {. x9 O& w/ S, i3 x: t
            Author = input.Author
; e' M) A6 T- p        }));
+ i; p$ _+ {. @3 _    }+ ]  K2 k5 e" @4 R6 u  E9 I
}
" E3 L" c5 ]  \( O) R7 K+ w8 u4 ~1 _
</code></pre>
" |: z" @; u" P: _& W9 Y<p>最后在注入服务的地方进行配置:</p>3 R; J9 Y0 y* ?' O% v1 C4 V
<ul>. W! `3 t, k  Y
<li><code>ProgramExtensions.cs</code></li>  j9 a  J! l0 u
</ul>4 |- [. z: Z4 S. I' P* f) @
<pre><code class="language-c#">builder.Services2 u( }( ~! j8 b# i1 q4 R" Z
    .AddGraphQLServer()
6 M  y, T; M- {1 a2 f    .SetPagingOptions(new PagingOptions: b, i' ^8 k& h) z& P: T
    {0 ~7 J9 I2 ]+ S. `
        MaxPageSize = 50,- R8 G1 y* h0 j* }. u6 `! J, P
        IncludeTotalCount = true) c/ W. ?4 A3 w2 h
    }). L) }% U- y3 L; |$ A9 Y4 U
    .AddFiltering()
7 z5 i; f4 C# t. C! r# z    .AddProjections()- |7 T, \' Q4 E( B. E$ i" \6 }
    .AddSorting()6 ~: Z; ~- _5 u7 Y2 j. e& _0 T
    .AddQueryType&lt;Query&gt;()
- Q' k9 V1 I7 }    .AddMutationType&lt;Mutation&gt;()9 A2 e( g2 }8 k3 W9 X& y) s. Y
    .AddMutationConventions(new MutationConventionOptions8 ?! A% L) N: k1 T3 Y
    {: @- R2 F( ^: {. n3 y4 ~
        ApplyToAllMutations = true,6 v8 [; N* x7 P1 u, i. @) @- A
        InputArgumentName = "input",, c4 F) w6 U$ h! W/ I
        InputTypeNamePattern = "{MutationName}Input",
0 S, r% Y3 L& T        PayloadTypeNamePattern = "{MutationName}Payload",
. v8 `! |7 U/ f' S! |: E- r        PayloadErrorTypeNamePattern = "{MutationName}Error",
8 |: N0 P" V0 ^        PayloadErrorsFieldName = "errors"4 _% J6 R$ R% w3 `8 q. [0 a& W
    })+ U4 _+ _: N- I+ U7 q: k8 O( `
    .AddType&lt;PostType&gt;();8 n. i+ h1 }+ X+ N: g# n' ]
</code></pre>
7 {& M& q8 Q. s# r<p>这样就实现了新增Post的需求,下面我们来验证一下。</p>" V5 b+ l6 |4 x
<h2 id="验证">验证</h2>
9 T" ?0 N, `3 M( L9 p<p>启动<code>Api</code>项目,调用接口:</p>
7 j# k* i; F" {4 V7 |<p><img src="https://img2022.cnblogs.com/blog/2487237/202202/2487237-20220211104544617-1400586374.png" ></p>
5 s6 R; X+ ~7 D<p>终端的日志输出如下:</p>
: R+ n; K5 `+ K0 J$ F5 B# f<pre><code class="language-bash">[10:45:15 INF] Executed DbCommand (1ms) [Parameters=[@p0='?' (DbType = Guid), @p1='?', @p2='?' (Size = 13), @p3='?', @p4='?' (DbType = DateTime), @p5='?', @p6='?' (DbType = DateTime), @p7='?', @p8='?', @p9='?' (DbType = DateTime), @p10='?' (Size = 30)], CommandType='Text', CommandTimeout='30']
5 ~3 `" B! u' Q1 o- vINSERT INTO "Posts" ("Id", "Abstraction", "Author", "Content", "Created", "CreatedBy", "LastModified", "LastModifiedBy", "Link", "PublishedAt", "Title")2 \* O' M1 R' n; L; l
VALUES (@p0, @p1, @p2, @p3, @p4, @p5, @p6, @p7, @p8, @p9, @p10);- B$ ?; x) N+ m6 N- z/ C1 T
[10:45:15 INF] Executed endpoint 'Hot Chocolate GraphQL Pipeline'$ R- q* x# k6 X7 }" {0 E
</code></pre>
1 u4 L6 I* K7 M, a$ T3 T2 m2 K<p>可以看到新建的Post已经存储到数据库中了,我们可以通过查询接口来获取详情:</p>* [( G0 }3 ]; R8 ^
<p><img src="https://img2022.cnblogs.com/blog/2487237/202202/2487237-20220211104851825-1533915064.png" ></p>
& v8 |& k9 {( z  j! v" e<h2 id="总结">总结</h2>6 M0 |4 O" p& E4 l: N. t
<p>在本文中我们实现了简单的新增Post操作,这里还有一些涉及到错误处理的内容,我没有在文章中演示,可以参考官方文档 <a  href="https://chillicream.com/docs/hotchocolate/defining-a-schema/mutations/#errors">Errors</a>,在自定义异常对象后,有三种方式可以进行错误处理:直接返回异常;使用异常工厂方法;使用构造函数。甚至可以在<code>AggregateExceptions</code>中一次性返回多个异常。基本思路都是通过添加属性<code>[Error(typeof(SomeUserDefinedException))]</code>来实现的。</p>
2 V  D( @! x/ J& g- K<p>在下一篇文章中,我们通过<code>Mutation</code>对已有数据进行更新。</p>
% H8 b* d1 w3 |$ V
) X- Y: u& D0 |3 J2 x+ P
回复

使用道具 举报

懒得打字嘛,点击右侧快捷回复 【右侧内容,后台自定义】
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|飞雪团队

GMT+8, 2026-2-27 07:22 , Processed in 0.062978 second(s), 22 queries , Gzip On.

Powered by Discuz! X3.4

Copyright © 2001-2021, Tencent Cloud.

快速回复 返回顶部 返回列表