Hi everybody...,
I am trying to retreive data from sql db tables, and insert into oracale db table.before inserting into oracle table i have to check the modified date column in oracle. if sql table is having updated data i have to insert.
I am using
jdbc api. I got connected to both databases and retreived data from databases. the code i wrote is below, but am stucked at comparing the data and inserting into oracle.
please help me.......
Thanks in advanse
---------------------------------------------------------------------------
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
public class Conn {
Connection con = null;
public static Connection getSqlConnection(
String Username, String Password)
throws SQLException {
String url = "jdbc:sqlserver://localhost\\SQLEXPRESSS:1433;databaseName=Murthy;";
Connection con = null;
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
con = DriverManager.getConnection(url, Username, Password);
if (con != null)
System.out.println("connected");
else
System.out.println("not connected");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return con;
}
public static Connection getOracleConnection(String Username,
String Password) throws SQLException {
String url = "jdbc:oracle:thin:@localhost:1521:XE";
Connection con = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
con = DriverManager.getConnection(url, Username, Password);
if (con != null)
System.out.println("connected");
else
System.out.println("not connected");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return con;
}
public void read() throws SQLException {
Connection con = null;
ResultSet res = null;
Statement stmt = null;
try {
con = getSqlConnection("sa", "amsol");
stmt = con.createStatement();
String query = "select * from [User]";
res = stmt.executeQuery(query);
while (res.next()) {
String ans = res.getString(1);
String ans1 = res.getString(2);
String ans2 = res.getString(3);
String ans3 = res.getString(4);
String ans4 = res.getString(5);
}
} catch (Exception e) {
System.out.println(e);
}
finally {
try {
if (stmt != null) stmt.close();
}
catch (Exception ee) {
} try { if (con != null) con.close(); } catch (Exception c) { } }
}
public void read2() throws SQLException {
con = getOracleConnection("system", "murthy");
Statement stmt = con.createStatement();
String query = "select * from tb_User";
ResultSet res1 = stmt.executeQuery(query);
while (res1.next()) {
String data = res1.getString(8);
}
}
public static void main(String[] args) throws SQLException {
Conn connect = new Conn();
connect.read();
connect.read2();
}
}