InstantDB Project
About InstantDB
Project Mail Lists
Short History
Reporting Bugs
Screen Shots
3rd Party Examples
FAQs

Software
Downloads
Documentation
CVS Repositories
Roadmap
License

About Enhydra.org
Who We Are
News, Articles & Events
Getting Involved
Contact Us

Community
Demos
Contributions
Resources
Case Studies
On The Edge! -NEW-
Commercial Vendors

/**
 * Import data from JDBC data source (Informxix SQL Server)
 * <p>
 * @author Jürgen Röder
 * @since  1.00 (2000-09-07 24:00:00)
 */
import java.io.*;
import java.sql.*;
import org.enhydra.instantdb.jdbc.*;
import org.enhydra.instantdb.db.*;

public class Import {

    private static final String IDB_DRIVER = new String("org.enhydra.instantdb.jdbc.idbDriver");
    private static final String INFORMIX_DRIVER = new String("com.informix.jdbc.IfxDriver");
    private static final String FS = new String(System.getProperty("file.separator"));
    private static final String PRP = new String(".prp");
    private static final String TXT = new String(".txt");
    private static final String SCHEMA = new String("_schema.txt");
    private static StringBuffer PROPERTY_DIRECTORY = new StringBuffer("d:").append(FS).append("de").append(FS).append("plus").append(FS).append("base").append(FS).append("properties").append(FS);

/**
 * Import data from JDBC data source (Informxix SQL Server)
 * <p>
 * @author Jürgen Röder
 * @since  1.0.0  (2000-09-07 24:00:00)
 * @param  String [] Parameter
 * @return void
 */
public static void main (String args[]) {

    String idbURL = new String("jdbc:idb:");
    String informixURL = new String("jdbc:informix-sqli://192.168.168.3:1528/jdata:INFORMIXSERVER=dbs730_rm300");
    String uid = new String("********");
    String pword = new String("******");

    Connection con = null;
    Statement stmt = null;
    CallableStatement cstmt = null;
    PreparedStatement pstmt = null;

    int rc = 0;

    if (args.length != 0) {
        String prpFile = new String(args[0] + PRP);
        String txtFile = new String(args[0] + TXT);
        String schemaFile = new String(args[0] + SCHEMA);

        //String sql_drop_table = new String("DROP TABLE " + args[0]);
        String sql_drop_table = new String("DROP TABLE stt");
        String sql_import_from_file = new String("IMPORT " + args[0] + " FROM '" + txtFile + "' USING '" + schemaFile + "' BUFFER 2048");
        String sql_import_from_jdbc = new String("IMPORT stt FROM URL '" + informixURL + "' USING 'SELECT * FROM stt' BUFFER 2048");
        //String sql_import_from_jdbc = new String("IMPORT " + args[0] + " FROM URL '" + informixURL + "' USING 'SELECT * FROM " + args[0]  + "' BUFFER 2048");
        //String sql_select = new String("SELECT * FROM " + args[0]);
        String sql_select = new String("SELECT * FROM stt");

        System.out.println("Import.main() sql_drop_table       = " + sql_drop_table);
        System.out.println("Import.main() sql_import_from_file = " + sql_import_from_file);
        System.out.println("Import.main() sql_import_from_jdbc = " + sql_import_from_jdbc);
        System.out.println("Import.main() sql_select           = " + sql_select);

        prpFile = PROPERTY_DIRECTORY + prpFile;
        schemaFile = PROPERTY_DIRECTORY + schemaFile;
	/*
	 * 1. Load driver(s)
	 */
        try {
	    Class.forName(IDB_DRIVER);
        } catch (Exception e) {
            System.out.println("Failed to load InstantDB JDBC Driver. " + e.getMessage());
        };

        try {
	    Class.forName(INFORMIX_DRIVER);
        } catch (Exception e) {
            System.out.println("Failed to load Informix JDBC Driver.  " + e.getMessage());
        };

	/*
	 * 2. Connect to database
	 */
	idbURL = idbURL + prpFile;
        System.out.println("Import.main() idbURL               = " + idbURL);

        try {
    	    //con = DriverManager.getConnection(idbURL, uid, pword);
       	    con = DriverManager.getConnection(idbURL);
        } catch (Exception e) {
            System.out.println("Import.main() Connection to database failed. " + e.getMessage());
        };

        /*
        try {
       	    con = DriverManager.getConnection(informixURL, "******", "*******");
        } catch (Exception e) {
            System.out.println("Import.main() Connection to database failed. " + e.getMessage());
        };
        */

        /*
        java.util.Enumeration enum = DriverManager.getDrivers();
        while(true) {
            if (enum.hasMoreElements()) {
                System.out.println(enum.nextElement());
            } else break;
        };
        */

	/*
	 * 3. Create statement
	 */
        try {
	    stmt = con.createStatement();
        } catch (Exception e) {
            System.out.println("Import.main() Create statement failed. " + e.getMessage());
        };

        /*
	 * 4. Create table using executeUpdate()
	 */
        try {


	    rc = stmt.executeUpdate("SET DEFAULT_USERNAME roeder");
	    System.out.println("Import.main() sql_set_default_username rc = " + rc);
	    rc = stmt.executeUpdate("SET DEFAULT_PASSWORD jr22056");
	    System.out.println("Import.main() sql_set_default_password rc = " + rc);


	    rc = stmt.executeUpdate(sql_drop_table);
	    System.out.println("Import.main() sql_drop_table       rc = " + rc);
	    //rc = stmt.executeUpdate(sql_import_from_file);
	    //System.out.println("Import.main() sql_import_from_file rc = " + rc);
	    rc = stmt.executeUpdate(sql_import_from_jdbc);
	    System.out.println("Import.main() sql_import_from_jdbc rc = " + rc);
        } catch (SQLException ex) {
            ex.printStackTrace ();
        };

        /*
	 * 5. Close connection
	 */
        try {
            stmt.close();
            con.close();
        } catch (SQLException ex) {
            ex.printStackTrace ();
        };


    } else {
        System.out.println("Import.main() No arguments specified...");
    };

}

}