过程与函数

apoc.agg.position

返回匹配给定 value 的 element 的索引

函数

apoc.agg.row

返回匹配给定 predicate 的 element 的索引

过程

apoc.agg.multiStats

apoc.agg.multiStats(nodeOrRel, keys) - 返回多维聚合

函数

apoc.agg.rollup

apoc.agg.rollup(<ANY>, [groupKeys], [aggKeys])

模拟 Oracle/Mysql 的 rollup 命令：`ROLLUP groupKeys, SUM(aggKey1), AVG(aggKey1), COUNT(aggKey1), SUM(aggKey2), AVG(aggKey2), …`

函数

apoc.algo.aStarWithPoint

等同于 apoc.algo.aStar，但接受 Point 类型作为 pointProperty，而不是接受数字类型作为经纬度属性

过程

apoc.bolt.load

apoc.bolt.load(url-or-key, kernelTransaction, params, config) - 通过 bolt 读取访问其他数据库

过程

apoc.bolt.load.fromLocal

过程

apoc.coll.avgDuration

apoc.coll.avgDuration([duration('P2DT3H'), duration('PT1H45S'), …]) - 返回持续时间值列表的平均值

函数

apoc.coll.fillObject

apoc.coll.fillObject(item, count) - 返回一个包含给定大小的相等项目列表

函数

apoc.config.list

apoc.config.list | 以键值表形式列出 Neo4j 配置

过程

apoc.config.map

apoc.config.map | 以映射形式列出 Neo4j 配置

过程

apoc.convert.toYaml

apoc.convert.toYaml(value, $config) - 将给定值序列化为 YAML 字符串

函数

apoc.convert.fromYaml

apoc.convert.fromYaml(value, $config) - 将 YAML 字符串反序列化为 Neo4j 值

函数

apoc.couchbase.append

apoc.couchbase.append(hostOrKey, bucket, documentId, content, config) yield id, expiry, cas, mutationToken, content - 将 couchbase json 文档附加到现有文档中。

过程

apoc.couchbase.exists

apoc.couchbase.exists(hostOrKey, bucket, documentId, config) yield value - 检查具有给定 ID 的 couchbase json 文档是否存在。

过程

apoc.couchbase.get

apoc.couchbase.get(hostOrKey, bucket, documentId, config) yield id, expiry, cas, mutationToken, content - 通过其唯一 ID 检索 couchbase json 文档。

过程

apoc.couchbase.insert

apoc.couchbase.insert(hostOrKey, bucket, documentId, jsonDocument, config) yield id, expiry, cas, mutationToken, content - 使用唯一 ID 插入 couchbase json 文档。

过程

apoc.couchbase.namedParamsQuery

apoc.couchbase.namedParamsQuery(hostkOrKey, bucket, statement, paramNames, paramValues, config) yield queryResult - 执行带有命名参数的 N1QL 语句。

过程

apoc.couchbase.posParamsQuery

apoc.couchbase.posParamsQuery(hostOrKey, bucket, statement, params, config) yield queryResult - 执行带有位置参数的 N1QL 语句。

过程

apoc.couchbase.prepend

apoc.couchbase.prepend(hostOrKey, bucket, documentId, content, config) yield id, expiry, cas, mutationToken, content - 将 couchbase json 文档前置到现有文档中。

过程

apoc.couchbase.query

apoc.couchbase.query(hostOrKey, bucket, statement, config) yield queryResult - 执行简单的无参数 N1QL 语句。

过程

apoc.couchbase.remove

apoc.couchbase.remove(hostOrKey, bucket, documentId, config) yield id, expiry, cas, mutationToken, content - 移除由其唯一 ID 标识的 couchbase json 文档。

过程

apoc.couchbase.replace

apoc.couchbase.replace(hostOrKey, bucket, documentId, jsonDocument, config) yield id, expiry, cas, mutationToken, content - 替换由其唯一 ID 标识的 couchbase json 文档的内容。

过程

apoc.couchbase.upsert

apoc.couchbase.upsert(hostOrKey, bucket, documentId, jsonDocument) yield id, expiry, cas, mutationToken, content - 插入或覆盖具有唯一 ID 的 couchbase json 文档。

过程

apoc.custom.dropAll

apoc.custom.dropAll(databaseName) - 最终删除所有先前添加的自定义过程/函数并返回信息

过程

apoc.custom.dropFunction

apoc.custom.dropFunction(name, databaseName) - 最终删除目标自定义函数

过程

apoc.custom.dropProcedure

apoc.custom.dropProcedure(name, databaseName) - 最终删除目标自定义过程

过程

apoc.custom.installFunction

apoc.custom.installFunction(signature, statement, databaseName, forceSingle, description) - 最终注册自定义 Cypher 函数

过程

apoc.custom.installProcedure

apoc.custom.installProcedure(signature, statement, databaseName, mode, description) - 最终注册自定义 Cypher 过程

过程

apoc.custom.list

apoc.custom.list() - 提供已注册的自定义过程/函数列表

过程

apoc.custom.show

apoc.custom.show(databaseName) - 提供已注册的自定义过程/函数列表

过程

apoc.cypher.parallel

apoc.cypher.parallel(fragment, paramMap, keyList) yield value - 通过 paramMap 中定义的具有键 keyList 的列表并行执行片段

过程

apoc.cypher.parallel2

apoc.cypher.parallel2(fragment, paramMap, keyList) yield value - 通过 paramMap 中定义的具有键 keyList 的列表，以并行批次方式执行片段

过程

apoc.cypher.runFile

apoc.cypher.runFile(file or url,[{statistics:true,timeout:10,parameters:{}}]) - 运行文件中的每条语句，均以分号分隔 - 目前不支持模式操作

过程

apoc.cypher.runFiles

apoc.cypher.runFiles([files or urls],[{statistics:true,timeout:10,parameters:{}}])) - 运行文件中的每条语句，均以分号分隔

过程

apoc.cypher.runFileReadOnly

apoc.cypher.runFileReadOnly(file or url,[{timeout:10,parameters:{}}]) - 运行文件中的每条 READ 语句，均以分号分隔

过程

apoc.cypher.runFilesReadOnly

apoc.cypher.runFilesReadOnly([files or urls],[{timeout:10,parameters:{}}])) - 运行文件中的每条 READ 语句，均以分号分隔

过程

apoc.cypher.runSchemaFile

apoc.cypher.runSchemaFile(file or url,[{statistics:true,timeout:10}]) - 仅允许模式操作，运行文件中的每条模式语句，均以分号分隔

过程

apoc.cypher.runSchemaFiles

apoc.cypher.runSchemaFiles([files or urls],{statistics:true,timeout:10}) - 仅允许模式操作，运行文件中的每条模式语句，均以分号分隔

过程

apoc.diff.graphs

apoc.diff.graphs(<source>, <dest>, <config>) - 比较两个图并返回结果

过程

apoc.diff.relationships

返回一个详细说明两个给定关系之间属性差异的映射

函数

apoc.data.email

apoc.data.email('email_address') as {personal,user,domain} - 将个人姓名、用户和域提取为映射

函数

apoc.dv.catalog.drop

按名称删除虚拟化资源配置

过程

apoc.dv.catalog.install

最终添加虚拟化资源配置

过程

apoc.dv.catalog.show

列出所有虚拟化资源配置

过程

apoc.dv.query

按名称查询虚拟化资源并返回虚拟节点

过程

apoc.dv.queryAndLink

按名称查询虚拟化资源，并返回使用虚拟关系链接到作为第一个参数传递的节点的虚拟节点

过程

apoc.es.delete

apoc.es.delete(host-or-key,index-or-null,type-or-null,id-or-null,query-or-null,$config) yield value - 在 elastic search 上执行 DELETE 操作

过程

apoc.es.get

apoc.es.get(host-or-key,index-or-null,type-or-null,id-or-null,query-or-null,payload-or-null,$config) yield value - 在 elastic search 上执行 GET 操作

过程

apoc.es.getRaw

apoc.es.getRaw(host-or-key,path,payload-or-null,$config) yield value - 在 elastic search 上执行原始 GET 操作

过程

apoc.es.post

apoc.es.post(host-or-key,index-or-null,type-or-null,query-or-null,payload-or-null,$config) yield value - 在 elastic search 上执行 POST 操作

过程

apoc.es.postRaw

apoc.es.postRaw(host-or-key,path,payload-or-null,$config) yield value - 在 elastic search 上执行原始 POST 操作

过程

apoc.es.put

apoc.es.put(host-or-key,index-or-null,type-or-null,id-or-null,query-or-null,payload-or-null,$config) yield value - 在 elastic search 上执行 PUT 操作

过程

apoc.es.query

apoc.es.query(host-or-key,index-or-null,type-or-null,query-or-null,payload-or-null,$config) yield value - 在 elastic search 上执行 SEARCH 操作

过程

apoc.es.stats

apoc.es.stats(host-or-key,$config) - elastic search 统计信息

过程

apoc.export.parquet.all

将整个数据库导出为 Parquet 文件。

过程

apoc.export.parquet.all.stream

将整个数据库导出为 Parquet 字节数组。

过程

apoc.export.parquet.data

将给定节点和关系导出为 Parquet 文件。

过程

apoc.export.parquet.data.stream

将给定节点和关系导出为 Parquet 字节数组。

过程

apoc.export.parquet.graph

将给定图导出为 Parquet 文件。

过程

apoc.export.parquet.graph.stream

将给定图导出为 Parquet 字节数组。

过程

apoc.export.parquet.query

将给定 Cypher 查询导出为 Parquet 文件。

过程

apoc.export.parquet.query.stream

将给定 Cypher 查询导出为 Parquet 字节数组。

过程

apoc.export.xls.all

apoc.export.xls.all(file,config) - 将整个数据库作为 xls 导出到提供的文件

过程

apoc.export.xls.data

apoc.export.xls.data(nodes,rels,file,config) - 将给定节点和关系作为 xls 导出到提供的文件

过程

apoc.export.xls.graph

apoc.export.xls.graph(graph,file,config) - 将给定图对象作为 xls 导出到提供的文件

过程

apoc.export.xls.query

apoc.export.xls.query(query,file,{config,…,params:{params}}) - 将 Cypher 语句的结果作为 xls 导出到提供的文件

过程

apoc.generate.ba

apoc.generate.ba(noNodes, edgesPerNode, label, type) - 根据 Barabasi-Albert 模型生成随机图

过程

apoc.generate.complete

apoc.generate.complete(noNodes, label, type) - 生成随机完全图

过程

apoc.generate.er

apoc.generate.er(noNodes, noEdges, label, type) - 根据 Erdos-Renyi 模型生成随机图

过程

apoc.generate.simple

apoc.generate.simple(degrees, label, type) - 根据给定的度分布生成简单随机图

过程

apoc.generate.ws

apoc.generate.ws(noNodes, degree, beta, label, type) - 根据 Watts-Strogatz 模型生成随机图

过程

apoc.gephi.add

apoc.gephi.add(url-or-key, workspace, data, weightproperty, ['exportproperty']) | 将传入的数据流传输到 Gephi

过程

apoc.get.nodes

apoc.get.nodes(node|id|[ids]) - 快速返回具有这些 ID 的所有节点

过程

apoc.get.rels

apoc.get.rels(rel|id|[ids]) - 快速返回具有这些 ID 的所有关系

过程

apoc.import.arrow

apoc.import.arrow(input, $config) - 从提供的 arrow 文件或字节数组导入 arrow

过程

apoc.import.gexf

从提供的 GraphML 文件导入图。

过程

apoc.import.parquet

从提供的文件或二进制文件导入 parquet

过程

apoc.jdbc.analytics

apoc.jdbc.analytics(<cypherQuery>, <jdbcUrl>, <sqlQueryOverTemporaryTable>, <paramsList>, $config) - 从 Cypher 查询创建临时表，并将复杂的分析委托给数据库定义的 JDBC URL

过程

apoc.load.csv

apoc.load.csv('urlOrBinary',{config}) YIELD lineNo, list, map - 以值流形式从 URL 加载 CSV，配置包含以下任何项：{skip:1,limit:5,header:false,sep:'TAB',ignore:['tmp'],nullValues:['na'],arraySep:';',mapping:{years:{type:'int',arraySep:'-',array:false,name:'age',ignore:false}}

过程

apoc.load.csvParams

apoc.load.csvParams('urlOrBinary', {httpHeader: value}, payload, {config}) YIELD lineNo, list, map - 在发送头部/有效负载的同时从 CSV URL（例如 web-api）加载，作为值流加载 CSV，配置包含以下任何项：{skip:1,limit:5,header:false,sep:'TAB',ignore:['tmp'],nullValues:['na'],arraySep:';',mapping:{years:{type:'int',arraySep:'-',array:false,name:'age',ignore:false}}

过程

apoc.load.directory

apoc.load.directory('pattern', 'urlDir', {config}) YIELD value - 加载参数 urlDir 指定的文件夹中满足给定模式的所有文件列表。如果未指定参数 urlDir 或为空，则加载导入文件夹的文件。

过程

apoc.load.directory.async.add

apoc.load.directory.async.add(name, cypher, pattern, urlDir, {}) YIELD name, status, pattern, cypher, urlDir, config, error - 添加或替换具有特定名称的文件夹监听器，该监听器在所有具有给定模式的文件触发时执行指定的 Cypher 查询。返回所有监听器的列表。可以在配置参数中指定事件类型。

过程

apoc.load.directory.async.list

apoc.load.directory.async.list() YIELD name, status, pattern, cypher, urlDir, config, error - 列出所有文件夹监听器

过程

apoc.load.directory.async.remove

apoc.load.directory.async.remove(name) YIELD name, status, pattern, cypher, urlDir, config, error - 按名称删除文件夹监听器，并返回所有剩余的监听器（如果有）

过程

apoc.load.directory.async.removeAll

apoc.load.directory.async.removeAll() - 删除所有文件夹监听器

过程

apoc.load.driver

apoc.load.driver('org.apache.derby.jdbc.EmbeddedDriver') 注册源数据库的 JDBC 驱动程序

过程

apoc.load.gexf

apoc.load.gexf(urlOrBinary, path, $config) - 从 URL 或二进制源加载 Gexf 文件

过程

apoc.load.html

apoc.load.html('url',{name: jquery, name2: jquery}, config) YIELD value - 加载 Html 页面并以映射形式返回结果

过程

apoc.load.htmlPlainText

apoc.load.htmlPlainText('urlOrHtml',{name: jquery, name2: jquery}, config) YIELD value - 加载 Html 页面并以映射形式返回结果

过程

apoc.load.jdbc

apoc.load.jdbc('key or url','table or statement', params, config) YIELD row - 从关系数据库加载，从完整表或 sql 语句加载

过程

apoc.load.jdbcUpdate

apoc.load.jdbcUpdate('key or url','statement',[params],config) YIELD row - 更新关系数据库，从带有可选参数的 SQL 语句更新

过程

apoc.load.ldap

apoc.load.ldap("key" or {connectionMap},{searchMap}) 从 ldap 源加载条目 (yield entry)

过程

apoc.load.parquet

从提供的文件或二进制文件加载 parquet

过程

apoc.load.xls

apoc.load.xls('url','selector',{config}) YIELD lineNo, list, map - 以行值流形式从 URL 加载 XLS，配置包含以下任何项：{skip:1,limit:5,header:false,ignore:['tmp'],arraySep:';',mapping:{years:{type:'int',arraySep:'-',array:false,name:'age',ignore:false, dateFormat:'iso_date', dateParse:['dd-MM-yyyy']}}

过程

apoc.log.debug

apoc.log.debug(message, params) - 记录调试消息

过程

apoc.log.error

apoc.log.error(message, params) - 记录错误消息

过程

apoc.log.info

apoc.log.info(message, params) - 记录信息消息

过程

apoc.log.warn

apoc.log.warn(message, params) - 记录警告消息

过程

apoc.map.renameKey

重命名 MAP 中的给定键。

函数

apoc.metrics.get

apoc.metrics.get(metricName, {}) - 按度量名称检索系统度量。可以传递额外的配置选项，以匹配 apoc.load.csv 可用的选项。

过程

apoc.metrics.list

apoc.metrics.list() - 获取可用度量列表

过程

apoc.metrics.storage

apoc.metrics.storage(directorySetting) - 检索关于 Neo4j 用于数据存储的设备的存储度量。directorySetting 可以是任何有效的 neo4j 目录设置名称，例如 'server.directories.data'。如果提供 null 作为 directorySetting，您将获得所有可用的目录设置。有关可用目录设置的列表，请参阅 Neo4j 操作手册中关于配置设置的参考。目录设置不是路径，它们是 neo4j.conf 设置键名称

过程

apoc.model.jdbc

apoc.model.jdbc('key or url', {schema:'<schema>', write: <true/false>, filters: { tables:[], views: [], columns: []}) YIELD nodes, relationships - 从关系数据库加载模式

过程

apoc.mongo.aggregate

apoc.mongo.aggregate(uri, pipeline, $config) yield value - 在 mongodb 集合上执行聚合操作

过程

apoc.mongo.count

apoc.mongo.count(uri, query, $config) yield value - 在 mongodb 集合上执行计数操作

过程

apoc.mongo.delete

apoc.mongo.delete(uri, query, $config) - 从 mongodb 集合中删除给定文档并返回受影响文档的数量

过程

apoc.mongo.find

apoc.mongo.find(uri, query, $config) yield value - 在 mongodb 集合上执行查找操作

过程

apoc.mongo.insert

apoc.mongo.insert(uri, documents, $config) yield value - 将给定文档插入到 mongodb 集合中

过程

apoc.mongo.update

apoc.mongo.update(uri, query, update, $config) - 更新 mongodb 集合中的给定文档并返回受影响文档的数量

过程

apoc.mongodb.get.byObjectId

apoc.mongodb.get.byObjectId(hostOrKey, db, collection, objectIdValue, config(default:{})) - 按对象 ID 值获取文档

过程

apoc.ml.openai.embedding

apoc.openai.embedding([texts], api_key, configuration) - 返回给定文本的嵌入

过程

apoc.ml.openai.completion

apoc.ml.openai.completion(prompt, api_key, configuration) - 提示补全 API

过程

apoc.ml.openai.chat

apoc.ml.openai.chat(messages, api_key, configuration]) - 提示补全 API

过程

apoc.ml.sagemaker.custom

apoc.ml.sagemaker.chat(body, $conf) - 创建可自定义的 SageMaker 调用

过程

apoc.ml.sagemaker.chat

apoc.ml.sagemaker.chat(messages, $conf) - 提示聊天补全 API

过程

apoc.ml.sagemaker.completion

apoc.ml.sagemaker.completion(prompt, $conf) - 提示补全 API

过程

apoc.ml.sagemaker.embedding

apoc.ml.sagemaker.embedding([texts], $configuration) - 返回给定文本的嵌入

过程

apoc.ml.bedrock.list

apoc.ml.bedrock.list() - 列出可用的 Bedrock 模型

过程

apoc.ml.bedrock.custom

apoc.ml.bedrock.custom(body, configuration) - 创建可自定义的 Bedrock 调用

过程

apoc.ml.bedrock.chat

apoc.ml.bedrock.chat(messages, $conf) - 提示补全 API

过程

apoc.ml.bedrock.completion

apoc.ml.bedrock.completion(prompt, $conf) - 提示补全 API

过程

apoc.ml.bedrock.embedding

apoc.ml.bedrock.embedding([texts], $configuration) - 返回给定文本的嵌入

过程

apoc.ml.bedrock.image

apoc.ml.bedrock.image(body, configuration) - 从提示生成图像

过程

apoc.ml.watson.embedding

apoc.ml.watson.embedding([texts], accessToken, $configuration) - 返回给定文本的嵌入

过程

apoc.ml.watson.chat

apoc.ml.watson.chat(messages, accessToken, $configuration) - 提示补全 API

过程

apoc.ml.watson.completion

apoc.ml.watson.completion(prompt, accessToken, $configuration) - 提示补全 API

过程

apoc.ml.mixedbread.custom

apoc.mixedbread.custom(, configuration) - 返回给定文本的嵌入

过程

apoc.ml.mixedbread.embedding

apoc.mixedbread.mixedbread([texts], api_key, configuration) - 返回给定文本的嵌入

过程

apoc.ml.rag

apoc.ml.rag() - 接收 Cypher 查询和自然语言查询，并以自然语言返回结果

过程

apoc.ml.fromCypher

apoc.ml.fromCypher() - 接收 Cypher 查询和自然语言查询，并以自然语言返回结果

过程

apoc.ml.query

apoc.ml.query() - 接收问题并以映射形式返回答案

过程

apoc.ml.schema

apoc.ml.schema() - 返回数据库的模式

过程

apoc.ml.cypher

apoc.ml.cypher() - 接收问题并返回 Cypher 查询

过程

apoc.ml.fromQueries

apoc.ml.fromQueries() - 接收 Cypher 查询列表并以自然语言返回结果

过程

apoc.ml.vertexai.embedding

apoc.vertexai.embedding([texts], accessToken, project, configuration) - 返回给定文本的嵌入

过程

apoc.ml.vertexai.completion

apoc.ml.vertexai.completion(prompt, accessToken, project, configuration) - 提示补全 API

过程

apoc.ml.vertexai.chat

apoc.ml.vertexai.chat(messages, accessToken, project, configuration]) - 提示补全 API

过程

apoc.ml.vertexai.stream

apoc.ml.vertexai.stream(contents, accessToken, project, configuration) - 提示流式 API

过程

apoc.ml.vertexai.custom

apoc.ml.vertexai.custom(contents, accessToken, project, configuration) - 提示可自定义的 API

过程

apoc.monitor.ids

apoc.monitor.ids() 返回此 neo4j 实例正在使用的对象 ID

过程

apoc.monitor.kernel

apoc.monitor.kernel() 返回关于 neo4j 内核的信息

过程

apoc.monitor.store

apoc.monitor.store() 返回关于 neo4j 图存储不同部分大小的信息

过程

apoc.monitor.tx

apoc.monitor.tx() 返回关于 neo4j 事务管理器的信息

过程

apoc.node.match

使用给定的动态标签匹配给定的 NODE 值。

过程

apoc.node.rebind

apoc.node.rebind(node) - 重绑定节点（即执行 Transaction.getNodeById(node.getId())

函数

apoc.nlp.aws.entities.graph

为提供的文本创建（虚拟）实体图

过程

apoc.nlp.aws.entities.stream

返回提供的文本的实体流

过程

apoc.nlp.aws.keyPhrases.graph

为提供的文本创建（虚拟）关键短语图

过程

apoc.nlp.aws.keyPhrases.stream

返回提供的文本的关键短语流

过程

apoc.nlp.aws.sentiment.graph

为提供的文本创建（虚拟）情感图

过程

apoc.nlp.aws.sentiment.stream

返回提供的文本中项的情感流

过程

apoc.nlp.azure.entities.graph

为提供的文本创建（虚拟）实体图

过程

apoc.nlp.azure.entities.stream

为提供的文本提供实体分析

过程

apoc.nlp.azure.keyPhrases.graph

为提供的文本创建（虚拟）关键短语图

过程

apoc.nlp.azure.keyPhrases.stream

为提供的文本提供实体分析

过程

apoc.nlp.azure.sentiment.graph

为提供的文本创建（虚拟）情感图

过程

apoc.nlp.azure.sentiment.stream

为提供的文本提供情感分析

过程

apoc.nlp.gcp.classify.graph

将文档分类为类别。

过程

apoc.nlp.gcp.classify.stream

将文档分类为类别。

过程

apoc.nlp.gcp.entities.graph

为提供的文本创建（虚拟）实体图

过程

apoc.nlp.gcp.entities.stream

返回提供的文本的实体流

过程

apoc.rel.match

使用给定的动态类型/属性匹配给定的 RELATIONSHIP 值。

过程

apoc.rel.rebind

apoc.rel.rebind(rel) - 重绑定关系（即执行 Transaction.getRelationshipById(rel.getId())

函数

apoc.redis.append

apoc.redis.append(uri, key, value, {config}) | 执行 'APPEND key value' 命令

过程

apoc.redis.configGet

apoc.redis.configGet(uri, parameter, {config}) | 执行 'CONFIG GET parameter' 命令

过程

apoc.redis.configSet

apoc.redis.configSet(uri, parameter, {config}) | 执行 'CONFIG SET parameter value' 命令

过程

apoc.redis.copy

apoc.redis.copy(uri, source, destination, {config}) | 执行 'COPY source destination' 命令，如果源被复制则返回 true，否则返回 false

过程

apoc.redis.eval

apoc.redis.eval(uri, script, outputType, keys, values, {config}) | 执行 'EVAL script' 命令。在提供给该过程的参数中，键绑定到 Lua 脚本的 KEYS[n] 特殊数组，值绑定到 Lua 脚本的 ARGV[n] 特殊数组。

过程

apoc.redis.exists

apoc.redis.exists(uri, keys, {config}) | 执行 'EXISTS keys' 命令

过程

apoc.redis.get

apoc.redis.get(uri, key, {config}) | 执行 'GET key' 命令

过程

apoc.redis.hdel

apoc.redis.hdel(uri, key, fields, {config}) | 执行 'HDEL key fields' 命令

过程

apoc.redis.hexists

apoc.redis.hexists(uri, key, field, {config}) | 执行 'HEXISTS key field' 命令

过程

apoc.redis.hget

apoc.redis.hget(uri, key, field, {config}) | 执行 'HGET key field' 命令

过程

apoc.redis.hgetall

apoc.redis.hgetall(uri, key, {config}) | 执行 'HGETALL key' 命令

过程

apoc.redis.hincrby

apoc.redis.hincrby(uri, key, field, amount, {config}) | 执行 'HINCRBY key field amount' 命令

过程

apoc.redis.hset

apoc.redis.hset(uri, key, field, value, {config}) | 执行 'HSET key field value' 命令，如果它是哈希中的新字段则返回 true，如果字段已存在则返回 false

过程

apoc.redis.incrby

apoc.redis.incrby(uri, key, amount, {config}) | 执行 'INCRBY key increment' 命令

过程

apoc.redis.info

apoc.redis.info(uri, {config}) | 执行 'INFO' 命令

过程

apoc.redis.lrange

apoc.redis.lrange(uri, key, start, stop, {config}) | 执行 'LRANGE key start stop' 命令

过程

apoc.redis.persist

apoc.redis.persist(uri, key, {config}) | 执行 'PERSIST key' 命令

过程

apoc.redis.pexpire

apoc.redis.pexpire(uri, key, time, isExpireAt {config}) | 执行 'PEXPIRE key time' 命令，如果 isExpireAt=true 则执行 'PEPXPIREAT'

过程

apoc.redis.pop

apoc.redis.pop(uri, key, {config}) | 执行 'LPOP key' 命令，如果 config right=true（默认）则执行 'RPOP'

过程

apoc.redis.pttl

apoc.redis.pttl(uri, key, {config}) | 执行 'PTTL key' 命令

过程

apoc.redis.push

apoc.redis.push(uri, key, values, {config}) | 执行 'LPUSH key field values' 命令，如果 config right=true（默认）则执行 'RPUSH'

过程

apoc.redis.sadd

apoc.redis.sadd(uri, key, members, {config}) | 执行 'SADD key members' 命令

过程

apoc.redis.scard

apoc.redis.scard(uri, key, {config}) | 执行 'SCARD key' 命令

过程

apoc.redis.smembers

apoc.redis.smembers(uri, key, {config}) | 执行 'SMEMBERS key' 命令

过程

apoc.redis.spop

apoc.redis.spop(uri, key, {config}) | 执行 'SPOP key' 命令

过程

apoc.redis.sunion

apoc.redis.sunion(uri, keys, {config}) | 执行 'SUNION keys' 命令

过程

apoc.redis.zadd

apoc.redis.zadd(uri, keys, scoresAndMembers, {config}) | 执行 'ZADD key scoresAndMembers' 命令，其中 scoresAndMembers 是由 score,member,score,member,… 组成的列表

过程

apoc.redis.zcard

apoc.redis.zcard(uri, key, {config}) | 执行 'ZCARD key' 命令

过程

apoc.redis.zrangebyscore

apoc.redis.zrangebyscore(uri, key, min, max, {config}) | 执行 'ZRANGEBYSCORE key min max' 命令

过程

apoc.redis.zrem

apoc.redis.zrem(uri, key, members, {config}) | 执行 'ZREM key members' 命令

过程

apoc.static.list

apoc.static.list(prefix) - 返回配置中静态存储的值 (apoc.static.<prefix>.*) 或服务器生命周期存储

过程

apoc.static.set

apoc.static.set(name, value) - 将值存储在服务器生命周期存储的键下，返回先前存储或配置的值

过程

apoc.static.get

apoc.static.get(name) - 返回配置中静态存储的值 (apoc.static.<key>) 或服务器生命周期存储

函数

apoc.static.getAll

apoc.static.getAll(prefix) - 返回配置中静态存储的值 (apoc.static.<prefix>.*) 或服务器生命周期存储

函数

apoc.systemdb.execute

过程

apoc.systemdb.export.metadata

过程

apoc.systemdb.graph

过程

apoc.temporal.overlap

函数

apoc.trigger.nodesByLabel

函数

apoc.trigger.propertiesByKey

函数

apoc.trigger.toNode

apoc.trigger.toNode(node, $removedLabels, $removedNodeProperties)

将节点重建为虚拟节点的函数，用于触发器中非 'afterAsync' 阶段

函数

apoc.trigger.toRelationship

apoc.trigger.toRelationship(rel, $removedRelationshipProperties)

将关系重建为虚拟关系的函数，用于触发器中非 'afterAsync' 阶段

函数

apoc.ttl.config

函数

apoc.ttl.expire

CALL apoc.ttl.expire(node,time,'time-unit') - 通过设置 :TTL 标签和 ttl 属性，在指定时间使节点过期

过程

apoc.ttl.expireIn

CALL apoc.ttl.expireIn(node,timeDelta,'time-unit') - 通过设置 :TTL 标签和 ttl 属性，在指定时间长度后使节点过期

过程

apoc.util.hashCode

apoc.util.hashCode(value) - 返回该值的 java.lang.Object#hashCode()

函数

apoc.uuid.drop

CALL apoc.uuid.drop(label, databaseName) yield label, installed, properties | 最终删除先前添加的 UUID 处理程序并返回 uuid 信息

过程

apoc.uuid.dropAll

CALL apoc.uuid.dropAll(databaseName) yield label, installed, properties | 最终删除所有先前添加的 UUID 处理程序并返回 uuids 信息

过程

apoc.uuid.list

CALL apoc.uuid.list() yield label, installed, properties | 提供所有已安装的 uuid 处理程序列表及其相关配置

过程

apoc.uuid.setup

CALL apoc.uuid.setup(label, databaseName, $config) | 最终为提供的 label 和 uuidProperty 添加 uuid 事务处理程序，如果 UUID 处理程序已存在，它将被新的替换

过程

apoc.uuid.show

CALL apoc.uuid.show(databaseName) | 列出数据库中所有最终安装的 UUID 处理程序

过程

apoc.vectordb.configure

apoc.vectordb.configure(vectorName, host, credentialsValue, mapping) - 将由第一个参数、host、credentials 和 mapping 定义的向量配置到 system db 中

过程

apoc.vectordb.custom

apoc.vectordb.custom(host, $configuration) - 完全可自定义的过程，返回通用对象结果

过程

apoc.vectordb.custom.get

apoc.vectordb.custom.get(host, $configuration) - 可自定义的获取/查询过程，从主机和配置映射中检索向量

过程

apoc.kafka.consume

apoc.kafka.consume(topic, {timeout: <long value>, from: <string>, groupId: <string>, commit: <boolean>, partitions:[{partition: <number>, offset: <number>}]}) YIELD event - 允许消费自定义主题

过程

apoc.kafka.publish

apoc.kafka.publish(topic, payload, config) - 允许从 Neo4j 到已配置流环境的自定义流式传输

过程

apoc.kafka.publish.sync

apoc.kafka.publish.sync(topic, payload, config) - 允许从 Neo4j 到已配置流环境的自定义同步流式传输

过程