JDBC¶

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class SampleJDBC {

// JDBC driver name and database URL
static final String JDBC_DRIVER = "com.mapd.jdbc.MapDDriver";
static final String DB_URL = "jdbc:mapd:localhost:9091:mapd";

//  Database credentials
static final String USER = "mapd";
static final String PASS = "HyperInteractive";

public static void main(String[] args) {
  Connection conn = null;
  Statement stmt = null;
  try {
    //STEP 1: Register the JDBC driver
    Class.forName(JDBC_DRIVER);

    //STEP 2: Open a connection
    conn = DriverManager.getConnection(DB_URL, USER, PASS);

    //STEP 3: Execute a query
    stmt = conn.createStatement();

    String sql = "SELECT uniquecarrier from flights_2008_10k"
            + " GROUP BY uniquecarrier limit 5";
    ResultSet rs = stmt.executeQuery(sql);

    //STEP 4: Extract data from the result set
    while (rs.next()) {
      String uniquecarrier = rs.getString("uniquecarrier");
      System.out.println("uniquecarrier: " + uniquecarrier);
    }

    //STEP 5: Clean up the environment
    rs.close();
    stmt.close();
    conn.close();
  } catch (SQLException se) {
    //Handle errors for JDBC
    se.printStackTrace();
  } catch (Exception e) {
    //Handle errors for Class.forName
    e.printStackTrace();
  } finally {
    //finally block used to close resources
    try {
      if (stmt != null) {
        stmt.close();
      }
    } catch (SQLException se2) {
    }// nothing we can do
    try {
      if (conn != null) {
        conn.close();
      }
    } catch (SQLException se) {
      se.printStackTrace();
    }//end finally try
  }//end try
}//end main
}//end SampleJDBC

javac SampleJDBC.java
java -cp $MAPD_PATH/bin/mapdjdbc-1.0-SNAPSHOT-jar-with-dependencies.jar:./  SampleJDBC