java 同步数据

  1 public void Sync_data(){
  2
  3     Connection ocd_query_erp = null;
  4         Connection o_to_portal=null;
  5
  6         String form_form_ocd_configuration="select org_vdc from OCD_Test";//从mysql拿对应到资源池的数据
  7         String form_erp_ocd_sql="select org_cid,vms,provider_vdc,org_vdc,cpu,ram,storage,storage_plus from OCD_Test";//从erp拿数据
  8         String portal_ocd_Insert_sql="insert into OCD_Test(org_cid,vms,provider_vdc,org_vdc,cpu,ram,storage,storage_plus) values(?,?,?,?,?,?,?,?)";
  9         String portal_ocd_Update_sql="update OCD_Test set org_cid=?,vms=?,provider_vdc=?,cpu=?,ram=?,storage=?,storage_plus=? where org_vdc =?";
 10
 11     List ocdIdList = new ArrayList();
 12
 13             PreparedStatement o_query_erp = null;
 14         PreparedStatement o_update_ocd = null;
 15         PreparedStatement o_insert_ocd = null;
 16
 17 //定义参数
 18     String org_cid="";
 19         int vms=0;
 20         String provider_vdc="";
 21         String org_vdc="";
 22         String cpu="";
 23         String ram="";
 24         int storage=0;
 25         int storage_plus;
 26
 27 //先获取到对应的数据库
 28         ocd_query_erp= this.getConnection(datasource_from[0].getDrv(), datasource_from[0].getUri(), datasource_from[0].getUid(), datasource_from[0].getPwd());
 29             o_to_portal = this.getConnection(datasource_from[0].getDrv(), datasource_from[0].getUri(), datasource_from[0].getUid(), datasource_from[0].getPwd());;
 30
 31 //预编译sql语句
 32     o_query_erp=ocd_query_erp.prepareStatement(form_erp_ocd_sql);
 33             o_update_ocd=to_portal.prepareStatement(portal_ocd_Update_sql);
 34             o_insert_ocd=to_portal.prepareStatement(portal_ocd_Insert_sql);
 35
 36         Statement o_to_portal_ = to_portal.createStatement();
 37             ResultSet ocd_configuration = o_to_portal_
 38                     .executeQuery(form_form_ocd_configuration);
 39             while (ocd_configuration.next()) {
 40                 String tmp = ocd_configuration.getString(1);
 41                 ocdIdList.add(tmp);
 42             }
 43             ocd_configuration.close();
 44             o_to_portal_.close();
 45
 46
 47 //加载数据
 48             rs_from = o_query_erp.executeQuery();
 49             if (rs_from != null) {
 50                 while (rs_from.next()) {
 51                         // select
 52                         // org_cid,vms,provider_vdc,org_vdc,cpu,ram,storage,storage_plus
 53                         // from OCD_Test
 54                         org_cid =    UI18n.getUnicode(rs_from.getString(1), "gbk");
 55                         vms = rs_from.getInt(2);
 56                         provider_vdc =    UI18n.getUnicode(rs_from.getString(3), "gbk");
 57                         org_vdc =     UI18n.getUnicode(rs_from.getString(4), "gbk");
 58                     //    org_vdc =     rs_from.getString(4), "gbk");
 59                         System.out.println(rs_from.getString(4));
 60                         System.out.println(org_vdc);
 61                         cpu = rs_from.getString(5);
 62                         ram = rs_from.getString(6);
 63                         storage = rs_from.getInt(7);
 64                         storage_plus = rs_from.getInt(8);
 65
 66                         if (!ocdIdList.contains(org_vdc)) {
 67         //    insert into OCD_Test(org_cid,vms,provider_vdc,org_vdc,cpu,ram,storage,storage_plus) values(?,?,?,?,?,?,?,?)";
 68                             o_insert_ocd.setString(1, org_cid);
 69                             o_insert_ocd.setInt(2, vms);
 70                             o_insert_ocd.setString(3, provider_vdc);
 71                             o_insert_ocd.setString(4, org_vdc);
 72                             o_insert_ocd.setString(5, cpu);
 73                             o_insert_ocd.setString(6, ram);
 74                             o_insert_ocd.setInt(7,storage);
 75                             o_insert_ocd.setInt(8, storage_plus);
 76
 77                             int result = o_insert_ocd.executeUpdate();
 78                             o_insert_ocd.clearParameters();
 79                             count_insert += result;
 80                             log.info(count_insert + "  INERT OCD_Test: org_vdc=" + org_vdc + " OK!");
 81                         } else {
 82
 83     //update OCD_Test set ,org_cid=?,vms=?,provider_vdc=?,cpu=?,ram=?,storage=?,storage_plus=? where org_vdc =?";
 84                             o_update_ocd.setString(1,org_cid );
 85                             o_update_ocd.setInt(2, vms);
 86                             o_update_ocd.setString(3, provider_vdc);
 87                             o_update_ocd.setString(4, cpu);
 88                             o_update_ocd.setString(5, ram);
 89                             o_update_ocd.setInt(6, storage);
 90                             o_update_ocd.setInt(7, storage_plus);
 91                             o_update_ocd.setString(8, org_vdc);
 92
 93                             System.out.println(o_update_ocd.toString());
 94                             count_update += o_update_ocd.executeUpdate();
 95                             log.info("UPDATE org_vdc=" + org_vdc + " OK!");
 96
 97                         }
 98                 }
 99             }
100
101
102 }
103
104