- AWS Code Sample demonstrates how to connect to an Amazon Redshift cluster using the JDBC API.

/* Copyright, Inc. or its affiliates. All Rights Reserved. This file is licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with the License. A copy of the License is located at This file 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. */ package com.example.redshift; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; import java.util.Properties; import java.sql.SQLException; import java.sql.ResultSet; /** * If you have issues connecting, check your inbound rules that belong to the security group */ public class ConnectToCluster { public static void main(String[] args) { final String USAGE = "\n" + "Usage:\n" + " ConnectToCluster <dbURL><masterUsername><masterUserPassword> \n\n" + "Where:\n" + " dbURL - The URL to the Amazon Redshift cluster \n" + " masterUsername - The master user name \n" + " masterUserPassword - The password that corresponds to the master user name \n" ; if (args.length < 3) { System.out.println(USAGE); System.exit(1); } String dbURL = args[0]; String masterUsername = args[1]; String masterUserPassword = args[2]; connectCluster(dbURL, masterUsername, masterUserPassword) ; } public static void connectCluster(String dbURL, String masterUsername, String masterUserPassword) { Connection conn = null; Statement stmt = null; try{ // Dynamically load driver at runtime // Redshift JDBC 4.1 driver: // Redshift JDBC 4 driver: Class.forName(""); // Open a connection and define properties System.out.println("Connecting to database..."); Properties props = new Properties(); // Uncomment the following line if using a key store // props.setProperty("ssl", "true"); props.setProperty("user", masterUsername); props.setProperty("password", masterUserPassword); conn = DriverManager.getConnection(dbURL, props); // Try a simple query System.out.println("Listing system tables..."); stmt = conn.createStatement(); String sql; sql = "select * from information_schema.tables;"; ResultSet rs = stmt.executeQuery(sql); // Get the data from the result set while({ // Retrieve two columns String catalog = rs.getString("table_catalog"); String name = rs.getString("table_name"); // Display values System.out.print("Catalog: " + catalog); System.out.println(", Name: " + name); } rs.close(); stmt.close(); conn.close(); }catch(SQLException | ClassNotFoundException ex){ // For convenience, handle all errors here ex.printStackTrace(); System.exit(1); }finally{ // Finally block to close resources try{ if(stmt!=null) stmt.close(); }catch(SQLException ex){ System.exit(1); }// Nothing we can do try{ if(conn!=null) conn.close(); }catch(SQLException ex){ ex.printStackTrace(); System.exit(1); } } System.out.println("Finished connectivity test."); } }

Sample Details

Service: Amazon Redshift

Last tested: 7/6/2020

Author: scmacdon - aws

Type: full-example