Stado -> update sf_commercerecord set status=integraltype where exists ( select * from sf_wofcust201205 where sf_commercerecord.mobileno=sf_wofcust201205.mobileno and sf_commercerecord.feecode=sf_wofcust201205.feecode );
SQLException: ERROR: UNEXPECTED_MESSAGE_RECIEVED (GOT, EXPECTED) :(1 , 41 )
If xdb.use_load_for_step=true, postgres logs:
ERROR: portal "C_6" does not exist
ERROR: portal "C_6" does not exist
ERROR: portal "C_6" does not exist
ERROR: portal "C_6" does not exist
If xdb.use_load_for_step=false, postgres logs:
ERROR: portal "C_14" does not exist
ERROR: portal "C_14" does not exist
ERROR: portal "C_14" does not exist
ERROR: portal "C_14" does not exist
ERROR: canceling statement due to user request
STATEMENT: INSERT INTO "TMPTsf_commercerecord_" ("status_new", "id_old") VALUES (2, '1342356489155')
ERROR: current transaction is aborted, commands ignored until end of transaction block
STATEMENT: DROP TABLE "TMPTsf_commercerecord_"
TABLEs:
create table sf_commercerecord
(
id int8 not null,
mobileno varchar(11) not null,
product integer not null ,
employeeid varchar(20) not null ,
netportid varchar(20) not null ,
commercetype char(4) not null ,
monthtime varchar(6) not null ,
feecode integer not null ,
integraltype smallint not null ,
empintegral float not null ,
netintegral float not null ,
expreward float ,
yxplanid integer not null ,
lastid int8 not null ,
status smallint not null,
primary key (id)
) partitioning key mobileno on all;
create index idx_sfcommercerecord on sf_commercerecord (commercetype,monthtime,lastid,status);
create index idx_sfcommercerecord_employeeid on sf_commercerecord (employeeid, commercetype);
create index idx_sfcommercerecord_netportid on sf_commercerecord (netportid, commercetype);
create table sf_wofcust201205
(
mobileno varchar(11) not null ,
feecode integer not null ,
recamt float not null
) partitioning key mobileno on all;
Stado -> execute direct on all 'select count(*) from sf_commercerecord';
+----------------+
| count | Node |
+----------------+
| 1497023 | 1 |
| 1502977 | 2 |
+----------------+
2 row(s).
Stado -> execute direct on all 'select count(*) from sf_wofcust201205';
+-----------------+
| count | Node |
+-----------------+
| 9981280 | 1 |
| 10018720 | 2 |
+-----------------+
2 row(s).
Stado -> update sf_commercerecord set status=integraltype where exists ( select * from sf_wofcust201205 where sf_commercereco rd.mobileno= sf_wofcust20120 5.mobileno and sf_commercereco rd.feecode= sf_wofcust20120 5.feecode ); MESSAGE_ RECIEVED (GOT, EXPECTED) :(1 , 41 )
SQLException: ERROR: UNEXPECTED_
If xdb.use_ load_for_ step=true, postgres logs:
ERROR: portal "C_6" does not exist
ERROR: portal "C_6" does not exist
ERROR: portal "C_6" does not exist
ERROR: portal "C_6" does not exist
If xdb.use_ load_for_ step=false, postgres logs: commercerecord_ " ("status_new", "id_old") VALUES (2, '1342356489155') commercerecord_ "
ERROR: portal "C_14" does not exist
ERROR: portal "C_14" does not exist
ERROR: portal "C_14" does not exist
ERROR: portal "C_14" does not exist
ERROR: canceling statement due to user request
STATEMENT: INSERT INTO "TMPTsf_
ERROR: current transaction is aborted, commands ignored until end of transaction block
STATEMENT: DROP TABLE "TMPTsf_
TABLEs:
create table sf_commercerecord
(
id int8 not null,
mobileno varchar(11) not null,
product integer not null ,
employeeid varchar(20) not null ,
netportid varchar(20) not null ,
commercetype char(4) not null ,
monthtime varchar(6) not null ,
feecode integer not null ,
integraltype smallint not null ,
empintegral float not null ,
netintegral float not null ,
expreward float ,
yxplanid integer not null ,
lastid int8 not null ,
status smallint not null,
primary key (id)
) partitioning key mobileno on all;
create index idx_sfcommercer ecord on sf_commercerecord (commercetype, monthtime, lastid, status) ; ecord_employeei d on sf_commercerecord (employeeid, commercetype); ecord_netportid on sf_commercerecord (netportid, commercetype);
create index idx_sfcommercer
create index idx_sfcommercer
create table sf_wofcust201205
(
mobileno varchar(11) not null ,
feecode integer not null ,
recamt float not null
) partitioning key mobileno on all;
Stado -> execute direct on all 'select count(*) from sf_commercerecord';
+----------------+
| count | Node |
+----------------+
| 1497023 | 1 |
| 1502977 | 2 |
+----------------+
2 row(s).
Stado -> execute direct on all 'select count(*) from sf_wofcust201205';
+-----------------+
| count | Node |
+-----------------+
| 9981280 | 1 |
| 10018720 | 2 |
+-----------------+
2 row(s).