Class cubpl::session¶

#include <pl_session.hpp>

Public Types¶

Type	Name
typedef std::unordered_map< QUERY_ID, query_cursor * >::iterator	cursor_iter
typedef std::unordered_map< QUERY_ID, query_cursor * >	cursor_map_type
typedef std::vector< PL_STACK_ID >	exec_stack_id_type
typedef std::unordered_map< PL_STACK_ID, execution_stack * >::iterator	exec_stack_iter
typedef std::unordered_map< PL_STACK_ID, execution_stack * >	exec_stack_map_type

Public Functions¶

Type	Name
void	add_session_cursor (cubthread::entry * thread_p, QUERY_ID query_id)
bool	check_reloading_pl_context_required (const connection_view & cv)
connection_view	claim_connection ()
void	clear_interrupt ()
execution_stack *	create_and_push_stack (cubthread::entry * thread_p)
query_cursor *	create_cursor (cubthread::entry * thread_p, QUERY_ID query_id, bool oid_included=false)
void	destroy_all_cursors ()
void	destroy_cursor (cubthread::entry * thread_p, QUERY_ID query_id)
METHOD_REQ_ID	get_and_increment_request_id ()
query_cursor *	get_cursor (cubthread::entry * thread_p, QUERY_ID query_id)
cubmethod::db_parameter_info *	get_db_parameter_info () const
SESSION_ID	get_id ()
int	get_interrupt_id ()
std::string	get_interrupt_msg ()
bool	is_interrupted ()
bool	is_session_cursor (QUERY_ID query_id)
bool	is_sp_running ()
bool	is_thread_involved (thread_id_t id)
void	mark_session_param_changed (int prm_id)
const std::vector< sys_param >	obtain_session_parameters (const connection_view & conn)
void	pop_and_destroy_stack (const PL_STACK_ID sid)
void	release_connection (connection_view & conn)
void	remove_session_cursor (cubthread::entry * thread_p, QUERY_ID query_id)
	session (SESSION_ID id)
void	set_db_parameter_info (cubmethod::db_parameter_info * param_info)
void	set_interrupt (int reason, std::string msg="")
void	set_local_error_for_interrupt ()
void	set_session_param (const sys_param & param)
void	set_session_params_all_required (bool is_required)
execution_stack *	top_stack ()
void	wait_until_pl_session_done ()
	~session ()

Public Types Documentation¶

typedef cursor_iter¶

using cubpl::session::cursor_iter =  std::unordered_map <QUERY_ID, query_cursor *>::iterator;

typedef cursor_map_type¶

using cubpl::session::cursor_map_type =  std::unordered_map <QUERY_ID, query_cursor *>;

typedef exec_stack_id_type¶

using cubpl::session::exec_stack_id_type =  std::vector <PL_STACK_ID>;

typedef exec_stack_iter¶

using cubpl::session::exec_stack_iter =  std::unordered_map <PL_STACK_ID, execution_stack *>::iterator;

typedef exec_stack_map_type¶

using cubpl::session::exec_stack_map_type =  std::unordered_map <PL_STACK_ID, execution_stack *>;

Public Functions Documentation¶

function add_session_cursor¶

void cubpl::session::add_session_cursor (
    cubthread::entry * thread_p,
    QUERY_ID query_id
)

function check_reloading_pl_context_required¶

bool cubpl::session::check_reloading_pl_context_required (
    const  connection_view & cv
)

function claim_connection¶

connection_view cubpl::session::claim_connection ()

function clear_interrupt¶

void cubpl::session::clear_interrupt ()

function create_and_push_stack¶

execution_stack * cubpl::session::create_and_push_stack (
    cubthread::entry * thread_p
)

function create_cursor¶

query_cursor * cubpl::session::create_cursor (
    cubthread::entry * thread_p,
    QUERY_ID query_id,
    bool oid_included=false
)

function destroy_all_cursors¶

void cubpl::session::destroy_all_cursors ()

function destroy_cursor¶

void cubpl::session::destroy_cursor (
    cubthread::entry * thread_p,
    QUERY_ID query_id
)

function get_and_increment_request_id¶

inline METHOD_REQ_ID cubpl::session::get_and_increment_request_id ()

function get_cursor¶

query_cursor * cubpl::session::get_cursor (
    cubthread::entry * thread_p,
    QUERY_ID query_id
)

function get_db_parameter_info¶

cubmethod::db_parameter_info * cubpl::session::get_db_parameter_info () const

function get_id¶

SESSION_ID cubpl::session::get_id ()

function get_interrupt_id¶

int cubpl::session::get_interrupt_id ()

function get_interrupt_msg¶

std::string cubpl::session::get_interrupt_msg ()

function is_interrupted¶

bool cubpl::session::is_interrupted ()

function is_session_cursor¶

bool cubpl::session::is_session_cursor (
    QUERY_ID query_id
)

function is_sp_running¶

bool cubpl::session::is_sp_running ()

function is_thread_involved¶

bool cubpl::session::is_thread_involved (
    thread_id_t id
)

function mark_session_param_changed¶

void cubpl::session::mark_session_param_changed (
    int prm_id
)

function obtain_session_parameters¶

const std::vector< sys_param > cubpl::session::obtain_session_parameters (
    const  connection_view & conn
)

function pop_and_destroy_stack¶

void cubpl::session::pop_and_destroy_stack (
    const  PL_STACK_ID sid
)

function release_connection¶

void cubpl::session::release_connection (
    connection_view & conn
)

function remove_session_cursor¶

void cubpl::session::remove_session_cursor (
    cubthread::entry * thread_p,
    QUERY_ID query_id
)

function session¶

cubpl::session::session (
    SESSION_ID id
)

function set_db_parameter_info¶

void cubpl::session::set_db_parameter_info (
    cubmethod::db_parameter_info * param_info
)

function set_interrupt¶

void cubpl::session::set_interrupt (
    int reason,
    std::string msg=""
)

function set_local_error_for_interrupt¶

void cubpl::session::set_local_error_for_interrupt ()

function set_session_param¶

void cubpl::session::set_session_param (
    const  sys_param & param
)

function set_session_params_all_required¶

void cubpl::session::set_session_params_all_required (
    bool is_required
)

function top_stack¶

execution_stack * cubpl::session::top_stack ()

function wait_until_pl_session_done¶

void cubpl::session::wait_until_pl_session_done ()

function ~session¶

cubpl::session::~session ()

The documentation for this class was generated from the following file cubrid/src/sp/pl_session.hpp