package?com;

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

import?util.JdbcUtil;

/**
?*?讀取流將數(shù)據(jù)轉(zhuǎn)成Map插入數(shù)據(jù)庫(kù)
?*/
public?class?Neo4jLoadCSV?{
	public?static?String[]?arr?=?{?“WS“?“XZ“?“JD“?“ZY“?};
	public?static?String[]?arr2?=?{?“網(wǎng)省“?“細(xì)則“?“階段“?“專業(yè)“?};

	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?‘總數(shù)‘?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?‘總數(shù)‘?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（“------------------節(jié)點(diǎn)數(shù)量-----------------“）;
			for?（Mapject>?map?:?list1）?{
				System.out.println（map）;
			}
			System.out.println（“-------------------關(guān)系數(shù)量----------------“）;
			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?				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?				for?（int?j?=?i;?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

?屬性????????????大小?????日期????時(shí)間???名稱
-----------?---------??----------?-----??----
?????目錄???????????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