sqoop导入hbase-sql数据库

lqfhib0f  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(451)

我想把我的数据从sql数据库迁移到hbase。我的问题之一是我的sql表没有主键,所以要克服这个问题。我在sqoop查询中使用复合键。我已成功地将数据从sql导入hbase,但主要问题是导入的数据不包含用于候选键的列,而这些候选键是导入数据所必需的。请对此给出一些解决方案。。!!我目前使用的sqoop查询的格式如下:

sqoop import --connect "jdbc:sqlserver://Ip:1433;database=dbname;username=test;password=test" --table TableName --hbase-create-table --hbase-table TableName --column-family NameSpace --hbase-row-key Candidate1,Candidate2,Candidate3 -m 1

另外,如果有人知道要为同一个表而不是单个表导入完整数据库的查询,请告诉我。

o3imoua4

o3imoua41#

经过大量研究,我发现了一个正确的语法,通过它,我可以正确加载所有数据,而不会丢失任何一列,如下所示:

sqoop import -D sqoop.hbase.add.row.key=true –connect “jdbc:sqlserver://IP:1433;database=DBNAME;username=UNAME;password=PWD” --table SQLTABLENAME –hbase-create-table –hbase-table HBASETABLENAME –column-family COLUMNFAMILYNAME –hbase-row-key PRIMARYKEY -m 1

sqoop import -D sqoop.hbase.add.row.key=true –connect “jdbc:sqlserver://IP:1433;database=DBNAME;username=UNAME;password=PWD” --table SQLTABLENAME –hbase-create-table –hbase-table HBASETABLENAME –column-family COLUMNFAMILYNAME –hbase-row-key CANDIDATEKEY1, CANDIDATEKEY2, CANDIDATEKEY3 -m 1

相关问题