public class Test2 {
	public static void main(String[] args) {
		long start = System.currentTimeMillis();
		String sql = "insert into mobile_place(number,place) values(?,?)";
		int count=0;
		PreparedStatement pstmt = null;
		Connection conn = JDBCUtil.getConnection();
		try {
			pstmt = conn.prepareStatement(sql);
			
			InputStreamReader is = new InputStreamReader(new FileInputStream(new File("D:/CC.txt")),"utf-8");
			BufferedReader br = new BufferedReader(is);
			//设置数据手动提交，自己管理事务
			conn.setAutoCommit(false);
			
			String s1 = null;
			String s2 = null;
			while(br.readLine() != null){
				count++;//每读取一行数据，计数器+1
				String str = br.readLine().toString().trim();//读取一行数据
				s1 = str.substring(0, str.indexOf(","));//取逗号以前的一段
				s2 = str.substring(str.indexOf(",")+1,str.length());//取逗号之后的一段
				
				pstmt.setString(1, s1);
				pstmt.setString(2, s2);
				pstmt.addBatch();//用PreparedStatement的批量处理
				
				if(count%1000==0){//当增加了1000个批处理的时候再提交
					pstmt.executeBatch();//执行批处理
					conn.commit();//提交
					conn.close();//关闭数据库
					conn = JDBCUtil.getConnection();//重新获取一次连接
					conn.setAutoCommit(false);
					pstmt = conn.prepareStatement(sql);
				}
				System.out.println("已插入"+count+"条数据");
			}
			if(count%1000!=0){//while循环外的判断，为了防止上面判断后剩下最后少于500条的数据没有被插入到数据库
				pstmt.executeBatch();
				conn.commit();
			}
			long end = System.currentTimeMillis();
			
			System.out.println("共花费时间:"+(end-start));
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			try {
				pstmt.close();
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
	}
}


//getConnection()为获取数据库连接 
public static Connection getConnection(){ 
try { 
Class.forName("com.mysql.jdbc.Driver"); 
} catch (ClassNotFoundException e) { 
e.printStackTrace(); 
} 
try { 
conn = DriverManager.getConnection(url, userName, password); 
} catch (SQLException e) { 
e.printStackTrace(); 
} 
return conn; 
}