Kopieren Sie eine Tabelle Daten und fügen Sie diese in eine andere Tabelle in der gleichen Datenbank mit JAVA?

Question

Ich möchte einige Daten aus einer MySQL-Datenbanktabelle auswählen und diese ausgewählten Daten mithilfe JAVA in eine andere Tabelle in derselben Datenbank einfügen. Beide Tabellen haben die gleiche Struktur. Bis jetzt kann ich Daten auswählen, aber ich kann diese Daten nicht einfügen.

Test und test_t sind die Tabellen.

item_id ist die einzige Spalte in der Tabelle.

Ich möchte auch Test Tabellendaten löschen, nachdem ich sie auf den Tisch test_t eingefügt. Diese Testtabelle ist wie eine temporäre Tabelle.

Dies ist meine Methode.

private void testM() throws Exception { 

     pooler = DBPool_SF.getInstance(); 
     dataSource = pooler.getDataSource(); 
     Connection con = dataSource.getConnection(); 
     con.setAutoCommit(false); 

     PreparedStatement ps,ps1 = null; 
     ResultSet rs = null; 

     String SEL_QUERY = "select item_id from test"; 
     String UPDATE_QUERY = "insert into test_t values(?)"; 

     ps = con.prepareStatement(SEL_QUERY); 
     rs = ps.executeQuery(); 
     ps1 = con.prepareStatement(UPDATE_QUERY); 

     while (rs.next()) { 

      String id = rs.getString("item_id"); 
      System.out.println(id); 
      ps1.setString(1,id); 
      ps1.addBatch(); 
      } 

      ps1.executeBatch(); 
     con.close(); 
    } 

Answer 1

Der folgende Code wird funktionieren. Wenn Sie setAutoCommit (false) angeben, müssen Sie am Ende ein Commit durchführen.

 con.setAutoCommit(false); 
     PreparedStatement ps, ps1 = null; 
     ResultSet rs = null; 
     Statement st = null; 

     String SEL_QUERY = "select item_id from test"; 
     String UPDATE_QUERY = "insert into test_t values(?)"; 
     String DELETE_QUERY = "delete from test"; 

     st = con.createStatement(); 
     ps = con.prepareStatement(SEL_QUERY); 
     rs = ps.executeQuery(); 
     ps1 = con.prepareStatement(UPDATE_QUERY); 

     while (rs.next()) 
     { 

      String id = rs.getString("item_id"); 
      System.out.println(" item_id : " + id); 
      ps1.setString(1, id); 
      ps1.addBatch(); 
     } 

     ps1.executeBatch(); 
     st.execute(DELETE_QUERY); 

     con.commit(); 
     con.close();