Site icon Spark By {Examples}

Hive – Create Database from Java Example

Naveen Nelamali
create hive table java

Let’s see how to connect Hive and create a Hive Database from Java 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.

Hive Java Dependency


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

Start HiveServer2

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


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

Below are complete Java example of how to create a Hive Database.

Create a Hive Table from Java Example


package com.sparkbyexamples.hive;

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

public class HiveCreateDatabase {
	public static void main(String[] args) {
		Connection con = null;
		try {
			String conStr = "jdbc:hive2://192.168.1.148:10000/default";
			Class.forName("org.apache.hive.jdbc.HiveDriver");
			con = DriverManager.getConnection(conStr, "", "");
			Statement 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 !!

Exit mobile version