18
18
Single table and multi table updates of tables.
19
Multi-table updates were introduced by Sinisa & Monty
22
#include "drizzled/sql_select.h"
23
#include "drizzled/error.h"
24
#include "drizzled/probes.h"
25
#include "drizzled/sql_base.h"
26
#include "drizzled/field/timestamp.h"
27
#include "drizzled/sql_parse.h"
28
#include "drizzled/optimizer/range.h"
29
#include "drizzled/records.h"
30
#include "drizzled/internal/my_sys.h"
31
#include "drizzled/internal/iocache.h"
32
#include "drizzled/transaction_services.h"
33
#include "drizzled/filesort.h"
23
#include <drizzled/sql_select.h>
24
#include <drizzled/error.h>
25
#include <drizzled/probes.h>
26
#include <drizzled/sql_base.h>
27
#include <drizzled/field/epoch.h>
28
#include <drizzled/sql_parse.h>
29
#include <drizzled/optimizer/range.h>
30
#include <drizzled/records.h>
31
#include <drizzled/internal/my_sys.h>
32
#include <drizzled/internal/iocache.h>
33
#include <drizzled/transaction_services.h>
34
#include <drizzled/filesort.h>
35
#include <drizzled/plugin/storage_engine.h>
35
37
#include <boost/dynamic_bitset.hpp>
130
int mysql_update(Session *session, TableList *table_list,
132
int update_query(Session *session, TableList *table_list,
131
133
List<Item> &fields, List<Item> &values, COND *conds,
132
134
uint32_t order_num, Order *order,
133
135
ha_rows limit, enum enum_duplicates,
136
138
bool using_limit= limit != HA_POS_ERROR;
137
139
bool used_key_is_modified;
138
140
bool transactional_table;
140
142
uint used_index= MAX_KEY, dup_key_found;
141
143
bool need_sort= true;
142
144
ha_rows updated, found;
163
165
table->covering_keys= table->getShare()->keys_in_use;
164
166
table->quick_keys.reset();
166
if (mysql_prepare_update(session, table_list, &conds, order_num, order))
168
if (prepare_update(session, table_list, &conds, order_num, order))
168
170
DRIZZLE_UPDATE_DONE(1, 0, 0);
205
if (select_lex->inner_refs_list.elements &&
207
if (select_lex->inner_refs_list.size() &&
206
208
fix_inner_refs(session, all_fields, select_lex, select_lex->ref_pointer_array))
208
210
DRIZZLE_UPDATE_DONE(1, 0, 0);
247
249
session->main_da.reset_diagnostics_area();
248
250
free_underlaid_joins(session, select_lex);
251
if (error || session->is_error())
251
253
DRIZZLE_UPDATE_DONE(1, 0, 0);
364
365
if (used_index == MAX_KEY || (select && select->quick))
366
info.init_read_record(session, table, select, 0, true);
367
if ((error= info.init_read_record(session, table, select, 0, true)))
370
info.init_read_record_idx(session, table, 1, used_index);
372
if ((error= info.init_read_record_idx(session, table, 1, used_index)))
373
376
session->set_proc_info("Searching rows for update");
405
408
/* Change select to use tempfile */
408
delete select->quick;
411
safe_delete(select->quick);
409
412
if (select->free_cond)
410
413
delete select->cond;
416
select= new optimizer::SqlSelect;
418
select= new optimizer::SqlSelect();
417
419
select->head=table;
419
421
if (tempfile.reinit_io_cache(internal::READ_CACHE,0L,0,0))
433
435
if (select && select->quick && select->quick->reset())
435
437
table->cursor->try_semi_consistent_read(1);
436
info.init_read_record(session, table, select, 0, true);
438
if ((error= info.init_read_record(session, table, select, 0, true)))
438
443
updated= found= 0;
449
454
session->set_proc_info("Updating");
451
456
transactional_table= table->cursor->has_transactions();
452
session->abort_on_warning= test(!ignore);
457
session->setAbortOnWarning(test(!ignore));
455
460
Assure that we can use position()
573
578
session->main_da.reset_diagnostics_area();
574
session->my_ok((ulong) session->row_count_func, found, id, buff);
575
session->status_var.updated_row_count+= session->row_count_func;
579
session->my_ok((ulong) session->rowCount(), found, id, buff);
580
session->status_var.updated_row_count+= session->rowCount();
577
582
session->count_cuted_fields= CHECK_FIELD_ERROR_FOR_NULL; /* calc cuted fields */
578
session->abort_on_warning= 0;
583
session->setAbortOnWarning(false);
579
584
DRIZZLE_UPDATE_DONE((error >= 0 || session->is_error()), found, updated);
580
585
return ((error >= 0 || session->is_error()) ? 1 : 0);
589
table->print_error(error,MYF(0));
584
592
free_underlaid_joins(session, select_lex);
585
593
if (table->key_read)
587
595
table->key_read=0;
588
596
table->cursor->extra(HA_EXTRA_NO_KEYREAD);
590
session->abort_on_warning= 0;
598
session->setAbortOnWarning(false);
592
600
DRIZZLE_UPDATE_DONE(1, 0, 0);
611
bool mysql_prepare_update(Session *session, TableList *table_list,
619
bool prepare_update(Session *session, TableList *table_list,
612
620
Item **conds, uint32_t order_num, Order *order)
614
622
List<Item> all_fields;
615
Select_Lex *select_lex= &session->lex->select_lex;
623
Select_Lex *select_lex= &session->getLex()->select_lex;
617
session->lex->allow_sum_func= 0;
625
session->getLex()->allow_sum_func= 0;
619
627
if (setup_tables_and_check_access(session, &select_lex->context,
620
628
&select_lex->top_join_list,