|
|
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<AddPostPayload> AddPostAsync(AddPostInput input, [Service] IRepository<Post> 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<Query>()
5 v$ M B! t0 {6 M$ c1 K6 I .AddMutationType<Mutation>()
- 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<PostType>();
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 |
|