电脑桌面
添加小米粒文库到电脑桌面
安装后可以在桌面快捷访问

hadoop与mysql数据库相连读出数据

hadoop与mysql数据库相连读出数据_第1页
1/6
hadoop与mysql数据库相连读出数据_第2页
2/6
hadoop与mysql数据库相连读出数据_第3页
3/6
hadoop 与mysql 数据库相连读出数据 用0.20.2 版本 有些类已经过时 但必须要用 因为新版本对数据库连接支持不够 运行 mysql 创建数据库School,建立 teacher 表,并自行填写值 view plaincopy to clipboardprint? 1. DROP TABLE IF EXISTS `school`.`teacher`; 2. 3. CREATE TABLE `school`.`teacher` ( 4. 5. `id` int(11) default NULL, 6. 7. `name` char(20) default NULL, 8. 9. `age` int(11) default NULL, 10. 11. `departmentID` int(11) default NULL 12. 13. ) ENGINE=InnoDB DEFAULT CHARSET=latin1; 在 eclipse 中运行编译通过 但要加入必须的库 以及 hadoop0.20.2 的 eclipse 的插件 view plaincopy to clipboardprint? 1. import java.io.IOException; 2. 3. import org.apache.hadoop.fs.Path; 4. import org.apache.hadoop.io.LongWritable; 5. import org.apache.hadoop.io.Text; 6. import org.apache.hadoop.mapred.FileOutputFormat; 7. import org.apache.hadoop.mapred.JobClient; 8. import org.apache.hadoop.mapred.JobConf; 9. import org.apache.hadoop.mapred.lib.IdentityReducer; 10. import org.apache.hadoop.mapred.lib.db.DBConfiguration; 11. import org.apache.hadoop.mapred.lib.db.DBInputFormat; 12. 13. public class DBAccess2 { 14. 15. 16. 17. public static void main(String[] args) throws IOException { 18. 19. JobConf conf = new JobConf(DBAccess2.class); 20. 21. conf.setOutputKeyClass(LongWritable.class); 22. 23. conf.setOutputValueClass(Text.class); 24. 25. 26. 27. conf.setInputFormat(DBInputFormat.class); 28. 29. FileOutputFormat.setOutputPath(conf, new Path("hdfs://localhost:9000/dbout")); 30. 31. 32. 33. DBConfiguration.configureDB(conf,"com.mysql.jdbc.Driver", 34. 35. "jdbc:mysql://localhost:3306/school","root","zxcvbnm"); 36. 37. 38. 39. String [] fields = {"id", "name", "age", "departmentID"}; 40. 41. DBInputFormat.setInput(conf, TeacherRecord.class, "teacher", 42. 43. null, "id", fields); 44. 45. 46. 47. conf.setMapperClass(DBAccess...

1、当您付费下载文档后,您只拥有了使用权限,并不意味着购买了版权,文档只能用于自身使用,不得用于其他商业用途(如 [转卖]进行直接盈利或[编辑后售卖]进行间接盈利)。
2、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。
3、如文档内容存在违规,或者侵犯商业秘密、侵犯著作权等,请点击“违规举报”。

碎片内容

hadoop与mysql数据库相连读出数据

确认删除?
VIP
微信客服
  • 扫码咨询
会员Q群
  • 会员专属群点击这里加入QQ群
客服邮箱
回到顶部