JdbcSql.java

/*
java -cp ".:/home/ubuntu/UnityJDBC/mongodb_unityjdbc_full.jar" -Djavax.net.ssl.trustStore=/home/ubuntu/downloads/certs/rds-truststore.jks -Djavax.net.ssl.trustStorePassword=<PASSWORD> JdbcSql mongodb.jdbc.MongoDriver "jdbc:mongodb://<USERNAME>:<PASSWORD>@<HOSTNAME>:27017/ab3?ssl=true" "SELECT * FROM ab3.venue"

java -cp ".:/home/ubuntu/CData/CData_MongoDB/lib/cdata.jdbc.mongodb.jar" JdbcSql cdata.jdbc.mongodb.MongoDBDriver "jdbc:mongodb:Server="<HOSTNAME>";User="<USERNAME>";Password="<PASSWORD>";SSLClientCert="";SSLClientCertType="PEMKEY_FILE";AuthMechanism="SCRAM-SHA-1";SSLServerCert="/home/ubuntu/rds-combined-ca-bundle.pem";UseSSL="True";" "SELECT * FROM ab3.venue;"

java -cp ".:../../Progress/DataDirect/JDBC_60/lib/mongodb.jar" -Djavax.net.ssl.trustStore=/home/ubuntu/downloads/certs/rds-truststore.jks -Djavax.net.ssl.trustStorePassword=<STOREPWD> JdbcSql com.ddtek.jdbc.mongodb.MongoDBDriver "jdbc:datadirect:mongodb://<HOSTNAME>:27017;EncryptionMethod=SSL;TrustStore=/home/ubuntu/downloads/certs/rds-truststore.jks;TrustStorePassword=<STOREPWD>;UserName=<USERNAME>;Password=<PASSWORD>" "SELECT * FROM test.testn;"
*/

import java.sql.*;
import java.lang.*;
import java.io.*;

public class JdbcSql {
    public static void main(String[] args) throws SQLException {
        String driverName = args[0];
        String conn = args[1];
        String query = args[2];
        ResultSet rs;
        try {
            Class.forName(driverName);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.exit(1);
        }

        System.err.println("driverName: " + driverName);
        System.err.println("conn: " + conn);
        System.err.println("query: " + query);
        Connection con = DriverManager.getConnection(conn);
        System.err.println("Connection created");
        DatabaseMetaData dm = con.getMetaData();
        Statement stmt = con.createStatement();
        System.err.println("Statement created");
        //rs = dm.getSchemas();
        rs = dm.getTables(null, null, null, new String[] {"TABLE"});
        //rs = stmt.executeQuery("SELECT * FROM testv1.testv1_xy");
        System.out.println("TABLES");
        printResults(rs);
        System.out.println();
        System.out.println("ab3.venues");
        rs = dm.getColumns("CData", "ab3", "venue", null);
        printResults(rs);
        System.out.println();
        System.out.println("Query: " + query);
        rs = stmt.executeQuery(query);
        printResults(rs);
    }

    public static void printResults(ResultSet rs) throws SQLException {
        ResultSetMetaData rsm = rs.getMetaData();
        StringBuilder sbh = new StringBuilder(rsm.getColumnName(1));
        for (int i = 2; i <= rsm.getColumnCount(); i++)
                sbh.append("," + rsm.getColumnName(i));
        System.out.println(sbh.toString());
        while (rs.next()) {
            StringBuilder sb = new StringBuilder(rs.getString(1));
            for (int i = 2; i <= rs.getMetaData().getColumnCount(); i++) {
                sb.append("," + rs.getString(i));
            }
            System.out.println(sb.toString());
        }
    }
}

JdbcTables.java

import java.sql.*;
import java.lang.*;
import java.io.*;

public class JdbcTables {

    /**
     * @param args
     * @throws SQLException
     */
    public static void main(String[] args) throws SQLException {
        String driverName = args[0];
        String conn = args[1];
        ResultSet rs;
        try {
            Class.forName(driverName);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.exit(1);
        }
        //replace "hive" here with the name of the user the queries should run as
        Connection con = DriverManager.getConnection(conn);
        DatabaseMetaData dm = con.getMetaData();
        Statement stmt = con.createStatement();
        //rs = dm.getSchemas();
        rs = dm.getTables(null, null, null, new String[] {"TABLE"});
        //rs = stmt.executeQuery("SELECT * FROM testv1.testv1_xy");
        System.err.println("con = " + con + " dm = " + dm + " rs = " + rs);
        while (rs.next()) {
            StringBuilder sb = new StringBuilder(rs.getString(1));
            for (int i = 2; i <= rs.getMetaData().getColumnCount(); i++) {
                sb.append("," + rs.getString(i));
            }
            System.out.println(sb.toString());
        }
    }
}