← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/sql_insert.cc

Style cleanup around TransactionContext::modified_non_trans_table and dead code removal

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/sql_insert.cc
413
413
    transactional_table= table->cursor->has_transactions();
414
414
 
415
415
    changed= (info.copied || info.deleted || info.updated);
416
 
    if ((changed && error <= 0) || session->transaction.stmt.modified_non_trans_table)
 
416
    if ((changed && error <= 0) || session->transaction.stmt.hasModifiedNonTransData())
417
417
    {
418
 
      if (session->transaction.stmt.modified_non_trans_table)
419
 
        session->transaction.all.modified_non_trans_table= true;
 
418
      if (session->transaction.stmt.hasModifiedNonTransData())
 
419
        session->transaction.all.markModifiedNonTransData();
420
420
    }
421
 
    assert(transactional_table || !changed || session->transaction.stmt.modified_non_trans_table);
 
421
    assert(transactional_table || !changed || session->transaction.stmt.hasModifiedNonTransData());
422
422
 
423
423
  }
424
424
  session->set_proc_info("end");
696
696
    then both on update triggers will work instead. Similarly both on
697
697
    delete triggers will be invoked if we will delete conflicting records.
698
698
 
699
 
    Sets session->transaction.stmt.modified_non_trans_table to true if table which is updated didn't have
 
699
    Sets session->transaction.stmt.modified_non_trans_data to true if table which is updated didn't have
700
700
    transactions.
701
701
 
702
702
  RETURN VALUE
895
895
            goto err;
896
896
          info->deleted++;
897
897
          if (!table->cursor->has_transactions())
898
 
            session->transaction.stmt.modified_non_trans_table= true;
 
898
            session->transaction.stmt.markModifiedNonTransData();
899
899
          /* Let us attempt do write_row() once more */
900
900
        }
901
901
      }
926
926
  if (key)
927
927
    free(key);
928
928
  if (!table->cursor->has_transactions())
929
 
    session->transaction.stmt.modified_non_trans_table= true;
 
929
    session->transaction.stmt.markModifiedNonTransData();
930
930
  return(0);
931
931
 
932
932
err:
1326
1326
      We must invalidate the table in the query cache before binlog writing
1327
1327
      and ha_autocommit_or_rollback.
1328
1328
    */
1329
 
    if (session->transaction.stmt.modified_non_trans_table)
1330
 
      session->transaction.all.modified_non_trans_table= true;
 
1329
    if (session->transaction.stmt.hasModifiedNonTransData())
 
1330
      session->transaction.all.markModifiedNonTransData();
1331
1331
  }
1332
1332
  assert(trans_table || !changed ||
1333
 
              session->transaction.stmt.modified_non_trans_table);
 
1333
              session->transaction.stmt.hasModifiedNonTransData());
1334
1334
 
1335
1335
  table->cursor->ha_release_auto_increment();
1336
1336
 
1392
1392
    changed= (info.copied || info.deleted || info.updated);
1393
1393
    transactional_table= table->cursor->has_transactions();
1394
1394
    assert(transactional_table || !changed ||
1395
 
                session->transaction.stmt.modified_non_trans_table);
 
1395
                session->transaction.stmt.hasModifiedNonTransData());
1396
1396
    table->cursor->ha_release_auto_increment();
1397
1397
  }
1398
1398
 
1701
1701
 
1702
1702
void select_create::send_error(uint32_t errcode,const char *err)
1703
1703
{
1704
 
 
1705
 
 
1706
1704
  /*
1707
1705
    This will execute any rollbacks that are necessary before writing
1708
1706
    the transcation cache.
1754
1752
 
1755
1753
void select_create::abort()
1756
1754
{
1757
 
 
1758
 
 
1759
1755
  /*
1760
1756
    In select_insert::abort() we roll back the statement, including
1761
1757
    truncating the transaction cache of the binary log. To do this, we
1772
1768
    log state.
1773
1769
  */
1774
1770
  select_insert::abort();
1775
 
  session->transaction.stmt.modified_non_trans_table= false;
1776
 
 
1777
1771
 
1778
1772
  if (m_plock)
1779
1773
  {