Changeset: 2927da8361fe for MonetDB URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=2927da8361fe Modified Files: sql/backends/monet5/sql_wlcr.c Branch: wlcr Log Message:
Add SQL transaction bounds diffs (40 lines): diff --git a/sql/backends/monet5/sql_wlcr.c b/sql/backends/monet5/sql_wlcr.c --- a/sql/backends/monet5/sql_wlcr.c +++ b/sql/backends/monet5/sql_wlcr.c @@ -92,6 +92,7 @@ WLCRprocess(void *arg) MalBlkPtr mb; InstrPtr q; str msg; + mvc *sql; c =MCforkClient(cntxt); if( c == 0){ @@ -109,6 +110,11 @@ WLCRprocess(void *arg) msg = SQLinitClient(c); if( msg != MAL_SUCCEED) mnstr_printf(c->fdout,"#Failed to initialize the client\n"); + msg = getSQLContext(c, mb, &sql, NULL); + if( msg) + mnstr_printf(c->fdout,"#Failed to access the transaction context: %s\n",msg); + if ((msg = checkSQLContext(c)) != NULL) + mnstr_printf(c->fdout,"#Inconsitent SQL contex : %s\n",msg); mnstr_printf(c->fdout,"#Ready to start the replayagainst '%s' batches %d threshold %d\n", wlcr_master, wlcr_replaybatches, wlcr_replaythreshold); @@ -145,9 +151,16 @@ WLCRprocess(void *arg) chkTypes(c->fdout,c->nspace, mb, FALSE); chkFlow(c->fdout,mb); chkDeclarations(c->fdout,mb); + sql->session->auto_commit = 0; + sql->session->ac_on_commit = 1; + sql->session->level = 0; + (void) mvc_trans(sql); msg= runMAL(c,mb,0,0); if( msg != MAL_SUCCEED) // they should succeed break; + if( mvc_commit(sql, 0, 0) < 0) + mnstr_printf(c->fdout,"#wlcr.process transaction commit failed"); + // cleanup trimMalVariables(mb, NULL); resetMalBlk(mb, 1); _______________________________________________ checkin-list mailing list checkin-list@monetdb.org https://www.monetdb.org/mailman/listinfo/checkin-list