我是 GrapQL 的新手。我正在尝试将它与弹簧靴一起使用。我可以成功查询,它正在返回我需要的数据,但我现在想使用突变。我需要在他注册时向数据库添加一个用途。
这是我的 schema.graphqls 文件:
type Token {
token: String
}
type Register {
message: String
}
type User {
username: String!
firstName: String!
lastName: String!
password: String!
role: String!
}
type Query {
login(username: String, password: String): Token
}
type Mutation {
register(input: RegisterUserInput!): Register
}
input RegisterUserInput {
username: String!
firstName: String!
lastName: String!
password: String!
role: String!
}
schema {
query: Query
mutation: Mutation
}
如您所见,寄存器是 Mutation 类型,它与 Query 一样添加到模式中。但由于某种原因,它看起来并没有进入 Mutation,它只是试图在 Query 中查找类型。
这是我的控制器:
@Autowired
private UserService userService;
/**
* Login the user and return generated token
* @param query
* @return String token
*/
@PostMapping("/login")
public ResponseEntity<Object> login(@RequestBody String query){
ExecutionResult executionResult = userService.getGraphQL().execute(query);
// Check if there are errors
if(!executionResult.getErrors().isEmpty()){
return new ResponseEntity<>(executionResult.getErrors().get(0).getMessage(), HttpStatus.UNAUTHORIZED);
}
return new ResponseEntity<>(executionResult, HttpStatus.OK);
}
/**
* Create new user and save him to database
* @param mutation
* @return String message
*/
@PostMapping("/register")
public ResponseEntity<Object> register(@RequestBody String mutation){
ExecutionResult executionResult = userService.getGraphQL().execute(mutation);
// Check if there are errors
if(!executionResult.getErrors().isEmpty()){
return new ResponseEntity<>(executionResult.getErrors().get(0).getMessage(), HttpStatus.UNAUTHORIZED);
}
return new ResponseEntity<>(executionResult, HttpStatus.OK);
}
正如我所说,登录工作正常,但注册返回我在标题中提到的错误。
我的服务等级:
@Value("classpath:graphql-schema/schema.graphqls")
Resource resource;
private GraphQL graphQL;
@Autowired
private LoginDataFetcher loginDataFetcher;
@Autowired
private RegisterDataFetcher registerDataFetcher;
@PostConstruct
public void loadSchema() throws IOException{
// Get the schema
File schemaFile = resource.getFile();
// Parse schema
TypeDefinitionRegistry typeDefinitionRegistry = new SchemaParser().parse(schemaFile);
RuntimeWiring runtimeWiring = buildRuntimeWiring();
GraphQLSchema graphQLSchema = new SchemaGenerator().makeExecutableSchema(typeDefinitionRegistry, runtimeWiring);
graphQL = GraphQL.newGraphQL(graphQLSchema).build();
}
private RuntimeWiring buildRuntimeWiring() {
return RuntimeWiring.newRuntimeWiring()
.type("Query", typeWiring ->
typeWiring
.dataFetcher("login", loginDataFetcher))
.type("Mutation", typeWiring ->
typeWiring
.dataFetcher("register", registerDataFetcher))
.build();
}
public GraphQL getGraphQL() {
return graphQL;
}
我的 LoginDataFetcher:
@Autowired
private AppUserRepository appUserRepository;
private JwtGenerator jwtGenerator;
public LoginDataFetcher(JwtGenerator jwtGenerator) {
this.jwtGenerator = jwtGenerator;
}
@Override
public TokenDAO get(DataFetchingEnvironment dataFetchingEnvironment) {
String username = dataFetchingEnvironment.getArgument("username");
String password = dataFetchingEnvironment.getArgument("password");
AppUser appUser = appUserRepository.findByUsername(username);
// If user is not foung
if(appUser == null){
throw new RuntimeException("Username does not exist");
}
// If the user is fount check passwords
if(!appUser.getPassword().equals(password)){
throw new RuntimeException("Incorrect password");
}
// Generate the token
String token = jwtGenerator.generate(appUser);
return new TokenDAO(token);
}
RegisterDataFetcher:
@Autowired
private AppUserRepository appUserRepository;
@Override
public RegisterDAO get(DataFetchingEnvironment dataFetchingEnvironment) {
String username = dataFetchingEnvironment.getArgument("username");
String firstName = dataFetchingEnvironment.getArgument("firstName");
String lastName = dataFetchingEnvironment.getArgument("lastName");
String password = dataFetchingEnvironment.getArgument("password");
String role = dataFetchingEnvironment.getArgument("role");
AppUser appUser = appUserRepository.findByUsername(username);
// Check if username exists
if(appUser != null){
throw new RuntimeException("Username already taken");
}
AppUser newAppUser = new AppUser(username, password, role, firstName, lastName);
// Save new user
appUserRepository.save(newAppUser);
return new RegisterDAO("You have successfully registered");
}
我在控制台中遇到的错误:
graphql.GraphQL : Query failed to validate : '{
register(username: "user", firstName: "Bla", lastName: "Blabla", password: "password", role: "DEVELOPER") {
message
}
}'
谢谢您的帮助。
更新
根据我得到的答案,我像这样更改了我的架构文件:
query UserQuery{
login(username: String, password: String){
token
}
}
mutation UserMutation{
register(input: RegisterUserInput) {
message
}
}
input RegisterUserInput {
username: String!
firstName: String!
lastName: String!
password: String!
role: String!
}
schema {
query: UserQuery
mutation: UserMutation
}
但是现在我收到了这个错误:
解析类型“查询”时不存在操作类型“UserQuery”解析类型“突变”时不存在操作类型“UserMutation”
那么现在的问题是什么?我怎样才能使这项工作?