File query_executor.h¶

FileList > cubrid > src > query > query_executor.h

#include "dbtype_def.h"
#include "query_list.h"
#include "system.h"
#include "thread_compat.hpp"
#include <time.h>

Classes¶

Type	Name
struct	upddel_class_instances_lock_info
struct	val_descr
struct	xasl_state

Public Types¶

Type	Name
typedef struct upddel_class_instances_lock_info	UPDDEL_CLASS_INSTANCE_LOCK_INFO
typedef struct val_descr	VAL_DESCR
typedef xasl_state	XASL_STATE

Public Functions¶

Type	Name
void	get_xasl_dumper_linked_in ()
bool	qdump_check_xasl_tree (xasl_node * xasl)
int	qexec_alloc_agg_hash_context_buildlist_xasl (THREAD_ENTRY * thread_p, xasl_node * xasl, XASL_STATE * xasl_state, bool not_use_membuf)
int	qexec_clear_func_pred (THREAD_ENTRY * thread_p, func_pred * pred_filter)
int	qexec_clear_list_cache_by_class (THREAD_ENTRY * thread_p, const OID * class_oid)
int	qexec_clear_partition_expression (THREAD_ENTRY * thread_p, regu_variable_node * expr)
int	qexec_clear_pred_context (THREAD_ENTRY * thread_p, pred_expr_with_context * pred_filter, bool dealloc_dbvalues)
int	qexec_clear_xasl (THREAD_ENTRY * thread_p, xasl_node * xasl, bool is_final, bool for_parallel_aptr)
int	qexec_clear_xasl_for_parallel_aptr (THREAD_ENTRY * thread_p, xasl_node * xasl, bool is_final)
xasl_state *	qexec_deep_copy_xasl_state (THREAD_ENTRY * thread_p, xasl_state * xasl_state)
int	qexec_execute_mainblock (THREAD_ENTRY * thread_p, xasl_node * xasl, xasl_state * xstate, UPDDEL_CLASS_INSTANCE_LOCK_INFO * p_class_instance_lock_info)
qfile_list_id *	qexec_execute_query (THREAD_ENTRY * thread_p, xasl_node * xasl, int dbval_cnt, const DB_VALUE * dbval_ptr, QUERY_ID query_id)
SCAN_CODE	qexec_execute_scan_ptr (THREAD_ENTRY * thread_p, xasl_node * xasl, XASL_STATE * xasl_state, void * scan_func_ptr)
int	qexec_execute_subquery_for_result_cache (THREAD_ENTRY * thread_p, xasl_node * xasl, xasl_state * xstate)
void	qexec_free_xasl_state (THREAD_ENTRY * thread_p, xasl_state * xasl_state)
int	qexec_get_tuple_column_value (QFILE_TUPLE tpl, int index, DB_VALUE * valp, tp_domain * domain)
qfile_list_id *	qexec_get_xasl_list_id (xasl_node * xasl)
int	qexec_hash_gby_agg_tuple_public (THREAD_ENTRY * thread_p, xasl_node * xasl, XASL_STATE * xasl_state, QFILE_TUPLE_RECORD * tplrec, QFILE_TUPLE_DESCRIPTOR * tpldesc, QFILE_LIST_ID * groupby_list, bool * output_tuple)
int	qexec_insert_tuple_into_list (THREAD_ENTRY * thread_p, qfile_list_id * list_id, valptr_list_node * outptr_list, val_descr * vd, qfile_tuple_record * tplrec)
void	qexec_replace_prior_regu_vars_prior_expr (THREAD_ENTRY * thread_p, regu_variable_node * regu, xasl_node * xasl, xasl_node * connect_by_ptr)
int	qexec_resolve_domains_for_aggregation_for_parallel_heap_scan_buildvalue_proc (THREAD_ENTRY * thread_p, xasl_node * xasl, void * vd, int * resolved)
int	qexec_resolve_domains_for_aggregation_for_parallel_heap_scan_g_agg (THREAD_ENTRY * thread_p, xasl_node * xasl, void * vd, int * resolved)
int	qexec_start_mainblock_iterations (THREAD_ENTRY * thread_p, xasl_node * xasl, xasl_state * xstate)

Macros¶

Type	Name
define	QEXEC_NULL_COMMAND_ID `-1 /\* [Invalid](broker__monitor_8c.md#function-timeout) [command](pl_8cpp.md#variable-command) [identifier](broker__monitor_8c.md#function-timeout) \*/`

Public Types Documentation¶

typedef UPDDEL_CLASS_INSTANCE_LOCK_INFO¶

typedef struct upddel_class_instances_lock_info UPDDEL_CLASS_INSTANCE_LOCK_INFO;

typedef VAL_DESCR¶

typedef struct val_descr VAL_DESCR;

typedef XASL_STATE¶

typedef struct xasl_state XASL_STATE;

Public Functions Documentation¶

function get_xasl_dumper_linked_in¶

void get_xasl_dumper_linked_in ()

function qdump_check_xasl_tree¶

bool qdump_check_xasl_tree (
    xasl_node * xasl
)

function qexec_alloc_agg_hash_context_buildlist_xasl¶

int qexec_alloc_agg_hash_context_buildlist_xasl (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    XASL_STATE * xasl_state,
    bool not_use_membuf
)

function qexec_clear_func_pred¶

int qexec_clear_func_pred (
    THREAD_ENTRY * thread_p,
    func_pred * pred_filter
)

function qexec_clear_list_cache_by_class¶

int qexec_clear_list_cache_by_class (
    THREAD_ENTRY * thread_p,
    const  OID * class_oid
)

function qexec_clear_partition_expression¶

int qexec_clear_partition_expression (
    THREAD_ENTRY * thread_p,
    regu_variable_node * expr
)

function qexec_clear_pred_context¶

int qexec_clear_pred_context (
    THREAD_ENTRY * thread_p,
    pred_expr_with_context * pred_filter,
    bool dealloc_dbvalues
)

function qexec_clear_xasl¶

int qexec_clear_xasl (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    bool is_final,
    bool for_parallel_aptr
)

function qexec_clear_xasl_for_parallel_aptr¶

int qexec_clear_xasl_for_parallel_aptr (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    bool is_final
)

function qexec_deep_copy_xasl_state¶

xasl_state * qexec_deep_copy_xasl_state (
    THREAD_ENTRY * thread_p,
    xasl_state * xasl_state
)

function qexec_execute_mainblock¶

int qexec_execute_mainblock (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    xasl_state * xstate,
    UPDDEL_CLASS_INSTANCE_LOCK_INFO * p_class_instance_lock_info
)

function qexec_execute_query¶

qfile_list_id * qexec_execute_query (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    int dbval_cnt,
    const  DB_VALUE * dbval_ptr,
    QUERY_ID query_id
)

function qexec_execute_scan_ptr¶

SCAN_CODE qexec_execute_scan_ptr (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    XASL_STATE * xasl_state,
    void * scan_func_ptr
)

function qexec_execute_subquery_for_result_cache¶

int qexec_execute_subquery_for_result_cache (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    xasl_state * xstate
)

function qexec_free_xasl_state¶

void qexec_free_xasl_state (
    THREAD_ENTRY * thread_p,
    xasl_state * xasl_state
)

function qexec_get_tuple_column_value¶

int qexec_get_tuple_column_value (
    QFILE_TUPLE tpl,
    int index,
    DB_VALUE * valp,
    tp_domain * domain
)

function qexec_get_xasl_list_id¶

qfile_list_id * qexec_get_xasl_list_id (
    xasl_node * xasl
)

function qexec_hash_gby_agg_tuple_public¶

int qexec_hash_gby_agg_tuple_public (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    XASL_STATE * xasl_state,
    QFILE_TUPLE_RECORD * tplrec,
    QFILE_TUPLE_DESCRIPTOR * tpldesc,
    QFILE_LIST_ID * groupby_list,
    bool * output_tuple
)

function qexec_insert_tuple_into_list¶

int qexec_insert_tuple_into_list (
    THREAD_ENTRY * thread_p,
    qfile_list_id * list_id,
    valptr_list_node * outptr_list,
    val_descr * vd,
    qfile_tuple_record * tplrec
)

function qexec_replace_prior_regu_vars_prior_expr¶

void qexec_replace_prior_regu_vars_prior_expr (
    THREAD_ENTRY * thread_p,
    regu_variable_node * regu,
    xasl_node * xasl,
    xasl_node * connect_by_ptr
)

function qexec_resolve_domains_for_aggregation_for_parallel_heap_scan_buildvalue_proc¶

int qexec_resolve_domains_for_aggregation_for_parallel_heap_scan_buildvalue_proc (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    void * vd,
    int * resolved
)

function qexec_resolve_domains_for_aggregation_for_parallel_heap_scan_g_agg¶

int qexec_resolve_domains_for_aggregation_for_parallel_heap_scan_g_agg (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    void * vd,
    int * resolved
)

function qexec_start_mainblock_iterations¶

int qexec_start_mainblock_iterations (
    THREAD_ENTRY * thread_p,
    xasl_node * xasl,
    xasl_state * xstate
)

Macro Definition Documentation¶

define QEXEC_NULL_COMMAND_ID¶

#define QEXEC_NULL_COMMAND_ID `-1   /* Invalid  command  identifier */`

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