Main.java package com.zhongkao;import java.io.BufferedReader;import java.io.File;import java.io.FileInputStream;import java.io.InputStream;import java.io.InputStreamReader;import java.sql.Connection;import java.sql.DriverManager;import java
package com.zhongkao; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.util.regex.Matcher; import java.util.regex.Pattern; public class Main { public static void main(String[] args) throws Exception { Main m = new Main(); m.process(); } private void process() throws Exception { Connection conn = getConnection(); String sql = "insert into list(code, name, s1, s2, score, type) values(?, ?, ?, ?, ?, ?)"; String code = null; String name = null; String s1 = null; String s2 = null; double score = 0d; String type = null; String filename = "/mydata/private/all.csv"; InputStream is = new FileInputStream(new File(filename)); BufferedReader reader = new BufferedReader(new InputStreamReader(is, "utf-8")); String line = null; int index = 0; while ((line = reader.readLine()) != null) { //code,name,s1,s2,score if (index == 0) { index++; continue; } String[] arr = line.split("[\\,]{1}"); code = arr[0]; name = arr[1]; s1 = arr[2]; s2 = arr[3]; score = Double.parseDouble(arr[4]); s2 = s2.replaceAll("(", "("); s2 = s2.replaceAll(")", ")"); s2 = s2.replaceAll(" ", ""); s2 = s2.replaceAll(" ", ""); //市一中(统招) String pattern = "(.*)\\((.*)\\).*"; Pattern r = Pattern.compile(pattern); Matcher m = r.matcher(s2); if (m.find( )) { s2 = m.group(1); type = m.group(2); } //System.out.println(s2 + ":" + type); PreparedStatement ps = conn.prepareStatement(sql); ps.setString(1, code); ps.setString(2, name); ps.setString(3, s1); ps.setString(4, s2); ps.setObject(5, score); ps.setString(6, type); ps.executeUpdate(); ps.close(); index++; System.out.println(name); } is.close(); conn.close(); } private Connection getConnection() throws Exception { Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://localhost:3306/zhong?useUnicode=true&characterEncoding=UTF-8"; Connection conn = DriverManager.getConnection(url, "root", "---------"); return conn; } }