python怎么与neo4j图数据库连接

python怎么与neo4j图数据库连接,第1张

一个快速的REST例子

首先来看些基本知识。如果没有服务API,Neo4j就不能支持其他语言。该接口提供一组基于JSON消息格式的RESTful Web服务和一个全面的发现机制。使用中使用这个接口的最快和最容易的方法是通过使用cURL:

1234567891011121314$ curl http://localhost:7474/db/data/{ "extensions" : { }, "node" : "http://localhost:7474/db/data/node", "node_index" : "http://localhost:7474/db/data/index/node", "relationship_index" : "http://localhost:7474/db/data/index/relationship", "extensions_info" : "http://localhost:7474/db/data/ext", "relationship_types" : "http://localhost:7474/db/data/relationship/types", "batch" : "http://localhost:7474/db/data/batch", "cypher" : "http://localhost:7474/db/data/cypher", "transaction" : "http://localhost:7474/db/data/transaction", "neo4j_version" : "2.0.0-M03"}

从这个端点返回JSON对象包含一组资源名称和URI下可以找到的Cypher端点。在消息载荷中接受传送来的Cyper请求并执行这些查询,在HTTP响应中返回结果。

正是这种REST API接口,使得现在已有的各种Neo4j驱动得以建立。py2neo提供了这些REST资源的简单封装,这使Python应用程序开发者可以放心使用Neo4j而不用考虑底层的客户机-服务器协议。

一个简单的应用

为实际验证py2neo,我们将着眼于建立一个简单的用于存储姓名和电子邮件地址的通讯录管理系统。我们自然会使用节点来模拟每一个独立实体,但它是要记住,Neo4j没有类型的概念。类型是从周围的关系和属性推断来的。

下面的关系图中人显示为红色、电子邮件地址节点显示为蓝色。这些当然是纯粹的逻辑演示节点,但数据本身并没有区别。 

我们的应用程序将完成两个功能:添加新的联系人信息和检索联系人的完整列表。为此,我们将创建一个Person类包装Py2neoNodeobject,这使我们有一个底层处理的实现且留出用户级的功能。上图中的ROOT节点是指上图中一个固定的参考点,我们沿着这个点开始。

让我们直接看看代码。下面是一个完整的小型应用。这个程序允许添加新的名字与一个或者更多email地址相连接的以及提供了一个容易的方式来显示这些连接信息的一个命令行工具。没有参数的运行是显示使用模式,而且这个唯一的依赖只是需要一个本地未修改的Neo4j实例(instance)而已。

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960#!/usr/bin/env python# -*- coding: utf-8 -*-  from __future__ import print_function  import sysfrom py2neo import neo4j, node, rel  graph_db = neo4j.GraphDatabaseService()  class Person(object):      _root = graph_db.get_or_create_indexed_node("reference",     "contacts", "root")      @classmethod  def create(cls, name, *emails):    person_node, _ = graph_db.create(node(name=name),       rel(cls._root, "PERSON", 0))    for email in emails:      graph_db.create(node(email=email), rel(cls._root, "EMAIL", 0),         rel(person_node, "EMAIL", 0))    return Person(person_node)      @classmethod  def get_all(cls):    return [Person(person.end_node) for person in       cls._root.match("PERSON")]      def __init__(self, node):    self._node = node      def __str__(self):    return self.name + "\n" + "\n".join(" <{0}>"       .format(email) for email in self.emails)      @property  def name(self):    return self._node["name"]      @property  def emails(self):    return [rel.end_node["email"] for rel in       self._node.match("EMAIL")]  if __name__ == "__main__":  if len(sys.argv) <2:    app = sys.argv[0]    print("Usage: {0} add <name><email>       [<email>...]".format(app))    print("    {0} list".format(app))    sys.exit()  method = sys.argv[1]  if method == "add":    print(Person.create(*sys.argv[2:]))  elif method == "list":    for person in Person.get_all():      print(person)  else:print("Unknown command")

在第09行上是第一行Py2neo代码,用来创建了一个GraphDatabaseService对象。通过这个,我们就可以访问使用Neo4j server的大多数功能。可选一个URI传递到这个构造器里,尽管如果什么都没有提供,代而取之的是使用默认的本地参数。也就是说下面两行是完全相等的:

123graph_db = neo4j.GraphDatabaseService()graph_db = neo4j.GraphDatabaseService("http://localhost:7474/db/data/")

第13行介绍了调用了get_or_create_indexed_node,它提供一种在图形里创建固定引用点的漂亮方式。传统的Neo4j索引允许节点和关系通过键值对访问,而在这个代码里我们使用了带连接的关键字和root值的引用索引实例。在第一次执行时,会创建一个新的节点,而且在随后的执行中,这个节点(即root)会复用(reused)。

在第17行,我们看见了推荐的节点和关系抽象的标记,以及接受和使用节点和关系抽象的 create方法。任意多的抽象都可以被传递到这个方法中,并且在单个批处理转换中创建实体并以指定它们的顺序作为一个列表返回。抽象节点用 节点函数表示并带有一些属性,然而抽象关系使用rel函数接受一个起始节点,类型和终止节点。上下文中,其他节点,关系起始和终止节点可能整合引用到在其他批处理中其他节点。在我们的例子中,我们把根节点连接到新创建的person节点,否则就作为项目0(item 0)了。

这次我们在第24行和38行上以match方法形式和关系见面[@Lesus 注: oschina代码行数有问题。对应于本文的第28和44行]。它试图使用一个特殊的条件集合(set)标识关系,然后使用列表(list)返回它们。这这些示例中,这个关系和PERSON关系相匹配,从root节点和EMAIL关系开始到所给定的person节点。和Cypher很相似,用来查询包含MATCH关键字的场景。

最后值得注意的一点是在上面的代码中访问节点属性的方式只是其中一种简单的方式。Py2neo重写了标准python的__getitem__和 __setitem__方法,通过方括号标识来方便访问任何属性。这点在第34和38行上可以看到。[@Lesus 注:对应于本文的第39和44行]

总结

在那里(代码行34和38)我们这样做了,这显示了它是如何快速简易地在JAVA环境之外拼凑出一个Neo4j应用程序,也显示了Py2neo是如何通过REST API来抽象出大多数沉重的负担。这里的例子并没有解决唯一性,尽管功能上提供了唯一索引和CypherCREATE UNIQUE语句。Django开发者可能也想要考虑一个层,如Neomodel,它在Py2neo顶层上表示了一个Djangoesque ORM-style 层。

在JAVA中使用Cypher涉及到org.neo4j.cypher.javacompat包的两个类.

类名方法名说明

ExecutionEnginepublic ExecutionResult execute(String query)执行query返回存储结果集的一个迭代器(ExecutionResult)

(用于执行Cypher Query)public ExecutionResult execute(String query, Map<String,Object>params)

执行query返回存储结果集的一个迭代器(ExecutionResult)

其中,params是query所需的参数

ExecutionResultpublic <T>Iterator<T>columnAs(String n)返回结果集中n作为列名指定的列信息的集合

(保存Cypher Query执行后的结果集)public List<String>columns()返回结果集各个列的列名

public Iterator<Map<String,Object>>iterator()结果集的一个迭代器,每个元素代表一行记录(存储为map)

public String toString()

public void toString(PrintWriter writer)

这个是服务器端证书存在问题,导致加密通讯失败,要联系站点服务提供商更正一下证书的问题。

windows系统 svn的https的证书认证信息保存在:

X(系统盘):\Users\#your usrname#\AppData\Roaming\Subversion\auth\svn.ssl.server

把这个svn.ssl.server文件夹直接删除,然后使用svn,再弹出的那个框时,选择第一个“永久授受”。

微信常见问题

1、怎么删除聊天记录。

可以删除单条消息,也可以删除会话。触屏手机上通过长按消息或会话的方式删除,有按键的手机则通过选项按钮找到删除入口。

2、我如何知道对方是否阅读了我的信息。

无法知道。是否已读的状态信息在我们看来是属于个人隐私,我们希望给您一个轻松自由的沟通环境,因此我们不会将是否已读的状态进行传送。

3、我退出客户端以后还能收到消息吗。

退出微信时会提示是否继续接收消息,如果选择不需要,微信将完全退出而不接收消息。


欢迎分享,转载请注明来源:夏雨云

原文地址:https://www.xiayuyun.com/zonghe/467966.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2023-06-05
下一篇2023-06-05

发表评论

登录后才能评论

评论列表(0条)

    保存