devbox
空白诗007
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Neo4j-Apoc

作者：空白诗007 | 2024-08-21 23:44:22

赞

踩

apoc.algo.cliques

APOC

https://neo4j-contrib.github.io/neo4j-apoc-procedures/#_virtual_nodes_rels

提供的函数 存储过程应有尽有， 也可以自行实现添加

CALL apoc.help("dijkstra")

Apoc配置：

  1. apoc.trigger.enabled=false/true  :  Enable triggers
  2.  
  3. apoc.ttl.enabled=false/true:  Enable time to live background task
  4.  
  5. apoc.jdbc.<key>.uri=jdbc-url-with-credentials :  配置数据库连接串
  6.  
  7. apoc.es.<key>.uri=es-url-with-credentials：  ES连接
  8.  
  9. apoc.mongodb.<key>.uri=mongodb-url-with-credentials： mongodb连接
  10.  
  11. apoc.couchbase.<key>.uri=couchbase-url-with-credentials： couchbase连接
  12.  
  13. apoc.jobs.scheduled.num_threads=number-of-threads： APOC调度器的线程池
  14.  
  15. apoc.jobs.pool.num_threads=number-of-threads: 执行器的线程池

有用的函数方法：

  1. 解析域名： WITH 'http://www.example.com/all-the-things' AS url RETURN apoc.data.domain(url) // will return 'www.example.com'
  2.  
  3. 日期函数： 
  4.  
  5.     apoc.date.parse('2015/03/25 03-15-59',['s'],['yyyy/MM/dd HH/mm/ss'])
  6.  
  7.     apoc.date.add(12345, 'ms', -365, 'd') 
  8.  
  9.  
  10. 格式转换：
  11.  
  12.     return apoc.number.format(12345.67) as value
  13.  
  14.     return apoc.number.format(12345, '#,##0.00;(#,##0.00)', 'it') as value
  15.  
  16. 数学运算：
  17.  
  18.     RETURN apoc.number.exact.add(stringA,stringB)
  19.  
  20.     RETURN apoc.number.exact.sub(stringA,stringB)
  21.  
  22.     ETURN apoc.number.exact.mul(stringA,stringB,[prec],[roundingModel]
  23.  
  24.     RETURN apoc.number.exact.div(stringA,stringB,[prec],[roundingModel])
  25.  
  26.     RETURN apoc.number.exact.toInteger(string,[prec],[roundingMode])
  27.  
  28.     RETURN apoc.number.exact.toFloat(string,[prec],[roundingMode])
  29.  
  30.     RETURN apoc.number.exact.toExact(number)
  31.  
  32. 比较节点不同：
  33.  
  34.     apoc.diff.nodes([leftNode],[rightNode])

图算法：

  1. 路径扩展(选择走哪些边， 哪些节点， 几层， 什么时候结束等等)：
  2.  
  3.     CALL apoc.path.expand(startNode <id>|Node, relationshipFilter, labelFilter, minLevel, maxLevel )
  4.  
  5.     MATCH (user:User) WHERE user.id = 460
  6.     CALL apoc.path.expandConfig(user,{relationshipFilter:"RATED",minLevel:3,maxLevel:3,bfs:false,uniqueness:"NONE"}) YIELD path
  7.     RETURN count(*);
  8.  
  9.  
  10.     apoc.path.subgraphAll(startNode <id>Node/list, {maxLevel, relationshipFilter, labelFilter, bfs:true, filterStartNode:true, limit:-1}) yield nodes, relationships
  11.  
  12.  
  13.     MATCH (user:User) WHERE user.id = 460
  14.     CALL apoc.path.subgraphNodes(user, {}) YIELD node
  15.     RETURN node;
  16.  
  17. Closeness Centrality：
  18.  
  19.     CALL apoc.algo.closeness(['TYPE'],nodes,'INCOMING') YIELD node, score
  20.  
  21. Betweenness Centrality：
  22.  
  23.     CALL apoc.algo.betweenness(['TYPE'],nodes,'BOTH') YIELD node, score
  24.  
  25.  
  26. pageRank:
  27.  
  28.     CALL apoc.algo.pageRank(nodes) YIELD node, score
  29.  
  30.     // only compute over relationships of types TYPE_1 or TYPE_2
  31.     
  32.     CALL apoc.algo.pageRankWithConfig(nodes,{types:'TYPE_1|TYPE_2'}) YIELD node, score
  33.  
  34.     // peroform 10 page rank iterations, computing only over relationships of type TYPE_1
  35.  
  36.     CALL apoc.algo.pageRankWithConfig(nodes,{iterations:10,types:'TYPE_1'}) YIELD node, score
  37.  
  38. dijkstra:
  39.  
  40.     apoc.algo.dijkstra(startNode, endNode, 'KNOWS|<WORKS_WITH|IS_MANAGER_OF>', 'distance') YIELD path, weight
  41.  
  42.     apoc.algo.dijkstraWithDefaultWeight(startNode, endNode, 'KNOWS|<WORKS_WITH|IS_MANAGER_OF>', 'distance', 10) YIELD path, weight
  43.  
  44.     example:
  45.  
  46.         MATCH (from:Loc{name:'A'}), (to:Loc{name:'D'})
  47.         CALL apoc.algo.dijkstra(from, to, 'ROAD', 'd') yield path as path, weight as weight
  48.         RETURN path, weight
  49.  
  50. community: 标签传播的社区发现算法
  51.  
  52.     apoc.algo.community(times,labels,partitionKey,type,direction,weightKey,batchSize)
  53.  
  54.     example:  遍历25轮， 
  55.  
  56.         CALL apoc.algo.community(25,null,'partition','X','OUTGOING','weight',10000)
  57.  
  58.  
  59. aStar: A*遍历算法
  60.  
  61.     apoc.algo.aStar(startNode, endNode, 'KNOWS|<WORKS_WITH|IS_MANAGER_OF>', 'distance','lat','lon') YIELD path, weight
  62.  
  63. cliques： 聚类社区算法：
  64.  
  65.     apoc.algo.cliques(minSize) YIELD clique
  66.  
  67.     apoc.algo.cliquesWithNode(startNode, minSize) YIELD clique
  68.  
  69. 各种距离算法：
  70.  
  71.     apoc.algo.cosineSimilarity([vector1], [vector2])   cosin相似度
  72.  
  73.     apoc.algo.euclideanDistance([vector1], [vector2])  欧几里得距离
  74.  
  75.     apoc.algo.euclideanSimilarity([vector1], [vector2])  欧几里得相似度

Virtual Nodes/Rels: 虚拟节点， 关系 类似视图的概念

  1. MATCH (a)-[r]->(b)
  2. WITH head(labels(a)) AS l, head(labels(b)) AS l2, type(r) AS rel_type, count(*) as count
  3. CALL apoc.create.vNode([l],{name:l}) yield node as a
  4. CALL apoc.create.vNode([l2],{name:l2}) yield node as b
  5. CALL apoc.create.vRelationship(a,rel_type,{count:count},b) yield rel
  6. RETURN *;
  7.  
  8. CALL apoc.create.vPattern({_labels:['Person'],name:'Mary'},'KNOWS',{since:2012},{_labels:['Person'],name:'Michael'})
  9.  
  10. CALL apoc.create.vPattern({_labels:['Person', 'Woman'],name:'Mary'},'KNOWS',{since:2012},{_labels:['Person', 'Man'],name:'Michael'})
  11.  
  12. CALL apoc.create.vPatternFull(['British','Person'],{name:'James', age:28},'KNOWS',{since:2009},['Swedish','Person'],{name:'Daniel', age:30})

Cypher Exectuion： 批量执行脚本

  1. CALL apoc.cypher.runFiles([files or urls],{config}) yield row, result   
  2.  
  3. runs each statement in the files, all semicolon separated
  4.  
  5.  
  6. CALL apoc.cypher.runFile(file or url,{config}) yield row, result
  7. runs each statement in the file, all semicolon separated - currently no schema operations

Manual Index: 手工索引， 默认不会自动更新

  1. synchronously同步更新 只有创建索引时指定autoUpdate:true， 才会真正生效， 更新图时性能上会有影响
  2.  
  3.     apoc.autoIndex.enabled=true  
  4.  
  5. asynchronously异步更新
  6.  
  7.     apoc.autoIndex.async=true  
  8.  
  9.     默认的异步更新参数：50000 operations or 5000 milliseconds 触发
  10.  
  11.     apoc.autoIndex.queue_capacity=100000
  12.     apoc.autoIndex.async_rollover_opscount=50000
  13.     apoc.autoIndex.async_rollover_millis=5000
  14.     apoc.autoIndex.tx_handler_stopwatch=false
  15.  
  16.  
  17. 添加多个节点属性缩影 配合search用， 重复执行会先删除再创建： apoc.index.addAllNodes('index-name',{label1:['prop1',…​],…​}, {options})  
  18.  
  19. options的选择(map形式给入)：
  20.  
  21.     type： fulltext/exact  全文索引/精确索引
  22.  
  23.     to_lower_case： false/true
  24.  
  25.     analyzer： classname   用哪种classname of lucene analyzer 
  26.  
  27.     similarity： classname   相似度计算的方式 classname for lucene similarity 
  28.  
  29.     autoUpdate：  true/false  是否自动更新
  30.  
  31.  
  32. 添加一个节点的属性索引(可以不存在这个属性字段) apoc.index.addNode(node,['prop1',…​])
  33.  
  34. 对于给定的标签，添加节点索引(索引名称的Label和node可以不一致)： apoc.index.addNodeByLabel('Label',node,['prop1',…​])
  35.  
  36. 给索引命名 默认是Label作为名称：  apoc.index.addNodeByName('name',node,['prop1',…​])
  37.  
  38. apoc.index.addNodeMap(node,{key:value})
  39.  
  40. apoc.index.addNodeMapByName(index, node,{key:value})
  41.  
  42. 关系索引： apoc.index.addRelationship(rel,['prop1',…​])
  43.  
  44. apoc.index.addRelationshipByName('name',rel,['prop1',…​])
  45.  
  46. apoc.index.addRelationshipMap(rel,{key:value})
  47.  
  48. apoc.index.addRelationshipMapByName(index, rel,{key:value})
  49.  
  50. 删除节点索引 apoc.index.removeNodeByName('name',node) remove node from an index for the given name
  51.  
  52.  
  53. 索引模糊查询(计算编辑距离)  apoc.index.search('index-name', 'query') YIELD node, weight
  54.  
  55. apoc.index.nodes('Label','prop:value*') YIELD node, weight
  56.  
  57. apoc.index.relationships('TYPE','prop:value*') YIELD rel, weight
  58.  
  59. 没理解： apoc.index.between(node1,'TYPE',node2,'prop:value*') YIELD rel, weight
  60.  
  61. 示例：
  62.     match (p:Person) call apoc.index.addNode(p,["name","age"]) RETURN count(*); // 129s for 1M People
  63.  
  64.     call apoc.index.nodes('Person','name:name100*') YIELD node, weight return * limit 2

Index Management：

  1. CALL apoc.index.remove('Thing') 
  2.  
  3. 展示： CALL apoc.index.list() 
  4.  
  5. CALL apoc.index.forNodes('name',{config}) YIELD type,name,config
  6.  
  7. CALL apoc.index.forRelationships('name',{config}) YIELD type,name,config

Triggers ： 触发器

apoc.trigger.enabled=true

Locking： 锁

  1. call apoc.lock.nodes([nodes])
  2.  
  3. call apoc.lock.rels([relationships])
  4.  
  5. call apoc.lock.all([nodes],[relationships])

Meta Graph: 展示节点， 关系标签的概览图

  1. CALL apoc.meta.graphSample()
  2.  
  3. CALL apoc.meta.graph
  4.  
  5. 有选择的展示一部分结果： CALL apoc.meta.subGraph({labels:[labels],rels:[rel-types],excludes:[label,rel-type,…​]})
  6.  
  7. 表格形式展示数据： CALL apoc.meta.data
  8.  
  9. Map形式展示数据： CALL apoc.meta.schema
  10.  
  11.  
  12. 快速查看图中各种存在的节点，边： CALL apoc.meta.stats yield labelCount, relTypeCount, propertyKeyCount, nodeCount, relCount, labels, relTypes, stats

Sehema: 查看各种索引， 约束

  1. apoc.schema.assert({indexLabel:[indexKeys],…​},{constraintLabel:[constraintKeys],…​}, dropExisting : true) yield label, key, unique, action
  2.  
  3. apoc.schema.nodes() yield name, label, properties, status, type
  4.  
  5. apoc.schema.relationships() yield name, type, properties, status
  6.  
  7. apoc.schema.node.indexExists(labelName, properties)
  8.  
  9. apoc.schema.node.constraintExists(labelName, properties)
  10.  
  11. apoc.schema.relationship.constraintExists(type, properties)

Streaming Data to Gephi： 导出数据到Gephi

apoc.gephi.add(url-or-key, workspace, data, weightproperty, ['exportproperty'])

原文地址：https://www.jianshu.com/p/851ab29420fd

转载于:https://www.cnblogs.com/jpfss/p/11365325.html

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/空白诗007/article/detail/1013765
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号