jdbc连接impala

2019-01-23  本文已影响0人  jinhm007

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

public class test_jdbc {

    public static void test(){

        Connection con = null;

        ResultSet rs = null;

        PreparedStatement ps = null;

        String JDBC_DRIVER = "com.cloudera.impala.jdbc41.Driver";

        String CONNECTION_URL = "jdbc:impala://192.168.2.20:21050";

        try

        {

            Class.forName(JDBC_DRIVER);

            con = (Connection) DriverManager.getConnection(CONNECTION_URL);

            ps = con.prepareStatement("select count(*) from billdetail;");

            rs = ps.executeQuery();

            while (rs.next())

            {

                System.out.println(rs.getString(1) );

            }

        } catch (Exception e)

        {

            e.printStackTrace();

        } finally

        {

            try {

                rs.close();

                ps.close();

                con.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

    public static void main(String[] args) {

        test();

    }

}

上一篇下一篇

猜你喜欢

热点阅读