File db_admin.c¶

FileList > compat > db_admin.c

#include "config.h"
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <ctype.h>
#include <assert.h>
#include <signal.h>
#include "authenticate.h"
#include "client_support.h"
#include "porting.h"
#include "system_parameter.h"
#include "storage_common.h"
#include "environment_variable.h"
#include "db.h"
#include "class_object.h"
#include "object_print.h"
#include "server_interface.h"
#include "boot_cl.h"
#include "locator_cl.h"
#include "optimizer.h"
#include "schema_manager.h"
#include "schema_template.h"
#include "object_accessor.h"
#include "set_object.h"
#include "virtual_object.h"
#include "parser.h"
#include "memory_alloc.h"
#include "execute_schema.h"
#include "network_interface_cl.h"
#include "pl_sr.h"
#include "jsp_cl.h"
#include "execute_statement.h"
#include "connection_support.hpp"
#include "trigger_manager.h"
#include "dbtype.h"
#include "method_callback.hpp"
#include "filesys_temp.hpp"
#include "tcp.h"

Classes¶

Type	Name
struct	db_host_status
struct	db_host_status_list

Public Types¶

Type	Name
typedef struct db_host_status	DB_HOST_STATUS
typedef struct db_host_status_list	DB_HOST_STATUS_LIST

Public Attributes¶

Type	Name
char	db_Client_ip_addr = `{ 0 }`
char	db_Database_name
char	db_Program_name
void(*	prev_sigfpe_handler = `[SIG\_DFL](broker__monitor_8c.md#function-timeout)`

Public Static Attributes¶

Type	Name
CUBRID_STMT_TYPE	db_Client_statement_type = `CUBRID\_STMT\_NONE`
int	db_Client_type = `DB\_CLIENT\_TYPE\_DEFAULT`
int	db_Connect_order = `[DB\_CONNECT\_ORDER\_SEQ](connection__cl_8h.md#define-db_connect_order_seq)`
int	db_Delayed_hosts_count = `0`
DB_HOST_STATUS_LIST	db_Host_status_list
int	db_Max_num_delayed_hosts_lookup = `0`
char *	db_Preferred_hosts = `[NULL](freelistheap_8h.md#define-null)`
int	is_doing_end_session = `-1`

Public Functions¶

Type	Name
int	db_2pc_attach_transaction (int global_transaction_id)
int	db_2pc_prepare_to_commit_transaction (int global_transaction_id)
int	db_2pc_prepare_transaction (void)
int	db_2pc_prepared_transactions (int gtrids, int size)
int	db_2pc_start_transaction (void)
int	db_abort_to_savepoint (const char * savepoint_name)
int	db_abort_to_savepoint_internal (const char * savepoint_name)
int	db_abort_transaction (void)
int	db_add_member (DB_OBJECT * user, DB_OBJECT * member)
DB_OBJECT *	db_add_user (const char * name, int * exists)
int	db_add_volume (const char * ext_path, const char * ext_name, const char * ext_comments, const int ext_npages, const DB_VOLPURPOSE ext_purpose)
int	db_add_volume_ex (DBDEF_VOL_EXT_INFO * ext_info)
int	db_check_authorization (MOP op, DB_AUTH auth)
int	db_check_authorization_and_grant_option (MOP op, DB_AUTH auth)
int	db_checkpoint (void)
int	db_chn (DB_OBJECT * obj, DB_FETCH_MODE purpose)
void	db_clear_delayed_hosts_count (void)
void	db_clear_host_connected (void)
void	db_clear_host_status (void)
bool	db_client_type_is_loaddb (void)
bool	db_client_type_is_loaddb_compat (void)
int	db_commit_is_needed (void)
int	db_commit_transaction (void)
int	db_disable_modification (void)
bool	db_disable_trigger (void)
bool	db_does_connected_host_have_status (int status)
int	db_drop_member (DB_OBJECT * user, DB_OBJECT * member)
int	db_drop_user (DB_OBJECT * user)
int	db_enable_modification (void)
bool	db_enable_trigger (void)
int	db_end_session (void)
int	db_error_code (void)
int	db_error_code_test (void)
int	db_error_init (const char * logfile)
const char *	db_error_string (int level)
const char *	db_error_string_test (int level)
int	db_fetch_array (DB_OBJECT objects, DB_FETCH_MODE purpose, int** quit_on_error)
int	db_fetch_composition (DB_OBJECT * object, DB_FETCH_MODE purpose, int max_level, int quit_on_error)
int	db_fetch_list (DB_OBJLIST * objects, DB_FETCH_MODE purpose, int quit_on_error)
int	db_fetch_seq (DB_SEQ * seq, DB_FETCH_MODE purpose, int quit_on_error)
int	db_fetch_set (DB_SET * set, DB_FETCH_MODE purpose, int quit_on_error)
int	db_find_or_create_session (const char * db_user, const char * program_name)
DB_OBJECT *	db_find_user (const char * name)
int	db_find_user_to_drop (const char * name, DB_OBJECT ** user)
void	db_flush_static_methods (void)
void	db_force_method_reload (MOP obj)
int	db_freepgs (const char * volume_label)
char *	db_get_client_ip_addr (void)
CUBRID_STMT_TYPE	db_get_client_statement_type (void)
int	db_get_client_type (void)
const char *	db_get_database_comments (void)
char *	db_get_database_name (void)
char *	db_get_database_version (void)
int	db_get_delayed_hosts_count (void)
int	db_get_global_transaction_info (int global_transaction_id, void * buffer, int size)
int	db_get_ha_server_state (char * buffer, int maxlen)
char *	db_get_host_connected (void)
int	db_get_host_list_with_given_status (char hostlist, int list_size, int** status)
bool	db_get_keep_session (void)
int	db_get_last_insert_id (DB_VALUE * value)
int	db_get_max_num_delayed_hosts_lookup (void)
DB_OBJECT_TYPE	db_get_object_type (MOP obj_)
DB_OBJECT *	db_get_owner (DB_OBJECT * class_obj)
int	db_get_row_count (int * row_count)
int	db_get_row_count_cache (void)
char *	db_get_server_session_key (void)
SESSION_ID	db_get_session_id (void)
int	db_get_system_parameters (char * data, int len)
void	db_get_tran_settings (int * lock_wait, DB_TRAN_ISOLATION * tran_isolation)
DB_OBJECT *	db_get_user (void)
char *	db_get_user_and_host_name (void)
char *	db_get_user_name (void)
int	db_get_variable (DB_VALUE * name, DB_VALUE * value)
int	db_grant (MOP user, MOP obj_, AU_TYPE auth, int grant_option)
int	db_grant_object (DB_OBJECT_TYPE object_type, DB_OBJECT * user, DB_OBJECT * obj_, DB_AUTH auth, int grant_option)
DB_IDENTIFIER *	db_identifier (DB_OBJECT * obj)
int	db_init (const char * program, int print_version, const char * dbname, const char * db_path, const char * vol_path, const char * log_path, const char * lob_path, const char * host_name, const bool overwrite, const char * comments, const char * addmore_vols_file, int npages, int desired_pagesize, int log_npages, int desired_log_page_size, const char * lang_charset)
int	db_last_volume (void)
void	db_link_static_methods (DB_METHOD_LINK * methods)
int	db_lock_read (DB_OBJECT * op)
int	db_lock_write (DB_OBJECT * op)
int	db_login (const char * name, const char * password)
bool	db_need_ignore_repl_delay (void)
bool	db_need_reconnect (void)
int	db_num_volumes (void)
DB_OBJECT *	db_object (DB_IDENTIFIER * oid)
void	db_objlist_free (DB_OBJLIST * list)
int	db_ping_server (int client_val, int * server_val)
void	db_preload_classes (const char * name1, ...)
void	db_print_stats (void)
db_error_log_handler_t	db_register_error_log_handler (db_error_log_handler_t f)
int	db_reset_latest_query_status (void)
int	db_reset_system_parameters_from_assignments (const char * data)
int	db_restart (const char * program, int print_version, const char * volume)
int	db_restart_ex (const char * program, const char * db_name, const char * db_user, const char * db_password, const char * preferred_hosts, int client_type)
int	db_revoke (MOP user, MOP obj_, AU_TYPE auth)
int	db_revoke_object (DB_OBJECT_TYPE object_type, MOP user, MOP obj_, AU_TYPE auth)
int	db_savepoint_transaction (const char * savepoint_name)
int	db_savepoint_transaction_internal (const char * savepoint_name)
void	db_set_client_ip_addr (const char * ip_addr)
void	db_set_client_statement_type (CUBRID_STMT_TYPE statement_type)
void	db_set_client_type (int client_type)
void	db_set_connect_order (int connect_order)
void	db_set_connected_host_status (char * host_connected)
int	db_set_global_transaction_info (int global_transaction_id, void * info, int size)
void	db_set_host_status (char * hostname, int status)
void	db_set_interrupt (int set)
int	db_set_isolation (DB_TRAN_ISOLATION isolation)
void	db_set_keep_session (const bool keep_session)
int	db_set_lock_timeout (int seconds)
void	db_set_max_num_delayed_hosts_lookup (int max_num_delayed_hosts_lookup)
int	db_set_password (DB_OBJECT * user, const char * old_passwd, const char * new_passwd)
void	db_set_preferred_hosts (const char * hosts)
void	db_set_server_session_key (const char * key)
void	db_set_session_id (const SESSION_ID session_id)
int	db_set_suppress_repl_on_transaction (int set)
int	db_set_system_parameters (const char * data)
int	db_set_system_parameters_for_ha_repl (const char * data)
int	db_set_user_comment (DB_OBJECT * user, const char * comment)
int	db_shutdown (void)
void	db_shutdown_without_request_to_server (void)
void	db_string_free (char * string)
void	db_synchronize_cache (void)
int	db_totalpgs (const char * volume_label)
void	db_unlink_static_methods (DB_METHOD_LINK * methods)
void	db_update_row_count_cache (const int row_count)
char *	db_vol_label (int volid, char * vol_fullname)
void	db_warnspace (const char * volume_label)
void	sigfpe_handler (int sig)

Public Static Functions¶

Type	Name
DB_HOST_STATUS *	db_add_host_status (char * hostname, int status)
DB_HOST_STATUS *	db_find_host_status (char * hostname)
int	fetch_set_internal (DB_SET * set, DB_FETCH_MODE purpose, int quit_on_error)
void	install_static_methods (void)

Public Types Documentation¶

typedef DB_HOST_STATUS¶

typedef struct db_host_status DB_HOST_STATUS;

typedef DB_HOST_STATUS_LIST¶

typedef struct db_host_status_list DB_HOST_STATUS_LIST;

Public Attributes Documentation¶

variable db_Client_ip_addr¶

char db_Client_ip_addr[16];

variable db_Database_name¶

char db_Database_name[255+1];

variable db_Program_name¶

char db_Program_name[PATH_MAX];

variable prev_sigfpe_handler¶

void(* prev_sigfpe_handler) (int);

Public Static Attributes Documentation¶

variable db_Client_statement_type¶

CUBRID_STMT_TYPE db_Client_statement_type;

variable db_Client_type¶

int db_Client_type;

variable db_Connect_order¶

int db_Connect_order;

variable db_Delayed_hosts_count¶

int db_Delayed_hosts_count;

variable db_Host_status_list¶

DB_HOST_STATUS_LIST db_Host_status_list;

variable db_Max_num_delayed_hosts_lookup¶

int db_Max_num_delayed_hosts_lookup;

variable db_Preferred_hosts¶

char* db_Preferred_hosts;

variable is_doing_end_session¶

int is_doing_end_session;

Public Functions Documentation¶

function db_2pc_attach_transaction¶

int db_2pc_attach_transaction (
    int global_transaction_id
)

function db_2pc_prepare_to_commit_transaction¶

int db_2pc_prepare_to_commit_transaction (
    int global_transaction_id
)

function db_2pc_prepare_transaction¶

int db_2pc_prepare_transaction (
    void
)

function db_2pc_prepared_transactions¶

int db_2pc_prepared_transactions (
    int gtrids,
    int size
)

function db_2pc_start_transaction¶

int db_2pc_start_transaction (
    void
)

function db_abort_to_savepoint¶

int db_abort_to_savepoint (
    const  char * savepoint_name
)

function db_abort_to_savepoint_internal¶

int db_abort_to_savepoint_internal (
    const  char * savepoint_name
)

function db_abort_transaction¶

int db_abort_transaction (
    void
)

function db_add_member¶

int db_add_member (
    DB_OBJECT * user,
    DB_OBJECT * member
)

function db_add_user¶

DB_OBJECT * db_add_user (
    const  char * name,
    int * exists
)

function db_add_volume¶

int db_add_volume (
    const  char * ext_path,
    const  char * ext_name,
    const  char * ext_comments,
    const  int ext_npages,
    const  DB_VOLPURPOSE ext_purpose
)

function db_add_volume_ex¶

int db_add_volume_ex (
    DBDEF_VOL_EXT_INFO * ext_info
)

function db_check_authorization¶

int db_check_authorization (
    MOP op,
    DB_AUTH auth
)

function db_check_authorization_and_grant_option¶

int db_check_authorization_and_grant_option (
    MOP op,
    DB_AUTH auth
)

function db_checkpoint¶

int db_checkpoint (
    void
)

function db_chn¶

int db_chn (
    DB_OBJECT * obj,
    DB_FETCH_MODE purpose
)

function db_clear_delayed_hosts_count¶

void db_clear_delayed_hosts_count (
    void
)

function db_clear_host_connected¶

void db_clear_host_connected (
    void
)

function db_clear_host_status¶

void db_clear_host_status (
    void
)

function db_client_type_is_loaddb¶

bool db_client_type_is_loaddb (
    void
)

function db_client_type_is_loaddb_compat¶

bool db_client_type_is_loaddb_compat (
    void
)

function db_commit_is_needed¶

int db_commit_is_needed (
    void
)

function db_commit_transaction¶

int db_commit_transaction (
    void
)

function db_disable_modification¶

int db_disable_modification (
    void
)

function db_disable_trigger¶

bool db_disable_trigger (
    void
)

function db_does_connected_host_have_status¶

bool db_does_connected_host_have_status (
    int status
)

function db_drop_member¶

int db_drop_member (
    DB_OBJECT * user,
    DB_OBJECT * member
)

function db_drop_user¶

int db_drop_user (
    DB_OBJECT * user
)

function db_enable_modification¶

int db_enable_modification (
    void
)

function db_enable_trigger¶

bool db_enable_trigger (
    void
)

function db_end_session¶

int db_end_session (
    void
)

function db_error_code¶

int db_error_code (
    void
)

function db_error_code_test¶

int db_error_code_test (
    void
)

function db_error_init¶

int db_error_init (
    const  char * logfile
)

function db_error_string¶

const  char * db_error_string (
    int level
)

function db_error_string_test¶

const  char * db_error_string_test (
    int level
)

function db_fetch_array¶

int db_fetch_array (
    DB_OBJECT ** objects,
    DB_FETCH_MODE purpose,
    int quit_on_error
)

function db_fetch_composition¶

int db_fetch_composition (
    DB_OBJECT * object,
    DB_FETCH_MODE purpose,
    int max_level,
    int quit_on_error
)

function db_fetch_list¶

int db_fetch_list (
    DB_OBJLIST * objects,
    DB_FETCH_MODE purpose,
    int quit_on_error
)

function db_fetch_seq¶

int db_fetch_seq (
    DB_SEQ * seq,
    DB_FETCH_MODE purpose,
    int quit_on_error
)

function db_fetch_set¶

int db_fetch_set (
    DB_SET * set,
    DB_FETCH_MODE purpose,
    int quit_on_error
)

function db_find_or_create_session¶

int db_find_or_create_session (
    const  char * db_user,
    const  char * program_name
)

function db_find_user¶

DB_OBJECT * db_find_user (
    const  char * name
)

function db_find_user_to_drop¶

int db_find_user_to_drop (
    const  char * name,
    DB_OBJECT ** user
)

function db_flush_static_methods¶

void db_flush_static_methods (
    void
)

function db_force_method_reload¶

void db_force_method_reload (
    MOP obj
)

function db_freepgs¶

int db_freepgs (
    const  char * volume_label
)

function db_get_client_ip_addr¶

char * db_get_client_ip_addr (
    void
)

function db_get_client_statement_type¶

CUBRID_STMT_TYPE db_get_client_statement_type (
    void
)

function db_get_client_type¶

int db_get_client_type (
    void
)

function db_get_database_comments¶

const  char * db_get_database_comments (
    void
)

function db_get_database_name¶

char * db_get_database_name (
    void
)

function db_get_database_version¶

char * db_get_database_version (
    void
)

function db_get_delayed_hosts_count¶

int db_get_delayed_hosts_count (
    void
)

function db_get_global_transaction_info¶

int db_get_global_transaction_info (
    int global_transaction_id,
    void * buffer,
    int size
)

function db_get_ha_server_state¶

int db_get_ha_server_state (
    char * buffer,
    int maxlen
)

function db_get_host_connected¶

char * db_get_host_connected (
    void
)

function db_get_host_list_with_given_status¶

int db_get_host_list_with_given_status (
    char ** hostlist,
    int list_size,
    int status
)

function db_get_keep_session¶

bool db_get_keep_session (
    void
)

function db_get_last_insert_id¶

int db_get_last_insert_id (
    DB_VALUE * value
)

function db_get_max_num_delayed_hosts_lookup¶

int db_get_max_num_delayed_hosts_lookup (
    void
)

function db_get_object_type¶

DB_OBJECT_TYPE db_get_object_type (
    MOP obj_
)

function db_get_owner¶

DB_OBJECT * db_get_owner (
    DB_OBJECT * class_obj
)

function db_get_row_count¶

int db_get_row_count (
    int * row_count
)

function db_get_row_count_cache¶

int db_get_row_count_cache (
    void
)

function db_get_server_session_key¶

char * db_get_server_session_key (
    void
)

function db_get_session_id¶

SESSION_ID db_get_session_id (
    void
)

function db_get_system_parameters¶

int db_get_system_parameters (
    char * data,
    int len
)

function db_get_tran_settings¶

void db_get_tran_settings (
    int * lock_wait,
    DB_TRAN_ISOLATION * tran_isolation
)

function db_get_user¶

DB_OBJECT * db_get_user (
    void
)

function db_get_user_and_host_name¶

char * db_get_user_and_host_name (
    void
)

function db_get_user_name¶

char * db_get_user_name (
    void
)

function db_get_variable¶

int db_get_variable (
    DB_VALUE * name,
    DB_VALUE * value
)

function db_grant¶

int db_grant (
    MOP user,
    MOP obj_,
    AU_TYPE auth,
    int grant_option
)

function db_grant_object¶

int db_grant_object (
    DB_OBJECT_TYPE object_type,
    DB_OBJECT * user,
    DB_OBJECT * obj_,
    DB_AUTH auth,
    int grant_option
)

function db_identifier¶

DB_IDENTIFIER * db_identifier (
    DB_OBJECT * obj
)

function db_init¶

int db_init (
    const  char * program,
    int print_version,
    const  char * dbname,
    const  char * db_path,
    const  char * vol_path,
    const  char * log_path,
    const  char * lob_path,
    const  char * host_name,
    const  bool overwrite,
    const  char * comments,
    const  char * addmore_vols_file,
    int npages,
    int desired_pagesize,
    int log_npages,
    int desired_log_page_size,
    const  char * lang_charset
)

function db_last_volume¶

int db_last_volume (
    void
)

function db_link_static_methods¶

void db_link_static_methods (
    DB_METHOD_LINK * methods
)

function db_lock_read¶

int db_lock_read (
    DB_OBJECT * op
)

function db_lock_write¶

int db_lock_write (
    DB_OBJECT * op
)

function db_login¶

int db_login (
    const  char * name,
    const  char * password
)

function db_need_ignore_repl_delay¶

bool db_need_ignore_repl_delay (
    void
)

function db_need_reconnect¶

bool db_need_reconnect (
    void
)

function db_num_volumes¶

int db_num_volumes (
    void
)

function db_object¶

DB_OBJECT * db_object (
    DB_IDENTIFIER * oid
)

function db_objlist_free¶

void db_objlist_free (
    DB_OBJLIST * list
)

function db_ping_server¶

int db_ping_server (
    int client_val,
    int * server_val
)

function db_preload_classes¶

void db_preload_classes (
    const  char * name1,
    ...
)

function db_print_stats¶

void db_print_stats (
    void
)

function db_register_error_log_handler¶

db_error_log_handler_t db_register_error_log_handler (
    db_error_log_handler_t f
)

function db_reset_latest_query_status¶

int db_reset_latest_query_status (
    void
)

function db_reset_system_parameters_from_assignments¶

int db_reset_system_parameters_from_assignments (
    const  char * data
)

function db_restart¶

int db_restart (
    const  char * program,
    int print_version,
    const  char * volume
)

function db_restart_ex¶

int db_restart_ex (
    const  char * program,
    const  char * db_name,
    const  char * db_user,
    const  char * db_password,
    const  char * preferred_hosts,
    int client_type
)

function db_revoke¶

int db_revoke (
    MOP user,
    MOP obj_,
    AU_TYPE auth
)

function db_revoke_object¶

int db_revoke_object (
    DB_OBJECT_TYPE object_type,
    MOP user,
    MOP obj_,
    AU_TYPE auth
)

function db_savepoint_transaction¶

int db_savepoint_transaction (
    const  char * savepoint_name
)

function db_savepoint_transaction_internal¶

int db_savepoint_transaction_internal (
    const  char * savepoint_name
)

function db_set_client_ip_addr¶

void db_set_client_ip_addr (
    const  char * ip_addr
)

function db_set_client_statement_type¶

void db_set_client_statement_type (
    CUBRID_STMT_TYPE statement_type
)

function db_set_client_type¶

void db_set_client_type (
    int client_type
)

function db_set_connect_order¶

void db_set_connect_order (
    int connect_order
)

function db_set_connected_host_status¶

void db_set_connected_host_status (
    char * host_connected
)

function db_set_global_transaction_info¶

int db_set_global_transaction_info (
    int global_transaction_id,
    void * info,
    int size
)

function db_set_host_status¶

void db_set_host_status (
    char * hostname,
    int status
)

function db_set_interrupt¶

void db_set_interrupt (
    int set
)

function db_set_isolation¶

int db_set_isolation (
    DB_TRAN_ISOLATION isolation
)

function db_set_keep_session¶

void db_set_keep_session (
    const  bool keep_session
)

function db_set_lock_timeout¶

int db_set_lock_timeout (
    int seconds
)

function db_set_max_num_delayed_hosts_lookup¶

void db_set_max_num_delayed_hosts_lookup (
    int max_num_delayed_hosts_lookup
)

function db_set_password¶

int db_set_password (
    DB_OBJECT * user,
    const  char * old_passwd,
    const  char * new_passwd
)

function db_set_preferred_hosts¶

void db_set_preferred_hosts (
    const  char * hosts
)

function db_set_server_session_key¶

void db_set_server_session_key (
    const  char * key
)

function db_set_session_id¶

void db_set_session_id (
    const  SESSION_ID session_id
)

function db_set_suppress_repl_on_transaction¶

int db_set_suppress_repl_on_transaction (
    int set
)

function db_set_system_parameters¶

int db_set_system_parameters (
    const  char * data
)

function db_set_system_parameters_for_ha_repl¶

int db_set_system_parameters_for_ha_repl (
    const  char * data
)

function db_set_user_comment¶

int db_set_user_comment (
    DB_OBJECT * user,
    const  char * comment
)

function db_shutdown¶

int db_shutdown (
    void
)

function db_shutdown_without_request_to_server¶

void db_shutdown_without_request_to_server (
    void
)

function db_string_free¶

void db_string_free (
    char * string
)

function db_synchronize_cache¶

void db_synchronize_cache (
    void
)

function db_totalpgs¶

int db_totalpgs (
    const  char * volume_label
)

function db_unlink_static_methods¶

void db_unlink_static_methods (
    DB_METHOD_LINK * methods
)

function db_update_row_count_cache¶

void db_update_row_count_cache (
    const  int row_count
)

function db_vol_label¶

char * db_vol_label (
    int volid,
    char * vol_fullname
)

function db_warnspace¶

void db_warnspace (
    const  char * volume_label
)

function sigfpe_handler¶

void sigfpe_handler (
    int sig
)

Public Static Functions Documentation¶

function db_add_host_status¶

static DB_HOST_STATUS * db_add_host_status (
    char * hostname,
    int status
)

function db_find_host_status¶

static DB_HOST_STATUS * db_find_host_status (
    char * hostname
)

function fetch_set_internal¶

static int fetch_set_internal (
    DB_SET * set,
    DB_FETCH_MODE purpose,
    int quit_on_error
)

function install_static_methods¶

static void install_static_methods (
    void
)

The documentation for this class was generated from the following file cubrid/src/compat/db_admin.c