Hive直连mysql抽数
时间: 2023-06-30 21:17:18 浏览: 76
pyflink实现hive关联mysql
5星 · 资源好评率100%
可以通过Hive的外部表功能,直接将MySQL中的数据导入到Hive中。具体步骤如下:
1. 在Hive中创建一个外部表,指向MySQL中的数据表。
2. 在Hive中执行查询语句,将MySQL中的数据读取到Hive中。
3. 对Hive中的数据进行处理和分析。
下面是一个简单的示例代码:
1. 创建外部表
```
CREATE EXTERNAL TABLE mysql_table (
id INT,
name STRING,
age INT
)
STORED BY 'org.apache.hadoop.hive.mysql.MySQLStorageHandler'
WITH SERDEPROPERTIES (
'serialization.format' = '1'
)
TBLPROPERTIES (
'mysql.host' = 'localhost',
'mysql.port' = '3306',
'mysql.database' = 'test',
'mysql.table' = 'user',
'mysql.username' = 'root',
'mysql.password' = 'password'
);
```
2. 查询数据
```
SELECT * FROM mysql_table;
```
通过以上的步骤,就可以直接将MySQL中的数据导入到Hive中,并在Hive中进行数据处理和分析。
阅读全文