org.jzy3d.io.hive.jdbc

Class HiveJdbcClient

java.lang.Object

org.jzy3d.io.hive.jdbc.HiveJdbcClient

public class HiveJdbcClient
extends java.lang.Object

export HIVE_CONF_DIR=/Users/martin/Dev/hadoop/spark/spark-trials

Constructor Summary

Constructors

Constructor and Description
HiveJdbcClient()

Method Summary

Modifier and Type	Method and Description
java.sql.Connection	connect(Config.HiveConnection connection)
java.sql.Connection	connect(java.lang.String ip, java.lang.String port, java.lang.String domain, java.lang.String user, java.lang.String password)
void	count(java.sql.Statement stmt, java.lang.String tableName)
void	createTable(java.sql.Statement stmt, java.lang.String tableName, java.lang.String schema)
void	describe(java.sql.Statement stmt, java.lang.String tableName)
void	dropTable(java.sql.Statement stmt, java.lang.String tableName)
void	exec(java.sql.Statement stmt, java.lang.String command)
void	exec(java.sql.Statement stmt, java.lang.String command, boolean print)
void	insertInto(java.sql.Statement stmt, java.lang.String tableName, int key, java.lang.String value)
void	loadData(java.sql.Statement stmt, java.lang.String tableName, java.lang.String localInpath)
static void	main(java.lang.String[] args) https://cwiki.apache.org/confluence/display/Hive/HiveServer2+Clients http: //chase-seibert.github.io/blog/2013/05/17/hive-insert-and-dump-csv-with -map-datatype.html
java.sql.ResultSet	selectAll(java.sql.Statement stmt, java.lang.String tableName)
java.sql.ResultSet	selectAll(java.sql.Statement stmt, java.lang.String tableName, boolean print)
void	showTables(java.sql.Statement stmt)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveJdbcClient

public HiveJdbcClient()

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.sql.SQLException

https://cwiki.apache.org/confluence/display/Hive/HiveServer2+Clients http: //chase-seibert.github.io/blog/2013/05/17/hive-insert-and-dump-csv-with -map-datatype.html

Throws:

java.sql.SQLException

connect

public java.sql.Connection connect(Config.HiveConnection connection)
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

connect

public java.sql.Connection connect(java.lang.String ip,
                                   java.lang.String port,
                                   java.lang.String domain,
                                   java.lang.String user,
                                   java.lang.String password)
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

insertInto

public void insertInto(java.sql.Statement stmt,
                       java.lang.String tableName,
                       int key,
                       java.lang.String value)
                throws java.sql.SQLException

Throws:

java.sql.SQLException

count

public void count(java.sql.Statement stmt,
                  java.lang.String tableName)
           throws java.sql.SQLException

Throws:

java.sql.SQLException

selectAll

public java.sql.ResultSet selectAll(java.sql.Statement stmt,
                                    java.lang.String tableName)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

selectAll

public java.sql.ResultSet selectAll(java.sql.Statement stmt,
                                    java.lang.String tableName,
                                    boolean print)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

loadData

public void loadData(java.sql.Statement stmt,
                     java.lang.String tableName,
                     java.lang.String localInpath)
              throws java.sql.SQLException

Throws:

java.sql.SQLException

describe

public void describe(java.sql.Statement stmt,
                     java.lang.String tableName)
              throws java.sql.SQLException

Throws:

java.sql.SQLException

showTables

public void showTables(java.sql.Statement stmt)
                throws java.sql.SQLException

Throws:

java.sql.SQLException

dropTable

public void dropTable(java.sql.Statement stmt,
                      java.lang.String tableName)
               throws java.sql.SQLException

Throws:

java.sql.SQLException

createTable

public void createTable(java.sql.Statement stmt,
                        java.lang.String tableName,
                        java.lang.String schema)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

exec

public void exec(java.sql.Statement stmt,
                 java.lang.String command)
          throws java.sql.SQLException

Throws:

java.sql.SQLException

exec

public void exec(java.sql.Statement stmt,
                 java.lang.String command,
                 boolean print)
          throws java.sql.SQLException

Throws:

java.sql.SQLException