skip to main | skip to sidebar

Java Programs and Examples with Output

Pages

▼
 
  • RSS
  • Twitter
Wednesday, October 3, 2012

Data insertion utility

Posted by Admin at 6:22 PM – 0 comments
 
This utility fetches data from one schema which ia on different server.and inserts the entire data into other server with same schema.
import java.util.ArrayList;
import java.util.List;
import java.util.Vector;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;

public class Example {

 public static void main(String[] args) throws InterruptedException {
  Connection connection = null; 
 try
 {
   
  //String driverName ="oracle.jdbc.pool.OracleConnectionPoolDataSource";
  String driverName ="oracle.jdbc.driver.OracleDriver";
  Class.forName(driverName);
  String username = "catoracle"; 
  String password = "catoracle";
  String url="jdbc:oracle:thin:@157.227.102.89:1521:offshore";
  connection = DriverManager.getConnection(url, username, password);
  ArrayList tableList = new ArrayList();
  tableList.add("CATC_AGED_WRITEOFF_RULE");
  tableList.add("CATC_APPLICATION");
  tableList.add("CATC_CASE_ADVICE");
  tableList.add("CATC_CASE_APRV_TEMP_DATA");
  tableList.add("CATC_CASE_ASS_ERRTYPE_CASHLTR");
  tableList.add("CATC_CASE_ASS_ERRTYPE_DLRAMT");
  tableList.add("CATC_CASE_ASS_FIMP_FC");
  tableList.add("CATC_CASE_CASH_LETTER");
  //tableList.add("CATC_CASE_CHECK_INFO");
  tableList.add("CATC_CASE_CORRESP");
  tableList.add("CATC_CASE_CORRESPONDENCE");
  //tableList.add("CATC_CASE_DATA");
  //tableList.add("CATC_CASE_DEPOSIT_INFO");
  //tableList.add("CATC_CASE_FINANCIAL_HIST");
  //tableList.add("CATC_CASE_GL_DATA");
  //tableList.add("CATC_CASE_NOTES");
  //tableList.add("CATC_CASE_OPSACCTING");
  //tableList.add("CATC_CASE_OTHER_INFO");
  //tableList.add("CATC_CASE_SYSTEM_NOTES");
  //tableList.add("CATC_CASE_TRANSFER_INFO");
  //tableList.add("CATC_CASE_WORK_ITEM");
  //tableList.add("CATC_CFS_TRANSACTION_DETAILS");
  tableList.add("CATC_CORRESPONDENCE");
  //tableList.add("CATC_CUSTOMER_REPORT_DATA");
  tableList.add("CATC_DUPLICATE_RULE");
  tableList.add("CATC_FED_PROD_CLT_MAPPING");
  tableList.add("CATC_FED_SOURCEOFWORK");
  tableList.add("CATC_HOLIDAY");
  tableList.add("CATC_MARKET");
  tableList.add("CATC_MKT_CONTROL_ACCOUNT");
  tableList.add("CATC_MKT_DEPT");
  tableList.add("CATC_MKT_DEPT_AGING_EXCEPTION");
  tableList.add("CATC_MKT_DEPT_BANK");
  tableList.add("CATC_MKT_DEPT_CAPTURE_SITE");
  tableList.add("CATC_MKT_DEPT_CASHLETTER");
  tableList.add("CATC_MKT_DEPT_ERRORTYPE");
  tableList.add("CATC_MKT_DEPT_ERR_CORTYP_COR");
  tableList.add("CATC_MKT_DEPT_ERR_CSHLTR_TYPE");
  tableList.add("CATC_MKT_DEPT_GL");
  tableList.add("CATC_MKT_DEPT_GL_CC");
  tableList.add("CATC_MKT_DEPT_RETURNREASON");
  tableList.add("CATC_MKT_DEPT_SITE");
  tableList.add("CATC_MKT_DEPT_SOURCEOFERROR");
  tableList.add("CATC_MKT_DEPT_SOURCEOFWORK");
  tableList.add("CATC_MKT_FIMP");
  tableList.add("CATC_OFFSET_RULE");
  tableList.add("CATC_PEND_CASE_RULE");
  tableList.add("CATC_PRIORITY_RULE");
  tableList.add("CATC_PROFILE");
  tableList.add("CATC_SMALL_WRITEOFF_RULE");
  tableList.add("CATC_SPECIAL_HAND_INSTR");
  tableList.add("CATC_SUB_ERRORTYPE");
  tableList.add("CATC_USER");
  tableList.add("CATC_USER_MKT_DEPT_SITE");
  tableList.add("CATC_UTIL");
  Statement st1=connection.createStatement();
  ResultSet rs1=null;
  ResultSetMetaData rsmd=null;
  int count=0;
  for(int j=0;j<tableList.size();j++){
   StringBuffer query = new StringBuffer();
   query.append("SELECT *");
   query.append("FROM "+tableList.get(j));
   rs1=st1.executeQuery(query.toString());
   rsmd=rs1.getMetaData();
   count=rsmd.getColumnCount();String insertquery = "SELECT 'insert into "+tableList.get(j)+" values ('|| ''''|| ";
   for(int i=1;i<=count-1;i++)
    {
     insertquery = insertquery+rsmd.getColumnName(i)+ "||''''|| ',' || ''''||" ;    
     
    }
    insertquery = insertquery+rsmd.getColumnName(count)+ "||''''||');'" ;  
    
   
   insertquery = insertquery+" "+"from "+tableList.get(j)+";";
   System.out.println(insertquery);
   insertquery=null;
 }
  
   
     
 } 
 catch (ClassNotFoundException e)
 {
   System.out.println(e);
 }
 catch (SQLException e)
 { 
  System.out.println(e);
 } 

  
 }
}

Leave a Reply

Newer Post Older Post
Subscribe to: Post Comments ( Atom )
  • Popular
  • Recent
  • Archives
Powered by Blogger.
 
 
 
© 2011 Java Programs and Examples with Output | Designs by Web2feel & Fab Themes

Bloggerized by DheTemplate.com - Main Blogger