Built with Tutify.io

    AIStudyLabs

    Hive Create Database from Scala Example

    Hive Create Database from Scala Example

    In this article, I will explain how to connect to Hive and create a Hive Database from Scala with an example, In order to connect and run Hive SQL you need to have hive-jdbc dependency, you can download this from Maven or use the below dependency on your pom.xml

    <a name="h-hive-scala-dependency"></a>

    Hive Scala Dependency

    
<dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>hive-jdbc</artifactId>
    <version>3.1.2</version>
</dependency>

    <a name="h-start-hiveserver2"></a>

    Start HiveServer2

    To connect to Hive from Scala, you need to start hiveserver2 from $HIVE_HOME/bin

    
prabha@namenode:~/hive/bin$ ./hiveserver2
2020-10-03 23:17:08: Starting HiveServer2

    Below is complete Scala example of how to create a Hive Database.

    <a name="h-create-a-hive-table-from-scala-example"></a>

    Create a Hive Table from Scala Example

    
package com.aistudylabs.hive;

import java.sql.Connection;
import java.sql.Statement;
import java.sql.DriverManager;

object HiveCreateDatabase extends App{
	var con = null;
	try {
		val conStr = "jdbc:hive2://192.168.1.148:10000/default";
		Class.forName("org.apache.hive.jdbc.HiveDriver");
		con = DriverManager.getConnection(conStr, "", "");
		val stmt = con.createStatement();
		stmt.executeQuery("CREATE DATABASE emp");
		System.out.println("Database emp created successfully.");
	} catch (Exception ex) {
		ex.printStackTrace();
	} finally {
		try {
			if (con != null)
				con.close();
		} catch (Exception ex) {
		}
	}
}

    Note: If you are using an older version of Hive, you should use the driver org.apache.hadoop.hive.jdbc.HiveDriver and your connection string should start with jdbc:hive://

    Happy Learning !!

    <a name="h-related-articles"></a>

    Related Articles