从现有 Neo4j 数据库中内省模式

使用一个独立的 npm 包 @neo4j/introspector,Neo4j 提供了一个工具,使能够从现有数据库中生成 GraphQL 类型定义。这通常是一次性的事情,应该被视为 GraphQL 模式的一个起点。

@neo4j/introspector 具有完全支持生成类型定义,包括

  • 一个 @relationship 指令,包括关系属性。

  • 一个 @node 类型,其中包含

    • label 用于映射节点标签可能使用 GraphQL 支持的字符集中不存在的字符的位置。

    • additionalLabels 用于具有多个标签的节点。

  • GraphQL 类型定义的只读版本。

如果元素属性在整个图中具有混合类型,则该属性将从生成的类型定义中排除。这样做的原因是,如果您的 GraphQL 服务器发现与指定类型不匹配的数据,它将抛出错误。

如果跳过了任何属性,则会在 调试日志 中进行说明。

使用示例

您可以使用编程 API 来内省 Neo4j 模式并生成 GraphQL 类型定义。以下是您可能会遇到的一些情况。

内省并持久化到文件

此示例内省数据库模式,生成 GraphQL 类型定义并将它们持久化到文件 schema.graphql。然后,您可以使用 GraphQL 服务器提供此文件

import { toGraphQLTypeDefs } from "@neo4j/introspector";
import fs from "fs";
import neo4j from "neo4j-driver";

const driver = neo4j.driver(
    "neo4j://localhost:7687",
    neo4j.auth.basic("username", "password")
);

const sessionFactory = () => driver.session({ defaultAccessMode: neo4j.session.READ })

// We create a async function here until "top level await" has landed
// so we can use async/await
async function main() {
    const typeDefs = await toGraphQLTypeDefs(sessionFactory)
    fs.writeFileSync('schema.graphql', typeDefs)
    await driver.close();
}
main()

内省并启动只读模式

此示例从数据库生成一个只读版本的模式,并立即启动一个 Apollo 服务器。这里,类型定义永远不会持久化到磁盘

import { ApolloServer } from "@apollo/server";
import { startStandaloneServer } from '@apollo/server/standalone';
import { Neo4jGraphQL } from "@neo4j/graphql";
import { toGraphQLTypeDefs } from "@neo4j/introspector";
import neo4j from "neo4j-driver";

const driver = neo4j.driver(
    "neo4j://localhost:7687",
    neo4j.auth.basic("username", "password")
);

const sessionFactory = () =>
    driver.session({ defaultAccessMode: neo4j.session.READ });

// We create a async function here until "top level await" has landed
// so we can use async/await
async function main() {
    const readonly = true; // We don't want to expose mutations in this case
    const typeDefs = await toGraphQLTypeDefs(sessionFactory, readonly);

    const neoSchema = new Neo4jGraphQL({ typeDefs, driver });

    const server = new ApolloServer({
        schema: await neoSchema.getSchema(),
    });

    await startStandaloneServer(server, {
        context: async ({ req }) => ({ req }),
    });
}

main();