summaryrefslogtreecommitdiff
path: root/storage
diff options
context:
space:
mode:
authorRich Prohaska <prohaska@tokutek.com>2014-07-16 10:13:16 -0400
committerRich Prohaska <prohaska@tokutek.com>2014-07-16 10:13:16 -0400
commit871dbcf60a174839877915334d4f745fc0687fdb (patch)
tree5fbf20a2969f38f57853bd979cceec2ff3157fe5 /storage
parentc5e99524588150dd7fbedd926b4596354aefdd86 (diff)
downloadmariadb-git-871dbcf60a174839877915334d4f745fc0687fdb.tar.gz
#262 enable bulk fetch for create select sql commands
Diffstat (limited to 'storage')
-rw-r--r--storage/tokudb/ha_tokudb.cc6
1 files changed, 3 insertions, 3 deletions
diff --git a/storage/tokudb/ha_tokudb.cc b/storage/tokudb/ha_tokudb.cc
index 43de1c05aa5..1be821bfe7e 100644
--- a/storage/tokudb/ha_tokudb.cc
+++ b/storage/tokudb/ha_tokudb.cc
@@ -4371,7 +4371,7 @@ static bool index_key_is_null(TABLE *table, uint keynr, const uchar *key, uint k
// error otherwise
//
int ha_tokudb::prepare_index_key_scan(const uchar * key, uint key_len) {
- TOKUDB_HANDLER_DBUG_ENTER("");
+ TOKUDB_HANDLER_DBUG_ENTER("%p %u", key, key_len);
int error = 0;
DBT start_key, end_key;
THD* thd = ha_thd();
@@ -4395,7 +4395,7 @@ int ha_tokudb::prepare_index_key_scan(const uchar * key, uint key_len) {
range_lock_grabbed = true;
range_lock_grabbed_null = index_key_is_null(table, tokudb_active_index, key, key_len);
- doing_bulk_fetch = (thd_sql_command(thd) == SQLCOM_SELECT);
+ doing_bulk_fetch = thd_sql_command(thd) == SQLCOM_SELECT || thd_sql_command(thd) == SQLCOM_CREATE_TABLE;
bulk_fetch_iteration = 0;
rows_fetched_using_bulk_fetch = 0;
error = 0;
@@ -5698,7 +5698,7 @@ int ha_tokudb::prelock_range( const key_range *start_key, const key_range *end_k
// at this point, determine if we will be doing bulk fetch
// as of now, only do it if we are doing a select
//
- doing_bulk_fetch = (thd_sql_command(thd) == SQLCOM_SELECT);
+ doing_bulk_fetch = thd_sql_command(thd) == SQLCOM_SELECT || thd_sql_command(thd) == SQLCOM_CREATE_TABLE;
bulk_fetch_iteration = 0;
rows_fetched_using_bulk_fetch = 0;