/*

* Copyright 2017 MapD Technologies, Inc.

*

* Licensed under the Apache License, Version 2.0 (the "License");

* you may not use this file except in compliance with the License.

* You may obtain a copy of the License at

*

* http://www.apache.org/licenses/LICENSE-2.0

*

* Unless required by applicable law or agreed to in writing, software

* distributed under the License is distributed on an "AS IS" BASIS,

* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

* See the License for the specific language governing permissions and

* limitations under the License.

*/

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 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 result set

while (rs.next()) {

String uniquecarrier = rs.getString("uniquecarrier");

System.out.println("uniquecarrier: " + uniquecarrier);

}

//STEP 5: Clean-up 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