database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-07-29 08:21:15 +03:00
Code Activity

Rename columnstore_use_cpimport_for_cache_inserts system variable to (#2053)

Browse Source 
columnstore_cache_use_import.
This commit is contained in:
Gagan Goel
2021-07-19 13:47:15 -04:00
committed by GitHub
parent 8637c1e1a8
commit c5502c02fa
3 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
dbcon/mysql/ha_mcs_impl.cpp
View File

@ -3042,7 +3042,7 @@ void ha_mcs_impl_start_bulk_insert(ha_rows rows, TABLE* table, bool is_cache_ins
if (ci->isCacheInsert) if (ci->isCacheInsert)
{ {
if (get_use_cpimport_for_cache_inserts(thd)) if (get_cache_use_import(thd))
ci->useCpimport = mcs_use_import_for_batchinsert_mode_t::ALWAYS; ci->useCpimport = mcs_use_import_for_batchinsert_mode_t::ALWAYS;
else else
ci->useCpimport = mcs_use_import_for_batchinsert_mode_t::OFF; ci->useCpimport = mcs_use_import_for_batchinsert_mode_t::OFF;

12
dbcon/mysql/ha_mcs_sysvars.cpp
View File

@ -352,7 +352,7 @@ static MYSQL_THDVAR_BOOL(
); );
static MYSQL_THDVAR_BOOL( static MYSQL_THDVAR_BOOL(
use_cpimport_for_cache_inserts, cache_use_import,
PLUGIN_VAR_RQCMDARG, PLUGIN_VAR_RQCMDARG,
"Use cpimport for the cache flush into ColumnStore", "Use cpimport for the cache flush into ColumnStore",
NULL, NULL,
@ -400,7 +400,7 @@ st_mysql_sys_var* mcs_system_variables[] =
MYSQL_SYSVAR(varbin_always_hex), MYSQL_SYSVAR(varbin_always_hex),
MYSQL_SYSVAR(replication_slave), MYSQL_SYSVAR(replication_slave),
MYSQL_SYSVAR(cache_inserts), MYSQL_SYSVAR(cache_inserts),
MYSQL_SYSVAR(use_cpimport_for_cache_inserts), MYSQL_SYSVAR(cache_use_import),
MYSQL_SYSVAR(cache_flush_threshold), MYSQL_SYSVAR(cache_flush_threshold),
NULL NULL
}; };
@ -663,13 +663,13 @@ void set_cache_inserts(THD* thd, bool value)
THDVAR(thd, cache_inserts) = value; THDVAR(thd, cache_inserts) = value;
} }
bool get_use_cpimport_for_cache_inserts(THD* thd) bool get_cache_use_import(THD* thd)
{ {
return ( thd == NULL ) ? false : THDVAR(thd, use_cpimport_for_cache_inserts); return ( thd == NULL ) ? false : THDVAR(thd, cache_use_import);
} }
void set_use_cpimport_for_cache_inserts(THD* thd, bool value) void set_cache_use_import(THD* thd, bool value)
{ {
THDVAR(thd, use_cpimport_for_cache_inserts) = value; THDVAR(thd, cache_use_import) = value;
} }
ulonglong get_cache_flush_threshold(THD* thd) ulonglong get_cache_flush_threshold(THD* thd)

4
dbcon/mysql/ha_mcs_sysvars.h
View File

@ -133,8 +133,8 @@ void set_replication_slave(THD* thd, bool value);
bool get_cache_inserts(THD* thd); bool get_cache_inserts(THD* thd);
void set_cache_inserts(THD* thd, bool value); void set_cache_inserts(THD* thd, bool value);
bool get_use_cpimport_for_cache_inserts(THD* thd); bool get_cache_use_import(THD* thd);
void set_use_cpimport_for_cache_inserts(THD* thd, bool value); void set_cache_use_import(THD* thd, bool value);
ulonglong get_cache_flush_threshold(THD* thd); ulonglong get_cache_flush_threshold(THD* thd);
void set_cache_flush_threshold(THD* thd, ulonglong value); void set_cache_flush_threshold(THD* thd, ulonglong value);