在Python中使用Neo4j数据库的教程

 一个快速的REST例子

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

$ 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)而已。
 

#!/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")