<dependencies>
<dependency>
<groupId>org.neo4j.driver</groupId>
<artifactId>neo4j-java-driver</artifactId>
<version>4.2.2</version>
</dependency>
</dependencies>
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
public class CSVReader {
public void readCSV(String filePath) {
String line = "";
try (BufferedReader br = new BufferedReader(new FileReader(filePath))) {
while ((line = br.readLine()) != null) {
String[] data = line.split(separator);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
import org.neo4j.driver.Driver;
import org.neo4j.driver.Session;
import org.neo4j.driver.exceptions.ClientException;
public class CSVParser {
private final Driver driver;
public CSVParser(Driver driver) {
this.driver = driver;
}
public void parseCSVAndInsert(String[] data) {
try (Session session = driver.session()) {
String cypherQuery = "CREATE (n:Node {property: $value})";
session.run(cypherQuery, parameters("value", data));
} catch (ClientException e) {
e.printStackTrace();
}
}
}
import org.neo4j.driver.AuthTokens;
import org.neo4j.driver.Driver;
import org.neo4j.driver.GraphDatabase;
import org.neo4j.driver.exceptions.ClientException;
public class Neo4jConfig {
private Driver driver;
public void connect() {
try {
driver = GraphDatabase.driver(uri, AuthTokens.basic(username, password));
} catch (ClientException e) {
e.printStackTrace();
}
}
public Driver getDriver() {
return driver;
}
public void close() {
driver.close();
}
}
public class CSVExample {
public static void main(String[] args) {
Neo4jConfig neo4jConfig = new Neo4jConfig();
neo4jConfig.connect();
CSVReader csvReader = new CSVReader();
CSVParser csvParser = new CSVParser(neo4jConfig.getDriver());
csvReader.readCSV("path_to_csv_file.csv");
csvParser.parseCSVAndInsert(data);
neo4jConfig.close();
}
}
