189 8069 5689

关系型数据库导入导出绝招出炉-创新互联

Sqoop作为数据传输的工具,对于Hadoop与传统数据库之间数据的传输起着桥梁作用,那么到底如何导入导出数据呢?

创新互联公司是专业的滨江网站建设公司,滨江接单;提供网站设计、成都做网站,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行滨江网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

第一:使用MapReduce作业来执行导入:

1Sqoop首先检查将要导入的表

1、确定主键(如果有的话),调用mapreduce,根据主键分割map

2、没有主键,运行边界查询确定导入的记录数(找到一个min和一个max,确定边界进行划分)

3、通过任务数来划分边界查询的结果,使得他们有相同的负载

2Sqoop为每个将导入的表生成Java源文件

1、在导入过程中编译和使用文件

2、导入后依然保留,可以被安全删除

第二:使用sqoop导入整个数据库:

(1)import-all-tables工具导入整个数据库

1、存储为逗号间隔的文件

2、默认导入到HDFS的home目录

3、数据将放在每个表的子目录中

关系型数据库导入导出绝招出炉

2)使用--warehouse-dir选项指定不同的基础目录关系型数据库导入导出绝招出炉

第三:使用Sqoop导入单个表:

1import工具导入单个表

1、示例:导入accounts表

以逗号分隔的方式存储数据到HDFS

关系型数据库导入导出绝招出炉

2、指定tab分隔字段

关系型数据库导入导出绝招出炉

第四:增量导入

(1)如果上次记录导入后发生了变更怎么办?

1、可以重新导入所有记录,但是效率低

(2)Sqooplastmodified增量模式导入新的和修改的记录

1、基于指定的timestamp列

2、确保当记录更新或者被添加时timestamp也更新

关系型数据库导入导出绝招出炉

(3)append增量模式只导入新纪录

1、基于指定列的最后一条记录

关系型数据库导入导出绝招出炉

第五:使用SqoopHadoop导出数据到RDBMS

(1)Sqoop的import工具把数据从RDBMS拉入到HDFS

(2)有时候也需要把HDFS的数据推回到RDBMS,当需要对大数据集进行批处理,并导出结果到RDBMS供其它系统访问

(3)Sqoop使用export工具,RDBMS表在导出前必须已存在

关系型数据库导入导出绝招出炉

掌握了以上方式,对于关系型数据库的导入和导出基本有一个明确的认知和了解,其实我们在日常的学习和实践过程中要多去看看别人的分享,毕竟做技术每个人的经历与经验不一样,有时候说不准会有意向不到的收获。我自己平时喜欢关注“大数据cn”、“大数据时代学习中心”这些微信服务号,对于我个人而言,起到了很大的促进作用,也期待每一个学习大数据的人都能够有所收获!

另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


本文题目:关系型数据库导入导出绝招出炉-创新互联
文章网址:http://jkwzsj.com/article/hhgcs.html

其他资讯