HIVE2.3.3安装(on Hadoop 2.8.5)

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>
<configuration>
 <!--Hive作业的HDFS根目录位置 -->
 <property>
  <name>hive.exec.scratchdir</name>
  <value>/user/hive/tmp</value>
 </property>
 <!--Hive作业的HDFS根目录创建写权限 -->
 <property>
  <name>hive.scratch.dir.permission</name>
  <value>755</value>
 </property>
 <!--hdfs上hive元数据存放位置 -->
 <property>
   <name>hive.metastore.warehouse.dir</name>
   <value>/user/hive/warehouse</value>
 </property>
 <!--连接数据库地址，名称 -->
 <property>
   <name>javax.jdo.option.ConnectionURL</name>
   <value>jdbc:mysql://hadoop-master1:3306/hive_metastore?createDatabaseIfNotExist=true</value>
 </property>
 <!--连接数据库驱动 -->
 <property>
   <name>javax.jdo.option.ConnectionDriverName</name>
   <value>com.mysql.jdbc.Driver</value>
 </property>
 <!--连接数据库用户名称 -->
 <property>
   <name>javax.jdo.option.ConnectionUserName</name>
   <value>root</value>
 </property>
 <!--连接数据库用户密码 -->
 <property>
   <name>javax.jdo.option.ConnectionPassword</name>
   <value>root</value>
 </property>
 <!--客户端显示当前查询表的头信息 -->
  <property>
   <name>hive.cli.print.header</name>
   <value>true</value>
 </property>
 <!--客户端显示当前数据库名称信息 -->
 <property>
   <name>hive.cli.print.current.db</name>
   <value>true</value>
 </property>
</configuration>

5:启动metastore服务

/root/apache-hive-2.3.3-bin/bin/schematool -dbType mysql -initSchema 

/root/apache-hive-2.3.3-bin/bin/hive --service metastore

package com.lijiahong.hive.jdbc; 
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class Test {

    private static String driverName = "org.apache.hive.jdbc.HiveDriver";
    private static String connctUrl = "jdbc:hive2://192.168.20.130:10000/dw";
    private static String userName = "root";
    private static String password = "123456";
    
    public static void main(String[] args) throws Exception {
        Class.forName(driverName);
   
        Connection con = DriverManager.getConnection(connctUrl, userName, password);
        Statement stmt = con.createStatement();
         
        ResultSet res = stmt.executeQuery( "select * from dw.test01" );
        while (res.next()) {
            System.out.println( res.getInt(1) +"," + res.getString(2)  );
        }    
        stmt.close();
        con.close();
    }
} 

package com.lijiahong.hive.jdbc.auth;

import javax.security.sasl.AuthenticationException;
import org.apache.hive.service.auth.PasswdAuthenticationProvider;

public class CustomPasswdAuthentication implements PasswdAuthenticationProvider {  
    
    @Override
    public void Authenticate(String user, String password) throws AuthenticationException {
       if(user.equals("root") && password.equals("123456") ) {
           System.out.println("user [" + user + "] auth check ok .. ");
       }
       else {
           System.out.println("user [" + user + "] auth check fail .. ");
           throw new AuthenticationException("user [" + user + "] auth check fail .. ");
       } 
    }
}