Hive 0.14 + hadoop 2.4.1 环境下的 jdbc连接

hive --service hiveserver 10010

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

package cn.pior.test;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

public class HiveTest {

    private static final String URLHIVE = "jdbc:hive://192.168.1.201:10010/default";

    private static Connection connection = null;

    public static Connection getHiveConnection() {

        if (null == connection) {

            synchronized (HiveTest.class) {

                if (null == connection) {

                    try {

                        Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");

                        connection = DriverManager.getConnection(URLHIVE, "",

                                "");

                    } catch (SQLException e) {

                        e.printStackTrace();

                    } catch (ClassNotFoundException e) {

                        e.printStackTrace();

                    }

                }

            }

        }

        return connection;

    }

    public static void createTable() throws SQLException {

        String tweetTableSql = "create table t2 (i int)";

        Statement stmt = getHiveConnection().createStatement();

        stmt.executeQuery(tweetTableSql);

        stmt.close();

    }

    public static void main(String[] args) throws SQLException {

        createTable();

        getHiveConnection().close();

    }

}