You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@pig.apache.org by Pham Phuong Tu <tu...@gmail.com> on 2014/08/16 10:03:00 UTC

How to use DBStorage with Mysql update command?

Hi guys,

Please tell me how to use DBStorage with Mysql update command like command
below:

STORE RESULT INTO '/data/result' USING
org.apache.pig.piggybank.storage.DBStorage('com.mysql.jdbc.Driver','jdbc:mysql://
192.168.1.1:3306/app','bigdata','bigdata','UPDATE app_statistic SET
num=num+$1 WHERE app_id=$0');

or

org.apache.pig.piggybank.storage.DBStorage('com.mysql.jdbc.Driver','jdbc:mysql://
192.168.1.1:3306/app','bigdata','bigdata','INSERT INTO app_statistic
(app_id,num) VALUES (?,?) ON DUPLICATE KEY UPDATE num=num+$1');

many thanks, please.
-- 
*-----------------------------------------*


*Pham Phuong TuBack-end & Big data developerSkype: phamphuongtu*

Fwd: How to use DBStorage with Mysql update command?

Posted by Pham Phuong Tu <tu...@gmail.com>.

Hi guys,

Please tell me how to use DBStorage with Mysql update command like command
below:

STORE RESULT INTO '/data/result' USING
org.apache.pig.piggybank.storage.DBStorage('com.mysql.jdbc.Driver','jdbc:mysql://
192.168.1.1:3306/app','bigdata','bigdata','UPDATE app_statistic SET
num=num+$1 WHERE app_id=$0');

or

org.apache.pig.piggybank.storage.DBStorage('com.mysql.jdbc.Driver','jdbc:mysql://
192.168.1.1:3306/app','bigdata','bigdata','INSERT INTO app_statistic
(app_id,num) VALUES (?,?) ON DUPLICATE KEY UPDATE num=num+$1');

many thanks, please.
-- 
*-----------------------------------------*


* Pham Phuong TuBack-end & Big data developerSkype: phamphuongtu *



-- 
*-----------------------------------------*


*Pham Phuong TuBack-end & Big data developerSkype: phamphuongtu*