Java读取CSV用Load命令插入Neo4j与JDBC读取Neo4j数库生成Echarts关系图

Java读取CSV用Load命令插入Neo4j与JDBC读取Neo4j数库生成Echarts关系图 需要注意的是 1.自己改jdbc用户名密码 2.插入数据时,csv需要放在你的数据库下的import文件夹 3.查询数据库生成Echarts关系图时自己下载Echarts3放在生成文件的同级目录js文件夹下

package com;

import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import util.JdbcUtil;

/**
 * 读取流将数据转成Map插入数据库
 */
public class Neo4jLoadCSV {
	public static String[] arr = { “WS“ “XZ“ “JD“ “ZY“ };
	public static String[] arr2 = { “网省“ “细则“ “阶段“ “专业“ };

	public static void deleteAll（） {
		JdbcUtil jdbcUtil = new JdbcUtil（）;
		jdbcUtil.getConnection（）;
		try {
			jdbcUtil.update（“MATCH （n） DETACH DELETE n “）;
		} catch （SQLException e） {
			e.printStackTrace（）;
		} finally {
			jdbcUtil.close（）;
		}
	}

	public static void queryCount（） {
		JdbcUtil jdbcUtil = new JdbcUtil（）;
		jdbcUtil.getConnection（）;
		try {
			Listject>> list1 = jdbcUtil
					.findList（“match （n） with ‘总数‘ as labels count（n） as count RETURN labelscount union all  MATCH （n） with labels（n）[0] as labels count（n） as count RETURN labelscount order by count desc“）;
			Listject>> list2 = jdbcUtil
					.findList（“match （）-[r]-（） with ‘总数‘ as type count（r） as count return typecount UNION all MATCH （）-[r]->（） with type（r） as type count（r） as count RETURN typecount order by count desc“）;
			System.out.println（“------------------节点数量-----------------“）;
			for （Mapject> map : list1） {
				System.out.println（map）;
			}
			System.out.println（“-------------------关系数量----------------“）;
			for （Mapject> map : list2） {
				System.out.println（map）;
			}
		} catch （SQLException e） {
			e.printStackTrace（）;
		} finally {
			jdbcUtil.close（）;
		}
	}

	public static void writeNode（String path） {
		JdbcUtil jdbcUtil = new JdbcUtil（）;
		jdbcUtil.getConnection（）;
		try {
			for （int i = 0; i < arr.length; i++） {
				StringBuffer sb = new StringBuffer（）;
				// sb.append（“ using periodic commit 500 “）;
				sb.append（“ load csv with headers from ‘“ + path + “‘ as line“）;
				sb.append（“ with line where line.“ + arr2[i] + “ is not null“）;
				sb.append（“ merge （:“ + arr[i] + “ {name:line.“ + arr2[i] + “value:‘‘}）“）;

				jdbcUtil.update（sb.toString（））;
				System.out.println（sb.toString（））;
			}
		} catch （Exception e） {
			e.printStackTrace（）;
		} finally {
			jdbcUtil.close（）;
		}

	}

	public static void writeLine（String path） {
		JdbcUtil jdbcUtil = new JdbcUtil（）;
		jdbcUtil.getConnection（）;
		try {
			for （int i = 0; i < arr.length - 1; i++） {
				for （int j = i; j < arr.length - 1; j++） {
					StringBuffer sb = new StringBuffer（）;
					// sb.append（“ using periodic commit 500 “）;
					sb.append（“ load csv with headers from ‘“ + path + “‘ as line“）;
					sb.append（“ with line where line.“ + arr2[i] + “ is not null and line.“ + arr2[j + 1] + “ is not null“）;
					sb.append（“ match （from:“ + arr[i] + “{name:line.“ + arr2[i] + “}）“）;
					sb.append（“       （to:“ + arr[j + 1] + “{name:line.“ + arr2[j + 1] + “}）“）;
					sb.append（“ merge （from）-[r:“ + arr[i] + arr[j + 1] + “{name:‘‘}]->（to）“）;
					jdbcUtil.update（sb.toString

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2018-02-06 16:48  noe4j\
     目录           0  2018-02-06 16:43  noe4j\lib\
     文件      159123  2017-05-15 13:58  noe4j\lib\json-lib-2.4-jdk15.jar
     文件     3222864  2017-03-14 09:11  noe4j\lib\neo4j-jdbc-driver-3.0.1.jar
     目录           0  2018-02-06 16:46  noe4j\src\
     目录           0  2018-02-06 16:41  noe4j\src\com\
     文件        4283  2018-02-06 16:58  noe4j\src\com\Neo4jLoadCSV.java
     文件       13126  2018-02-06 17:00  noe4j\src\com\Neo4jQuery.java
     文件         108  2017-04-25 09:44  noe4j\src\jdbc.properties
     目录           0  2018-02-06 16:41  noe4j\src\util\
     文件        6428  2018-02-06 16:41  noe4j\src\util\JdbcUtil.java