如何把.csv文件导入到mysql中以及如何使用mysql 脚本中的load data快速导入

1， 其中csv文件就相当于excel中的另一种保存形式，其中在插入的时候是和数据库中的表相对应的，这里面的colunm 就相当于数据库中的一列，对应csv表中的一列。

2，在我的数据库表中分别创建了两列A ，B属性为varchar。

3，在这里面中，表使用无事务的myISAM 和支持事务innodb都可以，但是MyISAM速度较快。

4， String sql = "load data infile 'E://test.csv' replace into table demo fields terminated by ',' enclosed by '\\'' lines terminated by '\\r\\n' (`A`,`B`) "; 这句话是MySql的脚本在java中的使用，这个插入速度特别快，JDBC自动解析该段代码进行数据的读出，并且插入到数据库。要注意在load
data中转义字符的使用。 如果要使用load
data直接进行执行一下这句话，（不过要记得更改成自己的文件名 和 表名）就可以把文件中的内容插入，速度特别快。值得一试哦

下面是我给出的一段最基本的 通过io进行插入的程序，比较详细。

package com.util.user;

import java.io.BufferedReader;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.LineNumberReader;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

public class OfChangeCSVToMysql {

/**

* @author clq

*/

public static void main(String[] args) {

try {

long start = System.currentTimeMillis();

Class.forName("com.mysql.jdbc.Driver");

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/girlandboy?rewriteBatchedStatements=true","root","1234");

conn.setAutoCommit(false);

List<String> listData = readFile("E://test.csv");//read a file return every line

for(String list:listData){

System.out.println(list);

/*

* in the csv file default splited with ',',every column to the database table's column

*/

String []column = list.split(",");

//The 'A' is the column in the csv,and in the database table

if(column[0].trim().equalsIgnoreCase("A")){

continue;

}

String sql = "insert into demo(A, B) values('"+column[0]+"','"+column[1]+"')";

PreparedStatement pstmt = conn.prepareStatement(sql);

pstmt.execute();

/ pstmt.addBatch()//this is the batch

}

/ / pstmt.executeBatch();

conn.commit();

System.out.println(System.currentTimeMillis() - start);

} catch (ClassNotFoundException e) {

e.printStackTrace();

} catch (SQLException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

public static List<String> readFile(String filePathAndName)throws IOException {

FileInputStream fis = new FileInputStream(filePathAndName);

InputStreamReader isr = new InputStreamReader(fis, "UTF-8");

BufferedReader br = new BufferedReader(isr);

LineNumberReader lnr = new LineNumberReader(br);

List<String> returnValue = new ArrayList<String>();

int cnt = 0;

while (true) {

cnt++;

String tempStr = lnr.readLine();

if (tempStr == null)

break;

if (tempStr.length() < 2)

continue;

returnValue.add(tempStr);

}

lnr.close();

br.close();

isr.close();

fis.close();

return returnValue;

}

}