mirror of
https://github.com/MariaDB/server.git
synced 2025-08-08 19:41:44 +02:00
08cbfa3979
We had a protection against it, by allowing versioned delete if: trx->id != table->vers_start_id() For replace this check fails: replace calls ha_delete_row(record[2]), but table->vers_start_id() returns the value from record[0], which is irrelevant. The same problem hits Field::is_max, which may have checked the wrong record. Fix: * Refactor Field::is_max to optionally accept a pointer as an argument. * Refactor vers_start_id and vers_end_id to always accept a pointer to the record. there is a difference with is_max is that is_max accepts the pointer to the field data, rather than to the record. Method val_int() would be too effortful to refactor to accept the argument, so instead the value in record is fetched directly, like it is done in Field_longlong.
147 lines
5.3 KiB
C++
147 lines
5.3 KiB
C++
/* Copyright (c) 2006, 2010, Oracle and/or its affiliates. All rights reserved.
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1335 USA */
|
|
|
|
#ifndef SQL_INSERT_INCLUDED
|
|
#define SQL_INSERT_INCLUDED
|
|
|
|
#include "sql_class.h" /* enum_duplicates */
|
|
#include "sql_list.h"
|
|
|
|
/* Instead of including sql_lex.h we add this typedef here */
|
|
typedef List<Item> List_item;
|
|
typedef struct st_copy_info COPY_INFO;
|
|
|
|
|
|
int mysql_prepare_insert(THD *thd, TABLE_LIST *table_list,
|
|
List<Item> &fields, List_item *values,
|
|
List<Item> &update_fields,
|
|
List<Item> &update_values, enum_duplicates duplic,
|
|
bool ignore,
|
|
COND **where, bool select_insert, bool * const cache_results);
|
|
bool mysql_insert(THD *thd,TABLE_LIST *table,List<Item> &fields,
|
|
List<List_item> &values, List<Item> &update_fields,
|
|
List<Item> &update_values, enum_duplicates flag,
|
|
bool ignore, select_result* result);
|
|
void upgrade_lock_type_for_insert(THD *thd, thr_lock_type *lock_type,
|
|
enum_duplicates duplic,
|
|
bool is_multi_insert);
|
|
int check_that_all_fields_are_given_values(THD *thd, TABLE *entry,
|
|
TABLE_LIST *table_list);
|
|
int vers_insert_history_row(TABLE *table);
|
|
int check_duplic_insert_without_overlaps(THD *thd, TABLE *table,
|
|
enum_duplicates duplic);
|
|
int write_record(THD *thd, TABLE *table, COPY_INFO *info,
|
|
select_result *returning= NULL);
|
|
void kill_delayed_threads(void);
|
|
bool binlog_create_table(THD *thd, TABLE *table, bool replace);
|
|
bool binlog_drop_table(THD *thd, TABLE *table);
|
|
int prepare_for_replace(TABLE *table, enum_duplicates handle_duplicates,
|
|
bool ignore);
|
|
int finalize_replace(TABLE *table, enum_duplicates handle_duplicates,
|
|
bool ignore);
|
|
static inline void restore_default_record_for_insert(TABLE *t)
|
|
{
|
|
restore_record(t,s->default_values);
|
|
if (t->triggers)
|
|
t->triggers->default_extra_null_bitmap();
|
|
}
|
|
|
|
|
|
class Write_record
|
|
{
|
|
THD *thd;
|
|
TABLE *table;
|
|
COPY_INFO *info;
|
|
|
|
ulonglong prev_insert_id;
|
|
ulonglong insert_id_for_cur_row= 0;
|
|
uchar *key;
|
|
ushort key_nr;
|
|
|
|
ushort last_unique_key;
|
|
bool use_triggers;
|
|
bool versioned;
|
|
bool can_optimize;
|
|
bool ignored_error;
|
|
|
|
int (*incomplete_records_cb)(void *arg1, void *arg2);
|
|
void *arg1, *arg2;
|
|
select_result *sink;
|
|
|
|
ushort get_last_unique_key() const;
|
|
// FINALIZATION
|
|
void notify_non_trans_table_modified();
|
|
int after_insert(ha_rows *inserted);
|
|
int after_ins_trg();
|
|
int send_data();
|
|
|
|
int on_ha_error(int error);
|
|
int restore_on_error();
|
|
|
|
bool is_fatal_error(int error);
|
|
int prepare_handle_duplicate(int error);
|
|
int locate_dup_record();
|
|
|
|
int replace_row(ha_rows *inserted, ha_rows *deleted);
|
|
int insert_on_duplicate_update(ha_rows *inserted, ha_rows *updated);
|
|
int single_insert(ha_rows *inserted);
|
|
public:
|
|
|
|
/**
|
|
@param thd thread context
|
|
@param info COPY_INFO structure describing handling of duplicates
|
|
and which is used for counting number of records inserted
|
|
and deleted.
|
|
@param sink result sink for the RETURNING clause
|
|
@param table
|
|
@param versioned
|
|
@param use_triggers
|
|
*/
|
|
Write_record(THD *thd, TABLE *table, COPY_INFO *info,
|
|
bool versioned, bool use_triggers, select_result *sink,
|
|
int (*incomplete_records_cb)(void *, void *),
|
|
void *arg1, void* arg2):
|
|
thd(thd), table(table), info(info), insert_id_for_cur_row(0),
|
|
key(NULL), last_unique_key(get_last_unique_key()),
|
|
use_triggers(use_triggers), versioned(versioned),
|
|
incomplete_records_cb(incomplete_records_cb), arg1(arg1), arg2(arg2),
|
|
sink(sink)
|
|
{
|
|
if (info->handle_duplicates == DUP_REPLACE)
|
|
{
|
|
bool has_delete_triggers= use_triggers &&
|
|
table->triggers->has_delete_triggers();
|
|
bool referenced_by_fk= table->file->referenced_by_foreign_key();
|
|
can_optimize= !referenced_by_fk && !has_delete_triggers
|
|
&& !versioned && !table->versioned();
|
|
}
|
|
}
|
|
Write_record(THD *thd, TABLE *table, COPY_INFO *info,
|
|
select_result *sink= NULL):
|
|
Write_record(thd, table, info, table->versioned(VERS_TIMESTAMP),
|
|
table->triggers, sink, NULL, NULL, NULL)
|
|
{}
|
|
Write_record() = default; // dummy, to allow later (lazy) initializations
|
|
|
|
/* Main entry point, see docs in sql_insert.cc */
|
|
int write_record();
|
|
|
|
int last_errno() { return info->last_errno; }
|
|
};
|
|
#ifdef EMBEDDED_LIBRARY
|
|
inline void kill_delayed_threads(void) {}
|
|
#endif
|
|
|
|
#endif /* SQL_INSERT_INCLUDED */
|