图数据库neo4j上机操作ppt课件.pptx
,图数据库Neo4j上机操作,主要内容,安装图数据库neo4j,数据导入到图数据库,图数据库模型准备,Cypher语句查询图数据库,IMPORT海量数据导入,下载Neo4j,了解关系型数据,关系型数据库数据,加载数据-01.建立单位节点和负责人的节点，构建控股负责关系,LOAD CSV WITH HEADERS FROM file:/D:/sample/单位基本信息.csv 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 公司 relations 控股关系MATCH (a:公司),(b:公司)WHERE a.上级公司 = b.公司编号CREATE (b)-r:控股-(a)RETURN r,LOADCSV提示错误,设置file:/与CypherLOAD CSV子句一起使用的URL的根目录。这必须设置为数据库服务器的文件系统上的单个目录，并将使所有从file:/URL相对于指定目录加载的请求（类似于unix chroot的操作）。默认值为import。这是一种安全措施，可防止数据库访问标准导入目录之外的文件。设置dbms.directories.import为空删除此安全措施，而是允许访问系统上的任何文件。,加载数据-01.建立单位节点和负责人的节点，构建控股负责关系,LOAD CSV WITH HEADERS FROM file:/D:/sample/单位基本信息.csv AS rowMERGE(c:公司公司编号:row.公司编号, 公司名称:row.公司名称, 建筑资质:row.建筑资质)MERGE(pc:公司公司编号:row.上级公司 )MERGE (p:人员编号:row.负责人编号, 姓名:row.公司负责人)CREATE (p)-r:负责-(c)CREATE (pc)-s:控股份额:row.股权控股-(c),MATCH (n:公司公司名称:D公司)-r:控股-(m) RETURN n,r,mMATCH (n:公司公司名称:C公司)-r:控股*0.2-(m) RETURN n, r, m,LOAD CSV WITH HEADERS FROM file:/D:/sample/项目基本信息.csv AS rowMERGE (p:建设项目项目编号:row.项目编号,项目名称:row.项目名称,项目时间:row.项目时间)MERGE (d:审批部门部门名称:row.审批部门)MERGE (c:公司公司名称:row.参建单位)MERGE (d)-:审批-(p)MERGE (c)-:参建-(p),加载数据-02.建立审批部门和项目的节点，构建审批参建关系,LOAD CSV WITH HEADERS FROM file:/D:/sample/人员关系信息.csv AS rowMERGE (p1:人员编号:row.编号1, 姓名:row.姓名1)MERGE (p2:人员编号:row.编号2, 姓名:row.姓名2)MERGE (p1)-:亲属名称:row.关系-(p2),加载数据-03.建立人员节点，并构建人员亲属关系,LOAD CSV WITH HEADERS FROM file:/D:/sample/审批单位人员.csv AS rowMERGE (d:审批部门部门名称:row.审批部门)MERGE (p:人员编号:row.审批人员编号, 姓名:row.审批人员)MERGE (p)-:任职职务:row.职务-(d),加载数据-04.建立审批部门和审批人员的节点，构建任职关系,CREATE INDEX ON :公司(公司名称) CREATE INDEX ON :人员(编号) CREATE INDEX ON :审批部门(部门名称) CREATE INDEX ON :建设项目(项目编号),加载数据-05.建立索引，提高数据查询效率,图数据库数据,1.获取和某个实体相关的所有关系和实体,2.获取某两个或多个实体之间的关系,3.动态更新图数据库的数据,图数据库在审计大数据关联分析中的应用场景（案例分析）,4.按照实体或者关系的模式进行匹配,1.获取和某个实体相关的所有关系和实体,MATCH p=(n:建设项目项目编号:P00002)-*-(m) RETURN p,2.获取某两个实体之间的关系,MATCH (p1:人员姓名:灰一),(p2:人员姓名:王三),p = (p1)-*2.10-(p2) return p,3.关系数据的更新,LOAD CSV WITH HEADERS FROM file:/C:/Users/Administrator/Desktop/neo4j测试/公司参建关系.csv AS rowMERGE (p:建设项目项目编号:row.项目编号)MERGE (c:公司公司名称:row.参建单位)MERGE (c)-r:参建-(p)set r.角色=row.参建类型,4.实体或者关系的模式匹配,MATCH (c:公司)-r1:控股*1.5-(d1:公司)-r2:参建-(p:建设项目),(c:公司)-r3:控股*1.5-(d2:公司)-r4:参建-(p:建设项目) WHERE r2.角色=总承包 and r4.角色=监理 RERURN c,r1,r2,d1,r3,r4,d2,p,5.实体或者关系的模式匹配-利益输送,MATCH path1=(p1:人员)-r1:负责-(c1:公司)-*-(p3:建设项目),path2 = (p2:人员)-r4:亲属-(p1:人员),path3 = (p3:建设项目)-r5:审批-(g:审批部门)-r6:任职-(p2:人员)return path1,path2,path3,/建设项目的施工总承包单位和监理单位被同一家单位控股MATCH path1=(e0:企业)-*1.5-(e1:企业)-r1:参建-(p:建设项目)(e2:企业)-r2:参建-(p:建设项目)-b2:建设-(n)WHERE r1.参建角色=施工总承包 and r2.参建角色=工程监理 RETURN path1,path2,/国有企业负责人的亲属负责或者参股的公司参与该单位的项目或者采购MATCH path1=(p1:自然人)-*1.5-(e1)-*1.5-(p2:自然人),path2=(p1:自然人)-r3:配偶-(p2:自然人)RETURN path1,path2,MATCH path1=(p1:企业)-r:供货-(p2:企业),path2=(e1:行政事业单位单位名称:上海市安全生产监督管理局)-r1:行政审批-(p3:企业)WHERE r.发票名称 = .*柴油|成品油.* and NOT (e1)-(p1)RETURN path1,一些可能的问题发现模式,配置图数据库neo4j3.2（ZIP文件）,配置图数据库neo4j3.2（ZIP文件）,添加系统变量：set NEO4J_HOME = C： neo4j-community-3.2.2PATH = C： neo4j-community-3.2.2 bin;,Neo4j海量数据导入方式,用LOAD CSV 方式只能导入小量数据，海量数据导入目前应用的是Neo4j 自带的工具,准备CSV,如果数据量不大，可以打开CSV修改头文件，如果是海量数据，可以将头文件和数据分开存储。,执行NEO4j-IMPORT命令,在资源管理器中，按住SHIFT键，在此打开命令窗口,neo4j-import.bat -into zhifu -nodes 收款单位.csv -nodes 预算单位.csv -relationships 支付关系.csv,练习：将财政支付的预算单位与支付单位关系导入到NEO4j 中,
