<dependency>
<groupId>org.neo4j.driver</groupId>
<artifactId>neo4j-java-driver</artifactId>
<version>4.3.6</version>
</dependency>
<dependency>
<groupId>com.opencsv</groupId>
<artifactId>opencsv</artifactId>
<version>5.5.2</version>
</dependency>
import org.neo4j.driver.AuthTokens;
import org.neo4j.driver.Driver;
import org.neo4j.driver.GraphDatabase;
import org.neo4j.driver.Session;
Driver driver = GraphDatabase.driver("bolt://localhost:7687", AuthTokens.basic("username", "password"));
try (Session session = driver.session()) {
// ...
}
import com.opencsv.CSVReader;
try (CSVReader reader = new CSVReader(new FileReader("path/to/csv/file.csv"))) {
String[] nextLine;
while ((nextLine = reader.readNext()) != null) {
// ...
}
}
String cypherQuery = "CREATE (n:Person {name: $name, age: $age})";
while ((nextLine = reader.readNext()) != null) {
String name = nextLine[0];
int age = Integer.parseInt(nextLine[1]);
session.run(cypherQuery, Values.parameters("name", name, "age", age));
}
import com.opencsv.CSVReader;
import org.neo4j.driver.AuthTokens;
import org.neo4j.driver.Driver;
import org.neo4j.driver.GraphDatabase;
import org.neo4j.driver.Session;
import java.io.FileReader;
import java.io.IOException;
public class Neo4jCSVReader {
public static void main(String[] args) {
Driver driver = GraphDatabase.driver("bolt://localhost:7687", AuthTokens.basic("username", "password"));
try (Session session = driver.session()) {
importDataFromCSV(session, "path/to/csv/file.csv");
}
driver.close();
}
private static void importDataFromCSV(Session session, String csvFilePath) {
try (CSVReader reader = new CSVReader(new FileReader(csvFilePath))) {
String[] nextLine;
while ((nextLine = reader.readNext()) != null) {
String name = nextLine[0];
int age = Integer.parseInt(nextLine[1]);
String cypherQuery = "CREATE (n:Person {name: $name, age: $age})";
session.run(cypherQuery, Values.parameters("name", name, "age", age));
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
Driver driver = GraphDatabase.driver("bolt://localhost:7687", AuthTokens.basic("username", "password"));
importDataFromCSV(session, "path/to/csv/file.csv");
