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文件夹下

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