Hive JDBC 操作 例子
阿新 • • 發佈:2017-07-30
name imp lex created conn sta 3.1 abc statement
pom.xml配置
<dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-jdbc</artifactId> <version>0.13.1</version> </dependency>
測試例程
1 import org.junit.Test; 2 3 import java.sql.SQLException; 4 import java.sql.Connection;5 import java.sql.ResultSet; 6 import java.sql.Statement; 7 import java.sql.DriverManager; 8 9 /** 10 * Created by Administrator on 2017/7/29. 11 */ 12 public class TestHiveJDBC { 13 14 private static String driverName = "org.apache.hive.jdbc.HiveDriver"; 15 16 @Test 17 public void TestConnection() throwsSQLException { 18 try { 19 Class.forName(driverName); 20 } catch (ClassNotFoundException e) { 21 // TODO Auto-generated catch block 22 e.printStackTrace(); 23 System.exit(1); 24 } 25 Connection con = null; 26 Statement stmt = null; 27 try{ 28 con = DriverManager.getConnection("jdbc:hive2://hadoop-senior.jason.com:10000/db_hive", "jason", "abc123"); 29 stmt = con.createStatement(); 30 // show tables 31 String sql = "select * from bf_log_20170712"; 32 ResultSet res = stmt.executeQuery(sql); 33 while(res.next()){ 34 System.out.println("ip: "+res.getString(1)+" name: "+res.getString(2)+" website: "+res.getString(3)); 35 } 36 }catch(SQLException e){ 37 e.printStackTrace(); 38 }finally { 39 stmt.close(); 40 con.close(); 41 } 42 } 43 44 }
Hive JDBC 操作 例子