Как вставить данные с помощью потока в jdbc?

Question

Я хочу вставить данные с помощью JDBC. я пишу этот код:

// Я хочу, чтобы начать темы здесь

 while(stmt_ver.next()){ 
     stmt_ver.setString(i, "test"+...); 
     stmt_ver.executeBatch(); 
     connection_ver.commit(); 
} 

// Я хочу закончить темы здесь

Как я могу сделать это с резьбой?

Answer 1

Здесь вы идете. Обновленный ответ с кодом

нитка классом

public class MyThreadedClass extends Thread{ 

    //Do what I need here on a thread 
    public void run(){ 
     //Do what I need here 
    } 
} 

Main

//Main class 
public static class MyProgramMain{ 

//Program main 
public static void main(String[] args) { 


       //Send 10 threads 
     for (int i=0; i<10; i++){ 

        //Init class (threaded) 
        MyThreadedClass threadedClass = new MyThreadedClass(); 

        //Execute code in the class run() method 
        threadedClass.start(); 
      } 
    } 
} 

Answer 2

new Thread(new Runnable(){ 
@Override public void run(){ 
//enter code here 
    } 
}).start(); 

EDIT Вы хотите вставить с большим количеством нитей параллельно ...

Есть много различных возможностей.

Вы должны прочитать: Параллели (параллельные коллекции) и Исполнители.

EDIT 2 Я согласен с Томасом Уригом, что введение потоков может быть более вредным, чем благословение здесь. Почему вы думаете, что это было бы полезно?

Answer 3

Ваш вопрос трудно ответить. Вы очень расплывчаты. Старайтесь быть ясными. Опубликуйте весь необходимый код. Попытайтесь объяснить, что вы сделали и что вы хотели бы сделать.

Вот вам какой-то намек. Он не будет работать, если вы копируете и мимо него, но я думаю, что это должно быть четко указано, что вы можете попробовать:

int i = 0; 
while(i < columnCount){ 

    // make a new statement 
    Statement stmt_ver = new Statement(); 

    // set your data and make the statement ready 
    stmt_ver.set... 

    // make a new thread that executes your data 
    // and let it run 
    new Thread(){ 

     public void run(){ 

      stmt_ver.addBatch(); 
      stmt_ver.executeBatch(); 
      connection_ver.commit(); 
     } 
    }.start(); 

    i++; 
} 

Это очень простое решение. Он запустит поток на каждой итерации. Поскольку процесс ввода-вывода обычно занимает некоторое время, это может улучшить время выполнения вашего кода. Но имейте в виду - нарезание резьбы непросто. Это очень простое, наивное решение. Это может вызвать больше проблем, чем решает. Если вы не знакомы с потоками (и, похоже, вы этого не сделали), не делайте этого!

Answer 4

public class MockCommonDao { 

    ArrayList<ArrayList> listOlists = new ArrayList<ArrayList>(); 

    public List CommonInsert(List<Object> example) 
     { 
     List<Future<Object>> listOlists = null; 
     ExecutorService executor = Executors.newFixedThreadPool(example.size()); 
     List<TransactionImpl> callingList = new ArrayList<MockCommonDao.TransactionImpl>(); 
     for (int i = 0; i < example.size(); i++) { 
      TransactionImpl localImpl = new TransactionImpl(example.get(i)); 
      callingList.add(localImpl); 
     } 
     try { 

      listOlists = executor.invokeAll(callingList); 

     } catch (InterruptedException e) { 

     } 
     return listOlists; 





     } 
private class TransactionImpl implements Callable<Object>{ 
      private Object example; 


      TransactionImpl(Object Criteria) { 
       this.example = Criteria; 

      } 


      @Override 
      public Object call() throws Exception { 

      private class TransactionImpl implements Callable<Object>{ 
      private Object example; 


      TransactionImpl(Object Criteria) { 
       this.example = Criteria; 

      } 


      @Override 
      public Object call() throws Exception { 

      while(stmt_ver.next()){ 
     stmt_ver.setString(i, "test"+...); 
     stmt_ver.executeBatch(); 
     connection_ver.commit(); 
} 
     } 
     }} 
     } 

Этот код будет делать simualtaneous вставки в зависимости от стоимости ваших нитей вы хотите создать для insert.example.size() определяет количество операций вставки, которые вы хотите выполнить. Надеюсь, вы имеете в виду это.