java多线程数据库操作

　　import Java.io.*;
　　
　　import java.sql.*;
　　
　　public class ToOracle {
　　
　　public static void main(String[] args) {
　　
　　int n = 10;//每个线程执行的个数
　　
　　//System.out.println("start action!!!!!!");
　　
　　ToOracle ac = new ToOracle();
　　
　　ThreadRun[] testrun = new ThreadRun[21];
　　
　　for (int i = 1; i <= 21; i++) {
　　
　　testrun[i] = ac.new ThreadRun();
　　
　　testrun[i].TRun(n);
　　
　　System.out.println("线程" + i + "已经启动");
　　
　　}
　　
　　//testrun[1] = ac.new ThreadRun();
　　
　　//testrun[1].TRun(10);
　　
　　for (int i = 1; i <= 21; i++) {
　　
　　testrun[i].TExit();
　　
　　}
　　
　　}
　　
　　class ThreadRun {
　　
　　String blobname = "D:eclipse est est1.txt"; //blob文件名
　　
　　String clobname = "D:eclipse est est2.txt"; //clob文件名
　　
　　String in = "insert into ";
　　
　　String in1 = "(order_id,ric_code,siz,price,trade_datetime,status,testblob,testclob) values(9,´asdfjkl´,21,123.34567,sysdate,´nill逆耳´,?,?)";
　　
　　String tablename = "orders1";
　　
　　String sqlstr = ""; // sql 语句
　　
　　ThreadUseExtends thread = new ThreadUseExtends(blobname, clobname,
　　
　　sqlstr);
　　
　　public void TRun(int n) {
　　
　　sqlstr = in + tablename + in1;
　　
　　thread = new ThreadUseExtends(blobname, clobname, sqlstr);
　　
　　//thread.start();
　　
　　thread.run(n);
　　
　　/*
　　
　　* int n=10; for (int i = 1; i <= 21; i++) { while(0 <n){ sqlstr[i] =
　　
　　* in + tablename + in1; thread[i] = new ThreadUseExtends(blobname,
　　
　　* clobname, sqlstr[i]); thread[i].start(); n--; }
　　
　　* System.out.println("线程" + i + "已经启动"); }
　　
　　*/
　　
　　//System.out.println("线程1已经启动");
　　
　　}
　　
　　public void TExit() {
　　
　　thread.interrupt();
　　
　　}
　　
　　class ThreadUseExtends extends Thread {
　　
　　String filename1;//blob filename
　　
　　String filename2;//clob filename
　　
　　String str;
　　
　　//构造函数要有（blob文件名,clob文件名,sql语句）
　　
　　public ThreadUseExtends(String name1, String name2, String sqlstr) {
　　
　　filename1 = name1;
　　
　　filename2 = name2;
　　
　　str = sqlstr;
　　
　　}
　　
　　ReadFiles r1 = new ReadFiles();
　　
　　public void run(int n) {
　　
　　while (n > 0) {
　　
　　try {
　　
　　String url = "jdbc:oracle:thin:@193.9.200.111:1521:ora9i";
　　
　　String login = "system"; // use your login here
　　
　　String passWord = "ti2003"; // use your password here
　　
　　Class.forName("oracle.jdbc.driver.OracleDriver");
　　
　　Connection con = DriverManager.getConnection(url,
　　
　　login, password);
　　
　　String testLong = r1.ReadFile(filename1);
　　
　　String testLong1 = r1.ReadFile(filename2);
　　
　　byte[] ba = testLong.getBytes();
　　
　　System.out.println("str=" + str);
　　
　　//String strSql = str; //"insert into
　　
　　// orders(order_id,ric_code,siz,price,trade_datetime,status,testblob,testclob)
　　
　　// values(8,´asdfjkl´,21,123.34567,sysdate,´nill逆耳´,?,?)";
　　
　　PreparedStatement stm = con.prepareStatement(str);
　　
　　stm.setBytes(1, ba);
　　
　　StringReader test = new StringReader(testLong1);
　　
　　stm.setCharacterStream(2, test, testLong.length());
　　
　　stm.execute();
　　
　　stm.close();
　　
　　con.close();
　　
　　} catch (Exception e) {
　　
　　e.printStackTrace();
　　
　　}
　　
　　n--;
　　
　　}//while
　　
　　}//run
　　
　　}//ThreadUseExtends class
　　
　　// ReadFiles class for read text!