|
1
5
6 package org.javabb.migration.betweendbs;
7 import java.sql.Connection  ;
8 import java.sql.PreparedStatement ;
9 import java.sql.ResultSet ;
10 import java.sql.SQLException ;
11 import java.sql.Statement ;
12
13 public class Jbb_post_text extends Jbb_Convert {
14
15 public void convert() throws ClassNotFoundException , SQLException {
16
17 sql = "select * from jbb_posts_text ORDER BY id_post";
18 System.out.println("TABLE JBB_POSTS_TEXT.");
19 Connection phpConn = this.getDbOrigin();
20 Statement stm = phpConn.createStatement();
21 System.out.println("\tReading data");
22 ResultSet rs = stm.executeQuery(sql);
23
24 Connection javaConn = this.getDbDest();
25
26 javaConn.createStatement().executeUpdate("delete from jbb_posts_text");
27 System.out.println("delete from posts_text is OK!");
28
29 PreparedStatement ps = javaConn.prepareStatement("insert into jbb_posts_text (id_post, post_body) values (?,?)");
30
31 System.out.println("\tInserting data ");
32 int i=0;
33 while (rs.next()) {
34 int idPost = rs.getInt("id_post");
35 ps.setInt (1, idPost);
36 ps.setString (2, rs.getString("post_body"));
37
38 ps.addBatch();
39
40 if(i%7000==0){
41 ps.executeBatch();
42 }
43
44 System.out.println("Post = " + idPost);
45 i++;
46 }
47 System.out.println("\n");
48
49 try {
50 ps.executeBatch();
51 } catch (SQLException e) {
52 System.out.println("\n\n" + e.getNextException().getMessage());
53 }
54
55 ps.close();
56 stm.close();
57 rs.close();
58 phpConn.close();
59 javaConn.close();
60 System.out.print("Done!\n\n");
61 }
62 } |
Popular Tags |
Java API By Example, From Geeks To Geeks.