File query_manager.h¶

FileList > cubrid > src > query > query_manager.h

#include "dbtype_def.h"
#include "file_manager.h"
#include "list_file.h"
#include "storage_common.h"
#include "thread_compat.hpp"

Classes¶

Type	Name
struct	qmgr_query_entry
struct	qmgr_temp_file
struct	qmgr_wait_args

Public Types¶

Type	Name
typedef struct qmgr_query_entry	QMGR_QUERY_ENTRY
enum	QMGR_QUERY_STATUS
enum	QMGR_QUERY_TYPE
typedef struct qmgr_temp_file	QMGR_TEMP_FILE
enum	QMGR_TEMP_FILE_MEMBUF_TYPE
enum	QMGR_TRAN_STATUS
typedef struct qmgr_wait_args	QMGR_WAIT_ARGS

Public Functions¶

Type	Name
void	qmgr_add_modified_class (THREAD_ENTRY * thread_p, const OID * class_oid)
int	qmgr_allocate_tran_entries (THREAD_ENTRY * thread_p, int trans_cnt)
QMGR_TRAN_STATUS	qmgr_check_dblink_trans (THREAD_ENTRY * thread_p, bool is_abort)
void	qmgr_clear_trans_wakeup (THREAD_ENTRY * thread_p, int tran_index, bool tran_died, bool is_abort)
QMGR_TEMP_FILE *	qmgr_create_new_temp_file (THREAD_ENTRY * thread_p, QUERY_ID query_id, QMGR_TEMP_FILE_MEMBUF_TYPE membuf_type)
QMGR_TEMP_FILE *	qmgr_create_result_file (THREAD_ENTRY * thread_p, QUERY_ID query_id)
int	qmgr_dblink_add_conn_handle (THREAD_ENTRY * thread_p, int conn_handle, char * conn_url, char * user_name, char * password, bool set_participant)
void	qmgr_dblink_clear_conn_entry (THREAD_ENTRY * thread_p)
int	qmgr_dblink_find_conn_handle (THREAD_ENTRY * thread_p, char * conn_url, char * user_name, char * password, bool set_participant)
DBLINK_CONN_ENTRY *	qmgr_dblink_get_conn_entry (THREAD_ENTRY * thread_p)
void	qmgr_dump (void)
void	qmgr_finalize (THREAD_ENTRY * thread_p)
int	qmgr_free_list_temp_file (THREAD_ENTRY * thread_p, QUERY_ID query_id, QMGR_TEMP_FILE * tfile_vfidp)
void	qmgr_free_old_page (THREAD_ENTRY * thread_p, PAGE_PTR page_ptr, QMGR_TEMP_FILE * tfile_vfidp)
void	qmgr_free_old_page_simple_fix (THREAD_ENTRY * thread_p, PAGE_PTR page_ptr, QMGR_TEMP_FILE * tfile_vfidp)
int	qmgr_free_temp_file_list (THREAD_ENTRY * thread_p, QMGR_TEMP_FILE * tfile_vfidp, QUERY_ID query_id, bool is_error)
QUERY_ID	qmgr_get_current_query_id (THREAD_ENTRY * thread_p)
PAGE_PTR	qmgr_get_new_page (THREAD_ENTRY * thread_p, VPID * vpidp, QMGR_TEMP_FILE * tfile_vfidp)
PAGE_PTR	qmgr_get_old_page (THREAD_ENTRY * thread_p, VPID * vpidp, QMGR_TEMP_FILE * tfile_vfidp)
PAGE_PTR	qmgr_get_old_page_read_only (THREAD_ENTRY * thread_p, VPID * vpidp, QMGR_TEMP_FILE * tfile_vfidp)
PAGE_PTR	qmgr_get_old_page_simple_fix (THREAD_ENTRY * thread_p, VPID * vpidp, QMGR_TEMP_FILE * tfile_vfidp)
QMGR_QUERY_ENTRY *	qmgr_get_query_entry (THREAD_ENTRY * thread_p, QUERY_ID query_id, int trans_ind)
int	qmgr_get_query_error_with_entry (QMGR_QUERY_ENTRY * query_entryp)
char *	qmgr_get_query_sql_user_text (THREAD_ENTRY * thread_p, QUERY_ID query_id, int tran_index)
struct drand48_data *	qmgr_get_rand_buf (THREAD_ENTRY * thread_p)
int	qmgr_get_sql_id (THREAD_ENTRY * thread_p, char sql_id_buf, char** * query, size_t sql_len)
int	qmgr_get_temp_file_membuf_pages (QMGR_TEMP_FILE * temp_file_p)
QMGR_TRAN_STATUS	qmgr_get_tran_status (THREAD_ENTRY * thread_p, int tran_index)
int	qmgr_initialize (THREAD_ENTRY * thread_p)
bool	qmgr_is_query_interrupted (THREAD_ENTRY * thread_p, QUERY_ID query_id)
void	qmgr_set_dirty_page (THREAD_ENTRY * thread_p, PAGE_PTR page_ptr, int free_page, LOG_DATA_ADDR * addrp, QMGR_TEMP_FILE * tfile_vfidp)
void	qmgr_set_query_error (THREAD_ENTRY * thread_p, QUERY_ID query_id)
void	qmgr_set_tran_status (THREAD_ENTRY * thread_p, int tran_index, QMGR_TRAN_STATUS trans_status)
void	qmgr_setup_empty_list_file (char * page_buf)

Macros¶

Type	Name
define	NULL_PAGEID_IN_PROGRESS `-2`
define	qmgr_free_old_page_and_init (thread_p, page_p, tfile_vfidp) `/* multi line expression */`
define	qmgr_free_old_page_simple_fix_and_init (thread_p, page_p, tfile_vfidp) `/* multi line expression */`

Public Types Documentation¶

typedef QMGR_QUERY_ENTRY¶

typedef struct qmgr_query_entry QMGR_QUERY_ENTRY;

enum QMGR_QUERY_STATUS¶

enum QMGR_QUERY_STATUS {
    QUERY_IN_PROGRESS,
    QUERY_COMPLETED,
    QUERY_CLOSED
};

enum QMGR_QUERY_TYPE¶

enum QMGR_QUERY_TYPE {
    OTHERS,
    M_QUERY,
    UNION_QUERY,
    VALUE_QUERY,
    GROUPBY_QUERY,
    ORDERBY_QUERY,
    DISTINCT_QUERY,
    ANALYTIC_QUERY
};

typedef QMGR_TEMP_FILE¶

typedef struct qmgr_temp_file QMGR_TEMP_FILE;

enum QMGR_TEMP_FILE_MEMBUF_TYPE¶

enum QMGR_TEMP_FILE_MEMBUF_TYPE {
    TEMP_FILE_MEMBUF_NONE = -1,
    TEMP_FILE_MEMBUF_NORMAL,
    TEMP_FILE_MEMBUF_KEY_BUFFER,
    TEMP_FILE_MEMBUF_NUM_TYPES
};

enum QMGR_TRAN_STATUS¶

enum QMGR_TRAN_STATUS {
    QMGR_TRAN_NULL,
    QMGR_TRAN_RUNNING,
    QMGR_TRAN_DELAYED_START,
    QMGR_TRAN_WAITING,
    QMGR_TRAN_RESUME_TO_DEALLOCATE,
    QMGR_TRAN_RESUME_DUE_DEADLOCK,
    QMGR_TRAN_TERMINATED,
    QMGR_TRAN_DBLINK_ABORTED
};

typedef QMGR_WAIT_ARGS¶

typedef struct qmgr_wait_args QMGR_WAIT_ARGS;

Public Functions Documentation¶

function qmgr_add_modified_class¶

void qmgr_add_modified_class (
    THREAD_ENTRY * thread_p,
    const  OID * class_oid
)

function qmgr_allocate_tran_entries¶

int qmgr_allocate_tran_entries (
    THREAD_ENTRY * thread_p,
    int trans_cnt
)

function qmgr_check_dblink_trans¶

QMGR_TRAN_STATUS qmgr_check_dblink_trans (
    THREAD_ENTRY * thread_p,
    bool is_abort
)

function qmgr_clear_trans_wakeup¶

void qmgr_clear_trans_wakeup (
    THREAD_ENTRY * thread_p,
    int tran_index,
    bool tran_died,
    bool is_abort
)

function qmgr_create_new_temp_file¶

QMGR_TEMP_FILE * qmgr_create_new_temp_file (
    THREAD_ENTRY * thread_p,
    QUERY_ID query_id,
    QMGR_TEMP_FILE_MEMBUF_TYPE membuf_type
)

function qmgr_create_result_file¶

QMGR_TEMP_FILE * qmgr_create_result_file (
    THREAD_ENTRY * thread_p,
    QUERY_ID query_id
)

function qmgr_dblink_add_conn_handle¶

int qmgr_dblink_add_conn_handle (
    THREAD_ENTRY * thread_p,
    int conn_handle,
    char * conn_url,
    char * user_name,
    char * password,
    bool set_participant
)

function qmgr_dblink_clear_conn_entry¶

void qmgr_dblink_clear_conn_entry (
    THREAD_ENTRY * thread_p
)

function qmgr_dblink_find_conn_handle¶

int qmgr_dblink_find_conn_handle (
    THREAD_ENTRY * thread_p,
    char * conn_url,
    char * user_name,
    char * password,
    bool set_participant
)

function qmgr_dblink_get_conn_entry¶

DBLINK_CONN_ENTRY * qmgr_dblink_get_conn_entry (
    THREAD_ENTRY * thread_p
)

function qmgr_dump¶

void qmgr_dump (
    void
)

function qmgr_finalize¶

void qmgr_finalize (
    THREAD_ENTRY * thread_p
)

function qmgr_free_list_temp_file¶

int qmgr_free_list_temp_file (
    THREAD_ENTRY * thread_p,
    QUERY_ID query_id,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_free_old_page¶

void qmgr_free_old_page (
    THREAD_ENTRY * thread_p,
    PAGE_PTR page_ptr,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_free_old_page_simple_fix¶

void qmgr_free_old_page_simple_fix (
    THREAD_ENTRY * thread_p,
    PAGE_PTR page_ptr,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_free_temp_file_list¶

int qmgr_free_temp_file_list (
    THREAD_ENTRY * thread_p,
    QMGR_TEMP_FILE * tfile_vfidp,
    QUERY_ID query_id,
    bool is_error
)

function qmgr_get_current_query_id¶

QUERY_ID qmgr_get_current_query_id (
    THREAD_ENTRY * thread_p
)

function qmgr_get_new_page¶

PAGE_PTR qmgr_get_new_page (
    THREAD_ENTRY * thread_p,
    VPID * vpidp,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_get_old_page¶

PAGE_PTR qmgr_get_old_page (
    THREAD_ENTRY * thread_p,
    VPID * vpidp,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_get_old_page_read_only¶

PAGE_PTR qmgr_get_old_page_read_only (
    THREAD_ENTRY * thread_p,
    VPID * vpidp,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_get_old_page_simple_fix¶

PAGE_PTR qmgr_get_old_page_simple_fix (
    THREAD_ENTRY * thread_p,
    VPID * vpidp,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_get_query_entry¶

QMGR_QUERY_ENTRY * qmgr_get_query_entry (
    THREAD_ENTRY * thread_p,
    QUERY_ID query_id,
    int trans_ind
)

function qmgr_get_query_error_with_entry¶

int qmgr_get_query_error_with_entry (
    QMGR_QUERY_ENTRY * query_entryp
)

function qmgr_get_query_sql_user_text¶

char * qmgr_get_query_sql_user_text (
    THREAD_ENTRY * thread_p,
    QUERY_ID query_id,
    int tran_index
)

function qmgr_get_rand_buf¶

struct  drand48_data * qmgr_get_rand_buf (
    THREAD_ENTRY * thread_p
)

function qmgr_get_sql_id¶

int qmgr_get_sql_id (
    THREAD_ENTRY * thread_p,
    char ** sql_id_buf,
    char * query,
    size_t sql_len
)

function qmgr_get_temp_file_membuf_pages¶

int qmgr_get_temp_file_membuf_pages (
    QMGR_TEMP_FILE * temp_file_p
)

function qmgr_get_tran_status¶

QMGR_TRAN_STATUS qmgr_get_tran_status (
    THREAD_ENTRY * thread_p,
    int tran_index
)

function qmgr_initialize¶

int qmgr_initialize (
    THREAD_ENTRY * thread_p
)

function qmgr_is_query_interrupted¶

bool qmgr_is_query_interrupted (
    THREAD_ENTRY * thread_p,
    QUERY_ID query_id
)

function qmgr_set_dirty_page¶

void qmgr_set_dirty_page (
    THREAD_ENTRY * thread_p,
    PAGE_PTR page_ptr,
    int free_page,
    LOG_DATA_ADDR * addrp,
    QMGR_TEMP_FILE * tfile_vfidp
)

function qmgr_set_query_error¶

void qmgr_set_query_error (
    THREAD_ENTRY * thread_p,
    QUERY_ID query_id
)

function qmgr_set_tran_status¶

void qmgr_set_tran_status (
    THREAD_ENTRY * thread_p,
    int tran_index,
    QMGR_TRAN_STATUS trans_status
)

function qmgr_setup_empty_list_file¶

void qmgr_setup_empty_list_file (
    char * page_buf
)

Macro Definition Documentation¶

define NULL_PAGEID_IN_PROGRESS¶

#define NULL_PAGEID_IN_PROGRESS `-2`

define qmgr_free_old_page_and_init¶

#define qmgr_free_old_page_and_init (
    thread_p,
    page_p,
    tfile_vfidp
) `/* multi line expression */`

define qmgr_free_old_page_simple_fix_and_init¶

#define qmgr_free_old_page_simple_fix_and_init (
    thread_p,
    page_p,
    tfile_vfidp
) `/* multi line expression */`

The documentation for this class was generated from the following file cubrid/src/query/query_manager.h