将Neo4j GraphQL与Memgraph集成以实现图遍历

Memgraph兼容Neo4j的Bolt协议，这意味着Neo4j生态的工具（包括Neo4j GraphQL）可以直接适配Memgraph，下面是具体的配置和实现步骤：

1. 安装依赖 #

首先在Node.js项目中安装必要的包：

npm install @neo4j/graphql neo4j-driver graphql apollo-server

这里用apollo-server作为GraphQL服务端载体，你也可以替换成其他服务端框架（如Express GraphQL）。

2. 定义GraphQL Schema #

使用Neo4j GraphQL的SDL扩展语法来定义图模型，核心是用@node标记节点类型，@relationship定义节点间的关系：

# schema.graphql
type User @node {
  id: ID! @unique
  name: String!
  # 定义用户到帖子的OUT方向关系
  posts: [Post!]! @relationship(type: "WROTE", direction: OUT)
}

type Post @node {
  id: ID! @unique
  title: String!
  # 定义帖子到用户的IN方向关系
  author: User! @relationship(type: "WROTE", direction: IN)
}

@unique指令会自动在Memgraph中创建对应字段的唯一约束，确保数据唯一性。

3. 配置驱动并连接Memgraph #

利用neo4j-driver连接Memgraph（因为兼容Bolt协议，无需额外驱动），然后初始化Neo4j GraphQL实例：

// index.js
import { Neo4jGraphQL } from '@neo4j/graphql';
import neo4j from 'neo4j-driver';
import { ApolloServer } from 'apollo-server';
import { readFileSync } from 'fs';
import { join } from 'path';

// 读取Schema文件
const typeDefs = readFileSync(join(__dirname, 'schema.graphql'), 'utf-8');

// 初始化Memgraph连接
const driver = neo4j.driver(
  'bolt://localhost:7687', // Memgraph默认Bolt端口为7687，远程实例替换成对应地址
  neo4j.auth.basic('memgraph', 'memgraph') // 默认用户名密码，根据你的Memgraph配置修改
);

// 创建Neo4j GraphQL实例
const neo4jGraphQL = new Neo4jGraphQL({
  typeDefs,
  driver,
});

// 启动GraphQL服务
async function startServer() {
  const schema = await neo4jGraphQL.getSchema();
  const server = new ApolloServer({
    schema,
    context: ({ req }) => ({ req }),
  });

  const { url } = await server.listen();
  console.log(`GraphQL服务已启动：${url}`);
}

startServer();

4. 关键注意事项 #

• Cypher兼容性：Memgraph支持绝大多数Neo4j Cypher语法，但部分高级特性（如部分聚合函数、自定义过程）可能存在差异，编写复杂查询时建议先在Memgraph Lab中验证。
• 索引优化：除了@unique，还可以用@index指令为非唯一字段创建索引，提升查询性能，比如name: String! @index。
• 事务支持：Neo4j GraphQL的事务机制完全兼容Memgraph，无需额外配置，突变操作默认会自动处理事务。
• 版本匹配：确保@neo4j/graphql和neo4j-driver使用较新版本，避免因版本差异导致的兼容问题，同时Memgraph建议使用最新稳定版。

5. 测试集成 #

启动服务后，访问默认的Apollo Playground（http://localhost:4000），执行以下测试：

创建数据的突变 #

mutation CreateUserWithPost {
  createUsers(input: [{ name: "Alice", posts: { create: [{ title: "Memgraph集成测试" }] } }]) {
    users {
      id
      name
      posts {
        title
      }
    }
  }
}

查询数据 #

query GetUsersWithPosts {
  users {
    id
    name
    posts {
      id
      title
    }
  }
}

如果能正常返回数据，说明集成成功。

内容的提问来源于stack exchange，提问作者Networkhopper