从现有 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();