Neo4j数据导入导出如何进行

Neo4j数据导入导出方法指南

一、数据导入方法

1. 使用neo4j-admin工具（全量/批量导入，推荐用于新数据库）

neo4j-admin是Neo4j官方提供的命令行工具，适用于全新数据库初始化或全量数据迁移，支持CSV、JSON等格式。
步骤：

• 准备数据文件：将节点和关系数据分别存为CSV文件（如nodes.csv、relationships.csv）。节点文件需包含:ID（唯一标识）、:LABEL（标签）和属性（如name:string）；关系文件需包含:START_ID（起始节点ID）、:END_ID（结束节点ID）、:TYPE（关系类型）和属性（如since:int）。
• 停止Neo4j服务：导入前必须停止数据库，避免数据不一致。
• 执行导入命令：

  neo4j-admin import --nodes=nodes.csv --relationships=relationships.csv --database=neo4j
  

  可选参数：--create-indexes=true（导入后自动创建索引，提升查询性能）。
  注意：此方法会覆盖目标数据库，仅适用于新数据库或完全替换数据的场景。

2. 使用LOAD CSV命令（增量导入，适合中小规模数据）

LOAD CSV是Neo4j内置的Cypher命令，用于增量导入CSV文件（如每日新增数据），无需停止服务。
步骤：

• 将CSV文件放入import目录：Neo4j默认从import目录读取文件（Docker环境中为/var/lib/neo4j/import）。
• 执行Cypher查询：

  LOAD CSV WITH HEADERS FROM 'file:///nodes.csv' AS row
  CREATE (:Person {id: toInteger(row.id), name: row.name, age: toInteger(row.age)});
  
  LOAD CSV WITH HEADERS FROM 'file:///relationships.csv' AS row
  MATCH (a:Person {id: toInteger(row.startId)}), (b:Person {id: toInteger(row.endId)})
  CREATE (a)-[:FRIENDS {since: toInteger(row.since)}]->(b);
  

  关键参数：WITH HEADERS（表示CSV第一行为标题行）、file:///（指向import目录）。

3. 使用APOC插件（灵活导入，支持多种格式）

APOC（Awesome Procedures On Cypher）是Neo4j的扩展插件，提供apoc.import系列过程，支持**CSV、JSON、XML、图文件（GraphML、GEXF）**等多种格式，功能更灵活。
步骤：

• 安装APOC插件：将APOC JAR文件放入plugins目录，修改neo4j.conf（添加dbms.security.procedures.unrestricted=apoc.*），重启Neo4j。
• 导入数据：
  • CSV文件：

    CALL apoc.import.csv(
      ["file:///nodes.csv", "Person:ID,name,age:int"],
      ["file:///relationships.csv", ":START_ID,:END_ID,:TYPE,since:int"],
      {database: "neo4j"}
    );
    

  • JSON文件：

    CALL apoc.import.json("file:///data.json", {database: "neo4j"});
    

优势：支持复杂数据结构（如嵌套JSON）、批量操作，且可自定义导入逻辑（如属性映射）。

4. 使用Neo4j Browser/DeskTop（手动导入，适合小规模数据）

• Neo4j Browser：登录浏览器（http://localhost:7474），点击顶部菜单栏的“+”→“Import”，选择CSV或JSON文件，按照向导配置节点/关系映射，点击“Execute”完成导入。
• Neo4j DeskTop：打开项目→选中数据库→点击“Manage”→“Open Folder”，将CSV文件放入import目录，然后在“Query”面板执行LOAD CSV命令。

二、数据导出方法

1. 使用neo4j-admin工具（全量导出，用于备份/迁移）

neo4j-admin可将整个数据库导出为二进制备份文件（.dump），包含数据、索引、约束等完整信息。
步骤：

• 停止Neo4j服务：导出前停止数据库，确保数据一致性。
• 执行导出命令：

  neo4j-admin dump --database=neo4j --to=/path/to/backup.dump
  

• 导入备份文件（目标环境）：

  neo4j-admin load --from=/path/to/backup.dump --database=neo4j --force
  

注意：备份文件较大，适合全量迁移或灾难恢复。

2. 使用APOC插件（灵活导出，支持多种格式）

APOC的apoc.export系列过程支持CSV、JSON、图文件（GraphML、GEXF）、Cypher脚本等格式，可导出特定子图或查询结果。
常用命令：

• 导出所有数据为Cypher脚本（包含节点和关系创建语句）：

  CALL apoc.export.cypher.all("all_data.cypher", {format: "plain"});
  

• 导出节点为CSV：

  CALL apoc.export.csv.nodes("nodes.csv", "MATCH (n:Person) RETURN n", {database: "neo4j"});
  

• 导出关系为JSON：

  CALL apoc.export.json.relationships("relationships.json", "MATCH ()-[r]->() RETURN r", {database: "neo4j"});
  

优势：支持过滤（如WHERE子句）、自定义输出路径（如绝对路径），适合部分数据迁移或分析。

3. 使用Cypher查询导出（特定数据导出，适合定制化需求）

通过Cypher查询筛选所需数据，然后使用apoc.export.query或LOAD CSV导出。
示例：导出所有年龄大于30的用户及其朋友关系：

MATCH (p:Person {age: gt(30)})-[r:FRIENDS]->(friend:Person)
RETURN p, r, friend

然后使用APOC导出查询结果：

CALL apoc.export.csv.query("MATCH (p:Person {age: gt(30)})-[r:FRIENDS]->(friend:Person) RETURN p, r, friend", "adult_friends.csv", {});

4. 使用Neo4j Browser/DeskTop（手动导出，适合小规模数据）

• Neo4j Browser：执行Cypher查询（如MATCH (n) RETURN n LIMIT 100），点击结果面板顶部的“Export”按钮，选择CSV或JSON格式下载。
• Neo4j DeskTop：打开数据库→点击“Data” tab→选中节点/关系表→点击“Export”按钮，选择格式和路径。

三、注意事项

1. 权限与路径：确保Neo4j对导入/导出目录有读写权限（如Docker中的import目录需挂载为rw）；路径使用绝对路径避免错误。
2. 数据一致性：全量导入/导出前停止Neo4j服务；增量导入时确保目标数据库已存在对应节点（可通过MERGE语句避免重复）。
3. 版本兼容性：neo4j-admin工具需与源/目标数据库版本一致，避免格式不兼容。
4. APOC配置：使用APOC前需安装插件并配置neo4j.conf，否则无法调用相关过程。