图基础知识及neo4j 图数据库的使用
一、概述
本篇文章记载了，图的基本知识，及图数据库neo4j的 安装、常用命令、 使用python 操作的一些代码片段。
二、图的基本知识
开篇引用：Graphs Are Everywhere,for Everyone
(对于每个人来说，图无处不在），图的魅力我无词言表。
1、节点 （看这张图）
2、关系
示例：
3、属性
节点 和关系都可以设置自己的属性（由key-Value 键值对组成了）
4、路径
路径由至少一个节点，通过各种关系连接组成，经常是作为一个查询或者遍历的结果
二、neo4j的安装
ubuntu系统 安装neo4j，参考了 博客的说明：
https://www.cnblogs.com/caoyusang/p/13610408.html
主要步骤如下：
1，从镜像中找的合适的镜像
docker search neo4j
2、选择官方版本的拉取镜像源
docker pull neo4j(:版本号) //缺省 “:版本号” 时默认安装latest版本的
3、查看本地镜像，检验是否拉起成功
docker images
4、设置neo4j容器运行的相关目录文件夹
在你根目录的任意一个子目录（我这里是/home)下建立四个基本的文件夹
data——数据存放的文件夹
logs——运行的日志文件夹
conf——数据库配置文件夹（在配置文件neo4j.conf中配置包括开放远程连接、设置默认激活的数据库）
5、启动命令 设置说明
docker run -d --name container_name \ //-d表示容器后台运行 --name指定容器名字
-p 7474:7474 -p 7687:7687 \ //映射容器的端口号到宿主机的端口号
-v /home/neo4j/data:/data \ //把容器内的数据目录挂载到宿主机的对应目录下
-v /home/neo4j/logs:/logs \ //挂载日志目录
-v /home/neo4j/conf:/var/lib/neo4j/conf //挂载配置目录
--env NEO4J_AUTH=neo4j/yourpassword \ //设定数据库的名字的访问密码
neo4j //指定使用的镜像
完整一行命令：
docker run -d --name container_name -p 7474:7474 -p 7687:7687 -v /home/neo4j/data:/data -v /home/neo4j/logs:/logs -v /home/neo4j/conf:/var/lib/neo4j/conf --env NEO4J_AUTH=neo4j/yourpassword neo4j
6、修改配置，支持外网远程访问
// 进入容器配置目录挂载在宿主机的对应目录，我这里是/home/neo4j/conf
cd /home/neo4j/conf
// vim编辑器打开neo4j.conf
vim neo4j.conf
// 进行以下更改
//在文件配置末尾添加这一行
dbms.connectors.default_listen_address=0.0.0.0 //指定连接器的默认监听ip为0.0.0.0，即允许任何ip连接到数据库
//修改
dbms.connector.bolt.listen_address=0.0.0.0:7687 //取消注释并把对bolt请求的监听“地址:端口”改为“0.0.0.0:7687”
dbms.connector.http.listen_address=0.0.0.0:7474 //取消注释并把对http请求的监听“地址:端口”改为“0.0.0.0:7474”
docker restart 容器id（或者容器名）
启动完后：http://192.xxx.xx.xx:7474/browser/ 进行登录查看
三、neo4j 原生操控
1、增
增加一个节点：create (n:Person {name:‘我’,age:31})
带有关系属性：create (p:Person{name:“我”,age:“31”})-[:包工程{金额:10000}]->(n:Person{name:“好大哥”,age:“35”})
2、删
删除无关系节点：match (n:Person{name:“TYD”}) delete n
删除关系：match (p:Person{name:“我”,age:“31”})-[f:包工程]->(n:Person{name:“好大哥”,age:“35”}) delete f
删除关系与节点：match (p:Person{name:“我”,age:“31”})-[f:包工程]->(n:Person{name:“好大哥”,age:“35”}) delete p,f,n
3、改
加上标签：match (t:Person) where id(t)=789 set t:好人return t
加上属性：match (a:好人) where id(a)=789 set a.战斗力=200 return a
修改属性：match (a:好人) where id(a)=789 set a.战斗力=500 return a
4、查
查找节点：match (p:Person) - [:包工程] -> (n:Person) return p,n
统计条数：MATCH p=()-[r:invent]->() RETURN count(p)
5、清空数据库
MATCH (n)
DETACH DELETE n
更多原生的操作可以 百度 cypher语言 进一步了解。
四、python 操控代码
需pip 安装插件
pip install py2neo==2020.1.1
以下提供简单的操控的python示例代码：
from py2neo import Graph, Node, Relationship, NodeMatcher, RelationshipMatcher
class Neo4jDB():
def __init__(self,host="http://192.XX.xx.xxx",user="neo4j",pwd='yourpassword'):
try:
self.graph=Graph(host,username=user,password=pwd)
self.matcher=NodeMatcher(self.graph)
self.cursor = None
except Exception as e:
print(host,user,pwd)
raise Exception(f"启动neo4j数据出错：{e}")
def initCusor(self):
self.cursor = self.graph.begin()
def commitCusor(self):
self.cursor.commit()
def __del__(self):
if self.matcher is not None:
self.matcher=None
if self.graph is not None:
self.graph=None
# 新增一个节点，支持马上提交生效，及结合事务方式（initCusor，commitCusor 与这两个方法配合），批量提交
def createNode(self,appDo):
try:
p=Node("NodeName",appId=appDo.id,name=appDo.name,address=appDo.address,country=appDo.country, aType=atype)
if self.cursor is not None:
self.cursor.create(p)
else:
self.graph.create(p)
return p
except Exception as e:
raise Exception(f"创建XX节点出错：{e}")
# 查找一个节点
def getApplicatnNodeById(self,appId):
try:
return self.matcher.match("NodeName", appId=appId).first()
except Exception as e:
raise Exception(f"查找XX节点出错：{e}")
# 新增一个关系，支持马上提交生效，及结合事务方式（initCusor，commitCusor 与这两个方法配合），批量提交
def addApplyRSType(self,sNode,eNode):
try:
r=Relationship(sNode,"RelationName",eNode)
if self.cursor is not None:
self.cursor.create(r)
else:
self.graph.create(r)
return r
except Exception as e:
raise Exception(f"创建XXX关系出错：{e}")
# 查找一个关系
def existRS(self,sNode,eNode):
try:
matcherF = RelationshipMatcher(self.graph)
return matcherF.match({sNode,eNode}, 'RelationName').first() is not None
except Exception as e:
raise Exception(f"查找XXX关系出错：{e}")
# 查找节点的数量
def getNodeCount(self):
return self.matcher.match("NodeName").count()
# 查找关系的数量
def getInvenCount(self):
matcherF = RelationshipMatcher(self.graph)
return matcherF.match(nodes=None, r_type="RelationName").count()
