实际项目中，经常需要对数据进行批量处理。[@more@]

下面这个例子，是从tab分隔的csv文件里读取数据，把数据写入hostname上的DBNAME的USER_MASTER里。

import java.io.*;
import java.sql.*;

import oracle.jdbc.*;

public class Batch2 {
	private static String sDBConnect = "jdbc:oracle:thin:@hostname:1521:DBNAME";
	private static String sDBUser = "user";
	private static String sDBPassword = "password";
	private static String sPath = "C:Batch";
	private static String sFileName = "csvfile.txt";//file name divide by t
	private static int iMax=10000;//max count
	private static int iCol=4;//column number
	
	public static void main(String[] args) {
	 do_Batch_User_Master();
	 System.out.println("Over.");
    }

  public static void do_Batch_User_Master(){
	  String [][]values=new String[iMax][iCol];
	  int i=do_readfile(values);
	  do_Batch_User_Master(values,i);
  }
  
  public static int do_readfile(String [][]values){
	  int i = 0;
	  String value[];
	  try {
          FileReader in = new FileReader(sPath+sFileName);
          BufferedReader br = new BufferedReader(in);
          String line;
          while ((line = br.readLine()) != null) {
              value = (line+"t0").split("t");
              if (do_check_have(value,values,i)) continue;
              
              values[i] = value;
              i++;
          }
          br.close();
          in.close();
      } catch (IOException e) {
          System.out.println(e);
      }
	return i;
  }
  
  public static boolean do_check_have(String []value,String [][]values,int icnt){
	  boolean bret = false;
	  
	  for ( int i=0;i < icnt ;i++ ) 
                 {
		  if(values[i][0].equals(value[0])){//double checked
			  bret = true;
			  break;
		  }
	  }
	  
	  return bret;
  }
      
  public static void do_Batch_User_Master(String [][]values,int icnt){
	  Connection con = null;
	  PreparedStatement pstm = null;
	  Statement	stm = null;
  	  ResultSet	rst = null;
	  StringBuffer sb =null;
	  
	    try {
	      DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
	      con = DriverManager.getConnection(sDBConnect,sDBUser,sDBPassword);
	
	      // disable autocommit 
	      con.setAutoCommit(false);
	      	      	  
	      sb = new StringBuffer();
	      sb.append("INSERT INTO USER_MASTER (USER_ID,PASSWORD,NAME,DEL_FLG) ");
	      sb.append("VALUES (?,?,?,?)");
	      // PrepareStatement
	      pstm = con.prepareStatement( sb.toString());
   		  
	      for( int i=0;i

文章标题：JAVA实现批处理
网站URL：http://myzitong.com/article/jhdecs.html