Как интегрировать базу данных Neo4j, фреймворк NestJS и GraphQL?

Я не работал над GraphQL, но знаю, что есть пакет npm (Neo4j-graphql-js) для перевода запросов GraphQL в запросы Cypher. Это упрощает совместное использование GraphQL и Neo4j.

Также проверьте GRANDstack, это интеграция с полным стеком разработки для создания приложений на основе Graph.

Предлагаю вам посетить Сообщество Neo4j.

Для этого я использую NestInterceptor:

@Injectable()
export class Neo4JGraphQLInterceptor implements NestInterceptor {
  intercept(
    context: ExecutionContext,
    next: CallHandler<any>,
  ): Observable<any> | Promise<Observable<any>> {
    const ctx = GqlExecutionContext.create(context);
    return neo4jgraphql(
      ctx.getRoot(),
      ctx.getArgs(),
      ctx.getContext(),
      ctx.getInfo(),
    );
  }
}

Чтобы использовать его в вашем Resolver:

@Resolver('Movie')
@UseInterceptors(Neo4JGraphQLInterceptor)
export class MovieResolver {}

Мой GraphQLModule настроен так:

@Module({
  imports: [
    GraphQLModule.forRoot({
      typePaths: ['./**/*.gql'],
      transformSchema: augmentSchema,
      context: {
        driver: neo4j.driver(
          'bolt://neo:7687',
          neo4j.auth.basic('neo4j', 'password1234'),
        ),
      },
    }),
  ],
  controllers: [...],
  providers: [..., MovieResolver, Neo4JGraphQLInterceptor],
})

Обратите внимание на использование transformSchema: augmentSchema для включения автоматически генерируемых мутаций и запросов (GRANDStack: расширение схемы)

Надеюсь, это немного поможет!

Это то, что у меня работает ... не так элегантно, как хотелось бы, но работает; Я хочу, чтобы только один сервис / провайдер имел доступ к моей базе данных, а не к сервису из каждого модуля, хотя это тоже работает. Поэтому я придерживаюсь формата Nest myModule-> myResolver-> myService -> Neo4jService. Итак, Neo4jService внедряется во все xService (ы). При необходимости я использую neo4jGraphql и augmentSchema и Cypher.

Код:

**appmodule.ts**
....
import { makeExecutableSchema } from 'graphql-tools';
import { v1 as neo4j } from 'neo4j-driver';
import { augmentTypeDefs, augmentSchema  } from 'neo4j-graphql-js';
import { Neo4jService } from './neo4j/neo4j.service';
import { MyModule } from './my/my.module';
import { MyResolver } from './my/my.resolver';
import { MyService } from './my/my.service';
....
import { typeDefs } from './generate-schema';  // SDL type file
...
const driver =  neo4j.driver('bolt://localhost:3000', neo4j.auth.basic('neo4j', 'neo4j'))

const schema = makeExecutableSchema({
  typeDefs: augmentTypeDefs(typeDefs),
 });
const augmentedSchema = augmentSchema(schema);   // Now we have an augmented schema

@Module({
  imports: [
    MyModule,

    GraphQLModule.forRoot({
      schema: augmentedSchema,       
      context: {
      driver,
       },
     }),
    ],
  controllers: [],

  providers: [ Neo4jService,
               myResolver,
             ],
})
export class AppModule {}

**myResolver.ts**

import { Args, Mutation, Query, Resolver  } from '@nestjs/graphql';

import { MyService } from './my.service';

@Resolver('My')
export class MyResolver {

    constructor(
        private readonly myService: MyService) {}

      @Query()
      async getData(object, params, ctx, resolveInfo) {
       return await this.myService.getData(object, params, ctx, resolveInfo);
      }

     *//Notice I am just passing the graphql params, etc to the myService*

}

**myService.ts**

import { Injectable } from '@nestjs/common';
import { Neo4jService } from '../neo4j/neo4j.service';

@Injectable()
export class MyService {

    constructor(private neo4jService: Neo4jService) {}

    async getData(object, params, ctx, resolveInfo) {
        return await this.neo4jService.getData(object, params, ctx, resolveInfo);
   }

     *// Again I am just passing the graphql params, etc to the neo4jService*
 }
**neo4jService.ts**
import { Injectable } from '@nestjs/common';
import { neo4jgraphql } from 'neo4j-graphql-js';


@Injectable()
export class Neo4jService {

        getData(object, params, ctx, resolveInfo) {
              return neo4jgraphql(object, params, ctx, resolveInfo);
            }
     .....
     ......
}

Поэтому в основном я отложил использование neo4jgraphql до тех пор, пока мы не дойдем до neo4jService. Теперь все мои вызовы БД здесь ... как я уже сказал, не элегантно, но работает.

Проблемы: Graphql generate не принимает @relation ... Я обнаружил, что были внесены изменения, и теперь вам нужен augmentTypeDefs. ...надеюсь это поможет РЕДАКТИРОВАТЬ Nestjs ужасно долго обрабатывает augmentSchema ... поэтому я бы рекомендовал пропустить его ... пока

Вот пример, который я создал для (NestJS + GraphQL + Neo4j). Надеюсь, это поможет!

NestJS + GraphQL + Neo4j