安装hive和安装mysql

首先检查系统安装的mysql版本,使用命令    rpm  -qa | grep mysql

若要安装自己的版本,则先执行删除操作       rpm  -e  xxxxx.rpm   --nodeps

然后安装自己的版本,        rpm  -i  xxxxx.rpm

安装hive和安装mysql

远程连接mysql,操作步骤如下:

1、进入mysql环境中 mysql -uroot -proot

2、设置mysql,授权hive可以远程连接mysql数据库 grant  all on hive.* to ‘root‘@‘%‘ identified by ‘root‘;

    上面这句话的含义是,授权所有匹配hive表的任意位置的root用户,identified by ‘root‘,是说前面root用户的密码,我的root用户密码设置的也是root。

3、设置完成后,刷新一下     flush  privileges;

创建表的两个步骤,首先创建一个表,然后给表加载数据。

创建一个表   CREATE TABLE t1(id int);

hive在hadoop中的表,实际上也是按文件系统的方式存放的,因此,可以给t1表中添加数据,可以有两种方式:

方式一,使用命令  LOAD DATA LOCAL INPATH  ‘/usr/local/id‘    INTO TABLE t1;

方式二,直接使用命令  hadoop fs -put /usr/local/id  /hive/t1

以上的id文件是在hadoop本地上。

创建多个字段的表t2

CREATE TABLE t2(id int,name string) FROM FORMAT DELIMITED FIELDS TERMINATED BY ‘\t‘;

然后在hadoop本地,例如/usr/local/目录下创建一个stu文件,里面包含两个字段,分别用制表符分隔开

然后添加到天t2中    hadoop fs -put /usr/local/stu /hive/t2

在hive中查询,除了select * from 语句,其他的所有语句都走mapreduce,因为select * from 是全盘扫描。

创建分区表

例如按天来存放表t3,

CREATE TABLE T3(id int)  PARTITIONED  BY  (day int);      这句话含义是,安装天数来存放表t3

LOAD DATA LOCAL INPATH ‘/root/id‘  INTO TABLE t3  PARTITION(day=‘22‘);

LOAD DATA LOCAL INPATH ‘/root/id‘  INTO TABLE t3  PARTITION(day=‘23‘);

执行以上语句话会在hive表(对应在hadoop中是hive文件夹)中分别创建22和23两个文件夹,每个文件夹下面都有t3.

那么查询的时候可以使用   select * from t3 where day=22;

桶表

桶表是对数据进行哈希取值(使用hash值对桶的个数进行取模),然后放在不同的文件中存储

create table t4(id int) clustered by(id) into 4 buckets;          //按照表中id那一列的hash值分配到4个桶中

    set hive.enforce.bucketing = true;

    insert into table t4 select id from t3;     //根据id的hash值将t3中的数据分配到t4的每个桶中

注:t4中每个桶对应一个文件,里面存放中从t3表分配过来的数据。

安装hive和安装mysql

分区表是使用文件进行划分,桶表使用文件进行划分。

外部表;

前面说的表都是内部表

外部表是存放在hive表外部的,通过时用命令

create external table t5(id int) location ‘/external‘; 

可以创建一个外部表t5,他在hive中只是一个链接,在hive中删除t5,只是删除了这个链接,这个表中的内容在外部还是存在的。

java客户端操作hive:

首先启动hive远程服务     安装hive和安装mysql

即,在终端执行命令    hive --service hiveserver >/dev/null  2>/dev/null &

然后在eclipse中添加hive的lib目录下的jar包

  1. package hive;
  2. import java.sql.Connection;
  3. import java.sql.DriverManager;
  4. import java.sql.ResultSet;
  5. import java.sql.Statement;
  6. public class App {
  7. public static void main(String[] args) throws Exception{
  8. Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");
  9. //链接default的数据库
  10. Connection con = DriverManager.getConnection("jdbc:hive://192.168.56.100:10000/default", "", "");
  11. Statement stmt = con.createStatement();
  12. //查询default数据库中的t1表
  13. String querySQL="SELECT * FROM default.t1";
  14. ResultSet res = stmt.executeQuery(querySQL);
  15. while (res.next()) {
  16. System.out.println(res.getInt(1));//注意数据库中列是1开始的
  17. }
  18. }
  19. }

安装hive和安装mysql,布布扣,bubuko.com

安装hive和安装mysql

上一篇:mysql中“Table ‘’ is read only”的解决办法


下一篇:MySQL日期时间函数大全