Comment 6 for bug 1160730

Revision history for this message
Alvin Peng (pengalvin) wrote :

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).