功能

存储过程/函数

描述

示例

数据转换

apoc.convert.toJson()

将节点、关系或任何图数据结构转换为 JSON 格式

MATCH (n:Person) RETURN apoc.convert.toJson(n)

集合操作

apoc.coll.flatten()

将嵌套的集合扁平化

RETURN apoc.coll.flatten([[1, 2], [3, 4]])

apoc.coll.sum()

计算集合中所有元素的和

RETURN apoc.coll.sum([1, 2, 3, 4])

apoc.text.join()

将集合中的元素连接成一个字符串

RETURN apoc.text.join(['a', 'b', 'c'], ',')

图算法

apoc.algo.shortestPath()

计算两个节点之间的最短路径

MATCH (start:Person {name: 'Alice'}), (end:Person {name: 'Bob'}) CALL apoc.algo.shortestPath(start, end, 'KNOWS') YIELD path RETURN path

apoc.algo.dijkstra()

Dijkstra 算法计算最短路径

MATCH (start:Person {name: 'Alice'}), (end:Person {name: 'Bob'}) CALL apoc.algo.dijkstra(start, end, 'KNOWS') YIELD path RETURN path

导入/导出数据

apoc.import.csv()

从 CSV 文件导入数据

CALL apoc.import.csv('file:///path/to/file.csv', {header:true}) YIELD nodes, relationships RETURN nodes

apoc.export.csv.all()

将所有图数据导出为 CSV 文件

CALL apoc.export.csv.all('file:///output.csv', {})

apoc.load.csv()

从 CSV 文件中加载数据

CALL apoc.load.csv('file:///path/to/file.csv') YIELD map RETURN map

apoc.load.json()

从外部 URL 加载 JSON 数据

CALL apoc.load.json('http://example.com/data.json') YIELD value RETURN value

外部系统集成

apoc.load.xml()

从外部 URL 加载 XML 数据

CALL apoc.load.xml('http://example.com/data.xml') YIELD value RETURN value

apoc.load.http()

通过 HTTP 请求获取外部数据

CALL apoc.load.http('http://example.com/api') YIELD value RETURN value

日期和时间处理

apoc.date.convert()

将日期时间字符串转换为时间戳

RETURN apoc.date.convert('2024-11-01T12:00:00', 'ISO_8601', 'milliseconds')

图数据操作

apoc.create.node()

创建节点并为其设置属性

CALL apoc.create.node(['Person'], {name: 'Alice', age: 30}) YIELD node RETURN node

apoc.create.relationship()

创建关系并设置属性

MATCH (a:Person {name: 'Alice'}), (b:Person {name: 'Bob'}) CALL apoc.create.relationship(a, 'KNOWS', {since: 2020}) YIELD rel RETURN rel

事务和批量操作

apoc.periodic.iterate()

按批次进行迭代处理

CALL apoc.periodic.iterate('MATCH (n:Person) RETURN n', 'SET n.processed = true', {batchSize: 1000}) YIELD batches, total RETURN batches, total

性能监控与统计

apoc.stats()

返回数据库的统计信息

RETURN apoc.stats()

路径和图遍历

apoc.path.expand()

扩展路径，获取指定节点的邻居

MATCH (a:Person {name: 'Alice'}) CALL apoc.path.expand(a, 'KNOWS', 1) YIELD path RETURN path

apoc.path.subgraphNodes()

获取路径的子图节点

MATCH (a:Person {name: 'Alice'}) CALL apoc.path.subgraphNodes(a, {relationshipFilter: 'KNOWS'}) YIELD node RETURN node

字符串处理

apoc.text.split()

按指定分隔符将字符串分割成多个部分

RETURN apoc.text.split('a,b,c,d', ',')

apoc.text.replace()

在字符串中进行替换操作

RETURN apoc.text.replace('Hello World', 'World', 'Neo4j')