HIVE数据导入MYSQL实现方式

*以下内容均转自其他CSDN博主的优秀内容

一、PYTHON脚本导数

import os
import pymysql
 
 
hive_sql = """
beeline -u jdbc:hive2://10.5.145.113:10000 -n 用户名 -p 密码 --showHeader=false --outputformat=csv2  -e "
SELECT * from table名;
"
"""
 
result = os.popen(hive_sql)
values = [x[:-1].split(',') for x in result]
 
 
db = pymysql.connect('IP地址', '用户名', '密码', '库名')
 
cursor = db.cursor()    #创建一个游标对象
 
mysql_sql = "insert into 库名.表名(col2, col2, col3, col4) values {}".format( 
",".join('("{}", "{}", {}, "{}")'.format(x[0], x[1],x[2],x[3]) for x in values) )
cursor.execute(mysql_sql)
db.commit()
 
res = cursor.fetchall()
print(res)
db.close()

二、SHELL脚本导数

#1、hive执行查询把数据保存到本地

最后

以上就是高高鸭子最近收集整理的关于HIVE数据导入MYSQL实现方式的全部内容，更多相关HIVE数据导入MYSQL实现方式内容请搜索靠谱客的其他文章。