Yc-Ma Blog

ONgDB图数据库集群数据导入测试案例

 
  • Yc-Ma
  • Jun 14, 2020

Here’s the table of contents:

  1. 测试数据集下载
  2. 数据集导入
    1. 创建索引
    2. 第一次导入
    3. 第二次导入：
  3. 集群信息查看常用CYPHER

本次数据导入测试，搭建了三节点ongdb图数据库集群，分别为2-core,1-replica。

测试数据集下载

twitter-2010.txt.gz

数据集导入

创建索引

CREATE INDEX ON :PersonTest(id);

第一次导入

USING PERIODIC COMMIT 1000
LOAD CSV FROM 'file:/twitter-2010.txt.gz' AS line FIELDTERMINATOR ' '
WITH toInt(line[0]) as id
MERGE (n:PersonTest {id:id})
ON CREATE
SET
	n.name = toString(id),
	n.sex = ['男','女'][(id % 2)],
	n.age = (id % 50) + 15,
	n.country = ['中国','美国','法国', '英国', '俄罗斯', '加拿大', '德国', '日本', '意大利''][(id % 9)];

第二次导入：

USING PERIODIC COMMIT 1000
LOAD CSV FROM 'file:/twitter-2010.txt.gz' AS line FIELDTERMINATOR ' '
WITH toInt(line[1]) as id
MERGE (n:PersonTest {id:id})
ON CREATE
SET
	n.name = toString(id),
	n.sex = ['男', '女''][(id % 2)],
	n.age = (id % 50) + 15,
	n.country = ['中国', '美国', '法国', '英国', '俄罗斯', '加拿大', '德国', '日本', '意大利'][(id % 9)];

集群信息查看常用CYPHER

  • 查看当前节点角色 
    CALL dbms.cluster.role()
  • 查看集群信息 
    CALL dbms.cluster.overview()
  • 查看数据库上正在运行的事务 
    CALL dbms.listTransactions()
  • 查看数据库是企业版还是社区版 
    CALL dbms.components() YIELD edition
  • 查看正在运行的查询 
    CALL dbms.listQueries() YIELD query RETURN query
  • algo与apoc插件信息查看 
    CALL algo.list()
CALL apoc.config.list()
Search