如何将Neo4j查询结果转换为D3兼容的Graph JSON格式

Neo4j作为常用的图数据库，其查询结果通常包含节点和关系的原始属性，而D3.js实现图可视化时，需要符合特定结构的Graph JSON数据，两者的格式差异需要通过转换逻辑来适配。

Neo4j查询结果的结构特点

通过Neo4j的官方驱动查询数据时，返回的结果中每个节点会包含identity、labels、properties等属性，关系会包含identity、type、start、end、properties等属性。以JavaScript驱动为例，查询所有节点和关系的代码返回的原始数据结构如下：

// 使用neo4j-driver查询数据
const neo4j = require('neo4j-driver');
const driver = neo4j.driver('neo4j://127.0.0.1:7687', neo4j.auth.basic('neo4j', 'password'));
const session = driver.session();

async function queryRawData() {
  const result = await session.run('MATCH (n)-[r]->(m) RETURN n, r, m');
  const records = result.records;
  // 原始节点和关系数据都在records中，每个record包含n、r、m三个字段
  return records;
}

D3兼容Graph JSON的格式要求

D3的力导向图等布局通常需要两个核心数组：nodes数组存储所有节点信息，每个节点需要唯一的id属性；links数组存储所有关系信息，每个关系需要source和target属性，对应节点的id。标准格式示例如下：

{
  "nodes": [
    {"id": "1", "label": "用户", "name": "张三"},
    {"id": "2", "label": "订单", "name": "订单1001"}
  ],
  "links": [
    {"source": "1", "target": "2", "type": "下单"}
  ]
}

完整转换实现步骤

1. 提取去重的节点集合

首先从Neo4j的查询结果中提取所有节点，根据节点的identity去重，避免重复节点出现在最终数据中。

2. 映射节点属性到D3格式

将Neo4j节点的identity转为字符串作为D3节点的id，同时保留需要的业务属性，比如labels、properties中的内容。

3. 转换关系到links数组

提取所有关系，将关系的start和end对应的节点id分别作为source和target，同时保留关系的type和业务属性。

可复用的转换代码示例

以下是完整的JavaScript转换函数，可直接对接Neo4j驱动返回的原始查询结果：

/**
 * 将Neo4j查询结果转换为D3兼容的Graph JSON
 * @param {Array} records - Neo4j查询返回的records数组
 * @returns {Object} 符合D3要求的Graph JSON对象
 */
function transformNeo4jToD3(records) {
  const nodeMap = new Map(); // 用于节点去重
  const links = [];

  records.forEach(record => {
    // 提取记录中的节点和关系，不同查询语句的字段名可能不同，这里适配n、r、m的结构
    const nodesInRecord = [];
    record.keys.forEach(key => {
      const value = record.get(key);
      if (value && value.identity !== undefined) {
        // 判断是节点还是关系，节点有labels属性，关系有type和start/end属性
        if (value.labels) {
          nodesInRecord.push(value);
        } else if (value.type && value.start !== undefined) {
          // 处理关系
          const sourceId = value.start.toString();
          const targetId = value.end.toString();
          links.push({
            source: sourceId,
            target: targetId,
            type: value.type,
            ...value.properties
          });
        }
      }
    });

    // 处理当前记录中的节点，去重后存入nodeMap
    nodesInRecord.forEach(node => {
      const nodeId = node.identity.toString();
      if (!nodeMap.has(nodeId)) {
        nodeMap.set(nodeId, {
          id: nodeId,
          labels: node.labels,
          ...node.properties
        });
      }
    });
  });

  // 将nodeMap转为nodes数组
  const nodes = Array.from(nodeMap.values());

  return {
    nodes: nodes,
    links: links
  };
}

// 使用示例
async function main() {
  const rawRecords = await queryRawData();
  const d3GraphData = transformNeo4jToD3(rawRecords);
  console.log(JSON.stringify(d3GraphData, null, 2));
  session.close();
  driver.close();
}

注意事项

• 如果Neo4j查询语句返回的字段名不是n、r、m，需要调整代码中提取节点的逻辑，匹配实际的字段名。
• 节点的id建议使用Neo4j原生的identity转换而来，保证唯一性，不要使用业务属性作为id避免冲突。
• 如果关系需要双向展示，可以在转换时同时生成正向和反向的link，或者在前端D3渲染时处理方向逻辑。

转换后的数据可以直接传入D3的力导向图布局函数，无需额外调整格式，大幅提升图可视化的开发效率。

Neo4jD3Graph_JSON数据转换图数据库修改时间：2026-07-11 16:06:30