JDBC¶

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

  public class Flights {

  // 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 = "myUserName";
  static final String PASS = "myPassWord";

  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 = “CREATE table flights(arr_timestamp timestamp, dep_timestamp timestamp, uniquecarrier varchar(50))”;
      stmt.executeUpdate(sql);
      sql = “insert into flights values(‘2017-04-23 06:30:0’, ‘2017-04-23 07:45:00’, ‘Southwest’)”;
      stmt.executeUpdate(sql);
      sql = “insert into flights values(‘2017-04-23 06:50:0’, ‘2017-04-23 09:45:00’, ‘American’)”;
      stmt.executeUpdate(sql);
      sql = “insert into flights values(‘2017-04-23 09:30:0’,’ 2017-04-23 12:45:00’, ‘United’)”;
      stmt.executeUpdate(sql);

      sql = "SELECT uniquecarrier from flights";
      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();
      if (stmt != null)
          stmt.close();
      if (conn != null)
          conn.close();
     }//end try
    }//end main
  }//end Flights

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