testconnection.java

一个java的ETL工具

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.DatabaseMetaData;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;


public class TestConnection
{
	public TestConnection()
	{
		DatabaseMetaData dbm;

		try
		{
			// Source DB - MS Access

			Class sourceClass = Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
			System.out.println ("Loaded " + sourceClass);

//			Connection sourceConnection = DriverManager.getConnection("jdbc:odbc:ITSRDB", "admin", "admin");
			Connection sourceConnection = DriverManager.getConnection("jdbc:odbc:AccessTest", "admin", "admin");
			
			dbm = sourceConnection.getMetaData();
			System.out.println(dbm.getDatabaseProductName());

			System.out.println("Connection OK");
			
			Statement sourceStatement = sourceConnection.createStatement(); //ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
//			ResultSet sourceRS = sourceStatement.executeQuery("SELECT MAIN_SUB_TYPE_ID,MAIN_SUB_TYPE FROM Table_Main_Sub_Type_Values");
			ResultSet sourceRS = sourceStatement.executeQuery("SELECT Field1,Field2,Field3,Field4 FROM FourTextFields");
			if (sourceRS != null)
				System.out.println("Successful RS");
			else
				System.out.println("Query Failed");
				
			
			
			// Target DB - Hypersonic SQL
			
			Class targetClass = Class.forName("org.hsqldb.jdbcDriver");
			System.out.println ("Loaded " + targetClass);

			Connection targetConnection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost", "sa", "");

			dbm = targetConnection.getMetaData();
			System.out.println(dbm.getDatabaseProductName());

			System.out.println("Connection OK");
		}
		catch (Exception e)
	  	{
			System.out.println(e);
			System.exit(0);
	  	}	
	}

	public static void main(String[] args)
	{
		TestConnection tc = new TestConnection();
	}	
}