关于使用java调用sqoop连接oracle的问题

[复制链接]
查看11 | 回复1 | 2021-1-27 05:40:48 | 显示全部楼层 |阅读模式
最近在学习使用sqoop的时候遇到一些问题,我使用的sqoop环境是sqoop-1.4.5-cdh5.4.0。这是我的代码,连接mysql的时候是正常的,但是连接oracle的时候status一直是error,不知道什么原因,请高手指点,谢谢!如果能够提供代码则感激不尽!
SqoopClientclient=newSqoopClient("http://192.168.3.223:12000/sqoop/");
//createaplaceholderforlink
longconnectorId=4;
MLinklink=client.createLink(connectorId);
link.setName("admin");
link.setCreationUser("hadoop");
MLinkConfiglinkConfig=link.getConnectorLinkConfig();
//fillinthelinkconfigvalues
linkConfig.getStringInput("linkConfig.connectionString").setValue("jdbc:oracle:thin:@192.168.3.130:1521:orcl");
linkConfig.getStringInput("linkConfig.jdbcDriver").setValue("oracle.jdbc.driver.OracleDriver");
linkConfig.getStringInput("linkConfig.username").setValue("root");
linkConfig.getStringInput("linkConfig.password").setValue("root");
//System.out.println("linkConfig.getConfigs()>>>"+linkConfig.getConfigs());
//savethelinkobjectthatwasfilled
Statusstatus=client.saveLink(link);
System.out.println("status>>>"+status);
if(status.canProceed()){
System.out.println("CreatedLinkwithLinkId:"+link.getPersistenceId());
}else{
System.out.println("Somethingwentwrongcreatingthelink");
}

控制台打印:
0[main]WARNorg.apache.hadoop.util.NativeCodeLoader-Unabletoloadnative-hadooplibraryforyourplatform...usingbuiltin-javaclasseswhereapplicable
status>>>ERROR
Somethingwentwrongcreatingthelink
分 -->
回复

使用道具 举报

千问 | 2021-1-27 05:40:48 | 显示全部楼层
忘记说了,oracle的驱动也已经放到hadoop和sqoop的lib目录下,项目里也添加了ojdbc14.jar
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

主题

0

回帖

4882万

积分

论坛元老

Rank: 8Rank: 8

积分
48824836
热门排行