图数据库neo4j上机操作.ppt

1、图数据库Neo4j上机操作主要内容安装图数据库neo4j数据导入到图数据库图数据库模型准备Cypher语句查询图数据库IMPORT海量数据导入 下载Neo4j 了解关系型数据企业基本信息表公司编号建筑资质负责人编号负责人名称公司名称上级公司股权控股项目基本信息项目编号参建单位项目名称审批部门项目时间行政单位信息表审批部门审批人员编号审批人员职务亲属关系表身份证号姓名关系关系人身份证号关系人姓名参建类型表项目编号参建单位参建类型公司编号公司名称负责人编号公司负责人建筑资质上级公司股权控股C100001A公司R000001张一一级C100001100%C100002B公司R000002李二二级C1

2、0000180%C100003C公司R000003王三二级C10000170%C100004D公司R000004张四二级C10000351%C100005E公司R000005李五二级C10000355%C100006F公司R000006王六二级C100002100%C100007G公司R000007张七三级C10000475%C100008H公司R000002李二三级C10000475%C100009I公司R000009王九三级C10000475%C100010J公司R000010张十二级C10000560%C100011K公司R000008刘一三级C10000560%C100012L公司R0

3、00005李五一级C100012100%项目编号参建单位项目名称审批部门项目时间P00001A公司某城市外环线道路改造工程A区建委2015P00001B公司某城市外环线道路改造工程A区建委2015P00002G公司某城市热力管道工程C区建委2016P00003E公司某城市轨道交通18号线工程B区建委2014P00003F公司某城市轨道交通18号线工程B区建委2014P00003D公司某城市轨道交通18号线工程B区建委2014P00004H公司某城市新建中环线快速路工程C区建委2013P00005I公司某城市新建长江隧道工程C区建委2015P00005J公司某城市新建长江隧道工程C区建委2015

4、P00005K公司某城市新建长江隧道工程C区建委2015P00005L公司某城市新建长江隧道工程C区建委2015审批部门审批人员编号审批人员职务A区建委S000001赤一审批A区建委S000002橙一综合C区建委S000003黄一审批C区建委S000004绿一综合B区建委S000005青一综合B区建委S000006蓝一审批B区建委S000007紫一综合C区建委S000008白一综合C区建委S000009黑一综合C区建委S000010灰一审批C区建委S000011明一综合C区建委S000012月一综合编号1姓名1关系编号2姓名2S000001赤一母女K000001李一S000002橙一夫妻K00

5、0002金二S000003黄一父子K000003黄豆豆S000004绿一夫妻K000004乐乐S000005青一父子K000005青禾S000006蓝一夫妻K000006欢欢S000007紫一父女K000007紫二S000008白一夫妻K000008甜甜S000009黑一父女K000009木木S000010灰一夫妻R000003王三S000011明一夫妻K000010西西S000012月一父子K000011月二 关系型数据库数据 加载数据-01.建立单位节点和负责人的节点，构建控股负责关系LOAD CSV WITH HEADERS FROM file:/D:/sample/单位基本信息.csv

6、 AS rowCREATE(n:公司)SET n=row,n.公司编号=n.公司编号,n.公司名称=n.公司名称,n.负责人=n.负责人编号,n.建筑资质=n.建筑资质,n.上级公司=n.上级公司LOAD CSV WITH HEADERS FROM file:/D:/sample/单位基本信息.csv AS rowMERGE(n:人员编号:row.负责人编号,姓名:row.公司负责人)-create人员and公司relations负责人关系MATCH(a:人员),(b:公司)WHERE a.编号=b.负责人编号CREATE(a)-r:负责-(b)RETURN r-create公司and公司re

7、lations控股关系MATCH(a:公司),(b:公司)WHERE a.上级公司=b.公司编号CREATE(b)-r:控股-(a)RETURN rLOADCSV提示错误设置file:/与CypherLOADCSV子句一起使用的URL的根目录。这必须设置为数据库服务器的文件系统上的单个目录，并将使所有从file:/URL相对于指定目录加载的请求（类似于unixchroot的操作）。默认值为import。这是一种安全措施，可防止数据库访问标准导入目录之外的文件。设置dbms.directories.import为空删除此安全措施，而是允许访问系统上的任何文件。加载数据-01.建立单位节点和负责人

8、的节点，构建控股负责关系LOAD CSV WITH HEADERS FROM file:/D:/sample/LOAD CSV WITH HEADERS FROM file:/D:/sample/单位基单位基本信息本信息.csv AS row.csv AS rowMERGE(c:MERGE(c:公司公司 公司编号公司编号:row.:row.公司编号公司编号,公司名称公司名称:row.:row.公司名称公司名称,建筑资质建筑资质:row.:row.建筑资质建筑资质)MERGE(pc:MERGE(pc:公司公司 公司编号公司编号:row.:row.上级公司上级公司 )MERGE(p:MERGE(p

9、人员人员 编号编号:row.:row.负责人编号负责人编号,姓名姓名:row.:row.公司负责人公司负责人)CREATE CREATE(p)-r:(p)-r:负责负责-(c)-(c)CREATE CREATE(pc)-s:(pc)-s:控股控股 份额份额:row.:row.股权控股股权控股-(c)-(c)MATCH(n:MATCH(n:公司公司 公司名称公司名称:D:D公司公司)-r:)-r:控股控股-(m)RETURN n,r,m-(m)RETURN n,r,mMATCH(n:MATCH(n:公司公司 公司名称公司名称:C:C公司公司)-r:)-r:控股控股*0.2-(m)RETURN

10、n,r,m0.2-(m)RETURN n,r,mLOAD CSV WITH HEADERS FROM LOAD CSV WITH HEADERS FROM file:/D:/sample/file:/D:/sample/项目基本信息项目基本信息.csv AS row.csv AS rowMERGE(p:MERGE(p:建设项目建设项目 项目编号项目编号:row.:row.项目编号项目编号,项目名项目名称称:row.:row.项目名称项目名称,项目时间项目时间:row.:row.项目时间项目时间)MERGE(d:MERGE(d:审批部门审批部门 部门名称部门名称:row.:row.审批部门审批部

11、门)MERGE(c:MERGE(c:公司公司 公司名称公司名称:row.:row.参建单位参建单位)MERGE MERGE(d)-:(d)-:审批审批-(p)-(p)MERGE MERGE(c)-:(c)-:参建参建-(p)-(p)加载数据-02.建立审批部门和项目的节点，构建审批参建关系LOAD CSV WITH HEADERS FROM LOAD CSV WITH HEADERS FROM file:/D:/sample/file:/D:/sample/人员关系信息人员关系信息.csv AS row.csv AS rowMERGE(p1:MERGE(p1:人员人员 编号编号:row.:ro

12、w.编号编号1,1,姓名姓名:row.:row.姓名姓名1)1)MERGE(p2:MERGE(p2:人员人员 编号编号:row.:row.编号编号2,2,姓名姓名:row.:row.姓名姓名2)2)MERGEMERGE (p1)-:(p1)-:亲属亲属 名称名称:row.:row.关系关系-(p2)-(p2)加载数据-03.建立人员节点，并构建人员亲属关系LOAD CSV WITH HEADERS FROM LOAD CSV WITH HEADERS FROM file:/D:/sample/file:/D:/sample/审批单位人员审批单位人员.csv AS row.csv AS rowM

13、ERGE(d:MERGE(d:审批部门审批部门 部门名称部门名称:row.:row.审批部门审批部门)MERGE(p:MERGE(p:人员人员 编号编号:row.:row.审批人员编号审批人员编号,姓名姓名:row.:row.审批人员审批人员)MERGE MERGE(p)-:(p)-:任职任职 职务职务:row.:row.职务职务-(d)-(d)加载数据-04.建立审批部门和审批人员的节点，构建任职关系建立审批部门和审批人员的节点，构建任职关系 CREATE INDEX ON:CREATE INDEX ON:公司公司(公司名称公司名称)CREATE INDEX ON:CREATE INDEX

14、ON:人员人员(编号编号)CREATE INDEX ON:CREATE INDEX ON:审批部门审批部门(部门名称部门名称)CREATE INDEX ON:CREATE INDEX ON:建设项目建设项目(项目编号项目编号)加载数据-05.建立索引，提高数据查询效率建立索引，提高数据查询效率 图数据库数据1.获取和某个实体相关的所有关系和实体2.获取某两个或多个实体之间的关系3.动态更新图数据库的数据 图数据库在审计大数据关联分析中的应用场景（案例分析）4.按照实体或者关系的模式进行匹配1.获取和某个实体相关的所有关系和实体MATCHp=(n:建设项目项目编号:P00002)(p)setr.

15、角色=row.参建类型4.实体或者关系的模式匹配MATCH(c:公司)-r1:控股*1.5-(d1:公司)-r2:参建-(p:建设项目),(c:公司)-r3:控股*1.5-(d2:公司)-r4:参建-(p:建设项目)WHEREr2.角色=总承包andr4.角色=监理RERURNc,r1,r2,d1,r3,r4,d2,p5.实体或者关系的模式匹配-利益输送MATCHpath1=(p1:人员)-r1:负责-(c1:公司)-*-(p3:建设项目),path2=(p2:人员)-r4:亲属-(p1:人员),path3=(p3:建设项目)-r5:审批-(g:审批部门)(e1:企业)-r1:参建-(p:建设

16、项目)(e2:企业)-r2:参建-(p:建设项目)(e1)(p2:企业),path2=(e1:行政事业单位单位名称:上海市安全生产监督管理局)-r1:行政审批-(p3:企业)WHEREr.发票名称=.*柴油|成品油.*andNOT(e1)-(p1)RETURNpath1一些可能的问题发现模式大数据技术简介R语言可视化应用建议图数据库配置图数据库neo4j3.2（ZIP文件）配置图数据库neo4j3.2（ZIP文件）添加系统变量：set NEO4J_HOME=C：neo4j-community-3.2.2PATH=C：neo4j-community-3.2.2 bin;大数据技术简介R语言可视化

17、应用建议图数据库Neo4j海量数据导入方式用LOAD CSV 方式只能导入小量数据，海量数据导入目前应用的是Neo4j 自带的工具大数据技术简介R语言可视化应用建议图数据库准备CSV如果数据量不大，可以打开CSV修改头文件，如果是海量数据，可以将头文件和数据分开存储。大数据技术简介R语言可视化应用建议图数据库执行NEO4j-IMPORT命令在资源管理器中，按住SHIFT键，在此打开命令窗口neo4j-import.bat-into zhifu-nodes 收款单位.csv-nodes 预算单位.csv-relationships 支付关系.csv 练习：将财政支付的预算单位与支付单位关系导入到NEO4j 中谢谢谢谢