summaryrefslogtreecommitdiff
path: root/sql/ha_partition.h
diff options
context:
space:
mode:
authorMattias Jonsson <mattias.jonsson@sun.com>2009-09-04 15:02:15 +0200
committerMattias Jonsson <mattias.jonsson@sun.com>2009-09-04 15:02:15 +0200
commitcc900f2c50f54cbe2c6540e27b86244b9f823dff (patch)
treec60c11fb29509be5d41fbb6f50c30ba28ea9e430 /sql/ha_partition.h
parent510eac6ec1e2a13166809df3d1200a354c06fb02 (diff)
downloadmariadb-git-cc900f2c50f54cbe2c6540e27b86244b9f823dff.tar.gz
Bug#35845: unneccesary call to ha_start_bulk_insert for not used partitions
(Backport) Problem is that when insert (ha_start_bulk_insert) in i partitioned table, it will call ha_start_bulk_insert for every partition, used or not. Solution is to delay the call to the partitions ha_start_bulk_insert until the first row is to be inserted into that partition
Diffstat (limited to 'sql/ha_partition.h')
-rw-r--r--sql/ha_partition.h10
1 files changed, 9 insertions, 1 deletions
diff --git a/sql/ha_partition.h b/sql/ha_partition.h
index d0301e24a93..f47dfe8f621 100644
--- a/sql/ha_partition.h
+++ b/sql/ha_partition.h
@@ -176,6 +176,11 @@ private:
This to ensure it will work with statement based replication.
*/
bool auto_increment_safe_stmt_log_lock;
+ /** For optimizing ha_start_bulk_insert calls */
+ MY_BITMAP m_bulk_insert_started;
+ ha_rows m_bulk_inserted_rows;
+ /** used for prediction of start_bulk_insert rows */
+ enum_monotonicity_info m_part_func_monotonicity_info;
public:
handler *clone(MEM_ROOT *mem_root);
virtual void set_part_info(partition_info *part_info)
@@ -353,7 +358,6 @@ public:
Bulk inserts are supported if all underlying handlers support it.
start_bulk_insert and end_bulk_insert is called before and after a
number of calls to write_row.
- Not yet though.
*/
virtual int write_row(uchar * buf);
virtual int update_row(const uchar * old_data, uchar * new_data);
@@ -361,6 +365,10 @@ public:
virtual int delete_all_rows(void);
virtual void start_bulk_insert(ha_rows rows);
virtual int end_bulk_insert();
+private:
+ ha_rows guess_bulk_insert_rows();
+ void start_part_bulk_insert(uint part_id);
+public:
virtual bool is_fatal_error(int error, uint flags)
{