{"id":1818,"date":"2020-07-01T05:54:49","date_gmt":"2020-06-30T21:54:49","guid":{"rendered":"http:\/\/39.97.231.10\/?p=1818"},"modified":"2020-07-01T05:54:49","modified_gmt":"2020-06-30T21:54:49","slug":"sqoop%e5%9f%ba%e6%9c%ac%e4%bd%bf%e7%94%a8","status":"publish","type":"post","link":"http:\/\/www.weijing.co\/?p=1818","title":{"rendered":"Sqoop\u57fa\u672c\u4f7f\u7528"},"content":{"rendered":"<div>\n<div>\n<div>\n<div>1.\u67e5\u770b\u547d\u4ee4\u5e2e\u52a9<\/div>\n<\/div>\n<\/div>\n<\/div>\n<article>\n<div>\n<pre>[hadoop@hadoop000 ~]$ sqoop help\nusage: sqoop COMMAND [ARGS]\nAvailable commands:\n  codegen            Generate code to interact with database records\n  create-hive-table  Import a table definition into Hive\n  eval               Evaluate a SQL statement and display the results\n  export             Export an HDFS directory to a database table\n  help               List available commands\n  import             Import a table from a database to HDFS\n  import-all-tables  Import tables from a database to HDFS\n  import-mainframe   Import datasets from a mainframe server to HDFS\n  job                Work with saved jobs\n  list-databases     List available databases on a server\n  list-tables        List available tables in a database\n  merge              Merge results of incremental imports\n  metastore          Run a standalone Sqoop metastore\n  version            Display version information\nSee \\'sqoop help COMMAND\\' for information on a specific command.\n# \u8fd9\u91cc\u63d0\u793a\u6211\u4eec\u4f7f\u7528sqoop help command\uff08\u8981\u67e5\u8be2\u7684\u547d\u4ee4\uff09\u8fdb\u884c\u8be5\u547d\u4ee4\u7684\u8be6\u7ec6\u67e5\u8be2\n<\/pre>\n<\/div>\n<h5>2.list-databases<\/h5>\n<div>\n<pre># \u67e5\u770blist-databases\u547d\u4ee4\u5e2e\u52a9\n[hadoop@hadoop000 ~]$ sqoop help list-databases\nusage: sqoop list-databases [GENERIC-ARGS] [TOOL-ARGS]\nCommon arguments:\n   --connect &lt;jdbc-uri&gt;                         Specify JDBC connect\n                                                string\n   --connection-manager &lt;class-name&gt;            Specify connection manager\n                                                class name\n   --connection-param-file &lt;properties-file&gt;    Specify connection\n                                                parameters file\n   --driver &lt;class-name&gt;                        Manually specify JDBC\n                                                driver class to use\n   --hadoop-home &lt;hdir&gt;                         Override\n                                                $HADOOP_MAPRED_HOME_ARG\n   --hadoop-mapred-home &lt;dir&gt;                   Override\n                                                $HADOOP_MAPRED_HOME_ARG\n   --help                                       Print usage instructions\n-P                                              Read password from console\n   --password &lt;password&gt;                        Set authentication\n                                                password\n   --password-alias &lt;password-alias&gt;            Credential provider\n                                                password alias\n   --password-file &lt;password-file&gt;              Set authentication\n                                                password file path\n   --relaxed-isolation                          Use read-uncommitted\n                                                isolation for imports\n   --skip-dist-cache                            Skip copying jars to\n                                                distributed cache\n   --username &lt;username&gt;                        Set authentication\n                                                username\n   --verbose                                    Print more information\n                                                while working\n# \u7b80\u5355\u4f7f\u7528\n[hadoop@oradb3 ~]$ sqoop list-databases \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306 \\\\\n&gt; --username root \\\\\n&gt; --password 123456\n# \u7ed3\u679c\ninformation_schema\nmysql\nperformance_schema\nslow_query_log\nsys\ntest\n<\/pre>\n<\/div>\n<h5>3.list-tables<\/h5>\n<div>\n<pre># \u547d\u4ee4\u5e2e\u52a9\n[hadoop@hadoop000 ~]$ sqoop help list-tables\nusage: sqoop list-tables [GENERIC-ARGS] [TOOL-ARGS]\nCommon arguments:\n   --connect &lt;jdbc-uri&gt;                         Specify JDBC connect\n                                                string\n   --connection-manager &lt;class-name&gt;            Specify connection manager\n                                                class name\n   --connection-param-file &lt;properties-file&gt;    Specify connection\n                                                parameters file\n   --driver &lt;class-name&gt;                        Manually specify JDBC\n                                                driver class to use\n   --hadoop-home &lt;hdir&gt;                         Override\n                                                $HADOOP_MAPRED_HOME_ARG\n   --hadoop-mapred-home &lt;dir&gt;                   Override\n                                                $HADOOP_MAPRED_HOME_ARG\n   --help                                       Print usage instructions\n-P                                              Read password from console\n   --password &lt;password&gt;                        Set authentication\n                                                password\n   --password-alias &lt;password-alias&gt;            Credential provider\n                                                password alias\n   --password-file &lt;password-file&gt;              Set authentication\n                                                password file path\n   --relaxed-isolation                          Use read-uncommitted\n                                                isolation for imports\n   --skip-dist-cache                            Skip copying jars to\n                                                distributed cache\n   --username &lt;username&gt;                        Set authentication\n                                                username\n   --verbose                                    Print more information\n                                                while working\n# \u4f7f\u7528\u65b9\u6cd5\n[hadoop@hadoop000 ~]$ sqoop list-tables \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root \\\\\n&gt; --password 123456\n# \u7ed3\u679c\nt_order\ntest0001\ntest_1013\ntest_dyc\ntest_tb\n<\/pre>\n<\/div>\n<h5>4.\u5c06mysql\u5bfc\u5165HDFS\u4e2d(import)<\/h5>\n<p>(\u9ed8\u8ba4\u5bfc\u5165\u5f53\u524d\u7528\u6237\u76ee\u5f55\u4e0b\/user\/\u7528\u6237\u540d\/\u8868\u540d)<br \/>\n\u8bf4\u5230\u8fd9\u91cc\u6269\u5c55\u4e00\u4e2a\u5c0f\u77e5\u8bc6\u70b9\uff1a<\/p>\n<ul>\n<li>hadoop fs -ls \u663e\u793a\u7684\u662f\u5f53\u524d\u7684\u7528\u6237\u76ee\u5f55 \u5373\/user\/hadoop<br \/>\nhadoop fs -ls \/ \u663e\u793a\u7684\u662fHDFS\u6839\u76ee\u5f55<\/li>\n<\/ul>\n<div>\n<pre># \u67e5\u770b\u547d\u4ee4\u5e2e\u52a9\n[hadoop@hadoop000 ~]$ sqoop help import\n# \u6267\u884cimport\n[hadoop@hadoop000 ~]$ sqoop import \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root \\\\\n&gt; --password 123456 \\\\\n&gt; --table students\n<\/pre>\n<\/div>\n<p>\u8fd9\u65f6\u5f88\u53ef\u80fd\u4f1a\u51fa\u73b0\u8fd9\u4e2a\u9519\u8bef<br \/>\nException in thread \\&#8221;main\\&#8221; java.lang.NoClassDefFoundError: org\/json\/JSONObject<br \/>\n\u8fd9\u91cc\u6211\u4eec\u9700\u8981\u5bfc\u5165java-json.jar\u5305\u00a0<a href=\\\"http:\/\/www.java2s.com\/Code\/Jar\/j\/Downloadjavajsonjar.htm\\\" target=\\\"_blank\\\" rel=\\\"nofollow noopener noreferrer\\\">\u4e0b\u8f7d\u5730\u5740<\/a> \u628ajava-json.jar\u6dfb\u52a0\u5230..\/sqoop\/lib\u76ee\u5f55\u4e0b\u5373\u53ef<\/p>\n<div>\n<pre># \u518d\u6b21\u6267\u884c import\u5bfc\u5165\n[hadoop@hadoop000 ~]$ sqoop import \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root \\\\\n&gt; --password 123456 \\\\\n&gt; --table students\n18\/07\/04 13:28:35 INFO sqoop.Sqoop: Running Sqoop version: 1.4.6-cdh5.7.0\n18\/07\/04 13:28:35 WARN tool.BaseSqoopTool: Setting your password on the command-line is insecure. Consider using -P instead.\n18\/07\/04 13:28:35 INFO manager.MySQLManager: Preparing to use a MySQL streaming resultset.\n18\/07\/04 13:28:35 INFO tool.CodeGenTool: Beginning code generation\n18\/07\/04 13:28:35 INFO manager.SqlManager: Executing SQL statement: SELECT t.* FROM `students` AS t LIMIT 1\n18\/07\/04 13:28:35 INFO manager.SqlManager: Executing SQL statement: SELECT t.* FROM `students` AS t LIMIT 1\n18\/07\/04 13:28:35 INFO orm.CompilationManager: HADOOP_MAPRED_HOME is \/home\/hadoop\/app\/hadoop-2.6.0-cdh5.7.0\n18\/07\/04 13:28:37 INFO orm.CompilationManager: Writing jar file: \/tmp\/sqoop-hadoop\/compile\/3024b8df04f623e8c79ed9b5b30ace75\/students.jar\n18\/07\/04 13:28:37 WARN manager.MySQLManager: It looks like you are importing from mysql.\n18\/07\/04 13:28:37 WARN manager.MySQLManager: This transfer can be faster! Use the --direct\n18\/07\/04 13:28:37 WARN manager.MySQLManager: option to exercise a MySQL-specific fast path.\n18\/07\/04 13:28:37 INFO manager.MySQLManager: Setting zero DATETIME behavior to convertToNull (mysql)\n18\/07\/04 13:28:37 INFO mapreduce.ImportJobBase: Beginning import of students\n18\/07\/04 13:28:38 INFO Configuration.deprecation: mapred.jar is deprecated. Instead, use mapreduce.job.jar\n18\/07\/04 13:28:39 INFO Configuration.deprecation: mapred.map.tasks is deprecated. Instead, use mapreduce.job.maps\n18\/07\/04 13:28:39 INFO client.RMProxy: Connecting to ResourceManager at \/0.0.0.0:8032\n18\/07\/04 13:28:41 INFO db.DBInputFormat: Using read commited transaction isolation\n18\/07\/04 13:28:41 INFO db.DataDrivenDBInputFormat: BoundingValsQuery: SELECT MIN(`id`), MAX(`id`) FROM `students`\n18\/07\/04 13:28:41 INFO db.IntegerSplitter: Split size: 0; Num splits: 4 from: 1001 to: 1003\n18\/07\/04 13:28:41 INFO mapreduce.JobSubmitter: number of splits:3\n18\/07\/04 13:28:42 INFO mapreduce.JobSubmitter: Submitting tokens for job: job_1530598609758_0015\n18\/07\/04 13:28:42 INFO impl.YarnClientImpl: Submitted application application_1530598609758_0015\n18\/07\/04 13:28:42 INFO mapreduce.Job: The url to track the job: http:\/\/oradb3:8088\/proxy\/application_1530598609758_0015\/\n18\/07\/04 13:28:42 INFO mapreduce.Job: Running job: job_1530598609758_0015\n18\/07\/04 13:28:52 INFO mapreduce.Job: Job job_1530598609758_0015 running in uber mode : false\n18\/07\/04 13:28:52 INFO mapreduce.Job:  map 0% reduce 0%\n18\/07\/04 13:28:58 INFO mapreduce.Job:  map 33% reduce 0%\n18\/07\/04 13:28:59 INFO mapreduce.Job:  map 67% reduce 0%\n18\/07\/04 13:29:00 INFO mapreduce.Job:  map 100% reduce 0%\n18\/07\/04 13:29:00 INFO mapreduce.Job: Job job_1530598609758_0015 completed successfully\n18\/07\/04 13:29:00 INFO mapreduce.Job: Counters: 30\n...\n18\/07\/04 13:29:00 INFO mapreduce.ImportJobBase: Transferred 40 bytes in 21.3156 seconds (1.8766 bytes\/sec)\n18\/07\/04 13:29:00 INFO mapreduce.ImportJobBase: Retrieved 3 records.\n# \u751f\u6210\u7684\u65e5\u5fd7\u4fe1\u606f\u5927\u5bb6\u4e00\u5b9a\u8981\u597d\u597d\u7406\u89e3\n# \u67e5\u770bHDFS\u4e0a\u7684\u6587\u4ef6\n[hadoop@hadoop000 ~]$ hadoop fs -ls \/user\/hadoop\/students\nFound 4 items\n-rw-r--r--   1 hadoop supergroup          0 2018-07-04 13:28 \/user\/hadoop\/students\/_SUCCESS\n-rw-r--r--   1 hadoop supergroup         13 2018-07-04 13:28 \/user\/hadoop\/students\/part-m-00000\n-rw-r--r--   1 hadoop supergroup         13 2018-07-04 13:28 \/user\/hadoop\/students\/part-m-00001\n-rw-r--r--   1 hadoop supergroup         14 2018-07-04 13:28 \/user\/hadoop\/students\/part-m-00002\n[hadoop@hadoop000 ~]$ hadoop fs -cat \/user\/hadoop\/students\/\\\"part*\\\"\n1001,lodd,23\n1002,sdfs,21\n1003,sdfsa,24\n<\/pre>\n<\/div>\n<p>\u6211\u4eec\u8fd8\u53ef\u4ee5\u52a0\u4e00\u4e9b\u5176\u4ed6\u53c2\u6570 \u4f7f\u5bfc\u5165\u8fc7\u7a0b\u66f4\u52a0\u53ef\u63a7<\/p>\n<blockquote><p>-m\u00a0\u6307\u5b9a\u542f\u52a8map\u8fdb\u7a0b\u4e2a\u6570\uff0c\u9ed8\u8ba4\u662f4\u4e2a<br \/>\n&#8211;delete-target-dir\u00a0\u5220\u9664\u76ee\u6807\u76ee\u5f55<br \/>\n&#8211;mapreduce-job-name\u00a0\u6307\u5b9amapreduce\u7684job\u7684\u540d\u5b57<br \/>\n&#8211;target-dir\u00a0\u5bfc\u5165\u5230\u6307\u5b9a\u76ee\u5f55<br \/>\n&#8211;fields-terminated-by\u00a0\u6307\u5b9a\u5b57\u6bb5\u4e4b\u95f4\u7684\u5206\u9694\u7b26<br \/>\n&#8211;null-string\u00a0\u542b\u4e49\u662f string\u7c7b\u578b\u7684\u5b57\u6bb5\uff0c\u5f53Value\u662fNULL\uff0c\u66ff\u6362\u6210\u6307\u5b9a\u7684\u5b57\u7b26<br \/>\n&#8211;null-non-string\u00a0\u542b\u4e49\u662f\u975estring\u7c7b\u578b\u7684\u5b57\u6bb5\uff0c\u5f53Value\u662fNULL\uff0c\u66ff\u6362\u6210\u6307\u5b9a\u5b57\u7b26<br \/>\n&#8211;columns\u00a0\u5bfc\u5165\u8868\u4e2d\u7684\u90e8\u5206\u5b57\u6bb5<br \/>\n&#8211;where\u00a0\u6309\u6761\u4ef6\u5bfc\u5165\u6570\u636e<br \/>\n&#8211;query\u00a0\u6309\u7167sql\u8bed\u53e5\u8fdb\u884c\u5bfc\u5165 \u4f7f\u7528&#8211;query\u5173\u952e\u5b57\uff0c\u5c31\u4e0d\u80fd\u4f7f\u7528&#8211;table\u548c&#8211;columns<br \/>\n&#8211;options-file \u5728\u6587\u4ef6\u4e2d\u6267\u884c<\/p><\/blockquote>\n<div>\n<pre># \u6267\u884c\u5bfc\u5165\n[hadoop@hadoop000 ~]$ sqoop import \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root --password 123456 \\\\\n&gt; --mapreduce-job-name FromMySQL2HDFS \\\\\n&gt; --delete-target-dir \\\\\n&gt; --table students \\\\\n&gt; -m 1\n# HDFS\u4e2d\u67e5\u770b\n[hadoop@hadoop000 ~]$ hadoop fs -ls \/user\/hadoop\/students\nFound 2 items\n-rw-r--r--   1 hadoop supergroup          0 2018-07-04 13:53 \/user\/hadoop\/students\/_SUCCESS\n-rw-r--r--   1 hadoop supergroup         40 2018-07-04 13:53 \/user\/hadoop\/students\/part-m-00000\n[hadoop@oradb3 ~]$ hadoop fs -cat \/user\/hadoop\/students\/\\\"part*\\\"\n1001,lodd,23\n1002,sdfs,21\n1003,sdfsa,24<\/pre>\n<\/div>\n<div>\n<pre># \u4f7f\u7528where \u53c2\u6570\n[hadoop@hadoop000 ~]$ sqoop import \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root --password 123456 \\\\\n&gt; --table students \\\\\n&gt; --mapreduce-job-name FromMySQL2HDFS2 \\\\\n&gt; --delete-target-dir \\\\\n&gt; --fields-terminated-by \\'\\\\t\\' \\\\\n&gt; -m 1 \\\\\n&gt; --null-string 0 \\\\\n&gt; --columns \\\"name\\\" \\\\\n&gt; --target-dir STU_COLUMN_WHERE \\\\\n&gt; --where \\'id&lt;1002\\'\n# HDFS \u7ed3\u679c\n[hadoop@hadoop000 ~]$ hadoop fs -cat STU_COLUMN_WHERE\/\\\"part*\\\"\nlodd<\/pre>\n<\/div>\n<div>\n<pre># \u4f7f\u7528query \u53c2\u6570\n[hadoop@hadoop000 ~]$ sqoop import \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root --password 123456 \\\\\n&gt; --mapreduce-job-name FromMySQL2HDFS3 \\\\\n&gt; --delete-target-dir \\\\\n&gt; --fields-terminated-by \\'\\\\t\\' \\\\\n&gt; -m 1 \\\\\n&gt; --null-string 0 \\\\\n&gt; --target-dir STU_COLUMN_QUERY \\\\\n&gt; --query \\\"select * from students where id&gt;1001 and \\\\$CONDITIONS\\\"\n# HDFS\u67e5\u770b\n[hadoop@hadoop000 ~]$ hadoop fs -cat STU_COLUMN_QUERY\/\\\"part*\\\"\n1002    sdfs    21\n1003    sdfsa   24<\/pre>\n<\/div>\n<div>\n<pre># \u4f7f\u7528options-file\u53c2\u6570\n[hadoop@hadoop000 ~]$ vi sqoop-import-hdfs.txt\nimport\n--connect\njdbc:mysql:\/\/localhost:3306\/test\n--username\nroot\n--password\n123456\n--table\nstudents\n--target-dir\nSTU_option_file\n# \u6267\u884c\u5bfc\u5165\n[hadoop@hadoop000 ~]$ sqoop --options-file \/home\/hadoop\/sqoop-import-hdfs.txt\n# HDFS\u67e5\u770b\n[hadoop@hadoop000 ~]$ hadoop fs -cat STU_option_file\/\\\"part*\\\"\n1001,lodd,23\n1002,sdfs,21\n1003,sdfsa,24\n<\/pre>\n<\/div>\n<h5>5.eval<\/h5>\n<p>\u67e5\u770b\u5e2e\u52a9\u547d\u4ee4\u5bf9\u4e0e\u8be5\u547d\u4ee4\u7684\u89e3\u91ca\u4e3a\uff1a Evaluate a SQL statement and display the results\uff0c\u4e5f\u5c31\u662f\u8bf4\u6267\u884c\u4e00\u4e2aSQL\u8bed\u53e5\u5e76\u67e5\u8be2\u51fa\u7ed3\u679c\u3002<\/p>\n<div>\n<pre># \u67e5\u770b\u547d\u4ee4\u5e2e\u52a9\n[hadoop@hadoop000 ~]$ sqoop help eval\nusage: sqoop eval [GENERIC-ARGS] [TOOL-ARGS]\nCommon arguments:\n   --connect &lt;jdbc-uri&gt;                         Specify JDBC connect\n                                                string\n   --connection-manager &lt;class-name&gt;            Specify connection manager\n                                                class name\n   --connection-param-file &lt;properties-file&gt;    Specify connection\n                                                parameters file\n   --driver &lt;class-name&gt;                        Manually specify JDBC\n                                                driver class to use\n   --hadoop-home &lt;hdir&gt;                         Override\n                                                $HADOOP_MAPRED_HOME_ARG\n   --hadoop-mapred-home &lt;dir&gt;                   Override\n                                                $HADOOP_MAPRED_HOME_ARG\n   --help                                       Print usage instructions\n-P                                              Read password from console\n   --password &lt;password&gt;                        Set authentication\n                                                password\n   --password-alias &lt;password-alias&gt;            Credential provider\n                                                password alias\n   --password-file &lt;password-file&gt;              Set authentication\n                                                password file path\n   --relaxed-isolation                          Use read-uncommitted\n                                                isolation for imports\n   --skip-dist-cache                            Skip copying jars to\n                                                distributed cache\n   --username &lt;username&gt;                        Set authentication\n                                                username\n   --verbose                                    Print more information\n                                                while working\nSQL evaluation arguments:\n-e,--query &lt;statement&gt;    Execute \\'statement\\' in SQL and exit\n# \u6267\u884c\n[hadoop@hadoop000 ~]$ sqoop eval \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root --password 123456 \\\\\n&gt; --query \\\"select * from students\\\"\n18\/07\/04 14:28:44 INFO sqoop.Sqoop: Running Sqoop version: 1.4.6-cdh5.7.0\n18\/07\/04 14:28:44 WARN tool.BaseSqoopTool: Setting your password on the command-line is insecure. Consider using -P instead.\n18\/07\/04 14:28:44 INFO manager.MySQLManager: Preparing to use a MySQL streaming resultset.\n----------------------------------------------------\n| id          | name                 | age         |\n----------------------------------------------------\n| 1001        | lodd                 | 23          |\n| 1002        | sdfs                 | 21          |\n| 1003        | sdfsa                | 24          |\n----------------------------------------------------\n<\/pre>\n<\/div>\n<h5>6.export (HDFS\u6570\u636e\u5bfc\u51fa\u5230MySQL\u6216Hive\u4e2d\u7684\u6570\u636e\u5bfc\u5165\u5230MySQL)<\/h5>\n<p>\u5e38\u7528\u53c2\u6570\uff1a<\/p>\n<blockquote><p>&#8211;table\u00a0\u6307\u5b9a\u5bfc\u51fa\u8868\u7684\u540d\u79f0<br \/>\n&#8211;input-fields-terminated-by\u00a0\u6307\u5b9ahdfs\u4e0a\u6587\u4ef6\u7684\u5206\u9694\u7b26\uff0c\u9ed8\u8ba4\u662f\u9017\u53f7<br \/>\n&#8211;export-dir\u00a0\u5bfc\u51fa\u6570\u636e\u7684\u76ee\u5f55<br \/>\n&#8211;columns\u00a0\u6307\u5b9a\u5bfc\u51fa\u7684\u5b57\u6bb5<\/p><\/blockquote>\n<p>\u5728\u6267\u884c\u5bfc\u51fa\u8bed\u53e5\u524dmysql\u8981\u5148\u521b\u5efa\u8868\uff08\u4e0d\u521b\u5efa\u8868\u4f1a\u62a5\u9519\uff09\uff1a<\/p>\n<div>\n<pre># HDFS\u539f\u6587\u4ef6\n[hadoop@hadoop000 ~]$ hadoop fs -cat \/user\/hadoop\/students\/part-m-00000\n1001,lodd,23\n1002,sdfs,21\n1003,sdfsa,24\n# export\u5bfc\u51fa\u5230mysql\n[hadoop@hadoop000 ~]$ sqoop export \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root \\\\\n&gt; --password 123456 \\\\\n&gt; --table students_demo \\\\\n&gt; --export-dir \/user\/hadoop\/students\/\n18\/07\/04 14:46:20 INFO sqoop.Sqoop: Running Sqoop version: 1.4.6-cdh5.7.0\n18\/07\/04 14:46:20 WARN tool.BaseSqoopTool: Setting your password on the command-line is insecure. Consider using -P instead.\n18\/07\/04 14:46:20 INFO manager.MySQLManager: Preparing to use a MySQL streaming resultset.\n18\/07\/04 14:46:20 INFO tool.CodeGenTool: Beginning code generation\n18\/07\/04 14:46:21 INFO manager.SqlManager: Executing SQL statement: SELECT t.* FROM `students_demo` AS t LIMIT 1\n18\/07\/04 14:46:21 INFO manager.SqlManager: Executing SQL statement: SELECT t.* FROM `students_demo` AS t LIMIT 1\n18\/07\/04 14:46:21 INFO orm.CompilationManager: HADOOP_MAPRED_HOME is \/home\/hadoop\/app\/hadoop-2.6.0-cdh5.7.0\n18\/07\/04 14:46:24 INFO orm.CompilationManager: Writing jar file: \/tmp\/sqoop-hadoop\/compile\/fc7b53dd6eef701c0731c7a7c4a4b340\/students_demo.jar\n18\/07\/04 14:46:24 INFO mapreduce.ExportJobBase: Beginning export of students_demo\n18\/07\/04 14:46:25 INFO Configuration.deprecation: mapred.jar is deprecated. Instead, use mapreduce.job.jar\n18\/07\/04 14:46:25 INFO Configuration.deprecation: mapred.map.max.attempts is deprecated. Instead, use mapreduce.map.maxattempts\n18\/07\/04 14:46:26 INFO Configuration.deprecation: mapred.reduce.tasks.speculative.execution is deprecated. Instead, use mapreduce.reduce.speculative\n18\/07\/04 14:46:26 INFO Configuration.deprecation: mapred.map.tasks.speculative.execution is deprecated. Instead, use mapreduce.map.speculative\n18\/07\/04 14:46:26 INFO Configuration.deprecation: mapred.map.tasks is deprecated. Instead, use mapreduce.job.maps\n...\n18\/07\/04 14:46:55 INFO mapreduce.ExportJobBase: Transferred 672 bytes in 29.3122 seconds (22.9256 bytes\/sec)\n18\/07\/04 14:46:55 INFO mapreduce.ExportJobBase: Exported 3 records.\n# mysql\u4e2d\u67e5\u770b\nmysql&gt; select * from students_demo;\n+------+-------+------+\n| id   | name  | age  |\n+------+-------+------+\n| 1001 | lodd  |   23 |\n| 1002 | sdfs  |   21 |\n| 1003 | sdfsa |   24 |\n+------+-------+------+\n3 rows in set (0.00 sec)\n<\/pre>\n<\/div>\n<p>\u5982\u679c\u518d\u5bfc\u5165\u4e00\u6b21\u4f1a\u8ffd\u52a0\u5728\u8868\u4e2d<\/p>\n<div>\n<pre># \u589e\u52a0columns\u53c2\u6570\n[hadoop@hadoop000 ~]$ sqoop export \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root \\\\\n&gt; --password 123456 \\\\\n&gt; --table students_demo2 \\\\\n&gt; --export-dir \/user\/hadoop\/students\/ \\\\\n&gt; --columns id,name\n# mysql\u7ed3\u679c\nmysql&gt; select * from students_demo2;\n+------+-------+------+\n| id   | name  | age  |\n+------+-------+------+\n| 1001 | lodd  | NULL |\n| 1002 | sdfs  | NULL |\n| 1003 | sdfsa | NULL |\n+------+-------+------+\n3 rows in set (0.00 sec)\n<\/pre>\n<\/div>\n<h5>7.MySQL\u7684\u4e2d\u7684\u6570\u636e\u5bfc\u5165\u5230Hive\u4e2d<\/h5>\n<p>\u5e38\u7528\u53c2\u6570\uff1a<\/p>\n<blockquote><p>&#8211;create-hive-table\u00a0\u521b\u5efa\u76ee\u6807\u8868\uff0c\u5982\u679c\u6709\u4f1a\u62a5\u9519<br \/>\n&#8211;hive-database\u00a0\u6307\u5b9ahive\u6570\u636e\u5e93<br \/>\n&#8211;hive-import\u00a0\u6307\u5b9a\u5bfc\u5165hive\uff08\u6ca1\u6709\u8fd9\u4e2a\u6761\u4ef6\u5bfc\u5165\u5230hdfs\u4e2d\uff09<br \/>\n&#8211;hive-overwrite\u00a0\u8986\u76d6<br \/>\n&#8211;hive-table\u00a0\u6307\u5b9ahive\u4e2d\u8868\u7684\u540d\u5b57\uff0c\u5982\u679c\u4e0d\u6307\u5b9a\u4f7f\u7528\u5bfc\u5165\u7684\u8868\u7684\u8868\u540d<br \/>\n&#8211;hive-partition-key\u00a0\u6307\u5b9aHive\u5206\u533a\u8868\u5b57\u6bb5<br \/>\n&#8211;hive-partition-value\u00a0\u6307\u5b9a\u5bfc\u5165\u7684\u5206\u533a\u503c<\/p><\/blockquote>\n<p>\u9996\u6b21\u5bfc\u5165\u53ef\u80fd\u4f1a\u62a5\u9519\u5982\u4e0b\uff1a<br \/>\n18\/07\/04 15:06:26 ERROR hive.HiveConfig: Could not load org.apache.hadoop.hive.conf.HiveConf. Make sure HIVE_CONF_DIR is set correctly. 18\/07\/04 15:06:26 ERROR tool.ImportTool: Encountered IOException running import job: java.io.IOException: java.lang.ClassNotFoundException: org.apache.hadoop.hive.conf.HiveConf<br \/>\n\u89e3\u51b3\u65b9\u6cd5\uff1a\u5230hive\u76ee\u5f55\u7684lib\u4e0b\u62f7\u8d1d\u51e0\u4e2ajar\u5305\uff0c\u95ee\u9898\u5c31\u89e3\u51b3\u4e86<\/p>\n<div>\n<pre># \u62a5\u9519\u89e3\u51b3\u65b9\u6cd5\n[hadoop@hadoop000 lib]$ pwd\n\/home\/hadoop\/app\/hive-1.1.0-cdh5.7.0\/lib\n[hadoop@hadoop000 lib]$ cp hive-common-1.1.0-cdh5.7.0.jar \/home\/hadoop\/app\/sqoop-1.4.6-cdh5.7.0\/lib\/\n[hadoop@hadoop000 lib]$ cp hive-shims* \/home\/hadoop\/app\/sqoop-1.4.6-cdh5.7.0\/lib\/<\/pre>\n<\/div>\n<div>\n<pre># \u62a5\u9519\u89e3\u51b3\u540e\u6267\u884c\u5bfc\u5165\n[hadoop@hadoop000 ~]$ sqoop import \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root --password 123456 \\\\\n&gt; --table students \\\\\n&gt; --create-hive-table \\\\\n&gt; --hive-database hive \\\\\n&gt; --hive-import \\\\\n&gt; --hive-overwrite \\\\\n&gt; --hive-table stu_import \\\\\n&gt; --mapreduce-job-name FromMySQL2HIVE \\\\\n&gt; --delete-target-dir \\\\\n&gt; --fields-terminated-by \\'\\\\t\\' \\\\\n&gt; -m 1 \\\\\n&gt; --null-non-string 0\n# Hive\u4e2d\u67e5\u770b\nhive&gt; show tables;\nOK\nstu_import\nTime taken: 0.051 seconds, Fetched: 1 row(s)\nhive&gt; select * from stu_import;\nOK\n1001    lodd    23\n1002    sdfs    21\n1003    sdfsa   24\nTime taken: 0.969 seconds, Fetched: 3 row(s)\n<\/pre>\n<\/div>\n<p>\u5efa\u8bae\uff1a\u5bfc\u5165Hive\u4e0d\u5efa\u8bae\u5927\u5bb6\u4f7f\u7528\u2013create-hive-table\u53c2\u6570,\u5efa\u8bae\u4e8b\u5148\u521b\u5efa\u597dhive\u8868\uff1b\u56e0\u4e3a\u81ea\u52a8\u521b\u5efa\u7684\u8868\u5b57\u6bb5\u7c7b\u578b\u53ef\u80fd\u5e76\u4e0d\u662f\u6211\u4eec\u60f3\u8981\u7684\u3002<\/p>\n<div>\n<pre># \u589e\u52a0partition\u53c2\u6570\n[hadoop@hadoop000 ~]$ sqoop import \\\\\n&gt; --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root --password 123456 \\\\\n&gt; --table students \\\\\n&gt; --create-hive-table \\\\\n&gt; --hive-database hive \\\\\n&gt; --hive-import \\\\\n&gt; --hive-overwrite \\\\\n&gt; --hive-table stu_import2 \\\\\n&gt; --mapreduce-job-name FromMySQL2HIVE2 \\\\\n&gt; --delete-target-dir \\\\\n&gt; --fields-terminated-by \\'\\\\t\\' \\\\\n&gt; -m 1 \\\\\n&gt; --null-non-string 0 \\\\\n&gt; --hive-partition-key dt \\\\\n&gt; --hive-partition-value \\\"2018-08-08\\\"\n# Hive\u4e2d\u67e5\u770b\nhive&gt; select * from stu_import2;\nOK\n1001    lodd    23      2018-08-08\n1002    sdfs    21      2018-08-08\n1003    sdfsa   24      2018-08-08\nTime taken: 0.192 seconds, Fetched: 3 row(s)\n<\/pre>\n<\/div>\n<h5>8.sqoop job\u7684\u4f7f\u7528<\/h5>\n<p>sqoop job\u53ef\u4ee5\u5c06\u6267\u884c\u7684\u8bed\u53e5\u53d8\u6210\u4e00\u4e2ajob\uff0c\u5e76\u4e0d\u662f\u5728\u521b\u5efa\u8bed\u53e5\u7684\u65f6\u5019\u6267\u884c\uff0c\u4f60\u53ef\u4ee5\u67e5\u770b\u8be5job\uff0c\u53ef\u4ee5\u4efb\u4f55\u65f6\u5019\u6267\u884c\u8be5job\uff0c\u4e5f\u53ef\u4ee5\u5220\u9664job\uff0c\u8fd9\u6837\u5c31\u65b9\u4fbf\u6211\u4eec\u8fdb\u884c\u4efb\u52a1\u7684\u8c03\u5ea6\u3002<\/p>\n<blockquote><p>&#8211;create\u00a0&lt;job-id&gt; \u521b\u5efa\u4e00\u4e2a\u65b0\u7684job.<br \/>\n&#8211;delete\u00a0&lt;job-id&gt; \u5220\u9664job<br \/>\n&#8211;exec\u00a0&lt;job-id&gt; \u6267\u884cjob<br \/>\n&#8211;show\u00a0&lt;job-id&gt; \u663e\u793ajob\u7684\u53c2\u6570<br \/>\n&#8211;list \u5217\u51fa\u6240\u6709\u7684job<\/p><\/blockquote>\n<div>\n<pre># \u521b\u5efajob\n[hadoop@hadoop000 ~]$ sqoop job --create person_job1 -- import --connect jdbc:mysql:\/\/localhost:3306\/test \\\\\n&gt; --username root \\\\\n&gt; --password 123456 \\\\\n&gt; --table students_demo \\\\\n&gt; -m 1 \\\\\n&gt; --delete-target-dir\n# \u67e5\u770bjob\n[hadoop@hadoop000 ~]$ sqoop job --list\nAvailable jobs:\n  person_job1\n# \u6267\u884cjob \u4f1a\u63d0\u793a\u8f93\u5165mysql root\u7528\u6237\u5bc6\u7801\n[hadoop@hadoop000 ~]$ sqoop job --exec person_job1\n# HDFS\u67e5\u770b\n[hadoop@hadoop000 lib]$ hadoop fs -ls \/user\/hadoop\/students_demo\nFound 2 items\n-rw-r--r--   1 hadoop supergroup          0 2018-07-04 15:34 \/user\/hadoop\/students_demo\/_SUCCESS\n-rw-r--r--   1 hadoop supergroup         40 2018-07-04 15:34 \/user\/hadoop\/students_demo\/part-m-00000\n<\/pre>\n<\/div>\n<p>\u6211\u4eec\u53d1\u73b0\u6267\u884cperson_job\u7684\u65f6\u5019\uff0c\u9700\u8981\u8f93\u5165\u6570\u636e\u5e93\u7684\u5bc6\u7801\uff0c\u600e\u4e48\u6837\u80fd\u4e0d\u8f93\u5165\u5bc6\u7801\u5462<br \/>\n\u914d\u7f6esqoop-site.xml\u5373\u53ef\u89e3\u51b3<\/p>\n<div>\n<pre># \u5c06sqoop.metastore.client.record.password\u53c2\u6570\u7684\u6ce8\u91ca\u53bb\u6389 \u6216\u8005\u518d\u6dfb\u52a0\u4e00\u4e0b\n[hadoop@hadoop000 conf]$ pwd\n\/home\/hadoop\/app\/sqoop-1.4.6-cdh5.7.0\/conf\n[hadoop@hadoop000 conf]$ vi sqoop-site.xml\n  &lt;property&gt;\n    &lt;name&gt;sqoop.metastore.client.record.password&lt;\/name&gt;\n    &lt;value&gt;true&lt;\/value&gt;\n    &lt;description&gt;If true, allow saved passwords in the metastore.\n    &lt;\/description&gt;\n  &lt;\/property&gt;<\/pre>\n<\/div>\n<\/article>\n","protected":false},"excerpt":{"rendered":"<p>1.\u67e5\u770b\u547d\u4ee4\u5e2e\u52a9 [hadoop@hadoop000 ~]$ sqoop help usage: sqoop  &hellip;<\/p>\n<p class=\"read-more\"> <a class=\"\" href=\"http:\/\/www.weijing.co\/?p=1818\"> <span class=\"screen-reader-text\">Sqoop\u57fa\u672c\u4f7f\u7528<\/span> \u67e5\u770b\u5168\u6587 &raquo;<\/a><\/p>\n","protected":false},"author":4,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"site-sidebar-layout":"default","site-content-layout":"default","ast-main-header-display":"","ast-hfb-above-header-display":"","ast-hfb-below-header-display":"","ast-hfb-mobile-header-display":"","site-post-title":"","ast-breadcrumbs-content":"","ast-featured-img":"","footer-sml-layout":"","theme-transparent-header-meta":"default","adv-header-id-meta":"","stick-header-meta":"","header-above-stick-meta":"","header-main-stick-meta":"","header-below-stick-meta":""},"categories":[136,118],"tags":[],"uagb_featured_image_src":{"full":false,"thumbnail":false,"medium":false,"medium_large":false,"large":false,"1536x1536":false,"2048x2048":false,"mailpoet_newsletter_max":false,"woocommerce_thumbnail":false,"woocommerce_single":false,"woocommerce_gallery_thumbnail":false,"shop_catalog":false,"shop_single":false,"shop_thumbnail":false},"uagb_author_info":{"display_name":"weijing","author_link":"http:\/\/www.weijing.co\/?author=4"},"uagb_comment_info":3,"uagb_excerpt":"1.\u67e5\u770b\u547d\u4ee4\u5e2e\u52a9 [hadoop@hadoop000 ~]$ sqoop help usage: sqoop &hellip;","_links":{"self":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/posts\/1818"}],"collection":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/users\/4"}],"replies":[{"embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=1818"}],"version-history":[{"count":0,"href":"http:\/\/www.weijing.co\/index.php?rest_route=\/wp\/v2\/posts\/1818\/revisions"}],"wp:attachment":[{"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=1818"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=1818"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.weijing.co\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=1818"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}