java 本地解析sql文件，执行批量更新

              java  解析sql文件，批量更新

 

package cn.com.superv.netmessage.util;

import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public  class DBTool {

 /**
  * @param args
  * @throws ClassNotFoundException
  * @throws SQLException
  * @throws IOException
  * @throws IllegalAccessException
  * @throws InstantiationException
  */
  //private final static ThreadLocal  local  = new ThreadLocal();
 
 public static void main(String[] args) throws ClassNotFoundException, SQLException, IOException, InstantiationException, IllegalAccessException {
  // TODO Auto-generated method stub
  //要获得的文件名
  String path = "data.sql";
  //连接变量
  String url,uid,pwd;
  Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
  url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
  uid = "netmessage";
  pwd = "netmessage";
        execute(url, uid, pwd, path);

 }
 public static Connection  getConnection(String url,String uid,String pwd) throws InstantiationException, IllegalAccessException, ClassNotFoundException{
   Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
   Connection cn = null;
  try {
   cn = DriverManager.getConnection(url,uid,pwd);
  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
   return cn;
 }
 public static void execute(String url,String uid,String pwd ,String path){
  Connection cn = null;
  try {
   cn = getConnection (url,uid,pwd);
  } catch (Exception e1) {
   // TODO Auto-generated catch block
   e1.printStackTrace();
  }
   Statement stmt = null;
      //读取文件
      try
      {stmt = cn.createStatement();
          InputStream r = new FileInputStream(path);
          ByteArrayOutputStream byteout = new ByteArrayOutputStream();
          byte tmp[] = new byte[99999];
          byte context[];
          int i = 0;
          while ((i = r.read(tmp)) != -1)
          {
              byteout.write(tmp);
          }
          context = byteout.toByteArray();
          String str = new String(context, "UTF-8");
          // 分隔行
          String stra[] = str.split(";");
          for (int n = 0; n < stra.length; n++)
          {
              System.out.println(stra[n]);
              stmt.addBatch(stra[n]);
          }
          stmt.executeBatch();
      }
      catch (Exception e)
      {
          e.printStackTrace();
      } finally {
         if(cn!=null){
       try {
      if(!cn.isClosed()){
         cn.close();
        }
     } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
     }
      }}
 }
}

 

http://www.1diaocha.com/user/Register.aspx?account=soqian
参加调查,轻松赚钱