本文详细介绍了如何在Apollo Server中结合Neo4j数据库，通过GraphQL查询并正确映射和返回中心节点及其关联节点。我们将探讨GraphQL模式定义、Neo4j数据查询以及Apollo Server解析器（Resolver）的实现细节，特别是如何处理嵌套的关联节点数据，确保数据结构与GraphQL类型定义一致，从而解决关联节点无法正确返回的问题。
1. 引言：GraphQL与Neo4j集成中的挑战
在构建基于图数据库（如neo4j）的应用程序时，通过graphql api暴露数据是一种常见且强大的模式。然而，当数据模型涉及复杂的关联关系时，如何将neo4j查询结果有效地映射到graphql类型，特别是处理嵌套的关联节点，可能会遇到挑战。本教程将以一个具体的案例为例，演示如何使用apollo server和neo4j驱动程序，解决graphql查询中关联节点无法正确返回的问题。
我们的目标是查询一个中心Company节点，并获取其通过特定路径连接的Company或Person节点，并将这些关联节点作为connectedNodes字段返回。
2. GraphQL Schema 定义
首先，我们需要定义GraphQL的类型模式（typeDefs），这决定了客户端可以查询的数据结构。
Schema说明：
JSON 标量：通过 graphql-scalars 库引入，允许我们在 Node 类型的 properties 字段中灵活地存储任何JSON结构，以适应不同节点类型（Company或Person）的动态属性。
Company 类型：包含公司基本信息和一个 connectedNodes 字段，该字段是一个 Node 类型的数组。
Person 类型：作为示例，展示了人员可能包含的属性。
Node 类型：这是一个关键的通用类型，用于表示所有关联节点。它包含 id、labels（节点的标签，如Company或Person）和 properties（节点的具体属性）。
Query.company：定义了一个根查询，通过 orgNo 参数查询单个 Company。
3. Neo4j 数据查询与驱动配置
我们使用官方的 neo4j-driver 连接到Neo4j数据库，并通过Cypher查询获取数据。
4. Apollo Server 解析器（Resolvers）的实现
解析器是连接GraphQL Schema和实际数据源的关键。我们将定义 Query.company 解析器来执行Neo4j查询并处理结果，以及一个 Company.connectedNodes 解析器来确保关联节点被正确地返回。
4.1 原始问题：关联节点未被正确返回
最初的问题在于，虽然 connectedNodes 数组在 Query.company 解析器中被成功构建，但它并没有被赋值给最终返回的 company 对象，导致GraphQL客户端无法获取到这些关联节点。
php版微信js-sdk支付接口类
php版微信js-sdk支付接口类
下载
4.2 解决方案：正确映射和返回关联节点
要解决这个问题，需要两个关键步骤：
在 Query.company 解析器中，将 connectedNodes 数组附加到返回的 company 对象上。
为 Company 类型定义一个 connectedNodes 字段的解析器。
尽管数据已经附加到 company 对象上，但为了确保Apollo Server能够正确地解析嵌套字段，显式地定义一个解析器是一种良好的实践，尤其是在数据可能来自不同来源或需要额外处理时。在这里，它只是简单地返回父对象中的 connectedNodes。
4.3 完整的 Apollo Server 启动代码
将 typeDefs 和 resolvers 传入 ApolloServer 实例并启动。
5. 关键点与注意事项
数据映射的准确性：
确保从Neo4j返回的数据结构能够准确地映射到GraphQL Schema中定义的类型。特别是对于 Node 这种通用类型，其 properties 字段配合 GraphQLJSON 提供了极大的灵活性。
解析器链：
理解Apollo Server的解析器链工作原理至关重要。当一个字段是复杂类型（如 Company.connectedNodes），即使其数据已包含在父对象中，为了确保解析的明确性和未来扩展性，通常会为其定义一个显式解析器。
错误处理和空值检查：
在实际生产代码中，应加入更健壮的错误处理和空值检查，例如当 result.records[0] 或 companyNode 为空时。
性能优化：
对于大规模的图数据查询，考虑Cypher查询的性能，例如使用索引、优化路径匹配深度等。
GraphQL Union/Interface：
如果 connectedNodes 中的节点类型（Company、Person）需要各自暴露其独有的字段（而不仅仅是通过 properties: JSON），那么更合适的做法是使用 GraphQL Union 或 Interface 类型来定义 Node，并为它们提供 __resolveType 解析器。本例中，type Node 配合 properties: JSON 已经满足了需求，因为它将所有节点属性都包裹在 properties 字段中。
6. 总结
通过以上步骤，我们成功地解决了在Apollo Server中从Neo4j数据库查询并返回关联节点的问题。核心在于：
在顶层查询解析器中，将所有需要返回的数据（包括关联节点）完整地构建并附加到父对象上。
为嵌套的复杂类型字段定义显式解析器，即使它只是简单地从父对象中取出数据。
这种模式确保了GraphQL API能够准确、高效地暴露图数据库的复杂关系数据，为客户端提供了清晰且可预测的数据接口。
const { ApolloServer, gql } = require('apollo-server');
const neo4j = require('neo4j-driver');
const { GraphQLJSON } = require('graphql-scalars'); // 用于处理动态属性
const typeDefs = gql`
scalar JSON # 定义一个JSON标量，用于存储不确定的属性集合
# 定义公司类型
type Company {
id: ID!
orgNo: String!
companyName: String!
address: String!
city: String!
zipCode: String!
connectedNodes: [Node] # 关联节点列表
}
# 定义人员类型 (虽然在解决方案中作为Node返回，但可以根据需要扩展)
type Person {
id: ID!
role: String
ZipCode: String
Street: String
test_id: String
label: String
City: String
RoleCode: String
Name: String
}
# 定义一个通用的节点接口或类型，用于表示关联节点
# 这里使用type Node，因为它足够灵活，可以通过properties字段包含不同节点的具体属性
type Node {
id: ID!
labels: [String]!
properties: JSON
}
# 定义查询类型
type Query {
company(orgNo: String!): Company # 根据组织编号查询公司
}
`;// Neo4j 驱动配置
const driver = neo4j.driver(
'bolt://localhost:7687', // Neo4j 数据库地址
neo4j.auth.basic('neo4j', 'password') // 认证信息
);
// Cypher 查询语句
// MATCH (source:Company {OrgNo: $orgNo}) 匹配中心公司节点
// OPTIONAL MATCH path = (source)-[*1..3]-(target) 可选匹配1到3跳的路径到目标节点
// WHERE NONE(rel IN relationships(path) WHERE rel.RoleCode IN ['REV', 'SU']) 过滤掉特定关系类型的路径
// RETURN source, COLLECT(DISTINCT target) AS connected_nodes 返回源节点和所有不重复的目标节点
const cypherQuery = `
MATCH (source:Company {OrgNo: $orgNo})
OPTIONAL MATCH path = (source)-[*1..3]-(target)
WHERE NONE(rel IN relationships(path) WHERE rel.RoleCode IN ['REV', 'SU'])
RETURN source, COLLECT(DISTINCT target) AS connected_nodes
`;// 原始的 Query.company 解析器（存在问题）
const resolvers_problematic = {
JSON: GraphQLJSON,
Query: {
company: async (_, { orgNo }) => {
const session = driver.session();
const result = await session.run(cypherQuery, { orgNo });
await session.close();
const companyNode = result.records[0]?.get('source')?.properties;
if (!companyNode) return null;
const connectedNodes = result.records[0]?.get('connected_nodes')?.map(record => {
// 映射逻辑...
return {
id: record.identity?.toString() || null,
labels: record.labels || [],
properties: record.properties || {}
};
}) || [];
const company = {
id: companyNode && companyNode['identity']?.toString() || '',
orgNo: companyNode && companyNode['OrgNo'] || null,
companyName: companyNode && companyNode['CompanyName'] || null,
address: companyNode && companyNode['Address'] || null,
city: companyNode && companyNode['City'] || null,
zipCode: companyNode && companyNode['ZipCode'] || ''
// ⚠️ 问题所在：connectedNodes 在这里没有被添加到 company 对象中
};
return company;
},
},
};const resolvers = {
JSON: GraphQLJSON, // 注册JSON标量解析器
Query: {
company: async (_, { orgNo }) => {
const session = driver.session();
const result = await session.run(cypherQuery, { orgNo });
session.close();
const companyNode = result.records[0]?.get('source')?.properties;
if (!companyNode) return null;
// 映射 Neo4j 返回的关联节点数据到 GraphQL 的 Node 类型
const connectedNodes = result.records[0]?.get('connected_nodes')?.map(record => {
return {
id: record.identity?.toString() || null, // Neo4j 内部ID
labels: record.labels || [], // 节点的标签数组
properties: record.properties || {} // 节点的所有属性
};
}) || [];
// 构建最终的 company 对象，并包含 connectedNodes
const company = {
id: companyNode && companyNode['identity']?.toString() || '',
orgNo: companyNode && companyNode['OrgNo'] || null,
companyName: companyNode && companyNode['CompanyName'] || null,
address: companyNode && companyNode['Address'] || null,
city: companyNode && companyNode['City'] || null,
zipCode: companyNode && companyNode['ZipCode'] || '',
connectedNodes: connectedNodes // ? 关键：将关联节点附加到 company 对象
};
return company;
},
},
// ? 关键：为 Company 类型的 connectedNodes 字段定义解析器
// Apollo Server 会在解析 Company 对象的 connectedNodes 字段时调用此解析器
// parent 参数就是 Query.company 解析器返回的 company 对象
Company: {
connectedNodes: async (parent) => parent.connectedNodes
},
};const server = new ApolloServer({
typeDefs,
resolvers,
});
server.listen().then(({ url }) => {
console.log(`Server running at ${url}`);
});