~drizzle-trunk/drizzle/development

 

/*

  Single table and multi table updates of tables.

*/

 

#include <boost/dynamic_bitset.hpp>

#include <list>

  Process usual UPDATE

 

  SYNOPSIS

    session                     thread handler

    fields              fields for update

    values              values of fields for update

    1  - error

*/

 

                 List<Item> &fields, List<Item> &values, COND *conds,

                 uint32_t order_num, Order *order,

                 ha_rows limit, enum enum_duplicates,

  bool          using_limit= limit != HA_POS_ERROR;

  bool          used_key_is_modified;

  bool          transactional_table;

  uint          used_index= MAX_KEY, dup_key_found;

  bool          need_sort= true;

  ha_rows       updated, found;

  Table         *table;

  optimizer::SqlSelect *select= NULL;

  ReadRecord    info;

  uint64_t     id;

  List<Item> all_fields;

  Session::killed_state_t killed_status= Session::NOT_KILLED;

  table->covering_keys= table->getShare()->keys_in_use;

  table->quick_keys.reset();

 

  {

    DRIZZLE_UPDATE_DONE(1, 0, 0);

    return 1;

    fix_inner_refs(session, all_fields, select_lex, select_lex->ref_pointer_array))

  {

    DRIZZLE_UPDATE_DONE(1, 0, 0);

  }

 

  if (conds)

     */

    session->main_da.reset_diagnostics_area();

    free_underlaid_joins(session, select_lex);

    {

      DRIZZLE_UPDATE_DONE(1, 0, 0);

      return 1;

        Filesort has already found and selected the rows we want to update,

        so we don't need the where clause

      */

    }

    else

    {

 

      if (used_index == MAX_KEY || (select && select->quick))

      {

      }

      else

      {

      }

 

      session->set_proc_info("Searching rows for update");

      /* Change select to use tempfile */

      if (select)

      {

        if (select->free_cond)

          delete select->cond;

        select->cond=0;

      }

      else

      {

        select->head=table;

      }

      if (tempfile.reinit_io_cache(internal::READ_CACHE,0L,0,0))

  if (select && select->quick && select->quick->reset())

    goto err;

  table->cursor->try_semi_consistent_read(1);

 

  updated= found= 0;

  /*

  session->set_proc_info("Updating");

 

  transactional_table= table->cursor->has_transactions();

 

  /*

    Assure that we can use position()