sh cca175-problem-5-step-6-sqoop-import.sh

Posted 2021-05-07

// On Terminal window-

sqoop job \
  --create hive_sqoop_job \
  -- import \
  --connect "jdbc:mysql://quickstart.cloudera:3306/retail_db" \
  --username "retail_dba" \
  --password "cloudera" \
  --table products_replica  \
  --check-column product_id \
  --incremental append \
  --last-value 0 \
  --hive-import \
  --hive-table products_hive \
  --hive-database problem5;

// On Hive window:

create database problem5;

use problem5;
create table products_hive (
  product_id int, 
  product_category_id int, 
  product_name string, 
  product_description string, 
  product_price float, 
  product_imaage string,
  product_grade int,  
  product_sentiment string
);

// On Terminal window

sqoop job --exec hive_sqoop_job

// On MySQL window

insert into products_replica 
  values (1378,4,'something 1376','something 2',10.00,'not avaialble',null,'NOT APPLICABLE');
insert into products_replica 
  values (1379,4,'something 1376','something 2',10.00,'not avaialble',null,'NOT APPLICABLE');

// On Terminal Window

sqoop job --exec hive_sqoop_job

// On Hive Window

select * from products_hive;