下面是一个使用Angular ngrx store和AWS Amplify API(Appsync)进行GraphQL的解决方案的示例代码:
首先,你需要安装必要的依赖项。在你的Angular项目根目录下,运行以下命令:
npm install @ngrx/store @ngrx/effects aws-amplify aws-amplify-angular
接下来,你需要配置AWS Amplify。在你的main.ts
文件中,添加以下代码:
import Amplify from 'aws-amplify';
import awsconfig from './aws-exports';
Amplify.configure(awsconfig);
然后,你可以在你的Angular组件中使用ngrx store来管理应用程序的状态。在你的组件中,创建一个Action来调用GraphQL查询,并使用ngrx效果来处理该Action。例如:
import { Component, OnInit } from '@angular/core';
import { Store } from '@ngrx/store';
import { loadItems } from './store/actions';
import { AppState } from './store/state';
@Component({
selector: 'app-root',
template: `
- {{ item.name }}
`,
})
export class AppComponent implements OnInit {
items$ = this.store.select(state => state.items);
constructor(private store: Store) {}
ngOnInit() {
this.store.dispatch(loadItems());
}
}
在上面的代码中,我们通过this.store.select
选择了一个Observable,它会自动订阅ngrx store中的items
状态,并在组件模板中显示。
接下来,我们需要定义一个Action和一个效果来处理GraphQL查询。在store/actions.ts
文件中,添加以下代码:
import { createAction, props } from '@ngrx/store';
export const loadItems = createAction('[Items] Load');
export const loadItemsSuccess = createAction(
'[Items] Load Success',
props<{ items: any[] }>()
);
export const loadItemsFailure = createAction(
'[Items] Load Failure',
props<{ error: any }>()
);
在store/effects.ts
文件中,添加以下代码:
import { Injectable } from '@angular/core';
import { Actions, createEffect, ofType } from '@ngrx/effects';
import { of } from 'rxjs';
import { catchError, map, mergeMap } from 'rxjs/operators';
import { APIService } from '../API.service';
import { loadItems, loadItemsFailure, loadItemsSuccess } from './actions';
@Injectable()
export class ItemEffects {
loadItems$ = createEffect(() =>
this.actions$.pipe(
ofType(loadItems),
mergeMap(() =>
this.apiService.ListItems().pipe(
map((response: any) => loadItemsSuccess({ items: response.items })),
catchError((error: any) => of(loadItemsFailure({ error })))
)
)
)
);
constructor(private actions$: Actions, private apiService: APIService) {}
}
在上面的代码中,我们使用了createEffect
函数来创建一个效果,它会监听loadItems
Action,并调用apiService.ListItems()
来进行GraphQL查询。根据查询结果,我们会发出loadItemsSuccess
或loadItemsFailure
Action。
最后,你需要在你的模块中配置ngrx store和效果。在你的app.module.ts
文件中,添加以下代码:
import { NgModule } from '@angular/core';
import { BrowserModule } from '@angular/platform-browser';
import { StoreModule } from '@ngrx/store';
import { EffectsModule } from '@ngrx/effects';
import { AppComponent } from './app.component';
import { ItemEffects } from './store/effects';
import { reducers } from './store/reducers';
@NgModule({
declarations: [AppComponent],
imports: [
BrowserModule,
StoreModule.forRoot(reducers),
EffectsModule.forRoot([ItemEffects]),
],
providers: [],
bootstrap: [AppComponent],
})
export class AppModule {}
在上面的代码中,我们使用StoreModule.forRoot
来配置ngrx store,并使用EffectsModule.forRoot
来配置效果。
这样,你就可以使用Angular ngrx store和AWS Amplify API(Appsync)进行GraphQL了。当你的组件初始化时,它会发出loadItems
Action,并触发效果来调用GraphQL查询。查询结果会更新ngrx store中的items
状态,并在组件模板中显示。