import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
@Override
public Driver getHiveJdbcDriver() {
  try {
    return new HiveDriver();
  } catch ( Exception ex ) {
    throw new RuntimeException( "Unable to load Hive JDBC driver", ex );
  }
}
 

import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
@Test
public void testGetProxyNotNull() throws Exception {
  assertTrue( DriverProxyInvocationChain.isInitialized() );
  if ( Boolean.parseBoolean( System.getProperty( "org.pentaho.hadoop.shims.check.hive1", "true" ) ) ) {
    // Create Hive driver
    Driver hiveDriver = new HiveDriver();
    // Create proxy to driver
    Driver driver = DriverProxyInvocationChain.getProxy( Driver.class, hiveDriver );
    assertNotNull( driver );
  }
}
 

import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
@Test
public void testDatabaseSelected() throws SQLException {
  Driver driverMock = mock( HiveDriver.class );
  Driver driverProxy = DriverProxyInvocationChain.getProxy( Driver.class, driverMock );

  Connection connectionMock = mock( Connection.class );
  doReturn( connectionMock ).when( driverMock ).connect( anyString(), (Properties) isNull() );

  Statement statementMock = mock( Statement.class );
  doReturn( statementMock ).when( connectionMock ).createStatement();

  driverProxy.connect( "jdbc:hive://host:port/dbName", null );
  verify( statementMock ).execute( "use dbName" );
}
 

import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
@Test
public void testGetTablesWithSchema() throws SQLException {
  Class hive2;
  try {
    hive2 = Class.forName( "org.apache.hive.jdbc.HiveDatabaseMetaData" );
  } catch ( ClassNotFoundException e ) {
    return;
  }
  if ( hive2 != null ) {
    Driver driverMock = mock( HiveDriver.class );
    Driver driverProxy = DriverProxyInvocationChain.getProxy( Driver.class, driverMock );

    Connection connectionMock = mock( Connection.class );
    doReturn( connectionMock ).when( driverMock ).connect( anyString(), (Properties) isNull() );

    Statement statementMock = mock( Statement.class );
    doReturn( statementMock ).when( connectionMock ).createStatement();

    ResultSet resultSet = mock( ResultSet.class );
    doReturn( resultSet ).when( statementMock ).executeQuery( anyString() );

    DatabaseMetaData databaseMetaDataMock = (DatabaseMetaData) mock( hive2 );
    doReturn( databaseMetaDataMock ).when( connectionMock ).getMetaData();

    String schema = "someSchema";
    doThrow( new SQLException( "Method is not supported" ) ).when( databaseMetaDataMock )
      .getTables( null, schema, null, null );

    Connection conn = driverProxy.connect( "jdbc:hive://host:port/dbName", null );

    conn.getMetaData().getTables( null, schema, null, null );
    verify( statementMock ).execute( "use dbName" );
    verify( statementMock ).executeQuery( "show tables in " + schema );
  }
}
 

import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
/**
 * @return the name of the Hive JDBC driver class used to access the database.
 */
@Override
public String driverClassName() {
  return HiveDriver.class.getName();
}
 

import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
@Bean
public Driver jdbcHiveDriver() {
  return new HiveDriver();
}
 

import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
@Bean
DataSource hiveDataSource() {
	return new SimpleDriverDataSource(new HiveDriver(), hiveUrl);
}
 

import org.apache.hive.jdbc.HiveDriver; //导入依赖的package包/类
private int runLoad(boolean disableMrUpdate) throws IOException, InterruptedException, ClassNotFoundException,
    SQLException {

  Configuration configuration = miniCluster.getMRConfiguration();
  writeSiteFiles(configuration);
  HiveConf hiveConf = new HiveConf(configuration, getClass());
  hiveConf.set("hive.server2.thrift.port", "0");
  HiveServer2 hiveServer2 = new HiveServer2();
  hiveServer2.init(hiveConf);
  hiveServer2.start();

  int port = waitForStartupAndGetPort(hiveServer2);

  Class.forName(HiveDriver.class.getName());
  String userName = UserGroupInformation.getCurrentUser().getShortUserName();
  Connection connection = DriverManager.getConnection("jdbc:hive2://localhost:" + port, userName, "");

  UserGroupInformation currentUser = UserGroupInformation.getCurrentUser();

  run(connection, "set blur.user.name=" + currentUser.getUserName());
  run(connection, "set blur.mr.update.disabled=" + disableMrUpdate);
  run(connection, "set hive.metastore.warehouse.dir=" + WAREHOUSE.toURI().toString());
  run(connection, "create database if not exists testdb");
  run(connection, "use testdb");

  run(connection, "CREATE TABLE if not exists testtable ROW FORMAT SERDE 'org.apache.blur.hive.BlurSerDe' "
      + "WITH SERDEPROPERTIES ( 'blur.zookeeper.connection'='" + miniCluster.getZkConnectionString() + "', "
      + "'blur.table'='" + TEST + "', 'blur.family'='" + FAM + "' ) "
      + "STORED BY 'org.apache.blur.hive.BlurHiveStorageHandler'");

  run(connection, "desc testtable");

  String createLoadTable = buildCreateLoadTable(connection);
  run(connection, createLoadTable);
  File dbDir = new File(WAREHOUSE, "testdb.db");
  File tableDir = new File(dbDir, "loadtable");
  int totalRecords = 100;
  generateData(tableDir, totalRecords);

  run(connection, "select * from loadtable");
  run(connection, "set " + BlurSerDe.BLUR_BLOCKING_APPLY + "=true");
  run(connection, "insert into table testtable select * from loadtable");
  connection.close();
  hiveServer2.stop();
  return totalRecords;
}