File ddl_log.c¶

#include <stdio.h>
#include <stdarg.h>
#include <stdlib.h>
#include <time.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/time.h>
#include <sys/timeb.h>
#include <signal.h>
#include <assert.h>
#include "porting.h"
#include "cas_common.h"
#include "ddl_log.h"
#include "parse_tree.h"
#include "system_parameter.h"
#include "environment_variable.h"
#include "broker_config.h"
#include "util_func.h"
#include "hide_password.h"
#include "db.h"

Classes¶

Type	Name
struct	t_ddl_audit_handle

Public Types¶

Type	Name
typedef struct t_ddl_audit_handle	T_DDL_AUDIT_HANDLE

Public Static Attributes¶

Type	Name
T_DDL_AUDIT_HANDLE	ddl_audit_handle
bool	ddl_logging_enabled = `[false](broker__monitor_8c.md#function-timeout)`
UINT64	ddl_logging_size = `0ULL`
bool	has_password_type = `[false](broker__monitor_8c.md#function-timeout)`
bool	is_executed_ddl_for_trans = `[false](broker__monitor_8c.md#function-timeout)`
bool	is_first_initialized = `[true](broker__monitor_8c.md#function-timeout)`

Public Functions¶

Type	Name
void	logddl_check_and_set_query_text (PT_NODE * statement, int stmt_type, PARSER_CONTEXT * parser)
void	logddl_check_ddl_audit_param ()
void	logddl_destroy ()
void	logddl_free (bool all_free)
void	logddl_init (T_APP_NAME app_name)
void	logddl_reset_query_text ()
void	logddl_set_broker_info (const int index, const char * br_name)
void	logddl_set_callback_stmt (int stmt_type, char * sql, int len, int err_code, HIDE_PWD_INFO_PTR hide_pwd_info_ptr)
void	logddl_set_commit_count (int count)
void	logddl_set_commit_mode (bool mode)
void	logddl_set_csql_input_type (T_CSQL_INPUT_TYPE input_type)
void	logddl_set_db_name (const char * db_name)
void	logddl_set_err_code (int err_code)
void	logddl_set_execute_type (char exe_type)
void	logddl_set_file_line (int file_line)
void	logddl_set_ip (const char * ip_addr)
void	logddl_set_load_filename (const char * load_filename)
void	logddl_set_loaddb_file_type (T_LOADDB_FILE_TYPE file_type)
void	logddl_set_msg (const char * fmt, ...)
void	logddl_set_start_time (struct timeval * time_val)
void	logddl_set_user_name (const char * user_name)
void	logddl_write ()
void	logddl_write_end ()
void	logddl_write_end_for_csql_fileinput (const char * fmt, ...)
void	logddl_write_tran_str (const char * fmt, ...)

Public Static Functions¶

Type	Name
bool	is_need_write ()
void	logddl_backup (const char * path)
int	logddl_create_dir (const char * new_dir)
bool	logddl_create_log_msg (FILE * fp)
bool	logddl_file_backup (T_APP_NAME app_name, T_CSQL_INPUT_TYPE csql_input_type)
int	logddl_file_copy (char * src_file, char * dest_file)
FILE *	logddl_fopen_and_lock (const char * path, const char * mode)
const char *	logddl_get_app_name (T_APP_NAME app_name)
int	logddl_get_current_date_time_string (char * buf, size_t size)
int	logddl_get_time_string (char * buf, struct timeval * time_val)
bool	logddl_is_ddl_type (int node_type, PT_NODE * node)
int	logddl_make_copy_dir (T_APP_NAME app_name, char * copy_filename, char * copy_fullpath, size_t buf_size)
int	logddl_make_copy_filename (T_APP_NAME app_name, const char * file_full_path, char * copy_filename, size_t buf_size)
void	logddl_make_filename (char * filename_buf, size_t buf_size, T_APP_NAME app_name)
FILE *	logddl_open (T_APP_NAME app_name)
void	logddl_set_sql_text (char * sql_text, int sql_len, HIDE_PWD_INFO_PTR hide_pwd_info_ptr)
bool	logddl_set_stmt_type (int stmt_type, PT_NODE * statement)
void	logddl_timeval_diff (struct timeval * start, struct timeval * end)

Macros¶

Type	Name
define	DDL_ELAPSED_TIME_LEN `(36)`
define	DDL_LOG_CSQL_FILE_PATH `"log/[ddl\_audit](broker__monitor_8c.md#function-timeout)/[csql"](broker__monitor_8c.md#function-timeout)`
define	DDL_LOG_LOADDB_FILE_PATH `"log/[ddl\_audit](broker__monitor_8c.md#function-timeout)/[loaddb"](broker__monitor_8c.md#function-timeout)`
define	DDL_LOG_MSG `(256)`
define	DDL_LOG_PATH `"log/[ddl\_audit"](broker__monitor_8c.md#function-timeout)`
define	DDL_TIME_LEN `(22)`
define	FILE_BUFFER_SIZE `(1024)`
define	MAX_RETRY_COUNT `100`
define	SQL_TEXT_INCR `(1024)`
define	SQL_TEXT_SIZE `(2048)`
define	SQL_TEXT_SIZE_MAX `(8192)`
define	TIME_STRING_SIZE `(16)`

Public Types Documentation¶

typedef T_DDL_AUDIT_HANDLE¶

typedef struct t_ddl_audit_handle T_DDL_AUDIT_HANDLE;

Public Static Attributes Documentation¶

variable ddl_audit_handle¶

T_DDL_AUDIT_HANDLE ddl_audit_handle;

variable ddl_logging_enabled¶

bool ddl_logging_enabled;

variable ddl_logging_size¶

UINT64 ddl_logging_size;

variable has_password_type¶

bool has_password_type;

variable is_executed_ddl_for_trans¶

bool is_executed_ddl_for_trans;

variable is_first_initialized¶

bool is_first_initialized;

Public Functions Documentation¶

function logddl_check_and_set_query_text¶

void logddl_check_and_set_query_text (
    PT_NODE * statement,
    int stmt_type,
    PARSER_CONTEXT * parser
)

function logddl_check_ddl_audit_param¶

void logddl_check_ddl_audit_param ()

function logddl_destroy¶

void logddl_destroy ()

function logddl_free¶

void logddl_free (
    bool all_free
)

function logddl_init¶

void logddl_init (
    T_APP_NAME app_name
)

function logddl_reset_query_text¶

void logddl_reset_query_text ()

function logddl_set_broker_info¶

void logddl_set_broker_info (
    const  int index,
    const  char * br_name
)

function logddl_set_callback_stmt¶

void logddl_set_callback_stmt (
    int stmt_type,
    char * sql,
    int len,
    int err_code,
    HIDE_PWD_INFO_PTR hide_pwd_info_ptr
)

function logddl_set_commit_count¶

void logddl_set_commit_count (
    int count
)

function logddl_set_commit_mode¶

void logddl_set_commit_mode (
    bool mode
)

function logddl_set_csql_input_type¶

void logddl_set_csql_input_type (
    T_CSQL_INPUT_TYPE input_type
)

function logddl_set_db_name¶

void logddl_set_db_name (
    const  char * db_name
)

function logddl_set_err_code¶

void logddl_set_err_code (
    int err_code
)

function logddl_set_execute_type¶

void logddl_set_execute_type (
    char exe_type
)

function logddl_set_file_line¶

void logddl_set_file_line (
    int file_line
)

function logddl_set_ip¶

void logddl_set_ip (
    const  char * ip_addr
)

function logddl_set_load_filename¶

void logddl_set_load_filename (
    const  char * load_filename
)

function logddl_set_loaddb_file_type¶

void logddl_set_loaddb_file_type (
    T_LOADDB_FILE_TYPE file_type
)

function logddl_set_msg¶

void logddl_set_msg (
    const  char * fmt,
    ...
)

function logddl_set_start_time¶

void logddl_set_start_time (
    struct  timeval * time_val
)

function logddl_set_user_name¶

void logddl_set_user_name (
    const  char * user_name
)

function logddl_write¶

void logddl_write ()

function logddl_write_end¶

void logddl_write_end ()

function logddl_write_end_for_csql_fileinput¶

void logddl_write_end_for_csql_fileinput (
    const  char * fmt,
    ...
)

function logddl_write_tran_str¶

void logddl_write_tran_str (
    const  char * fmt,
    ...
)

Public Static Functions Documentation¶

function is_need_write¶

static inline bool is_need_write ()

function logddl_backup¶

static void logddl_backup (
    const  char * path
)

function logddl_create_dir¶

static int logddl_create_dir (
    const  char * new_dir
)

function logddl_create_log_msg¶

static bool logddl_create_log_msg (
    FILE * fp
)

function logddl_file_backup¶

static bool logddl_file_backup (
    T_APP_NAME app_name,
    T_CSQL_INPUT_TYPE csql_input_type
)

function logddl_file_copy¶

static int logddl_file_copy (
    char * src_file,
    char * dest_file
)

function logddl_fopen_and_lock¶

static FILE * logddl_fopen_and_lock (
    const  char * path,
    const  char * mode
)

function logddl_get_app_name¶

static const  char * logddl_get_app_name (
    T_APP_NAME app_name
)

function logddl_get_current_date_time_string¶

static int logddl_get_current_date_time_string (
    char * buf,
    size_t size
)

function logddl_get_time_string¶

static int logddl_get_time_string (
    char * buf,
    struct  timeval * time_val
)

function logddl_is_ddl_type¶

static bool logddl_is_ddl_type (
    int node_type,
    PT_NODE * node
)

function logddl_make_copy_dir¶

static int logddl_make_copy_dir (
    T_APP_NAME app_name,
    char * copy_filename,
    char * copy_fullpath,
    size_t buf_size
)

function logddl_make_copy_filename¶

static int logddl_make_copy_filename (
    T_APP_NAME app_name,
    const  char * file_full_path,
    char * copy_filename,
    size_t buf_size
)

function logddl_make_filename¶

static void logddl_make_filename (
    char * filename_buf,
    size_t buf_size,
    T_APP_NAME app_name
)

function logddl_open¶

static FILE * logddl_open (
    T_APP_NAME app_name
)

function logddl_set_sql_text¶

static void logddl_set_sql_text (
    char * sql_text,
    int sql_len,
    HIDE_PWD_INFO_PTR hide_pwd_info_ptr
)

function logddl_set_stmt_type¶

static bool logddl_set_stmt_type (
    int stmt_type,
    PT_NODE * statement
)

function logddl_timeval_diff¶

static void logddl_timeval_diff (
    struct  timeval * start,
    struct  timeval * end
)

Macro Definition Documentation¶

define DDL_ELAPSED_TIME_LEN¶

#define DDL_ELAPSED_TIME_LEN `(36)`

define DDL_LOG_CSQL_FILE_PATH¶

#define DDL_LOG_CSQL_FILE_PATH `"log/ ddl_audit / csql"`

define DDL_LOG_LOADDB_FILE_PATH¶

#define DDL_LOG_LOADDB_FILE_PATH `"log/ ddl_audit / loaddb"`

define DDL_LOG_MSG¶

#define DDL_LOG_MSG `(256)`

define DDL_LOG_PATH¶

#define DDL_LOG_PATH `"log/ ddl_audit"`

define DDL_TIME_LEN¶

#define DDL_TIME_LEN `(22)`

define FILE_BUFFER_SIZE¶

#define FILE_BUFFER_SIZE `(1024)`

define MAX_RETRY_COUNT¶

#define MAX_RETRY_COUNT `100`

define SQL_TEXT_INCR¶

#define SQL_TEXT_INCR `(1024)`

define SQL_TEXT_SIZE¶

#define SQL_TEXT_SIZE `(2048)`

define SQL_TEXT_SIZE_MAX¶

#define SQL_TEXT_SIZE_MAX `(8192)`

define TIME_STRING_SIZE¶

#define TIME_STRING_SIZE `(16)`

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