LS0gKDEpIENyZWF0ZSBhIERhdGFiYXNlCkNSRUFURSBEQVRBQkFTRSBzYWxlc19kYjsKVVNFIHNhbGVzX2RiOwoKLS0gKDIpIENyZWF0ZSBhIFRhYmxlCkNSRUFURSBUQUJMRSBzYWxlcyAoCiAgICBpZCBJTlQsCiAgICBwcm9kdWN0IFNUUklORywKICAgIHByaWNlIEZMT0FULAogICAgcXVhbnRpdHkgSU5UCikKUk9XIEZPUk1BVCBERUxJTUlURUQKRklFTERTIFRFUk1JTkFURUQgQlkgJywnClNUT1JFRCBBUyBURVhURklMRTsKCi0tICgzKSBMb2FkIERhdGEgZnJvbSBMb2NhbCBGaWxlIChFeGFtcGxlKQpMT0FEIERBVEEgTE9DQUwgSU5QQVRIICcvaG9tZS9oYWRvb3Avc2FsZXNkYXRhLnR4dCcgSU5UTyBUQUJMRSBzYWxlczsKCi0tICg0KSBJbnNlcnQgRGF0YSBNYW51YWxseQpJTlNFUlQgSU5UTyBUQUJMRSBzYWxlcyBWQUxVRVMgCigxLCAnTGFwdG9wJywgNTUwMDAuMCwgMiksCigyLCAnTW91c2UnLCA1MDAuMCwgNSksCigzLCAnS2V5Ym9hcmQnLCA4MDAuMCwgMyk7CgotLSAoNSkgVmlldyBEYXRhClNFTEVDVCAqIEZST00gc2FsZXM7CgotLSAoNikgRmlsdGVyIFJlY29yZHMKU0VMRUNUICogRlJPTSBzYWxlcyBXSEVSRSBwcmljZSAmZ3Q7IDEwMDA7CgotLSAoNykgVXBkYXRlIERhdGEgKEhpdmUgc3VwcG9ydHMgdXBkYXRlIGZyb20gdjAuMTQrIHdpdGggT1JDIGZvcm1hdCkKLS0gRmlyc3QsIGNvbnZlcnQgdGFibGUgdG8gdHJhbnNhY3Rpb25hbApBTFRFUiBUQUJMRSBzYWxlcyBTRVQgVEJMUFJPUEVSVElFUyAoJ3RyYW5zYWN0aW9uYWwnPSd0cnVlJyk7ClNFVCBoaXZlLnR4bi5tYW5hZ2VyPW9yZy5hcGFjaGUuaGFkb29wLmhpdmUucWwubG9ja21nci5EYlR4bk1hbmFnZXI7ClNFVCBoaXZlLnN1cHBvcnQuY29uY3VycmVuY3k9dHJ1ZTsKClVQREFURSBzYWxlcyBTRVQgcHJpY2UgPSA2MDAwMC4wIFdIRVJFIGlkID0gMTsKCi0tICg4KSBEZWxldGUgYSBSZWNvcmQKREVMRVRFIEZST00gc2FsZXMgV0hFUkUgaWQgPSAyOwoKLS0gKDkpIFRydW5jYXRlIFRhYmxlIChSZW1vdmUgYWxsIHJvd3MpClRSVU5DQVRFIFRBQkxFIHNhbGVzOwoKLS0gKDEwKSBEcm9wIFRhYmxlCkRST1AgVEFCTEUgc2FsZXM7
-- (1) Create a Database
CREATE DATABASE sales_db;
USE sales_db;
-- (2) Create a Table
CREATE TABLE sales (
id INT,
product STRING,
price FLOAT,
quantity INT
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
STORED AS TEXTFILE;
-- (3) Load Data from Local File (Example)
LOAD DATA LOCAL INPATH '/home/hadoop/salesdata.txt' INTO TABLE sales;
-- (4) Insert Data Manually
INSERT INTO TABLE sales VALUES
(1, 'Laptop', 55000.0, 2),
(2, 'Mouse', 500.0, 5),
(3, 'Keyboard', 800.0, 3);
-- (5) View Data
SELECT * FROM sales;
-- (6) Filter Records
SELECT * FROM sales WHERE price > 1000;
-- (7) Update Data (Hive supports update from v0.14+ with ORC format)
-- First, convert table to transactional
ALTER TABLE sales SET TBLPROPERTIES ('transactional'='true');
SET hive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager;
SET hive.support.concurrency=true;
UPDATE sales SET price = 60000.0 WHERE id = 1;
-- (8) Delete a Record
DELETE FROM sales WHERE id = 2;
-- (9) Truncate Table (Remove all rows)
TRUNCATE TABLE sales;
-- (10) Drop Table
DROP TABLE sales;