File cas_cgw_execute.c¶

FileList > broker > cas_cgw_execute.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/time.h>
#include <assert.h>
#include "cas_util.h"
#include "cas_log.h"
#include "perf_monitor.h"
#include "transaction_cl.h"
#include "ddl_log.h"
#include "cas_cgw_execute.h"
#include "cas_cgw_odbc.h"

Public Types¶

Type	Name
typedef int(*	T_FETCH_FUNC

Public Attributes¶

Type	Name
T_COL_BINDER *	col_binding = `[NULL](freelistheap_8h.md#define-null)`
T_COL_BINDER *	col_binding_buff = `[NULL](freelistheap_8h.md#define-null)`

Public Static Attributes¶

Type	Name
T_FETCH_FUNC	fetch_func = `/* multi line expression */`

Public Functions¶

Type	Name
int	get_cgw_tuple_count (T_SRV_HANDLE * srv_handle)
int	ux_cgw_auto_commit (T_NET_BUF * net_buf, T_REQ_INFO * req_info)
int	ux_cgw_check_connection (void)
int	ux_cgw_cursor (int srv_h_id, int offset, int origin, T_NET_BUF * net_buf)
void	ux_cgw_cursor_close (T_SRV_HANDLE * srv_handle)
int	ux_cgw_end_tran (int tran_type, bool reset_con_status, bool ddl_audit_log)
int	ux_cgw_execute (T_SRV_HANDLE * srv_handle, char flag, int max_col_size, int max_row, int argc, void argv, T_NET_BUF** * net_buf, T_REQ_INFO * req_info, CACHE_TIME * clt_cache_time, int * clt_cache_reusable)
int	ux_cgw_fetch (T_SRV_HANDLE * srv_handle, int cursor_pos, int fetch_count, char fetch_flag, int result_set_index, T_NET_BUF * net_buf, T_REQ_INFO * req_info)
void	ux_cgw_free_stmt (T_SRV_HANDLE * srv_handle)
int	ux_cgw_is_database_connected (void)
int	ux_cgw_prepare (char * sql_stmt, int flag, char auto_commit_mode, T_NET_BUF * net_buf, T_REQ_INFO * req_info, unsigned int query_seq_num)

Public Static Functions¶

Type	Name
int	cgw_fetch_result (T_SRV_HANDLE * srv_handle, int cursor_pos, int fetch_count, char fetch_flag, int result_set_idx, T_NET_BUF * net_buf, T_REQ_INFO * req_info)
int	cgw_prepare_column_list_info_set (SQLHSTMT hstmt, char prepare_flag, char stmt_type, T_BROKER_VERSION client_version, T_NET_BUF * net_buf)
bool	do_commit_after_execute (const t_srv_handle & server_handle)
int	fetch_call (T_SRV_HANDLE * srv_handle, T_NET_BUF * net_buf, T_REQ_INFO * req_info)
int	fetch_not_supported (T_SRV_HANDLE * srv_handle, int cursor_pos, int fetch_count, char fetch_flag, int result_set_idx, T_NET_BUF * net_buf, T_REQ_INFO * req_info)
char	ux_cgw_get_stmt_type (char * stmt)

Macros¶

Type	Name
define	DBLINK_HINT `"DBLINK"`

Public Types Documentation¶

typedef T_FETCH_FUNC¶

typedef int(* T_FETCH_FUNC) (T_SRV_HANDLE *, int, int, char, int, T_NET_BUF *, T_REQ_INFO *);

Public Attributes Documentation¶

variable col_binding¶

T_COL_BINDER* col_binding;

variable col_binding_buff¶

T_COL_BINDER* col_binding_buff;

Public Static Attributes Documentation¶

variable fetch_func¶

T_FETCH_FUNC fetch_func[];

Public Functions Documentation¶

function get_cgw_tuple_count¶

int get_cgw_tuple_count (
    T_SRV_HANDLE * srv_handle
)

function ux_cgw_auto_commit¶

int ux_cgw_auto_commit (
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info
)

function ux_cgw_check_connection¶

int ux_cgw_check_connection (
    void
)

function ux_cgw_cursor¶

int ux_cgw_cursor (
    int srv_h_id,
    int offset,
    int origin,
    T_NET_BUF * net_buf
)

function ux_cgw_cursor_close¶

void ux_cgw_cursor_close (
    T_SRV_HANDLE * srv_handle
)

function ux_cgw_end_tran¶

int ux_cgw_end_tran (
    int tran_type,
    bool reset_con_status,
    bool ddl_audit_log
)

function ux_cgw_execute¶

int ux_cgw_execute (
    T_SRV_HANDLE * srv_handle,
    char flag,
    int max_col_size,
    int max_row,
    int argc,
    void ** argv,
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info,
    CACHE_TIME * clt_cache_time,
    int * clt_cache_reusable
)

function ux_cgw_fetch¶

int ux_cgw_fetch (
    T_SRV_HANDLE * srv_handle,
    int cursor_pos,
    int fetch_count,
    char fetch_flag,
    int result_set_index,
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info
)

function ux_cgw_free_stmt¶

void ux_cgw_free_stmt (
    T_SRV_HANDLE * srv_handle
)

function ux_cgw_is_database_connected¶

int ux_cgw_is_database_connected (
    void
)

function ux_cgw_prepare¶

int ux_cgw_prepare (
    char * sql_stmt,
    int flag,
    char auto_commit_mode,
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info,
    unsigned  int query_seq_num
)

Public Static Functions Documentation¶

function cgw_fetch_result¶

static int cgw_fetch_result (
    T_SRV_HANDLE * srv_handle,
    int cursor_pos,
    int fetch_count,
    char fetch_flag,
    int result_set_idx,
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info
)

function cgw_prepare_column_list_info_set¶

static int cgw_prepare_column_list_info_set (
    SQLHSTMT hstmt,
    char prepare_flag,
    char stmt_type,
    T_BROKER_VERSION client_version,
    T_NET_BUF * net_buf
)

function do_commit_after_execute¶

static bool do_commit_after_execute (
    const  t_srv_handle & server_handle
)

function fetch_call¶

static int fetch_call (
    T_SRV_HANDLE * srv_handle,
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info
)

function fetch_not_supported¶

static int fetch_not_supported (
    T_SRV_HANDLE * srv_handle,
    int cursor_pos,
    int fetch_count,
    char fetch_flag,
    int result_set_idx,
    T_NET_BUF * net_buf,
    T_REQ_INFO * req_info
)

function ux_cgw_get_stmt_type¶

static char ux_cgw_get_stmt_type (
    char * stmt
)

Macro Definition Documentation¶

define DBLINK_HINT¶

#define DBLINK_HINT `"DBLINK"`

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