Hive - Tạo cơ sở dữ liệu
Hive là một công nghệ cơ sở dữ liệu có thể xác định cơ sở dữ liệu và bảng để phân tích dữ liệu có cấu trúc. Chủ đề cho phân tích dữ liệu có cấu trúc là lưu trữ dữ liệu theo cách lập bảng và chuyển các truy vấn để phân tích nó. Chương này giải thích cách tạo cơ sở dữ liệu Hive. Hive chứa một cơ sở dữ liệu mặc định có têndefault.
Tạo Tuyên bố Cơ sở dữ liệu
Tạo cơ sở dữ liệu là một câu lệnh dùng để tạo cơ sở dữ liệu trong Hive. Cơ sở dữ liệu trong Hive là mộtnamespacehoặc một bộ sưu tập các bảng. Cácsyntax cho câu lệnh này như sau:
CREATE DATABASE|SCHEMA [IF NOT EXISTS] <database name>
Ở đây, IF NOT EXISTS là một mệnh đề tùy chọn, nó thông báo cho người dùng rằng một cơ sở dữ liệu có cùng tên đã tồn tại. Chúng ta có thể sử dụng SCHEMA thay cho DATABASE trong lệnh này. Truy vấn sau được thực thi để tạo cơ sở dữ liệu có tênuserdb:
hive> CREATE DATABASE [IF NOT EXISTS] userdb;
or
hive> CREATE SCHEMA userdb;
Truy vấn sau được sử dụng để xác minh danh sách cơ sở dữ liệu:
hive> SHOW DATABASES;
default
userdb
Chương trình JDBC
Chương trình JDBC để tạo cơ sở dữ liệu được đưa ra dưới đây.
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveCreateDb {
private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException {
// Register driver and create driver instance
Class.forName(driverName);
// get connection
Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/default", "", "");
Statement stmt = con.createStatement();
stmt.executeQuery("CREATE DATABASE userdb");
System.out.println(“Database userdb created successfully.”);
con.close();
}
}
Lưu chương trình trong một tệp có tên HiveCreateDb.java. Các lệnh sau được sử dụng để biên dịch và thực thi chương trình này.
$ javac HiveCreateDb.java
$ java HiveCreateDb
Đầu ra:
Database userdb created successfully.