如何使用sqoop将oracle中的数据导入HBase中

如何使用sqoop将oracle中的数据导入HBase中

--取两个日期间的工作天数
SELECt COUNT(*) INTO vn
FROM (SELECt vod + ROWNUM - 1 RN
FROM DUAL
CONNECT BY ROWNUM <= vnd - vod)
WHERe TO_CHAr(RN, 'D') BETWEEN 2 AND 6;

--返回数字
RETURN vn;

--异常判断并返回-1
EXCEPTION
WHEN OTHERS THEN
RETURN -1;
END fun_get_workdays;

然后select id,fun_get_workdays(begin_date date, end_date date) from table

使用sqoop工具。 1、在行键选择那里，通过用“”，将需要做行键的多个列写在一起就可以了。 2、例如要将a和b列同时做行键，那么--hbase-row-key "a,b"就可以了。 sqoop是一款开源的工具，主要用于在hadoop(hive)与传统的数据库(mysql、postgresql...)间进行数据的传递，可以将 一个关系型数据库（例如 ： mysql ,oracle ,postgres等）中的数据导进到hadoop的hdfs中，也可以将hdfs的数据导进到关系型数据库中。