Read .CVS file and store data into MySQL Database
-: Read .CVS file and store data into MySQL Database :-
Code:-
public static void studentdata() {
String csvFilePath = "D:\\Student.csv";
try {
BufferedReader lineReader = new BufferedReader(new FileReader(csvFilePath));
CSVParser records = CSVParser.parse(lineReader, CSVFormat.EXCEL.withFirstRecordAsHeader().withIgnoreHeaderCase().withTrim());
ArrayList<Student> students = new ArrayList<Student>();
for (CSVRecord record : records) {
Student student = new Student();
student.setStudentId(Integer.parseInt(record.get(0)));
student.setStudentName(record.get(1));
students.add(student);
}
PreparedStatement statement = null;
Connection con = dbconnection();
String sql = "INSERT INTO student(STUDENTID, STUDENTNAME) VALUES (?, ?)";
statement = con.prepareStatement(sql);
for (Student record : students) {
statement.setInt(1, record.getStudentId());
statement.setString(2, record.getStudentName());
statement.addBatch();
}
statement.executeBatch();
con.commit();
con.close();
} catch (SQLException ex) {
ex.printStackTrace();
} catch (FileNotFoundException ex) {
ex.printStackTrace();
} catch (IOException ex) {
ex.printStackTrace();
}
}
public static Connection dbconnection() {
Connection connection = null;
try {
Class.forName("com.mysql.jdbc.Driver");
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?", "root", "root");
System.out.println("connection sucessfull");
connection.setAutoCommit(false);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
Leave a Comment