diff options
author | Alexander Barkov <bar@mariadb.com> | 2019-10-16 16:22:04 +0400 |
---|---|---|
committer | Alexander Barkov <bar@mariadb.com> | 2019-10-16 21:47:41 +0400 |
commit | 9c9606152505792fcb8f4b7386e5b6a25e2790b4 (patch) | |
tree | 7378473d2d09c4c4ad77d168fe43d7271b0c8e69 | |
parent | 5a052ab6b11aadcf62bb3a7efb2acbe14355e0b1 (diff) | |
download | mariadb-git-9c9606152505792fcb8f4b7386e5b6a25e2790b4.tar.gz |
Part2: MDEV-20837 Add MariaDB_FUNCTION_PLUGIN
Removing MariaDB_FUNCTION_COLLECTION_PLUGIN
-rw-r--r-- | cmake/abi_check.cmake | 1 | ||||
-rw-r--r-- | include/mysql/plugin.h | 3 | ||||
-rw-r--r-- | include/mysql/plugin_function_collection.h | 101 | ||||
-rw-r--r-- | include/mysql/plugin_function_collection.h.pp | 679 | ||||
-rw-r--r-- | sql/item_create.cc | 128 | ||||
-rw-r--r-- | sql/item_create.h | 25 | ||||
-rw-r--r-- | sql/item_geofunc.cc | 20 | ||||
-rw-r--r-- | sql/sql_plugin.cc | 17 |
8 files changed, 69 insertions, 905 deletions
diff --git a/cmake/abi_check.cmake b/cmake/abi_check.cmake index 8590e2f7bb6..98877be9351 100644 --- a/cmake/abi_check.cmake +++ b/cmake/abi_check.cmake @@ -47,7 +47,6 @@ IF(CMAKE_C_COMPILER_ID MATCHES "GNU|Clang" AND RUN_ABI_CHECK) ${CMAKE_SOURCE_DIR}/include/mysql/plugin_encryption.h ${CMAKE_SOURCE_DIR}/include/mysql/plugin_data_type.h ${CMAKE_SOURCE_DIR}/include/mysql/plugin_function.h - ${CMAKE_SOURCE_DIR}/include/mysql/plugin_function_collection.h ) ADD_CUSTOM_TARGET(abi_check ALL diff --git a/include/mysql/plugin.h b/include/mysql/plugin.h index ab67f7f4853..07e7597fbd8 100644 --- a/include/mysql/plugin.h +++ b/include/mysql/plugin.h @@ -90,14 +90,13 @@ typedef struct st_mysql_xid MYSQL_XID; #define MYSQL_AUDIT_PLUGIN 5 #define MYSQL_REPLICATION_PLUGIN 6 #define MYSQL_AUTHENTICATION_PLUGIN 7 -#define MYSQL_MAX_PLUGIN_TYPE_NUM 13 /* The number of plugin types */ +#define MYSQL_MAX_PLUGIN_TYPE_NUM 12 /* The number of plugin types */ /* MariaDB plugin types */ #define MariaDB_PASSWORD_VALIDATION_PLUGIN 8 #define MariaDB_ENCRYPTION_PLUGIN 9 #define MariaDB_DATA_TYPE_PLUGIN 10 #define MariaDB_FUNCTION_PLUGIN 11 -#define MariaDB_FUNCTION_COLLECTION_PLUGIN 12 /* We use the following strings to define licenses for plugins */ #define PLUGIN_LICENSE_PROPRIETARY 0 diff --git a/include/mysql/plugin_function_collection.h b/include/mysql/plugin_function_collection.h deleted file mode 100644 index c1b51ac5883..00000000000 --- a/include/mysql/plugin_function_collection.h +++ /dev/null @@ -1,101 +0,0 @@ -#ifndef MARIADB_PLUGIN_FUNCTION_COLLECTION_INCLUDED -#define MARIADB_PLUGIN_FUNCTION_COLLECTION_INCLUDED -/* Copyright (C) 2019, Alexander Barkov and MariaDB - - 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 */ - -/** - @file - - Data Type Plugin API. - - This file defines the API for server plugins that manage function collections. -*/ - -#ifdef __cplusplus - -#include <mysql/plugin.h> - -/* - API for data type plugins. (MariaDB_FUNCTION_COLLECTION_PLUGIN) -*/ -#define MariaDB_FUNCTION_COLLECTION_INTERFACE_VERSION (MYSQL_VERSION_ID << 8) - - -class Native_func_registry_array -{ - const Native_func_registry *m_elements; - size_t m_count; -public: - Native_func_registry_array() - :m_elements(NULL), - m_count(0) - { } - Native_func_registry_array(const Native_func_registry *elements, size_t count) - :m_elements(elements), - m_count(count) - { } - const Native_func_registry& element(size_t i) const - { - DBUG_ASSERT(i < m_count); - return m_elements[i]; - } - size_t count() const { return m_count; } -}; - - -class Plugin_function_collection -{ - int m_interface_version; - const Native_func_registry_array m_native_func_registry_array; - HASH m_hash; -public: - bool init(); - void deinit() - { - my_hash_free(&m_hash); - } - static int init_plugin(st_plugin_int *plugin) - { - Plugin_function_collection *coll= - reinterpret_cast<Plugin_function_collection*>(plugin->plugin->info); - return coll->init(); - } - static int deinit_plugin(st_plugin_int *plugin) - { - Plugin_function_collection *coll= - reinterpret_cast<Plugin_function_collection*>(plugin->plugin->info); - coll->deinit(); - return 0; - } -public: - Plugin_function_collection(int interface_version, - const Native_func_registry_array &nfra) - :m_interface_version(interface_version), - m_native_func_registry_array(nfra) - { - bzero((void*) &m_hash, sizeof(m_hash)); - } - Create_func *find_native_function_builder(THD *thd, - const LEX_CSTRING &name) const; -}; - - -/** - Data type plugin descriptor -*/ - -#endif /* __cplusplus */ - -#endif /* MARIADB_PLUGIN_FUNCTION_COLLECTION_INCLUDED */ diff --git a/include/mysql/plugin_function_collection.h.pp b/include/mysql/plugin_function_collection.h.pp deleted file mode 100644 index 75baf7d7e10..00000000000 --- a/include/mysql/plugin_function_collection.h.pp +++ /dev/null @@ -1,679 +0,0 @@ -class THD; -class Item; -typedef char my_bool; -typedef void * MYSQL_PLUGIN; -extern "C" { -extern "C" { -extern struct base64_service_st { - int (*base64_needed_encoded_length_ptr)(int length_of_data); - int (*base64_encode_max_arg_length_ptr)(void); - int (*base64_needed_decoded_length_ptr)(int length_of_encoded_data); - int (*base64_decode_max_arg_length_ptr)(); - int (*base64_encode_ptr)(const void *src, size_t src_len, char *dst); - int (*base64_decode_ptr)(const char *src, size_t src_len, - void *dst, const char **end_ptr, int flags); -} *base64_service; -int my_base64_needed_encoded_length(int length_of_data); -int my_base64_encode_max_arg_length(void); -int my_base64_needed_decoded_length(int length_of_encoded_data); -int my_base64_decode_max_arg_length(); -int my_base64_encode(const void *src, size_t src_len, char *dst); -int my_base64_decode(const char *src, size_t src_len, - void *dst, const char **end_ptr, int flags); -} -extern "C" { -extern void (*debug_sync_C_callback_ptr)(THD*, const char *, size_t); -} -extern "C" { -struct encryption_service_st { - unsigned int (*encryption_key_get_latest_version_func)(unsigned int key_id); - unsigned int (*encryption_key_get_func)(unsigned int key_id, unsigned int key_version, - unsigned char* buffer, unsigned int* length); - unsigned int (*encryption_ctx_size_func)(unsigned int key_id, unsigned int key_version); - int (*encryption_ctx_init_func)(void *ctx, const unsigned char* key, unsigned int klen, - const unsigned char* iv, unsigned int ivlen, - int flags, unsigned int key_id, - unsigned int key_version); - int (*encryption_ctx_update_func)(void *ctx, const unsigned char* src, unsigned int slen, - unsigned char* dst, unsigned int* dlen); - int (*encryption_ctx_finish_func)(void *ctx, unsigned char* dst, unsigned int* dlen); - unsigned int (*encryption_encrypted_length_func)(unsigned int slen, unsigned int key_id, unsigned int key_version); -}; -extern struct encryption_service_st encryption_handler; -static inline unsigned int encryption_key_id_exists(unsigned int id) -{ - return encryption_handler.encryption_key_get_latest_version_func(id) != (~(unsigned int)0); -} -static inline unsigned int encryption_key_version_exists(unsigned int id, unsigned int version) -{ - unsigned int unused; - return encryption_handler.encryption_key_get_func((id),(version),(NULL),(&unused)) != (~(unsigned int)0); -} -static inline int encryption_crypt(const unsigned char* src, unsigned int slen, - unsigned char* dst, unsigned int* dlen, - const unsigned char* key, unsigned int klen, - const unsigned char* iv, unsigned int ivlen, - int flags, unsigned int key_id, unsigned int key_version) -{ - void *ctx= alloca(encryption_handler.encryption_ctx_size_func((key_id),(key_version))); - int res1, res2; - unsigned int d1, d2; - if ((res1= encryption_handler.encryption_ctx_init_func((ctx),(key),(klen),(iv),(ivlen),(flags),(key_id),(key_version)))) - return res1; - res1= encryption_handler.encryption_ctx_update_func((ctx),(src),(slen),(dst),(&d1)); - res2= encryption_handler.encryption_ctx_finish_func((ctx),(dst + d1),(&d2)); - *dlen= d1 + d2; - return res1 ? res1 : res2; -} -} -extern "C" { -struct st_encryption_scheme_key { - unsigned int version; - unsigned char key[16]; -}; -struct st_encryption_scheme { - unsigned char iv[16]; - struct st_encryption_scheme_key key[3]; - unsigned int keyserver_requests; - unsigned int key_id; - unsigned int type; - void (*locker)(struct st_encryption_scheme *self, int release); -}; -extern struct encryption_scheme_service_st { - int (*encryption_scheme_encrypt_func) - (const unsigned char* src, unsigned int slen, - unsigned char* dst, unsigned int* dlen, - struct st_encryption_scheme *scheme, - unsigned int key_version, unsigned int i32_1, - unsigned int i32_2, unsigned long long i64); - int (*encryption_scheme_decrypt_func) - (const unsigned char* src, unsigned int slen, - unsigned char* dst, unsigned int* dlen, - struct st_encryption_scheme *scheme, - unsigned int key_version, unsigned int i32_1, - unsigned int i32_2, unsigned long long i64); -} *encryption_scheme_service; -int encryption_scheme_encrypt(const unsigned char* src, unsigned int slen, - unsigned char* dst, unsigned int* dlen, - struct st_encryption_scheme *scheme, - unsigned int key_version, unsigned int i32_1, - unsigned int i32_2, unsigned long long i64); -int encryption_scheme_decrypt(const unsigned char* src, unsigned int slen, - unsigned char* dst, unsigned int* dlen, - struct st_encryption_scheme *scheme, - unsigned int key_version, unsigned int i32_1, - unsigned int i32_2, unsigned long long i64); -} -extern "C" { -enum thd_kill_levels { - THD_IS_NOT_KILLED=0, - THD_ABORT_SOFTLY=50, - THD_ABORT_ASAP=100, -}; -extern struct kill_statement_service_st { - enum thd_kill_levels (*thd_kill_level_func)(const THD*); -} *thd_kill_statement_service; -enum thd_kill_levels thd_kill_level(const THD*); -} -extern "C" { -typedef struct logger_handle_st LOGGER_HANDLE; -extern struct logger_service_st { - void (*logger_init_mutexes)(); - LOGGER_HANDLE* (*open)(const char *path, - unsigned long long size_limit, - unsigned int rotations); - int (*close)(LOGGER_HANDLE *log); - int (*vprintf)(LOGGER_HANDLE *log, const char *fmt, va_list argptr); - int (*printf)(LOGGER_HANDLE *log, const char *fmt, ...); - int (*write)(LOGGER_HANDLE *log, const char *buffer, size_t size); - int (*rotate)(LOGGER_HANDLE *log); -} *logger_service; - void logger_init_mutexes(); - LOGGER_HANDLE *logger_open(const char *path, - unsigned long long size_limit, - unsigned int rotations); - int logger_close(LOGGER_HANDLE *log); - int logger_vprintf(LOGGER_HANDLE *log, const char *fmt, va_list argptr); - int logger_printf(LOGGER_HANDLE *log, const char *fmt, ...); - int logger_write(LOGGER_HANDLE *log, const char *buffer, size_t size); - int logger_rotate(LOGGER_HANDLE *log); -} -extern "C" { -extern struct my_md5_service_st { - void (*my_md5_type)(unsigned char*, const char*, size_t); - void (*my_md5_multi_type)(unsigned char*, ...); - size_t (*my_md5_context_size_type)(); - void (*my_md5_init_type)(void *); - void (*my_md5_input_type)(void *, const unsigned char *, size_t); - void (*my_md5_result_type)(void *, unsigned char *); -} *my_md5_service; -void my_md5(unsigned char*, const char*, size_t); -void my_md5_multi(unsigned char*, ...); -size_t my_md5_context_size(); -void my_md5_init(void *context); -void my_md5_input(void *context, const unsigned char *buf, size_t len); -void my_md5_result(void *context, unsigned char *digest); -} -extern "C" { -enum my_aes_mode { - MY_AES_ECB, MY_AES_CBC -}; -extern struct my_crypt_service_st { - int (*my_aes_crypt_init)(void *ctx, enum my_aes_mode mode, int flags, - const unsigned char* key, unsigned int klen, - const unsigned char* iv, unsigned int ivlen); - int (*my_aes_crypt_update)(void *ctx, const unsigned char *src, unsigned int slen, - unsigned char *dst, unsigned int *dlen); - int (*my_aes_crypt_finish)(void *ctx, unsigned char *dst, unsigned int *dlen); - int (*my_aes_crypt)(enum my_aes_mode mode, int flags, - const unsigned char *src, unsigned int slen, unsigned char *dst, unsigned int *dlen, - const unsigned char *key, unsigned int klen, const unsigned char *iv, unsigned int ivlen); - unsigned int (*my_aes_get_size)(enum my_aes_mode mode, unsigned int source_length); - unsigned int (*my_aes_ctx_size)(enum my_aes_mode mode); - int (*my_random_bytes)(unsigned char* buf, int num); -} *my_crypt_service; -int my_aes_crypt_init(void *ctx, enum my_aes_mode mode, int flags, - const unsigned char* key, unsigned int klen, - const unsigned char* iv, unsigned int ivlen); -int my_aes_crypt_update(void *ctx, const unsigned char *src, unsigned int slen, - unsigned char *dst, unsigned int *dlen); -int my_aes_crypt_finish(void *ctx, unsigned char *dst, unsigned int *dlen); -int my_aes_crypt(enum my_aes_mode mode, int flags, - const unsigned char *src, unsigned int slen, unsigned char *dst, unsigned int *dlen, - const unsigned char *key, unsigned int klen, const unsigned char *iv, unsigned int ivlen); -int my_random_bytes(unsigned char* buf, int num); -unsigned int my_aes_get_size(enum my_aes_mode mode, unsigned int source_length); -unsigned int my_aes_ctx_size(enum my_aes_mode mode); -} -extern "C" { -extern struct my_print_error_service_st { - void (*my_error_func)(unsigned int nr, unsigned long MyFlags, ...); - void (*my_printf_error_func)(unsigned int nr, const char *fmt, unsigned long MyFlags,...); - void (*my_printv_error_func)(unsigned int error, const char *format, unsigned long MyFlags, va_list ap); -} *my_print_error_service; -extern void my_error(unsigned int nr, unsigned long MyFlags, ...); -extern void my_printf_error(unsigned int my_err, const char *format, unsigned long MyFlags, ...); -extern void my_printv_error(unsigned int error, const char *format, unsigned long MyFlags,va_list ap); -} -extern "C" { -extern struct my_snprintf_service_st { - size_t (*my_snprintf_type)(char*, size_t, const char*, ...); - size_t (*my_vsnprintf_type)(char *, size_t, const char*, va_list); -} *my_snprintf_service; -size_t my_snprintf(char* to, size_t n, const char* fmt, ...); -size_t my_vsnprintf(char *to, size_t n, const char* fmt, va_list ap); -} -extern "C" { -extern struct progress_report_service_st { - void (*thd_progress_init_func)(THD* thd, unsigned int max_stage); - void (*thd_progress_report_func)(THD* thd, - unsigned long long progress, - unsigned long long max_progress); - void (*thd_progress_next_stage_func)(THD* thd); - void (*thd_progress_end_func)(THD* thd); - const char *(*set_thd_proc_info_func)(THD*, const char *info, - const char *func, - const char *file, - unsigned int line); -} *progress_report_service; -void thd_progress_init(THD* thd, unsigned int max_stage); -void thd_progress_report(THD* thd, - unsigned long long progress, - unsigned long long max_progress); -void thd_progress_next_stage(THD* thd); -void thd_progress_end(THD* thd); -const char *set_thd_proc_info(THD*, const char * info, const char *func, - const char *file, unsigned int line); -} -extern "C" { -extern struct my_sha1_service_st { - void (*my_sha1_type)(unsigned char*, const char*, size_t); - void (*my_sha1_multi_type)(unsigned char*, ...); - size_t (*my_sha1_context_size_type)(); - void (*my_sha1_init_type)(void *); - void (*my_sha1_input_type)(void *, const unsigned char *, size_t); - void (*my_sha1_result_type)(void *, unsigned char *); -} *my_sha1_service; -void my_sha1(unsigned char*, const char*, size_t); -void my_sha1_multi(unsigned char*, ...); -size_t my_sha1_context_size(); -void my_sha1_init(void *context); -void my_sha1_input(void *context, const unsigned char *buf, size_t len); -void my_sha1_result(void *context, unsigned char *digest); -} -extern "C" { -extern struct my_sha2_service_st { - void (*my_sha224_type)(unsigned char*, const char*, size_t); - void (*my_sha224_multi_type)(unsigned char*, ...); - size_t (*my_sha224_context_size_type)(); - void (*my_sha224_init_type)(void *); - void (*my_sha224_input_type)(void *, const unsigned char *, size_t); - void (*my_sha224_result_type)(void *, unsigned char *); - void (*my_sha256_type)(unsigned char*, const char*, size_t); - void (*my_sha256_multi_type)(unsigned char*, ...); - size_t (*my_sha256_context_size_type)(); - void (*my_sha256_init_type)(void *); - void (*my_sha256_input_type)(void *, const unsigned char *, size_t); - void (*my_sha256_result_type)(void *, unsigned char *); - void (*my_sha384_type)(unsigned char*, const char*, size_t); - void (*my_sha384_multi_type)(unsigned char*, ...); - size_t (*my_sha384_context_size_type)(); - void (*my_sha384_init_type)(void *); - void (*my_sha384_input_type)(void *, const unsigned char *, size_t); - void (*my_sha384_result_type)(void *, unsigned char *); - void (*my_sha512_type)(unsigned char*, const char*, size_t); - void (*my_sha512_multi_type)(unsigned char*, ...); - size_t (*my_sha512_context_size_type)(); - void (*my_sha512_init_type)(void *); - void (*my_sha512_input_type)(void *, const unsigned char *, size_t); - void (*my_sha512_result_type)(void *, unsigned char *); -} *my_sha2_service; -void my_sha224(unsigned char*, const char*, size_t); -void my_sha224_multi(unsigned char*, ...); -size_t my_sha224_context_size(); -void my_sha224_init(void *context); -void my_sha224_input(void *context, const unsigned char *buf, size_t len); -void my_sha224_result(void *context, unsigned char *digest); -void my_sha256(unsigned char*, const char*, size_t); -void my_sha256_multi(unsigned char*, ...); -size_t my_sha256_context_size(); -void my_sha256_init(void *context); -void my_sha256_input(void *context, const unsigned char *buf, size_t len); -void my_sha256_result(void *context, unsigned char *digest); -void my_sha384(unsigned char*, const char*, size_t); -void my_sha384_multi(unsigned char*, ...); -size_t my_sha384_context_size(); -void my_sha384_init(void *context); -void my_sha384_input(void *context, const unsigned char *buf, size_t len); -void my_sha384_result(void *context, unsigned char *digest); -void my_sha512(unsigned char*, const char*, size_t); -void my_sha512_multi(unsigned char*, ...); -size_t my_sha512_context_size(); -void my_sha512_init(void *context); -void my_sha512_input(void *context, const unsigned char *buf, size_t len); -void my_sha512_result(void *context, unsigned char *digest); -} -extern "C" { -struct st_mysql_lex_string -{ - char *str; - size_t length; -}; -typedef struct st_mysql_lex_string MYSQL_LEX_STRING; -struct st_mysql_const_lex_string -{ - const char *str; - size_t length; -}; -typedef struct st_mysql_const_lex_string MYSQL_CONST_LEX_STRING; -extern struct thd_alloc_service_st { - void *(*thd_alloc_func)(THD*, size_t); - void *(*thd_calloc_func)(THD*, size_t); - char *(*thd_strdup_func)(THD*, const char *); - char *(*thd_strmake_func)(THD*, const char *, size_t); - void *(*thd_memdup_func)(THD*, const void*, size_t); - MYSQL_CONST_LEX_STRING *(*thd_make_lex_string_func)(THD*, - MYSQL_CONST_LEX_STRING *, - const char *, size_t, int); -} *thd_alloc_service; -void *thd_alloc(THD* thd, size_t size); -void *thd_calloc(THD* thd, size_t size); -char *thd_strdup(THD* thd, const char *str); -char *thd_strmake(THD* thd, const char *str, size_t size); -void *thd_memdup(THD* thd, const void* str, size_t size); -MYSQL_CONST_LEX_STRING -*thd_make_lex_string(THD* thd, MYSQL_CONST_LEX_STRING *lex_str, - const char *str, size_t size, - int allocate_lex_string); -} -extern "C" { -extern struct thd_autoinc_service_st { - void (*thd_get_autoinc_func)(const THD* thd, - unsigned long* off, unsigned long* inc); -} *thd_autoinc_service; -void thd_get_autoinc(const THD* thd, - unsigned long* off, unsigned long* inc); -} -extern "C" { -extern struct thd_error_context_service_st { - const char *(*thd_get_error_message_func)(const THD* thd); - unsigned int (*thd_get_error_number_func)(const THD* thd); - unsigned long (*thd_get_error_row_func)(const THD* thd); - void (*thd_inc_error_row_func)(THD* thd); - char *(*thd_get_error_context_description_func)(THD* thd, - char *buffer, - unsigned int length, - unsigned int max_query_length); -} *thd_error_context_service; -const char *thd_get_error_message(const THD* thd); -unsigned int thd_get_error_number(const THD* thd); -unsigned long thd_get_error_row(const THD* thd); -void thd_inc_error_row(THD* thd); -char *thd_get_error_context_description(THD* thd, - char *buffer, unsigned int length, - unsigned int max_query_length); -} -extern "C" { -extern struct thd_rnd_service_st { - double (*thd_rnd_ptr)(THD* thd); - void (*thd_c_r_p_ptr)(THD* thd, char *to, size_t length); -} *thd_rnd_service; -double thd_rnd(THD* thd); -void thd_create_random_password(THD* thd, char *to, size_t length); -} -extern "C" { -typedef int MYSQL_THD_KEY_T; -extern struct thd_specifics_service_st { - int (*thd_key_create_func)(MYSQL_THD_KEY_T *key); - void (*thd_key_delete_func)(MYSQL_THD_KEY_T *key); - void *(*thd_getspecific_func)(THD* thd, MYSQL_THD_KEY_T key); - int (*thd_setspecific_func)(THD* thd, MYSQL_THD_KEY_T key, void *value); -} *thd_specifics_service; -int thd_key_create(MYSQL_THD_KEY_T *key); -void thd_key_delete(MYSQL_THD_KEY_T *key); -void* thd_getspecific(THD* thd, MYSQL_THD_KEY_T key); -int thd_setspecific(THD* thd, MYSQL_THD_KEY_T key, void *value); -} -typedef long my_time_t; -enum enum_mysql_timestamp_type -{ - MYSQL_TIMESTAMP_NONE= -2, MYSQL_TIMESTAMP_ERROR= -1, - MYSQL_TIMESTAMP_DATE= 0, MYSQL_TIMESTAMP_DATETIME= 1, MYSQL_TIMESTAMP_TIME= 2 -}; -typedef struct st_mysql_time -{ - unsigned int year, month, day, hour, minute, second; - unsigned long second_part; - my_bool neg; - enum enum_mysql_timestamp_type time_type; -} MYSQL_TIME; -extern "C" { -extern struct thd_timezone_service_st { - my_time_t (*thd_TIME_to_gmt_sec)(THD* thd, const MYSQL_TIME *ltime, unsigned int *errcode); - void (*thd_gmt_sec_to_TIME)(THD* thd, MYSQL_TIME *ltime, my_time_t t); -} *thd_timezone_service; -my_time_t thd_TIME_to_gmt_sec(THD* thd, const MYSQL_TIME *ltime, unsigned int *errcode); -void thd_gmt_sec_to_TIME(THD* thd, MYSQL_TIME *ltime, my_time_t t); -} -extern "C" { -typedef enum _thd_wait_type_e { - THD_WAIT_SLEEP= 1, - THD_WAIT_DISKIO= 2, - THD_WAIT_ROW_LOCK= 3, - THD_WAIT_GLOBAL_LOCK= 4, - THD_WAIT_META_DATA_LOCK= 5, - THD_WAIT_TABLE_LOCK= 6, - THD_WAIT_USER_LOCK= 7, - THD_WAIT_BINLOG= 8, - THD_WAIT_GROUP_COMMIT= 9, - THD_WAIT_SYNC= 10, - THD_WAIT_NET= 11, - THD_WAIT_LAST= 12 -} thd_wait_type; -extern struct thd_wait_service_st { - void (*thd_wait_begin_func)(THD*, int); - void (*thd_wait_end_func)(THD*); -} *thd_wait_service; -void thd_wait_begin(THD* thd, int wait_type); -void thd_wait_end(THD* thd); -} -extern "C" { -enum json_types -{ - JSV_BAD_JSON=-1, - JSV_NOTHING=0, - JSV_OBJECT=1, - JSV_ARRAY=2, - JSV_STRING=3, - JSV_NUMBER=4, - JSV_TRUE=5, - JSV_FALSE=6, - JSV_NULL=7 -}; -extern struct json_service_st { - enum json_types (*json_type)(const char *js, const char *js_end, - const char **value, int *value_len); - enum json_types (*json_get_array_item)(const char *js, const char *js_end, - int n_item, - const char **value, int *value_len); - enum json_types (*json_get_object_key)(const char *js, const char *js_end, - const char *key, - const char **value, int *value_len); - enum json_types (*json_get_object_nkey)(const char *js,const char *js_end, - int nkey, - const char **keyname, const char **keyname_end, - const char **value, int *value_len); - int (*json_escape_string)(const char *str,const char *str_end, - char *json, char *json_end); - int (*json_unescape_json)(const char *json_str, const char *json_end, - char *res, char *res_end); -} *json_service; -enum json_types json_type(const char *js, const char *js_end, - const char **value, int *value_len); -enum json_types json_get_array_item(const char *js, const char *js_end, - int n_item, - const char **value, int *value_len); -enum json_types json_get_object_key(const char *js, const char *js_end, - const char *key, - const char **value, int *value_len); -enum json_types json_get_object_nkey(const char *js,const char *js_end, int nkey, - const char **keyname, const char **keyname_end, - const char **value, int *value_len); -int json_escape_string(const char *str,const char *str_end, - char *json, char *json_end); -int json_unescape_json(const char *json_str, const char *json_end, - char *res, char *res_end); -} -} -struct st_mysql_xid { - long formatID; - long gtrid_length; - long bqual_length; - char data[128]; -}; -typedef struct st_mysql_xid MYSQL_XID; -enum enum_mysql_show_type -{ - SHOW_UNDEF, SHOW_BOOL, SHOW_UINT, SHOW_ULONG, - SHOW_ULONGLONG, SHOW_CHAR, SHOW_CHAR_PTR, - SHOW_ARRAY, SHOW_FUNC, SHOW_DOUBLE, - SHOW_SINT, SHOW_SLONG, SHOW_SLONGLONG, SHOW_SIMPLE_FUNC, - SHOW_SIZE_T, SHOW_always_last -}; -enum enum_var_type -{ - SHOW_OPT_DEFAULT= 0, SHOW_OPT_SESSION, SHOW_OPT_GLOBAL -}; -struct st_mysql_show_var { - const char *name; - void *value; - enum enum_mysql_show_type type; -}; -struct system_status_var; -typedef int (*mysql_show_var_func)(THD*, struct st_mysql_show_var*, void *, struct system_status_var *status_var, enum enum_var_type); -struct st_mysql_sys_var; -struct st_mysql_value; -typedef int (*mysql_var_check_func)(THD* thd, - struct st_mysql_sys_var *var, - void *save, struct st_mysql_value *value); -typedef void (*mysql_var_update_func)(THD* thd, - struct st_mysql_sys_var *var, - void *var_ptr, const void *save); -struct st_mysql_plugin -{ - int type; - void *info; - const char *name; - const char *author; - const char *descr; - int license; - int (*init)(void *); - int (*deinit)(void *); - unsigned int version; - struct st_mysql_show_var *status_vars; - struct st_mysql_sys_var **system_vars; - void * __reserved1; - unsigned long flags; -}; -struct st_maria_plugin -{ - int type; - void *info; - const char *name; - const char *author; - const char *descr; - int license; - int (*init)(void *); - int (*deinit)(void *); - unsigned int version; - struct st_mysql_show_var *status_vars; - struct st_mysql_sys_var **system_vars; - const char *version_info; - unsigned int maturity; -}; -extern "C" { -enum enum_ftparser_mode -{ - MYSQL_FTPARSER_SIMPLE_MODE= 0, - MYSQL_FTPARSER_WITH_STOPWORDS= 1, - MYSQL_FTPARSER_FULL_BOOLEAN_INFO= 2 -}; -enum enum_ft_token_type -{ - FT_TOKEN_EOF= 0, - FT_TOKEN_WORD= 1, - FT_TOKEN_LEFT_PAREN= 2, - FT_TOKEN_RIGHT_PAREN= 3, - FT_TOKEN_STOPWORD= 4 -}; -typedef struct st_mysql_ftparser_boolean_info -{ - enum enum_ft_token_type type; - int yesno; - int weight_adjust; - char wasign; - char trunc; - char prev; - char *quot; -} MYSQL_FTPARSER_BOOLEAN_INFO; -typedef struct st_mysql_ftparser_param -{ - int (*mysql_parse)(struct st_mysql_ftparser_param *, - const char *doc, int doc_len); - int (*mysql_add_word)(struct st_mysql_ftparser_param *, - const char *word, int word_len, - MYSQL_FTPARSER_BOOLEAN_INFO *boolean_info); - void *ftparser_state; - void *mysql_ftparam; - const struct charset_info_st *cs; - const char *doc; - int length; - unsigned int flags; - enum enum_ftparser_mode mode; -} MYSQL_FTPARSER_PARAM; -struct st_mysql_ftparser -{ - int interface_version; - int (*parse)(MYSQL_FTPARSER_PARAM *param); - int (*init)(MYSQL_FTPARSER_PARAM *param); - int (*deinit)(MYSQL_FTPARSER_PARAM *param); -}; -} -struct st_mysql_daemon -{ - int interface_version; -}; -struct st_mysql_information_schema -{ - int interface_version; -}; -struct st_mysql_storage_engine -{ - int interface_version; -}; -struct handlerton; - struct Mysql_replication { - int interface_version; - }; -struct st_mysql_value -{ - int (*value_type)(struct st_mysql_value *); - const char *(*val_str)(struct st_mysql_value *, char *buffer, int *length); - int (*val_real)(struct st_mysql_value *, double *realbuf); - int (*val_int)(struct st_mysql_value *, long long *intbuf); - int (*is_unsigned)(struct st_mysql_value *); -}; -extern "C" { -int thd_in_lock_tables(const THD* thd); -int thd_tablespace_op(const THD* thd); -long long thd_test_options(const THD* thd, long long test_options); -int thd_sql_command(const THD* thd); -void thd_storage_lock_wait(THD* thd, long long value); -int thd_tx_isolation(const THD* thd); -int thd_tx_is_read_only(const THD* thd); -int mysql_tmpfile(const char *prefix); -unsigned long thd_get_thread_id(const THD* thd); -void thd_get_xid(const THD* thd, MYSQL_XID *xid); -void mysql_query_cache_invalidate4(THD* thd, - const char *key, unsigned int key_length, - int using_trx); -void *thd_get_ha_data(const THD* thd, const struct handlerton *hton); -void thd_set_ha_data(THD* thd, const struct handlerton *hton, - const void *ha_data); -void thd_wakeup_subsequent_commits(THD* thd, int wakeup_error); -} -class Native_func_registry_array -{ - const Native_func_registry *m_elements; - size_t m_count; -public: - Native_func_registry_array() - :m_elements(NULL), - m_count(0) - { } - Native_func_registry_array(const Native_func_registry *elements, size_t count) - :m_elements(elements), - m_count(count) - { } - const Native_func_registry& element(size_t i) const - { - DBUG_ASSERT(i < m_count); - return m_elements[i]; - } - size_t count() const { return m_count; } -}; -class Plugin_function_collection -{ - int m_interface_version; - const Native_func_registry_array m_native_func_registry_array; - HASH m_hash; -public: - bool init(); - void deinit() - { - my_hash_free(&m_hash); - } - static int init_plugin(st_plugin_int *plugin) - { - Plugin_function_collection *coll= - reinterpret_cast<Plugin_function_collection*>(plugin->plugin->info); - return coll->init(); - } - static int deinit_plugin(st_plugin_int *plugin) - { - Plugin_function_collection *coll= - reinterpret_cast<Plugin_function_collection*>(plugin->plugin->info); - coll->deinit(); - return 0; - } -public: - Plugin_function_collection(int interface_version, - const Native_func_registry_array &nfra) - :m_interface_version(interface_version), - m_native_func_registry_array(nfra) - { - bzero((void*) &m_hash, sizeof(m_hash)); - } - Create_func *find_native_function_builder(THD *thd, - const LEX_CSTRING &name) const; -}; diff --git a/sql/item_create.cc b/sql/item_create.cc index 246850d9548..486f4fc591e 100644 --- a/sql/item_create.cc +++ b/sql/item_create.cc @@ -36,7 +36,6 @@ #include "sql_time.h" #include "sql_type_geom.h" #include <mysql/plugin_function.h> -#include <mysql/plugin_function_collection.h> extern "C" uchar* @@ -49,80 +48,22 @@ get_native_fct_hash_key(const uchar *buff, size_t *length, } -bool Plugin_function_collection::init() +bool Native_func_registry_array::append_to_hash(HASH *hash) const { - DBUG_ENTER("Plugin_function_collection::init"); - if (my_hash_init(&m_hash, - system_charset_info, - (ulong) m_native_func_registry_array.count(), - 0, - 0, - (my_hash_get_key) get_native_fct_hash_key, - NULL, /* Nothing to free */ - MYF(0))) - DBUG_RETURN(true); - - for (size_t i= 0; i < m_native_func_registry_array.count(); i++) + DBUG_ENTER("Native_func_registry_array::append_to_hash"); + for (size_t i= 0; i < count(); i++) { - const Native_func_registry &func= m_native_func_registry_array.element(i); + const Native_func_registry &func= element(i); DBUG_ASSERT(func.builder != NULL); - if (my_hash_insert(&m_hash, (uchar*) &func)) + if (my_hash_insert(hash, (uchar*) &func)) DBUG_RETURN(true); } - DBUG_RETURN(false); } -Create_func * -Plugin_function_collection::find_native_function_builder(THD *thd, - const LEX_CSTRING &name) - const -{ - const Native_func_registry *func; - func= (const Native_func_registry*) my_hash_search(&m_hash, - (uchar*) name.str, - name.length); - return func ? func->builder : NULL; -} - - -class Plugin_find_native_func_builder_param -{ - bool find_native_function_builder(THD *thd, - const Plugin_function_collection *pfc) - { - // plugin_foreach() will stop iterating when this function returns TRUE - return ((builder= pfc->find_native_function_builder(thd, name))) != NULL; - } - static my_bool find_in_plugin(THD *thd, plugin_ref plugin, void *data) - { - Plugin_find_native_func_builder_param *param= - reinterpret_cast<Plugin_find_native_func_builder_param*>(data); - const Plugin_function_collection *fc= - reinterpret_cast<Plugin_function_collection*> - (plugin_decl(plugin)->info); - return param->find_native_function_builder(thd, fc); - } -public: - LEX_CSTRING name; - Create_func *builder; - Plugin_find_native_func_builder_param(const LEX_CSTRING &name_arg) - :name(name_arg), builder(NULL) - { } - Create_func *find(THD *thd) - { - if (!plugin_foreach(thd, - Plugin_find_native_func_builder_param::find_in_plugin, - MariaDB_FUNCTION_COLLECTION_PLUGIN, this)) - return NULL; - return builder; - } -}; - - #ifdef HAVE_SPATIAL -extern Plugin_function_collection plugin_function_collection_geometry; +extern Native_func_registry_array native_func_registry_array_geom; #endif @@ -5633,11 +5574,12 @@ static Native_func_registry func_array[] = { { STRING_WITH_LEN("WSREP_LAST_SEEN_GTID") }, BUILDER(Create_func_wsrep_last_seen_gtid)}, { { STRING_WITH_LEN("WSREP_SYNC_WAIT_UPTO_GTID") }, BUILDER(Create_func_wsrep_sync_wait_upto)}, #endif /* WITH_WSREP */ - { { STRING_WITH_LEN("YEARWEEK") }, BUILDER(Create_func_year_week)}, - - { {0, 0}, NULL} + { { STRING_WITH_LEN("YEARWEEK") }, BUILDER(Create_func_year_week)} }; +Native_func_registry_array + native_func_registry_array(func_array, array_elements(func_array)); + static HASH native_functions_hash; /* @@ -5649,10 +5591,13 @@ static HASH native_functions_hash; int item_create_init() { DBUG_ENTER("item_create_init"); - + size_t count= native_func_registry_array.count(); +#ifdef HAVE_SPATIAL + count+= native_func_registry_array_geom.count(); +#endif if (my_hash_init(& native_functions_hash, system_charset_info, - array_elements(func_array), + (ulong) count, 0, 0, (my_hash_get_key) get_native_fct_hash_key, @@ -5660,17 +5605,33 @@ int item_create_init() MYF(0))) DBUG_RETURN(1); - if (item_create_append(func_array)) + if (native_func_registry_array.append_to_hash(&native_functions_hash)) DBUG_RETURN(1); #ifdef HAVE_SPATIAL - if (plugin_function_collection_geometry.init()) + if (native_func_registry_array_geom.append_to_hash(&native_functions_hash)) DBUG_RETURN(1); #endif +#ifndef DBUG_OFF + for (uint i=0 ; i < native_functions_hash.records ; i++) + { + Native_func_registry *func; + func= (Native_func_registry*) my_hash_element(& native_functions_hash, i); + DBUG_PRINT("info", ("native function: %s length: %u", + func->name.str, (uint) func->name.length)); + } +#endif + DBUG_RETURN(0); } + +/* + This function is used (dangerously) by plugin/versioning/versioning.cc + TODO: MDEV-20842 Wrap SQL functions defined in + plugin/versioning/versioning.cc into MariaDB_FUNCTION_PLUGIN +*/ int item_create_append(Native_func_registry array[]) { Native_func_registry *func; @@ -5683,15 +5644,6 @@ int item_create_append(Native_func_registry array[]) DBUG_RETURN(1); } -#ifndef DBUG_OFF - for (uint i=0 ; i < native_functions_hash.records ; i++) - { - func= (Native_func_registry*) my_hash_element(& native_functions_hash, i); - DBUG_PRINT("info", ("native function: %s length: %u", - func->name.str, (uint) func->name.length)); - } -#endif - DBUG_RETURN(0); } @@ -5705,9 +5657,6 @@ void item_create_cleanup() { DBUG_ENTER("item_create_cleanup"); my_hash_free(& native_functions_hash); -#ifdef HAVE_SPATIAL - plugin_function_collection_geometry.deinit(); -#endif DBUG_VOID_RETURN; } @@ -5746,16 +5695,7 @@ find_native_function_builder(THD *thd, const LEX_CSTRING *name) if ((builder= function_plugin_find_native_function_builder(thd, *name))) return builder; - if ((builder= Plugin_find_native_func_builder_param(*name).find(thd))) - return builder; - -#ifdef HAVE_SPATIAL - if (!builder) - builder= plugin_function_collection_geometry. - find_native_function_builder(thd, *name); -#endif - - return builder; + return NULL; } Create_qfunc * diff --git a/sql/item_create.h b/sql/item_create.h index 3cbf8a70181..c9bdb23dffe 100644 --- a/sql/item_create.h +++ b/sql/item_create.h @@ -315,5 +315,30 @@ Item *create_func_dyncol_get(THD *thd, Item *num, Item *str, const char *c_len, const char *c_dec, CHARSET_INFO *cs); Item *create_func_dyncol_json(THD *thd, Item *str); + + +class Native_func_registry_array +{ + const Native_func_registry *m_elements; + size_t m_count; +public: + Native_func_registry_array() + :m_elements(NULL), + m_count(0) + { } + Native_func_registry_array(const Native_func_registry *elements, size_t count) + :m_elements(elements), + m_count(count) + { } + const Native_func_registry& element(size_t i) const + { + DBUG_ASSERT(i < m_count); + return m_elements[i]; + } + size_t count() const { return m_count; } + bool append_to_hash(HASH *hash) const; +}; + + #endif diff --git a/sql/item_geofunc.cc b/sql/item_geofunc.cc index 541edf6a3b5..c107c93d584 100644 --- a/sql/item_geofunc.cc +++ b/sql/item_geofunc.cc @@ -39,7 +39,7 @@ #include <m_ctype.h> #include "opt_range.h" #include "item_geofunc.h" -#include <mysql/plugin_function_collection.h> +#include "item_create.h" bool Item_geometry_func::fix_length_and_dec() @@ -3733,16 +3733,6 @@ Create_func_y Create_func_y::s_singleton; /*************************************************************************/ -class FHash: public HASH -{ -public: - FHash() - { - bzero((HASH *) this, sizeof(HASH)); - } -}; - - #define GEOM_BUILDER(F) & F::s_singleton @@ -3907,10 +3897,8 @@ static Native_func_registry func_array_geom[] = }; -Plugin_function_collection - plugin_function_collection_geometry( - MariaDB_FUNCTION_COLLECTION_INTERFACE_VERSION, - Native_func_registry_array(func_array_geom, - array_elements(func_array_geom))); +Native_func_registry_array + native_func_registry_array_geom(func_array_geom, + array_elements(func_array_geom)); #endif /*HAVE_SPATIAL*/ diff --git a/sql/sql_plugin.cc b/sql/sql_plugin.cc index 2beb9fa0267..1ba8137acf5 100644 --- a/sql/sql_plugin.cc +++ b/sql/sql_plugin.cc @@ -40,7 +40,6 @@ #include <mysql/plugin_encryption.h> #include <mysql/plugin_data_type.h> #include <mysql/plugin_function.h> -#include <mysql/plugin_function_collection.h> #include "sql_plugin_compat.h" #ifdef HAVE_LINK_H @@ -95,8 +94,7 @@ const LEX_CSTRING plugin_type_names[MYSQL_MAX_PLUGIN_TYPE_NUM]= { STRING_WITH_LEN("PASSWORD VALIDATION") }, { STRING_WITH_LEN("ENCRYPTION") }, { STRING_WITH_LEN("DATA TYPE") }, - { STRING_WITH_LEN("FUNCTION") }, - { STRING_WITH_LEN("FUNCTION COLLECTION") } + { STRING_WITH_LEN("FUNCTION") } }; extern int initialize_schema_table(st_plugin_int *plugin); @@ -117,16 +115,14 @@ plugin_type_init plugin_type_initialize[MYSQL_MAX_PLUGIN_TYPE_NUM]= { 0, ha_initialize_handlerton, 0, 0,initialize_schema_table, initialize_audit_plugin, 0, 0, 0, initialize_encryption_plugin, 0, - 0, // FUNCTION - Plugin_function_collection::init_plugin + 0 // FUNCTION }; plugin_type_init plugin_type_deinitialize[MYSQL_MAX_PLUGIN_TYPE_NUM]= { 0, ha_finalize_handlerton, 0, 0, finalize_schema_table, finalize_audit_plugin, 0, 0, 0, finalize_encryption_plugin, 0, - 0, // FUNCTION - Plugin_function_collection::deinit_plugin + 0 // FUNCTION }; /* @@ -140,7 +136,6 @@ static int plugin_type_initialization_order[MYSQL_MAX_PLUGIN_TYPE_NUM]= MariaDB_ENCRYPTION_PLUGIN, MariaDB_DATA_TYPE_PLUGIN, MariaDB_FUNCTION_PLUGIN, - MariaDB_FUNCTION_COLLECTION_PLUGIN, MYSQL_STORAGE_ENGINE_PLUGIN, MYSQL_INFORMATION_SCHEMA_PLUGIN, MYSQL_FTPARSER_PLUGIN, @@ -184,8 +179,7 @@ static int min_plugin_info_interface_version[MYSQL_MAX_PLUGIN_TYPE_NUM]= MariaDB_PASSWORD_VALIDATION_INTERFACE_VERSION, MariaDB_ENCRYPTION_INTERFACE_VERSION, MariaDB_DATA_TYPE_INTERFACE_VERSION, - MariaDB_FUNCTION_INTERFACE_VERSION, - MariaDB_FUNCTION_COLLECTION_INTERFACE_VERSION + MariaDB_FUNCTION_INTERFACE_VERSION }; static int cur_plugin_info_interface_version[MYSQL_MAX_PLUGIN_TYPE_NUM]= { @@ -200,8 +194,7 @@ static int cur_plugin_info_interface_version[MYSQL_MAX_PLUGIN_TYPE_NUM]= MariaDB_PASSWORD_VALIDATION_INTERFACE_VERSION, MariaDB_ENCRYPTION_INTERFACE_VERSION, MariaDB_DATA_TYPE_INTERFACE_VERSION, - MariaDB_FUNCTION_INTERFACE_VERSION, - MariaDB_FUNCTION_COLLECTION_INTERFACE_VERSION + MariaDB_FUNCTION_INTERFACE_VERSION }; static struct |