java读取csv文件,跳过第一行,将数据导入到数据库中,使用javacsv
2018-04-02 12:45
1586 查看
public class TestReadcsvFile {
public static void main(String[] args) {
readFile("D:/csvf/csvTestFile.csv");
}
public static void readFile(String filePath){
Connection conn = null;
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/test";
CsvReader read = null;
try {
Class.forName(driver);
conn = (Connection) DriverManager.getConnection(url, "root", "panpan");
// 创建CSV读对象 例如:CsvReader(文件路径,分隔符,编码格式);
read = new CsvReader(filePath, ',', Charset.forName("UTF-8"));
// 跳过第一行 如果需要,可以忽略
read.readHeaders();
while(read.readRecord()){
System.out.println(read.getRawRecord());
String lineTxt = read.getRawRecord();
String[] columns = lineTxt.split(",");
String sql = "insert into T_USER(NAME,PASSWORD,AGE,ADDRESS) values(?,?,?,?)";
PreparedStatement ps = (PreparedStatement) conn.prepareStatement(sql);
ps.setString(1, columns[0]);
ps.setString(2, columns[1]);
ps.setString(3, columns[2]);
ps.setString(4, columns[3]);
ps.executeUpdate();
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
conn.close();
read.close();
} catch (Exception e) {
// TODO Auto-generated catch block
System.out.println("读取文件出错");
e.printStackTrace();
}
}
}
public static void main(String[] args) {
readFile("D:/csvf/csvTestFile.csv");
}
public static void readFile(String filePath){
Connection conn = null;
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/test";
CsvReader read = null;
try {
Class.forName(driver);
conn = (Connection) DriverManager.getConnection(url, "root", "panpan");
// 创建CSV读对象 例如:CsvReader(文件路径,分隔符,编码格式);
read = new CsvReader(filePath, ',', Charset.forName("UTF-8"));
// 跳过第一行 如果需要,可以忽略
read.readHeaders();
while(read.readRecord()){
System.out.println(read.getRawRecord());
String lineTxt = read.getRawRecord();
String[] columns = lineTxt.split(",");
String sql = "insert into T_USER(NAME,PASSWORD,AGE,ADDRESS) values(?,?,?,?)";
PreparedStatement ps = (PreparedStatement) conn.prepareStatement(sql);
ps.setString(1, columns[0]);
ps.setString(2, columns[1]);
ps.setString(3, columns[2]);
ps.setString(4, columns[3]);
ps.executeUpdate();
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
try {
conn.close();
read.close();
} catch (Exception e) {
// TODO Auto-generated catch block
System.out.println("读取文件出错");
e.printStackTrace();
}
}
}
}
需要导入javacsv,mysql-connector-java jar包。
相关文章推荐
- java使用javacsv读取csv文件 导入Mysql数据库
- 2.5 使用Groovy导入CSV文件的数据到一个内存模式的H2数据库
- node.js 读取csv文件数据处理导入mongodb 数据库
- java读取内存中的csv文件,跳过第一行
- 使用ODBC, 将CSV文件里的数据导入DataSet
- 读取Excel文件中的数据,并将其导入数据库
- java中使用POI导入excel数据的过程中,遇到读取以科学计数法显示的数据
- 如何将数据库的数据导入到csv文件中
- Java从.CSV文件中读取数据和写入
- 在rails 4 中 使用 CSV 组件来 把csv文件导入到数据库
- 关于Java Web 使用 iText 将数据库中的 表 的数据 生成 PDF 格式文件(升級版本)
- 使用hibernate读取txt文件导入数据库
- 把数据库文件写入csv文件和从csv文件中导入数据到数据库中
- R—读取数据(导入csv,txt,excel文件)
- java实现读取XML文件数据插入到数据库中
- Java连接数据库+连续读取文件夹下txt文件+读取出txt文件后字符串简单分割连接处理+导入jar包
- Java读取本地文件,然后把数据存到mysql.(以csv文件为例)
- Java读取csv文件并将内容插入到数据库
- 使用POI实现上传ecxel文件,并读取其中数据并存入数据库
- 使用SQL*Loader将CSV文件数据导入ORACLE数据表