step"s1_init" {SELECT'init'FROMpg_create_logical_replication_slot('isolation_slot','test_decoding'); }

step"s1_begin" {BEGIN; }

step"s1_insert_tbl1" {INSERTINTOtbl1 (val1,val2)VALUES (1,1); }

step"s1_insert_tbl1_3col" {INSERTINTOtbl1 (val1,val2,val3)VALUES (1,1,1); }

step"s1_insert_tbl2" {INSERTINTOtbl2 (val1,val2)VALUES (1,1); }

step"s1_insert_tbl2_3col" {INSERTINTOtbl2 (val1,val2,val3)VALUES (1,1,1); }

step"s1_commit" {COMMIT; }

step"s2_alter_tbl1_float" {ALTERTABLEtbl1ALTERCOLUMNval2TYPEfloat; }

step"s2_alter_tbl1_char" {ALTERTABLEtbl1ALTERCOLUMNval2TYPEcharactervarying; }

step"s2_alter_tbl1_text" {ALTERTABLEtbl1ALTERCOLUMNval2TYPEtext; }

step"s2_alter_tbl1_boolean" {ALTERTABLEtbl1ALTERCOLUMNval2TYPEboolean; }

step"s2_alter_tbl1_add_int" {ALTERTABLEtbl1ADDCOLUMNval3INTEGER; }

step"s2_alter_tbl1_add_float" {ALTERTABLEtbl1ADDCOLUMNval3FLOAT; }

step"s2_alter_tbl1_add_char" {ALTERTABLEtbl1ADDCOLUMNval3charactervarying; }

step"s2_alter_tbl1_add_boolean" {ALTERTABLEtbl1ADDCOLUMNval3BOOLEAN; }

step"s2_alter_tbl1_add_text" {ALTERTABLEtbl1ADDCOLUMNval3TEXT; }

step"s2_alter_tbl2_float" {ALTERTABLEtbl2ALTERCOLUMNval2TYPEfloat; }

step"s2_alter_tbl2_char" {ALTERTABLEtbl2ALTERCOLUMNval2TYPEcharactervarying; }

step"s2_alter_tbl2_text" {ALTERTABLEtbl2ALTERCOLUMNval2TYPEtext; }

step"s2_alter_tbl2_add_int" {ALTERTABLEtbl2ADDCOLUMNval3INTEGER; }

step"s2_alter_tbl2_add_float" {ALTERTABLEtbl2ADDCOLUMNval3FLOAT; }

step"s2_alter_tbl2_add_char" {ALTERTABLEtbl2ADDCOLUMNval3charactervarying; }

step"s2_alter_tbl2_add_boolean" {ALTERTABLEtbl2ADDCOLUMNval3BOOLEAN; }

step"s2_alter_tbl2_add_text" {ALTERTABLEtbl2ADDCOLUMNval3TEXT; }

step"s2_alter_tbl2_drop_3rd_col" {ALTERTABLEtbl2DROPCOLUMNval3; }

step"s2_alter_tbl2_3rd_char" {ALTERTABLEtbl2ALTERCOLUMNval3TYPEcharactervarying; }

step"s0_insert" {INSERTINTOharvestVALUES (1,2,3); }

step"s0_end_sub0" {RELEASESAVEPOINTs0; }

step"s0_end_sub1" {RELEASESAVEPOINTs1; }

step"s0_insert2" {INSERTINTOharvestVALUES (1,2,3,4); }

step"s0_commit" {COMMIT; }

step"s0_get_changes" {SELECTdataFROMpg_logical_slot_get_changes('isolation_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1'); }

Parsed test spec with4 sessions

Parsed test spec with3 sessions

starting permutation: s1_trig_rep_b_u s1_trig_rep_a_u s1_ins_a s1_ins_b s1_b_rc s2_b_rc s1_upd_a_data s1_c s2_upd_a_data s2_c s0_rep

step s1_trig_rep_b_u: CREATE TRIGGER rep_b_u BEFORE UPDATE ON trigtest FOR EACH ROW EXECUTE PROCEDURE trig_report();

puts("isolationtester (PostgreSQL) "PG_VERSION);

exit(0);

default:

fprintf(stderr,"Usage: isolationtester [-n] [CONNINFO]\n");

fprintf(stderr,"Usage: isolationtester [CONNINFO]\n");

returnEXIT_FAILURE;

}

}

run_testspec(TestSpec*testspec)

{

inti;

if (testspec->permutations)

run_named_permutations(testspec);

run_all_permutations(testspec);

for (i=0;i<testspec->nallsteps;i++)

{

if (!testspec->allsteps[i]->used)

fprintf(stderr,"unused step name: %s\n",

testspec->allsteps[i]->name);

}

}

printf("\nstarting permutation:");

for (i=0;i<nsteps;i++)

{

steps[i]->used= true;

printf(" %s",steps[i]->name);

}

printf("\n");

{

intsession;

boolused;

char*name;

char*sql;

char*errormsg;

$$ = pg_malloc(sizeof(Step));

$$->name =$2;

$$->sql =$3;

$$->used =false;

$$->errormsg =NULL;

}

;

step"s2_b_rc" {BEGINISOLATIONLEVELREADCOMMITTED;SELECT1; }

step"s2_b_rr" {BEGINISOLATIONLEVELREPEATABLEREAD;SELECT1; }

step"s2_c" {COMMIT; }

step"s2_r" {ROLLBACK; }

step"s2_ins_a" {INSERTINTOtrigtestVALUES ('key-a','val-a-s2')RETURNING*; }

step"s2_del_a" {

RETURNING*;

}

step"s3_b_rc" {BEGINISOLATIONLEVELREADCOMMITTED;SELECT1; }

step"s3_c" {COMMIT; }

step"s3_r" {ROLLBACK; }

step"s3_del_a" {

noisy_oper('upd',key,'=','key-a')AND

noisy_oper('upk',data,'<>','mismatch')

}

step"s3_upd_a_data" {

noisy_oper('upd',key,'=','key-a')AND

noisy_oper('upk',data,'<>','mismatch')

RETURNING*;

}

step"s1_begin"{BEGIN; }

step"s1_update"{UPDATEtab_freezeSETx=x+1WHEREid=3; }

step"s1_commit"{COMMIT; }

step"s1_vacuum"{VACUUMFREEZEtab_freeze; }

step"s1_selectone"{

BEGIN;

SETLOCALenable_seqscan=false;

COMMIT;

}

step"s1_selectall"{SELECT*FROMtab_freezeORDERBYname,id; }

step"s1_reindex"{REINDEXTABLEtab_freeze; }

step"s2_begin"{BEGIN; }

step"s3_begin"{BEGIN; }

step"s3_key_share"{SELECTidFROMtab_freezeWHEREid=3FORKEYSHARE; }

step"s3_commit"{COMMIT; }

step"s3_vacuum"{VACUUMFREEZEtab_freeze; }

step"donothing2" {INSERTINTOints(key,val)VALUES(1,'donothing2')ONCONFLICTDONOTHING; }

step"select2" {SELECT*FROMints; }

step"c2" {COMMIT; }

step"a2" {ABORT; }

step"insert2" {INSERTINTOupsert(key,payload)VALUES('FOOFOO','insert2')ONCONFLICT (lower(key))DOUPDATEsetkey=EXCLUDED.key,payload=upsert.payload||' updated by insert2'; }

step"select2" {SELECT*FROMupsert; }

step"c2" {COMMIT; }

step"a2" {ABORT; }

step"insert2" {INSERTINTOupsert(key,val)VALUES(1,'insert2')ONCONFLICT (key)DOUPDATEsetval=upsert.val||' updated by insert2'; }

step"select2" {SELECT*FROMupsert; }

step"c2" {COMMIT; }

step"a2" {ABORT; }

step"s2b"{BEGINISOLATIONLEVELREADCOMMITTED; }

step"s2u"{UPDATEfooSETb='EFG'WHEREa=1; }

step"s2u2"{UPDATEfootrgSETb='XYZ'WHEREa=1; }

step"s2i"{INSERTINTObarVALUES(7); }

step"s2d"{DELETEFROMfooWHEREa=1; }

step"s0_begin" {begin; }

step"s0_keyshare" {selectidfromtlu_jobwhereid=1forkeyshare;}

step"s0_share" {selectidfromtlu_jobwhereid=1forshare;}

step"s0_rollback" {rollback; }

step"s1_share" {selectidfromtlu_jobwhereid=1forshare; }

step"s1_fornokeyupd" {selectidfromtlu_jobwhereid=1fornokeyupdate; }

step"s1_update" {updatetlu_jobsetname='b'whereid=1; }

step"s1_delete" {deletefromtlu_jobwhereid=1; }

step"s1_savept_e" {savepoints1_e; }

step"s1_savept_f" {savepoints1_f; }

step"s1_rollback_e" {rollbacktos1_e; }

step"s2_update" {updatetlu_jobsetname='b'whereid=1; }

step"s2_delete" {deletefromtlu_jobwhereid=1; }

step"s2_rollback" {rollback; }

step"s2_commit" {commit; }

setup {begin; }