Database Reference
In-Depth Information
Example 15-2. Populating the database
%
mysql hadoopguide
Welcome to the MySQL monitor. Commands end with ; or \g.
Your MySQL connection id is 257
Server version: 5.6.21 MySQL Community Server (GPL)
Type 'help;' or '\h' for help. Type '\c' to clear the current input
statement.
mysql>
CREATE TABLE widgets(id INT NOT NULL PRIMARY KEY AUTO_INCREMENT,
->
widget_name VARCHAR(64) NOT NULL,
->
price DECIMAL(10,2),
->
design_date DATE,
->
version INT,
->
design_comment VARCHAR(100));
Query OK, 0 rows affected (0.00 sec)
mysql>
INSERT INTO widgets VALUES (NULL, 'sprocket', 0.25, '2010-02-10',
->
1, 'Connects two gizmos');
Query OK, 1 row affected (0.00 sec)
mysql>
INSERT INTO widgets VALUES (NULL, 'gizmo', 4.00, '2009-11-30', 4,
->
NULL);
Query OK, 1 row affected (0.00 sec)
mysql>
INSERT INTO widgets VALUES (NULL, 'gadget', 99.99, '1983-08-13',
->
13, 'Our flagship product');
Query OK, 1 row affected (0.00 sec)
mysql>
quit;
In this listing, we created a new table called
widgets
. We'll be using this fictional
product database in further examples in this chapter. The
widgets
table contains several
fields representing a variety of data types.
Before going any further, you need to download the JDBC driver JAR file for MySQL
(Connector/J) and add it to Sqoop's classpath, which is simply achieved by placing it in
Sqoop's
lib
directory.
Now let's use Sqoop to import this table into HDFS:
%
sqoop import --connect jdbc:mysql://localhost/hadoopguide \
>
--table widgets -m 1
...
14/10/28 21:36:23 INFO tool.CodeGenTool: Beginning code generation
...