#!/bin/bash

# MySQL 数据库连接参数
MYSQL_HOST="localhost"
MYSQL_USER="root"
MYSQL_PASSWORD="123456"
DATABASE="bigdata_ibecs"

# 删除 Hive 数据库（如果存在）
hive -e "DROP DATABASE IF EXISTS $DATABASE CASCADE;"

# 创建 Hive 数据库（如果不存在）
hive -e "CREATE DATABASE IF NOT EXISTS $DATABASE;"

echo "正在导入表 $DATABASE 到 Hive..."

# 导入数据到 Hive
/opt/sqoop/bin/sqoop import-all-tables --connect "jdbc:mysql://$MYSQL_HOST:3306/$DATABASE" --username $MYSQL_USER --password $MYSQL_PASSWORD --hive-import --hive-database $DATABASE --create-hive-table --hive-overwrite --fields-terminated-by ',' --null-string '\\N' --null-non-string '\\N' --escaped-by '\\' -m 1

echo "导入完毕！"