~drizzle-trunk/drizzle/development

#include <drizzled/probes.h>

#include <drizzled/sql_base.h>

#include <drizzled/field/timestamp.h>

 

/*

  check that all fields are real fields

  uint32_t keynr;

  MY_BITMAP unique_map; /* Fields in offended unique. */

  my_bitmap_map unique_map_buf[bitmap_buffer_size(MAX_FIELDS)];

  /*

    Only duplicate key errors print the key value.

    If storage engine does always read all columns, we have the value alraedy.

  uint64_t     id;

  List<Item> all_fields;

  Session::killed_state killed_status= Session::NOT_KILLED;

  for ( ; ; )

  {

    if (open_tables(session, &table_list, &table_count, 0))

  table->mark_columns_needed_for_update();

 

  /* Check if we are modifying a key that we are used to search with */

  if (select && select->quick)

  {

    used_index= select->quick->index;

      SORT_FIELD  *sortorder;

      ha_rows examined_rows;

 

      if (!(sortorder=make_unireg_sortorder(order, &length, NULL)) ||

          (table->sort.found_records= filesort(session, table, sortorder, length,

                                               select, limit, 1,

      limit= tmp_limit;

      table->file->try_semi_consistent_read(0);

      end_read_record(&info);

      /* Change select to use tempfile */

      if (select)

      {

 

  if (ignore)

    table->file->extra(HA_EXTRA_IGNORE_DUP_KEY);

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

    goto err;

  table->file->try_semi_consistent_read(1);

  init_read_record(&info,session,table,select,0,1);

 

  updated= found= 0;

  session->set_proc_info("Updating");

 

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

 

            1) is covered by exec_bulk_update calls.

            2) and 3) is handled by the bulk_update_row method.

            bulk_update_row can execute the updates including the one

            defined in the bulk_update_row or not including the row

            in the call. This is up to the handler implementation and can

  */

  if ((error < 0) || session->transaction.stmt.modified_non_trans_table)

  {

    if (session->transaction.stmt.modified_non_trans_table)

      session->transaction.all.modified_non_trans_table= true;

  }

 

  session->lex->allow_sum_func= 0;

 

                                    &select_lex->top_join_list,

                                    table_list,

                                    &select_lex->leaf_tables,

 

 

/***************************************************************************

***************************************************************************/

 

/*

  Item_field *item;

  table_map map= 0;

 

    map|= item->used_tables();

  return map;

}

  const bool using_lock_tables= session->locked_tables != 0;

  bool original_multiupdate= (session->lex->sql_command == SQLCOM_UPDATE_MULTI);

  bool need_reopen= false;

 

  /* following need for prepared statements, to run next time multi-update */

  session->lex->sql_command= SQLCOM_UPDATE_MULTI;

    further check in multi_update::prepare whether to use record cache.

  */

  lex->select_lex.exclude_from_table_unique_test= false;

  if (session->fill_derived_tables() &&

      mysql_handle_derived(lex, &mysql_derived_filling))

    return(true);

{

  multi_update *result;

  bool res;

  if (!(result= new multi_update(table_list,

                                 session->lex->select_lex.leaf_tables,

                                 fields, values,

  List_iterator_fast<Item> value_it(*values);

  uint32_t i, max_fields;

  uint32_t leaf_table_count= 0;

  session->count_cuted_fields= CHECK_FIELD_WARN;

  session->cuted_fields=0L;

  session->set_proc_info("updating main table");

multi_update::initialize_tables(JOIN *join)

{

  TableList *table_ref;

  if ((session->options & OPTION_SAFE_UPDATES) && error_if_full_join(join))

    return(1);

  main_table=join->join_tab->table;

    Table *tbl= table;

    do

    {

      Field_varstring *field= new Field_varstring(tbl->file->ref_length, 0,

                                                  tbl->alias, tbl->s, &my_charset_bin);

      if (!field)

        return(1);

      field->init(tbl);

      do

      {

        tbl->file->position(tbl->record[0]);

        field_num++;

      } while ((tbl= tbl_it++));

 

    if (do_update && table_count > 1)

    {

      /* Add warning here */

         todo/fixme: do_update() is never called with the arg 1.

         should it change the signature to become argless?

      */

  }

  if (session->transaction.stmt.modified_non_trans_table)

  {