Google

Thursday, August 16, 2007

Porting Data From one Database to another Database using JDBC

import java.io.*;
import java.net.*;
import java.sql.*;
public class Porting
{
static final String DRIVER_NAME = "sun.jdbc.odbc.JdbcOdbcDriver";
static Connection conn = null,con1=null;
public static void main(String[] args)
{
try
{
Class.forName(DRIVER_NAME);
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnectio("jdbc:odbc:aaa");
con1=DriverManager.getConnection("jdbc:mysql://localhost:3306/employee/user=null&password=null");
if(con1==null)
{
System.out.println("Connection not established");
}
else
{
System.out.println("Connection established");
}
PreparedStatement prp=null;
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("select * from tablename");
int i=1;
while (rs.next())
{
prp=conn.prepareStatement("insert into tablename values (?,?)");
prp.setString(1,rs.getString("uid"));
prp.setString(2,rs.getString("PWD"));
int x=prp.executeUpdate();
if (x!=0)
{
System.out.println(i+" record is inserted");
}
else
{
System.out.println("record is not inserted");
}
i++;
}
rs.close();
stmt.close();
}
catch (ClassNotFoundException cnfe)
{
System.err.println("ClassNotFoundException Was Thrown");
cnfe.printStackTrace();
}
catch (SQLException sqle)
{
System.err.println("SQLException Was Thrown");
sqle.printStackTrace();
}
finally
{
try
{
if(conn!=null)
{
conn.close();
}
if(con1!=null)
{
con1.close();
}
}
catch(Exception e)
}
}
}