Neo4j导入数据的几种方法

1. create语句

CREATE (a:Person {name: '张三', sex: '男'}) 

如利用create批量写入，这里我使用的是scala+spark，代码如下：

object Neo4jConnect { def main(args: Array[String]):Unit = { //数据库连接 val spark=SparkSession.builder().appName("play") .master("local[*]") .config("spark.neo4j.bolt.url", "bolt://localhost:7687") .config("spark.neo4j.bolt.user", "neo4j") .config("spark.neo4j.bolt.password", "neo4j") .getOrCreate() val neo=Neo4j(spark.sparkContext) val sql="CREATE (a:Person {name: '张三', sex: '男'}) RETURN a" //测试语句 val rawGraphnode=neo.cypher(sql).loadRowRdd rawGraphnode.take(10).foreach(println(_)) } } } 

java也测试过，速度很慢

public class createConn { /** * 创建节点并增加属性 */ public static void createNode(){ Session session = driver.session(); session.run( "CREATE (a:Person {name: {name}, title: {title}})", parameters( "name", "Arthur001", "title", "King001" ) ); StatementResult result = session.run( "MATCH (a:Person) WHERE a.name = {name} " + "RETURN a.name AS name, a.title AS title", parameters( "name", "Arthur001" ) ); while ( result.hasNext()) { Record record = result.next(); System.out.println( record.get( "title" ).asString() + " " + record.get( "name" ).asString() ); } session.close(); driver.close(); } } 

1. load csv 命令导入

LOAD CSV FROM "file:///actors.csv" AS line CREATE (a:actors{personId:line[0],name:line[1],type:line[2]}) 

actors.csv放入neo4j安装目录下的import文件夹下

其他几种暂时没有用过，因为现阶段需要实时插入。
持续更新。。。