飞雪团队

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

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

[复制链接]

9321

主题

9409

帖子

3万

积分

管理员

Rank: 9Rank: 9Rank: 9

积分
30293
发表于 2022-2-12 14:35:41 | 显示全部楼层 |阅读模式
9 I0 K+ n+ x" K4 r
<h2 id="系列导航">系列导航</h2>
8 d6 p! h6 \4 Q5 [7 ~<p><a  href="https://www.cnblogs.com/code4nothing/p/graphql-net6-0.html">使用Hot Chocolate和.NET 6构建GraphQL应用文章索引</a></p>/ x( D' @" T7 i$ s
<h2 id="需求">需求</h2>
. q3 H# H% `' `+ j6 g<p>在讨论完GraphQL中的查询需求后,这篇文章我们将演示如何实现GraphQL中的数据添加任务。</p>" L) P5 G4 i4 U4 Y8 ]: S& ^  ~
<h2 id="思路">思路</h2>
- D! }, T8 p8 F" F& C  P<p>在GraphQL中,对数据进行查询使用<code>query</code>,而对于修改数据则需要使用<code>mutation</code>,包括新增和修改数据。Hot Chocolate在使用Mutation的逻辑上和使用Query的基本一致,但是需要根据需要定义用于创建或者更新的数据对象,所以我们直接进行实现。</p>' q# S" ]4 w9 U# O& w- B8 l' n
<h2 id="实现">实现</h2>* h2 A; J8 A. _' d7 B
<p>为了保持简单,我们先定义以下两个类型:</p>6 M7 e" @! ]( [: S- a9 ?  w( Q
<pre><code class="language-c#">// 定义新增Post的参数
6 T- Q& \4 b! d( t" `$ I9 m! Zpublic record AddPostInput(string Title, string Author);# W& S: m7 o/ l0 ^% X2 _8 u% E
. W1 g! t4 u; H& l' [" ~
// 定义新增Post的返回对象3 e: M/ v3 A: l& h- ]1 k+ b
public record AddPostPayload(Post Post);
0 h3 q) D6 m: {</code></pre>
0 E! p+ ^! q; ]: _- x5 L; L4 L<p>新建<code>Mutation.cs</code>用来定义相关接口:</p>  \3 d1 a. m* ]# @9 _" W
<ul>
4 `. K( P: `: F) p* R. P' y' ]7 _<li><code>Mutation.cs</code></li>1 o7 S% C# M% f0 _- D
</ul>+ f: ^. Y! A& r6 K
<pre><code class="language-c#">namespace PostGraphi.Api.GraphQL;. m+ E: Y" n' y+ |. M; H
( B8 O) {0 M4 ]9 Z
public class Mutation
4 b0 G/ {, K2 }7 u$ K{/ M+ z! T- {3 D- D+ T
    public async Task&lt;AddPostPayload&gt; AddPostAsync(AddPostInput input, [Service] IRepository&lt;Post&gt; repository). P4 w3 d0 S! v' k( `
    {
2 l. E2 X$ E7 ]. l0 G6 d        return new AddPostPayload(await repository.AddAsync(new Post
6 E0 J0 J1 K0 i  G) }( d, q        {
+ I0 W3 X& R7 ?+ Y) |            Title = input.Title,
4 ?" f. `7 O: o. `8 G: Y- H+ G) E            Author = input.Author
4 v! u( W& w; t" {! X        }));
# i. s' N# n% ~0 T$ q+ P    }
5 A' v  ^$ \3 C* s# H0 w  T0 k& r}
3 z; y8 _2 e4 A* y7 D- X5 b4 Q( j. y- S' Y
</code></pre>
. h* G1 _9 O, o% \* K* K<p>最后在注入服务的地方进行配置:</p>2 b& l" n; U' E5 i: _) |
<ul>" Q8 I7 O; v6 `8 Q
<li><code>ProgramExtensions.cs</code></li># X2 N( a! _0 `! z" @
</ul>
* c4 J( m5 F% o2 S2 |<pre><code class="language-c#">builder.Services9 R& n; s, F! A% e- g- i
    .AddGraphQLServer()  _. \5 {+ w; w# r; K
    .SetPagingOptions(new PagingOptions
& U7 l* A' [3 o: T/ e4 d    {4 U2 ^& o* q9 h
        MaxPageSize = 50,2 z: A4 O/ ^6 i7 }5 l6 J/ A( G
        IncludeTotalCount = true- J& t; o: e) l0 ^
    })
* G- h. z. ~  S) s0 V4 n. p    .AddFiltering()0 e1 z4 _6 o, i6 G1 z8 ~$ e
    .AddProjections()
7 ^6 W/ l; i7 l4 v    .AddSorting()  D* }0 L# U: C" F. o' Z
    .AddQueryType&lt;Query&gt;()
5 v$ M  B! t0 {6 M$ c1 K6 I    .AddMutationType&lt;Mutation&gt;()
- r' K: i4 j* B8 q7 U    .AddMutationConventions(new MutationConventionOptions, z+ L" |+ ~& h. o. d  T+ M8 S
    {
7 ^' m+ b5 q) Q; u7 h% ?/ R4 C2 T( o        ApplyToAllMutations = true,( J( B( ~* q) T7 u, y
        InputArgumentName = "input",- @$ d8 v0 I! P7 J# [6 H
        InputTypeNamePattern = "{MutationName}Input",
: n" p( T5 t4 ]$ i% b. d2 _$ l4 X. E8 \        PayloadTypeNamePattern = "{MutationName}Payload",% M7 g) J0 X5 r6 {$ u$ k3 x  a1 i# c
        PayloadErrorTypeNamePattern = "{MutationName}Error",
& G- e6 G4 i7 q        PayloadErrorsFieldName = "errors"
9 \! A. B+ ~, O. _    })1 ]) F8 V' V  b* ^' K& v
    .AddType&lt;PostType&gt;();
5 U$ k% I+ P% M$ g. \</code></pre>* s' k1 ]5 m. k& k. K: Y
<p>这样就实现了新增Post的需求,下面我们来验证一下。</p>
* g" T2 i2 m! K) ]- n2 {<h2 id="验证">验证</h2>
( j1 t" \3 ]0 `5 T9 f<p>启动<code>Api</code>项目,调用接口:</p>
$ O+ Y% L- E! ]% J  z<p><img src="https://img2022.cnblogs.com/blog/2487237/202202/2487237-20220211104544617-1400586374.png" ></p>
! E2 |3 e: X7 t7 M<p>终端的日志输出如下:</p>
5 a- _3 w) m+ C! v' B8 p<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']
; G6 Q" d: v4 P7 BINSERT INTO "Posts" ("Id", "Abstraction", "Author", "Content", "Created", "CreatedBy", "LastModified", "LastModifiedBy", "Link", "PublishedAt", "Title")
, A. y4 I1 J4 fVALUES (@p0, @p1, @p2, @p3, @p4, @p5, @p6, @p7, @p8, @p9, @p10);/ k8 l7 C4 r/ J% Q. C) Q2 M0 g
[10:45:15 INF] Executed endpoint 'Hot Chocolate GraphQL Pipeline'
, B: h  k! y. U, n6 A# j</code></pre>3 B4 z# p6 w: x0 x& {
<p>可以看到新建的Post已经存储到数据库中了,我们可以通过查询接口来获取详情:</p>  _2 \$ p6 |4 i; N( U1 h2 V
<p><img src="https://img2022.cnblogs.com/blog/2487237/202202/2487237-20220211104851825-1533915064.png" ></p>
) T4 }9 m) x6 X* g% S! e<h2 id="总结">总结</h2>
% E% h6 C# w) R6 g7 u<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>1 k6 [: I- ?# K& L- U
<p>在下一篇文章中,我们通过<code>Mutation</code>对已有数据进行更新。</p>6 {8 j7 }4 l/ V, B- x" q- T

6 I3 Q* g& n& s4 c0 e0 B4 X
回复

使用道具 举报

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

本版积分规则

手机版|飞雪团队

GMT+8, 2026-11-4 15:52 , Processed in 0.063916 second(s), 22 queries , Gzip On.

Powered by Discuz! X3.4

Copyright © 2001-2021, Tencent Cloud.

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