Inheritance diagram for eXtremeDB.DatabaseWrapper:

Classes
struct	McoErrorInfo_t

class	McoSqlErrorInfo

struct	sql_server_session_info_t

Public Types
enum class	session_state_t { s_wait , s_active , s_done , s_canceled }

Public Member Functions
IntPtr	StartTransaction (IntPtr con, int type, int pri, int level)

bool	CommitTransactionPhase (IntPtr con, int phase)

bool	CommitTransaction (IntPtr con)

void	RollbackTransaction (IntPtr con)

IntPtr	StartSqlTransaction (IntPtr con, int type, int pri, int level)

void	ReleaseSqlTransaction (IntPtr trans)

void	SetCommitPolicy (IntPtr con, int policy)

void	DiskFlush (IntPtr con)

void	Disconnect (IntPtr con)

IntPtr	Connect (String name, byte[]? context)

IntPtr	ConnectEngine (string host, int port, int maxAttempts, bool localDomain, int txBufSize, int connectTimeout, int readTimeout, int compressionLevel, Database.SSLParameters? sslParameters, string? user, string? password)

IntPtr	ConnectDistributedEngine (string[] hosts, int nReplicas, SqlRemoteConnection.ReplicationType replType, int maxAttempts, bool localDomain, int txBufSize, int connectTimeout, int readTimeout, int compressionLevel, Database.SSLParameters? sslParameters, string? user, string? password)

bool	Save (IntPtr con, String name)

void	SaveMetadata (IntPtr con, String metadataFile, bool saveDefaults)

void	SaveDictionary (IntPtr con, String dictionaryFile)

void	DatabaseExtendDev (String dbname, IntPtr dev, byte[] context)

bool	DatabaseDetachDev (String dbname, IntPtr dev, byte[] context)

IntPtr	AllocPrivateMemory (ulong size)

void	setRuntimeOption (int option, int val)

int	getRuntimeOption (int option)

Database.RuntimeInfo	getRuntimeInfo ()

void	Close (String name)

Int32	GetFreePages (IntPtr con)

Int32	GetTotalPages (IntPtr con)

Int16	GetDbPageSize (IntPtr con)

ClassStat	GetClassStat (IntPtr con, int ClassCode)

Int16	IndexStatCount (IntPtr con)

IndexStat	GetIndexStat (IntPtr con, Int16 index)

DiskInfo	GetDiskInfo (IntPtr con)

void	IgnoreTtl (IntPtr con, bool ignore)

bool	IsTtlIgnored (IntPtr con)

int	GetSystemCurrentTime ()

IntPtr	OpenEngine (IntPtr con)

IntPtr	ExecuteQuery (IntPtr engine, IntPtr trans, string query, Object[] args)

int	ExecuteStatement (IntPtr engine, IntPtr trans, string query, params Object[] args)

void	CloseEngine (IntPtr engine)

bool	HasNext (IntPtr cursor)

IntPtr	NextRecord (IntPtr cursor)

void	CloseCursor (IntPtr cursor)

IntPtr	GetSqlCursor (IntPtr resultSet)

string[]	GetColumnNames (IntPtr resultSet)

int[]	GetColumnTypes (IntPtr resultSet)

int	GetNumberOfColumns (IntPtr resultSet)

void	CloseResultSet (IntPtr resultSet)

int	RecordSize (IntPtr record)

object	GetColumn (IDatabaseWrapper wrapper, IntPtr record, int i)

IntPtr	serverInit (SqlServer.OpenParameters op)

void	serverStart (IntPtr server)

void	serverStop (IntPtr server)

SqlServer.SessionInfo[]	server_getSessionsInfo (IntPtr server)

static void	mco_error_set_handler (extremedb_error_handler h)

static IntPtr	exdb_alloc_memory (ulong size)

static IntPtr	exdb_allocate_device_array (int ndev)

static void	exdb_set_conventional_memory_device (IntPtr devs, int devno, uint assignment, UInt64 size, IntPtr ptr, int flags)

static void	exdb_set_named_memory_device (IntPtr devs, int devno, uint assignment, UInt64 size, string name, int flags, IntPtr hint)

static void	exdb_set_file_device (IntPtr devs, int devno, uint assignment, int flags, string name)

static void	exdb_set_multifile_device (IntPtr devs, int devno, uint assignment, int flags, string name, UInt64 segment_size)

static void	exdb_set_raid_device (IntPtr devs, int devno, uint assignment, int flags, string name, int level, UInt64 offset)

static void	setRuntimeOption_impl (int option, int val)

static int	getRuntimeOption_impl (int option)

static void	exdb_mco_get_runtime_info (ref mco_runtime_info_t info)

static MCO_RET_E	mco_db_connect (string name, out IntPtr conh)

static MCO_RET_E	mco_db_disconnect (IntPtr con)

static MCO_RET_E	mco_db_close (String name)

static void	mco_db_params_init (ref Database.mco_db_params_t dbparams)

static void	mco_ssl_params_init (ref Database.mco_ssl_params_t sslparams)

static Int64	mco_time2ticks (Int64 time, int scale)

static MCO_RET_E	database_open (string name, IntPtr devs, int nDevices, ref Database.mco_db_params_t db_params)

static MCO_RET_E	mco_trans_start_ex (IntPtr db, int type, int pri, int level, ref IntPtr p_trans)

static MCO_RET_E	mco_trans_commit (IntPtr t)

static MCO_RET_E	mco_trans_commit_phase1 (IntPtr t)

static MCO_RET_E	mco_trans_commit_phase2 (IntPtr t)

static MCO_RET_E	mco_trans_rollback (IntPtr t)

static MCO_RET_E	mco_trans_upgrade (IntPtr t)

static MCO_RET_E	ssl_init ()

static MCO_RET_E	ssl_load_verify_locations (string caFile, string caPath)

static void	Close_impl (String name)

static MCO_RET_E	exdb_runtime_stop ()

static MCO_RET_E	exdb_runtime_start (Database.Mode mode, string runtime_path)

static int	exdb_mco_md_get_type ()

static IntPtr	Connect_impl (String name, byte[] context)

static void	Disconnect_impl (IntPtr con)

static unsafe MCO_RET_E	exdb_sql_create_engine (IntPtr dbh, out IntPtr database, out IntPtr err_info)

static unsafe MCO_RET_E	exdb_sql_destroy_engine (IntPtr database, out IntPtr err_info)

static unsafe void	exdb_set_ws_limit (ulong limit)

static unsafe MCO_RET_E	exdb_vexecuteStatement (IntPtr engine, IntPtr trans, string query, void *values, int len, out Int64 ret, out IntPtr errinfo)

static unsafe IntPtr	exdb_vexecuteQuery (IntPtr engine, IntPtr trans, string query, void *values, int len, out IntPtr errinfo)

static unsafe MCO_RET_E	exdb_engine_close (IntPtr engine, out IntPtr errinfo)

static unsafe IntPtr	exdb_start_transaction (IntPtr id, int type, int pri, int level, out IntPtr errinfo)

static unsafe void	exdb_release_transaction (IntPtr id)

static unsafe int	exdb_result_ncolumns (IntPtr rset, out IntPtr errinfo)

static unsafe IntPtr	exdb_result_column_name (IntPtr rset, int i, out IntPtr errinfo)

static unsafe IntPtr	exdb_result_get_sql_cursor (IntPtr rset, out IntPtr errinfo)

static unsafe void	exdb_result_release (IntPtr pset)

static unsafe bool	exdb_result_is_remote (IntPtr pset)

static unsafe IntPtr	exdb_result_get_field (IntPtr pset, int i)

static unsafe int	exdb_field_get_type (IntPtr fld)

static unsafe SqlType	exdb_field_get_element_type (IntPtr fld)

static unsafe IntPtr	exdb_rec_value (IntPtr id, int i, out SqlType typeret, out IntPtr errinfo)

static unsafe long	exdb_val_int (IntPtr pval)

static unsafe long	exdb_val_time (IntPtr pval)

static unsafe void	exdb_val_numeric (IntPtr pval, out Int64 val_ret, out byte precision_ret)

static unsafe int	exdb_val_blob_available (IntPtr pval)

static unsafe int	exdb_val_blob_get (IntPtr pval, IntPtr buffer, int size)

static unsafe double	exdb_val_dbl (IntPtr pval)

static unsafe IntPtr	exdb_val_str (IntPtr pval, IntPtr prec, out IntPtr errinfo)

static void	CloseEngine_impl (IntPtr engine)

static void	free_error_info (IntPtr err_info)

static MCO_RET_E	exdb_sql_has_next_impl (IntPtr cursor, out IntPtr err_info)

static IntPtr	exdb_sql_next_record_impl (IntPtr cursor, out IntPtr err_info)

static void	CloseCursor_impl (IntPtr cursor)

static IntPtr	GetSqlCursor_impl (IntPtr resultSet)

static int	GetNumberOfColumns_impl (IntPtr resultSet)

static void	CloseResultSet_impl (IntPtr resultSet)

static int	RecordSize_impl (IntPtr record)

static object	GetColumn (IntPtr record, int i)

static IntPtr	exdb_create_remote_sql_engine (int txBufSize)

static void	exdb_delete_remote_sql_engine (IntPtr engine)

static MCO_RET_E	exdb_rsql_engine_open (IntPtr engine, string host, int port, int maxAttempts, bool localDomain, int connectTimeout, int readTimeout, int compressionLevel, out IntPtr errinfo)

static MCO_RET_E	exdb_rsql_engine_open_ssl (IntPtr engine, string host, int port, int maxAttempts, bool localDomain, ref Database.mco_ssl_params_t ssl_params, int connectTimeout, int readTimeout, int compressionLevel, out IntPtr errinfo)

static MCO_RET_E	exdb_rsql_engine_authenticate (IntPtr engine, string user, string password, out IntPtr errinfo)

static IntPtr	exdb_create_distributed_sql_engine (int txBufSize)

static void	exdb_delete_distributed_sql_engine (IntPtr engine)

static MCO_RET_E	exdb_distributed_engine_open (IntPtr engine, IntPtr nodes, int nNodes, int nReplicas, SqlRemoteConnection.ReplicationType replType, int maxAttempts, out int badNode, bool localDomain, int connectTimeout, int readTimeout, int compressionLevel, out IntPtr errinfo)

static MCO_RET_E	exdb_distributed_engine_open_ssl (IntPtr engine, IntPtr nodes, int nNodes, int nReplicas, SqlRemoteConnection.ReplicationType replType, int maxAttempts, out int badNode, bool localDomain, ref Database.mco_ssl_params_t ssl_params, int connectTimeout, int readTimeout, int compressionLevel, out IntPtr errinfo)

static MCO_RET_E	exdb_distributed_engine_authenticate (IntPtr engine, string user, string password, out IntPtr errinfo)

static IntPtr	exdb_mcosql_server_create (ref SqlServer.open_parameters_t oparams, out IntPtr errinfo)

static MCO_RET_E	exdb_mcosql_server_start (IntPtr server, out IntPtr errinfo)

static MCO_RET_E	exdb_mcosql_server_stop (IntPtr server, out IntPtr errinfo)

Public Member Functions inherited from eXtremeDB.IDatabaseWrapper
int	ExecuteStatement (IntPtr engine, IntPtr trans, string query, Object[] args)

Static Public Member Functions
static void	CheckError (MCO_RET_E rc)

static void	ThrowErrorInfo (IntPtr ptr, string? prefix=null)

Protected Member Functions
void	error_handler (string msg)

delegate void	session_info_handler_delegate (ref sql_server_session_info_t s, IntPtr context)

SqlServer.SessionInfo	convert_sql_server_session_info (sql_server_session_info_t s)

void	session_info_handler (ref sql_server_session_info_t s, IntPtr context)

Static Protected Member Functions
static MCO_RET_E	exdb_mcosql_server_get_session_info (IntPtr pserver, [MarshalAs(UnmanagedType.FunctionPtr)]session_info_handler_delegate h, IntPtr context, out IntPtr errinfo)

Member Enumeration Documentation

◆ session_state_t

enum eXtremeDB.DatabaseWrapper.session_state_t

strong

Enumerator
s_wait
s_active
s_done
s_canceled

Member Function Documentation

◆ AllocPrivateMemory()

IntPtr eXtremeDB.DatabaseWrapper.AllocPrivateMemory ( ulong size )

Implements eXtremeDB.IDatabaseWrapper.

◆ CheckError()

static void eXtremeDB.DatabaseWrapper.CheckError ( MCO_RET_E rc )

static

◆ Close()

void eXtremeDB.DatabaseWrapper.Close ( String name )

Implements eXtremeDB.IDatabaseWrapper.

◆ Close_impl()

static void eXtremeDB.DatabaseWrapper.Close_impl ( String name )

◆ CloseCursor()

void eXtremeDB.DatabaseWrapper.CloseCursor ( IntPtr cursor )

Implements eXtremeDB.IDatabaseWrapper.

◆ CloseCursor_impl()

static void eXtremeDB.DatabaseWrapper.CloseCursor_impl ( IntPtr cursor )

◆ CloseEngine()

void eXtremeDB.DatabaseWrapper.CloseEngine ( IntPtr engine )

Implements eXtremeDB.IDatabaseWrapper.

◆ CloseEngine_impl()

static void eXtremeDB.DatabaseWrapper.CloseEngine_impl ( IntPtr engine )

◆ CloseResultSet()

void eXtremeDB.DatabaseWrapper.CloseResultSet ( IntPtr resultSet )

Implements eXtremeDB.IDatabaseWrapper.

◆ CloseResultSet_impl()

static void eXtremeDB.DatabaseWrapper.CloseResultSet_impl ( IntPtr resultSet )

◆ CommitTransaction()

bool eXtremeDB.DatabaseWrapper.CommitTransaction ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ CommitTransactionPhase()

bool eXtremeDB.DatabaseWrapper.CommitTransactionPhase	(	IntPtr	con,
		int	phase
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ Connect()

IntPtr eXtremeDB.DatabaseWrapper.Connect	(	String	name,
		byte ?[]	context
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ Connect_impl()

static IntPtr eXtremeDB.DatabaseWrapper.Connect_impl	(	String	name,
		byte[]	context
	)

◆ ConnectDistributedEngine()

IntPtr eXtremeDB.DatabaseWrapper.ConnectDistributedEngine	(	string[]	hosts,
		int	nReplicas,
		SqlRemoteConnection.ReplicationType	replType,
		int	maxAttempts,
		bool	localDomain,
		int	txBufSize,
		int	connectTimeout,
		int	readTimeout,
		int	compressionLevel,
		Database.SSLParameters?	sslParameters,
		string?	user,
		string?	password
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ ConnectEngine()

IntPtr eXtremeDB.DatabaseWrapper.ConnectEngine	(	string	host,
		int	port,
		int	maxAttempts,
		bool	localDomain,
		int	txBufSize,
		int	connectTimeout,
		int	readTimeout,
		int	compressionLevel,
		Database.SSLParameters?	sslParameters,
		string?	user,
		string?	password
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ convert_sql_server_session_info()

SqlServer.SessionInfo eXtremeDB.DatabaseWrapper.convert_sql_server_session_info ( sql_server_session_info_t s )

protected

◆ database_open()

static MCO_RET_E eXtremeDB.DatabaseWrapper.database_open	(	string	name,
		IntPtr	devs,
		int	nDevices,
		ref Database.mco_db_params_t	db_params
	)

◆ DatabaseDetachDev()

bool eXtremeDB.DatabaseWrapper.DatabaseDetachDev	(	String	dbname,
		IntPtr	dev,
		byte[]	context
	)

◆ DatabaseExtendDev()

void eXtremeDB.DatabaseWrapper.DatabaseExtendDev	(	String	dbname,
		IntPtr	dev,
		byte[]	context
	)

◆ Disconnect()

void eXtremeDB.DatabaseWrapper.Disconnect ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ Disconnect_impl()

static void eXtremeDB.DatabaseWrapper.Disconnect_impl ( IntPtr con )

◆ DiskFlush()

void eXtremeDB.DatabaseWrapper.DiskFlush ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ error_handler()

void eXtremeDB.DatabaseWrapper.error_handler ( string msg )

protected

◆ exdb_alloc_memory()

static IntPtr eXtremeDB.DatabaseWrapper.exdb_alloc_memory ( ulong size )

◆ exdb_allocate_device_array()

static IntPtr eXtremeDB.DatabaseWrapper.exdb_allocate_device_array ( int ndev )

◆ exdb_create_distributed_sql_engine()

static IntPtr eXtremeDB.DatabaseWrapper.exdb_create_distributed_sql_engine ( int txBufSize )

◆ exdb_create_remote_sql_engine()

static IntPtr eXtremeDB.DatabaseWrapper.exdb_create_remote_sql_engine ( int txBufSize )

◆ exdb_delete_distributed_sql_engine()

static void eXtremeDB.DatabaseWrapper.exdb_delete_distributed_sql_engine ( IntPtr engine )

◆ exdb_delete_remote_sql_engine()

static void eXtremeDB.DatabaseWrapper.exdb_delete_remote_sql_engine ( IntPtr engine )

◆ exdb_distributed_engine_authenticate()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_distributed_engine_authenticate	(	IntPtr	engine,
		string	user,
		string	password,
		out IntPtr	errinfo
	)

◆ exdb_distributed_engine_open()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_distributed_engine_open	(	IntPtr	engine,
		IntPtr	nodes,
		int	nNodes,
		int	nReplicas,
		SqlRemoteConnection.ReplicationType	replType,
		int	maxAttempts,
		out int	badNode,
		bool	localDomain,
		int	connectTimeout,
		int	readTimeout,
		int	compressionLevel,
		out IntPtr	errinfo
	)

◆ exdb_distributed_engine_open_ssl()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_distributed_engine_open_ssl	(	IntPtr	engine,
		IntPtr	nodes,
		int	nNodes,
		int	nReplicas,
		SqlRemoteConnection.ReplicationType	replType,
		int	maxAttempts,
		out int	badNode,
		bool	localDomain,
		ref Database.mco_ssl_params_t	ssl_params,
		int	connectTimeout,
		int	readTimeout,
		int	compressionLevel,
		out IntPtr	errinfo
	)

◆ exdb_engine_close()

static unsafe MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_engine_close	(	IntPtr	engine,
		out IntPtr	errinfo
	)

◆ exdb_field_get_element_type()

static unsafe SqlType eXtremeDB.DatabaseWrapper.exdb_field_get_element_type ( IntPtr fld )

◆ exdb_field_get_type()

static unsafe int eXtremeDB.DatabaseWrapper.exdb_field_get_type ( IntPtr fld )

◆ exdb_mco_get_runtime_info()

static void eXtremeDB.DatabaseWrapper.exdb_mco_get_runtime_info ( ref mco_runtime_info_t info )

◆ exdb_mco_md_get_type()

static int eXtremeDB.DatabaseWrapper.exdb_mco_md_get_type ( )

◆ exdb_mcosql_server_create()

static IntPtr eXtremeDB.DatabaseWrapper.exdb_mcosql_server_create	(	ref SqlServer.open_parameters_t	oparams,
		out IntPtr	errinfo
	)

◆ exdb_mcosql_server_get_session_info()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_mcosql_server_get_session_info	(	IntPtr	pserver,
		[MarshalAs(UnmanagedType.FunctionPtr)] session_info_handler_delegate	h,
		IntPtr	context,
		out IntPtr	errinfo
	)

staticprotected

◆ exdb_mcosql_server_start()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_mcosql_server_start	(	IntPtr	server,
		out IntPtr	errinfo
	)

◆ exdb_mcosql_server_stop()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_mcosql_server_stop	(	IntPtr	server,
		out IntPtr	errinfo
	)

◆ exdb_rec_value()

static unsafe IntPtr eXtremeDB.DatabaseWrapper.exdb_rec_value	(	IntPtr	id,
		int	i,
		out SqlType	typeret,
		out IntPtr	errinfo
	)

◆ exdb_release_transaction()

static unsafe void eXtremeDB.DatabaseWrapper.exdb_release_transaction ( IntPtr id )

◆ exdb_result_column_name()

static unsafe IntPtr eXtremeDB.DatabaseWrapper.exdb_result_column_name	(	IntPtr	rset,
		int	i,
		out IntPtr	errinfo
	)

◆ exdb_result_get_field()

static unsafe IntPtr eXtremeDB.DatabaseWrapper.exdb_result_get_field	(	IntPtr	pset,
		int	i
	)

◆ exdb_result_get_sql_cursor()

static unsafe IntPtr eXtremeDB.DatabaseWrapper.exdb_result_get_sql_cursor	(	IntPtr	rset,
		out IntPtr	errinfo
	)

◆ exdb_result_is_remote()

static unsafe bool eXtremeDB.DatabaseWrapper.exdb_result_is_remote ( IntPtr pset )

◆ exdb_result_ncolumns()

static unsafe int eXtremeDB.DatabaseWrapper.exdb_result_ncolumns	(	IntPtr	rset,
		out IntPtr	errinfo
	)

◆ exdb_result_release()

static unsafe void eXtremeDB.DatabaseWrapper.exdb_result_release ( IntPtr pset )

◆ exdb_rsql_engine_authenticate()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_rsql_engine_authenticate	(	IntPtr	engine,
		string	user,
		string	password,
		out IntPtr	errinfo
	)

◆ exdb_rsql_engine_open()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_rsql_engine_open	(	IntPtr	engine,
		string	host,
		int	port,
		int	maxAttempts,
		bool	localDomain,
		int	connectTimeout,
		int	readTimeout,
		int	compressionLevel,
		out IntPtr	errinfo
	)

◆ exdb_rsql_engine_open_ssl()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_rsql_engine_open_ssl	(	IntPtr	engine,
		string	host,
		int	port,
		int	maxAttempts,
		bool	localDomain,
		ref Database.mco_ssl_params_t	ssl_params,
		int	connectTimeout,
		int	readTimeout,
		int	compressionLevel,
		out IntPtr	errinfo
	)

◆ exdb_runtime_start()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_runtime_start	(	Database.Mode	mode,
		string	runtime_path
	)

◆ exdb_runtime_stop()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_runtime_stop ( )

◆ exdb_set_conventional_memory_device()

static void eXtremeDB.DatabaseWrapper.exdb_set_conventional_memory_device	(	IntPtr	devs,
		int	devno,
		uint	assignment,
		UInt64	size,
		IntPtr	ptr,
		int	flags
	)

◆ exdb_set_file_device()

static void eXtremeDB.DatabaseWrapper.exdb_set_file_device	(	IntPtr	devs,
		int	devno,
		uint	assignment,
		int	flags,
		string	name
	)

◆ exdb_set_multifile_device()

static void eXtremeDB.DatabaseWrapper.exdb_set_multifile_device	(	IntPtr	devs,
		int	devno,
		uint	assignment,
		int	flags,
		string	name,
		UInt64	segment_size
	)

◆ exdb_set_named_memory_device()

static void eXtremeDB.DatabaseWrapper.exdb_set_named_memory_device	(	IntPtr	devs,
		int	devno,
		uint	assignment,
		UInt64	size,
		string	name,
		int	flags,
		IntPtr	hint
	)

◆ exdb_set_raid_device()

static void eXtremeDB.DatabaseWrapper.exdb_set_raid_device	(	IntPtr	devs,
		int	devno,
		uint	assignment,
		int	flags,
		string	name,
		int	level,
		UInt64	offset
	)

◆ exdb_set_ws_limit()

static unsafe void eXtremeDB.DatabaseWrapper.exdb_set_ws_limit ( ulong limit )

◆ exdb_sql_create_engine()

static unsafe MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_sql_create_engine	(	IntPtr	dbh,
		out IntPtr	database,
		out IntPtr	err_info
	)

Creates a new eXtremeSQL engine

◆ exdb_sql_destroy_engine()

static unsafe MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_sql_destroy_engine	(	IntPtr	database,
		out IntPtr	err_info
	)

Destroys the eXtremeSQL engine created by mcoapi_create_engine function

Returns: the status of the operation as described in the error_code enum

◆ exdb_sql_has_next_impl()

static MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_sql_has_next_impl	(	IntPtr	cursor,
		out IntPtr	err_info
	)

◆ exdb_sql_next_record_impl()

static IntPtr eXtremeDB.DatabaseWrapper.exdb_sql_next_record_impl	(	IntPtr	cursor,
		out IntPtr	err_info
	)

◆ exdb_start_transaction()

static unsafe IntPtr eXtremeDB.DatabaseWrapper.exdb_start_transaction	(	IntPtr	id,
		int	type,
		int	pri,
		int	level,
		out IntPtr	errinfo
	)

◆ exdb_val_blob_available()

static unsafe int eXtremeDB.DatabaseWrapper.exdb_val_blob_available ( IntPtr pval )

◆ exdb_val_blob_get()

static unsafe int eXtremeDB.DatabaseWrapper.exdb_val_blob_get	(	IntPtr	pval,
		IntPtr	buffer,
		int	size
	)

◆ exdb_val_dbl()

static unsafe double eXtremeDB.DatabaseWrapper.exdb_val_dbl ( IntPtr pval )

◆ exdb_val_int()

static unsafe long eXtremeDB.DatabaseWrapper.exdb_val_int ( IntPtr pval )

◆ exdb_val_numeric()

static unsafe void eXtremeDB.DatabaseWrapper.exdb_val_numeric	(	IntPtr	pval,
		out Int64	val_ret,
		out byte	precision_ret
	)

◆ exdb_val_str()

static unsafe IntPtr eXtremeDB.DatabaseWrapper.exdb_val_str	(	IntPtr	pval,
		IntPtr	prec,
		out IntPtr	errinfo
	)

◆ exdb_val_time()

static unsafe long eXtremeDB.DatabaseWrapper.exdb_val_time ( IntPtr pval )

◆ exdb_vexecuteQuery()

static unsafe IntPtr eXtremeDB.DatabaseWrapper.exdb_vexecuteQuery	(	IntPtr	engine,
		IntPtr	trans,
		string	query,
		void *	values,
		int	len,
		out IntPtr	errinfo
	)

◆ exdb_vexecuteStatement()

static unsafe MCO_RET_E eXtremeDB.DatabaseWrapper.exdb_vexecuteStatement	(	IntPtr	engine,
		IntPtr	trans,
		string	query,
		void *	values,
		int	len,
		out Int64	ret,
		out IntPtr	errinfo
	)

◆ ExecuteQuery()

IntPtr eXtremeDB.DatabaseWrapper.ExecuteQuery	(	IntPtr	engine,
		IntPtr	trans,
		string	query,
		Object[]	args
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ ExecuteStatement()

int eXtremeDB.DatabaseWrapper.ExecuteStatement	(	IntPtr	engine,
		IntPtr	trans,
		string	query,
		params Object[]	args
	)

◆ free_error_info()

static void eXtremeDB.DatabaseWrapper.free_error_info ( IntPtr err_info )

◆ GetClassStat()

ClassStat eXtremeDB.DatabaseWrapper.GetClassStat	(	IntPtr	con,
		int	ClassCode
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ GetColumn() [1/2]

object eXtremeDB.DatabaseWrapper.GetColumn	(	IDatabaseWrapper	wrapper,
		IntPtr	record,
		int	i
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ GetColumn() [2/2]

static object eXtremeDB.DatabaseWrapper.GetColumn	(	IntPtr	record,
		int	i
	)

◆ GetColumnNames()

string [] eXtremeDB.DatabaseWrapper.GetColumnNames ( IntPtr resultSet )

Implements eXtremeDB.IDatabaseWrapper.

◆ GetColumnTypes()

int [] eXtremeDB.DatabaseWrapper.GetColumnTypes ( IntPtr resultSet )

Implements eXtremeDB.IDatabaseWrapper.

◆ GetDbPageSize()

Int16 eXtremeDB.DatabaseWrapper.GetDbPageSize ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ GetDiskInfo()

DiskInfo eXtremeDB.DatabaseWrapper.GetDiskInfo ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ GetFreePages()

Int32 eXtremeDB.DatabaseWrapper.GetFreePages ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ GetIndexStat()

IndexStat eXtremeDB.DatabaseWrapper.GetIndexStat	(	IntPtr	con,
		Int16	index
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ GetNumberOfColumns()

int eXtremeDB.DatabaseWrapper.GetNumberOfColumns ( IntPtr resultSet )

Implements eXtremeDB.IDatabaseWrapper.

◆ GetNumberOfColumns_impl()

static int eXtremeDB.DatabaseWrapper.GetNumberOfColumns_impl ( IntPtr resultSet )

◆ getRuntimeInfo()

Database.RuntimeInfo eXtremeDB.DatabaseWrapper.getRuntimeInfo ( )

Implements eXtremeDB.IDatabaseWrapper.

◆ getRuntimeOption()

int eXtremeDB.DatabaseWrapper.getRuntimeOption ( int option )

Implements eXtremeDB.IDatabaseWrapper.

◆ getRuntimeOption_impl()

static int eXtremeDB.DatabaseWrapper.getRuntimeOption_impl ( int option )

◆ GetSqlCursor()

IntPtr eXtremeDB.DatabaseWrapper.GetSqlCursor ( IntPtr resultSet )

Implements eXtremeDB.IDatabaseWrapper.

◆ GetSqlCursor_impl()

static IntPtr eXtremeDB.DatabaseWrapper.GetSqlCursor_impl ( IntPtr resultSet )

◆ GetSystemCurrentTime()

int eXtremeDB.DatabaseWrapper.GetSystemCurrentTime ( )

◆ GetTotalPages()

Int32 eXtremeDB.DatabaseWrapper.GetTotalPages ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ HasNext()

bool eXtremeDB.DatabaseWrapper.HasNext ( IntPtr cursor )

Implements eXtremeDB.IDatabaseWrapper.

◆ IgnoreTtl()

void eXtremeDB.DatabaseWrapper.IgnoreTtl	(	IntPtr	con,
		bool	ignore
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ IndexStatCount()

Int16 eXtremeDB.DatabaseWrapper.IndexStatCount ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ IsTtlIgnored()

bool eXtremeDB.DatabaseWrapper.IsTtlIgnored ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ mco_db_close()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_db_close ( String name )

◆ mco_db_connect()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_db_connect	(	string	name,
		out IntPtr	conh
	)

◆ mco_db_disconnect()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_db_disconnect ( IntPtr con )

◆ mco_db_params_init()

static void eXtremeDB.DatabaseWrapper.mco_db_params_init ( ref Database.mco_db_params_t dbparams )

◆ mco_error_set_handler()

static void eXtremeDB.DatabaseWrapper.mco_error_set_handler ( extremedb_error_handler h )

◆ mco_ssl_params_init()

static void eXtremeDB.DatabaseWrapper.mco_ssl_params_init ( ref Database.mco_ssl_params_t sslparams )

◆ mco_time2ticks()

static Int64 eXtremeDB.DatabaseWrapper.mco_time2ticks	(	Int64	time,
		int	scale
	)

◆ mco_trans_commit()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_trans_commit ( IntPtr t )

◆ mco_trans_commit_phase1()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_trans_commit_phase1 ( IntPtr t )

◆ mco_trans_commit_phase2()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_trans_commit_phase2 ( IntPtr t )

◆ mco_trans_rollback()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_trans_rollback ( IntPtr t )

◆ mco_trans_start_ex()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_trans_start_ex	(	IntPtr	db,
		int	type,
		int	pri,
		int	level,
		ref IntPtr	p_trans
	)

◆ mco_trans_upgrade()

static MCO_RET_E eXtremeDB.DatabaseWrapper.mco_trans_upgrade ( IntPtr t )

◆ NextRecord()

IntPtr eXtremeDB.DatabaseWrapper.NextRecord ( IntPtr cursor )

Implements eXtremeDB.IDatabaseWrapper.

◆ OpenEngine()

IntPtr eXtremeDB.DatabaseWrapper.OpenEngine ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ RecordSize()

int eXtremeDB.DatabaseWrapper.RecordSize ( IntPtr record )

Implements eXtremeDB.IDatabaseWrapper.

◆ RecordSize_impl()

static int eXtremeDB.DatabaseWrapper.RecordSize_impl ( IntPtr record )

◆ ReleaseSqlTransaction()

void eXtremeDB.DatabaseWrapper.ReleaseSqlTransaction ( IntPtr trans )

Implements eXtremeDB.IDatabaseWrapper.

◆ RollbackTransaction()

void eXtremeDB.DatabaseWrapper.RollbackTransaction ( IntPtr con )

Implements eXtremeDB.IDatabaseWrapper.

◆ Save()

bool eXtremeDB.DatabaseWrapper.Save	(	IntPtr	con,
		String	name
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ SaveDictionary()

void eXtremeDB.DatabaseWrapper.SaveDictionary	(	IntPtr	con,
		String	dictionaryFile
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ SaveMetadata()

void eXtremeDB.DatabaseWrapper.SaveMetadata	(	IntPtr	con,
		String	metadataFile,
		bool	saveDefaults
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ server_getSessionsInfo()

SqlServer.SessionInfo [] eXtremeDB.DatabaseWrapper.server_getSessionsInfo ( IntPtr server )

Implements eXtremeDB.IDatabaseWrapper.

◆ serverInit()

IntPtr eXtremeDB.DatabaseWrapper.serverInit ( SqlServer.OpenParameters op )

Implements eXtremeDB.IDatabaseWrapper.

◆ serverStart()

void eXtremeDB.DatabaseWrapper.serverStart ( IntPtr server )

Implements eXtremeDB.IDatabaseWrapper.

◆ serverStop()

void eXtremeDB.DatabaseWrapper.serverStop ( IntPtr server )

Implements eXtremeDB.IDatabaseWrapper.

◆ session_info_handler()

void eXtremeDB.DatabaseWrapper.session_info_handler	(	ref sql_server_session_info_t	s,
		IntPtr	context
	)

protected

◆ session_info_handler_delegate()

delegate void eXtremeDB.DatabaseWrapper.session_info_handler_delegate	(	ref sql_server_session_info_t	s,
		IntPtr	context
	)

protected

◆ SetCommitPolicy()

void eXtremeDB.DatabaseWrapper.SetCommitPolicy	(	IntPtr	con,
		int	policy
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ setRuntimeOption()

void eXtremeDB.DatabaseWrapper.setRuntimeOption	(	int	option,
		int	val
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ setRuntimeOption_impl()

static void eXtremeDB.DatabaseWrapper.setRuntimeOption_impl	(	int	option,
		int	val
	)

◆ ssl_init()

static MCO_RET_E eXtremeDB.DatabaseWrapper.ssl_init ( )

◆ ssl_load_verify_locations()

static MCO_RET_E eXtremeDB.DatabaseWrapper.ssl_load_verify_locations	(	string	caFile,
		string	caPath
	)

◆ StartSqlTransaction()

IntPtr eXtremeDB.DatabaseWrapper.StartSqlTransaction	(	IntPtr	con,
		int	type,
		int	pri,
		int	level
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ StartTransaction()

IntPtr eXtremeDB.DatabaseWrapper.StartTransaction	(	IntPtr	con,
		int	type,
		int	pri,
		int	level
	)

Implements eXtremeDB.IDatabaseWrapper.

◆ ThrowErrorInfo()

static void eXtremeDB.DatabaseWrapper.ThrowErrorInfo	(	IntPtr	ptr,
		string?	prefix = `null`
	)

static

The documentation for this class was generated from the following file:

/home/trac/projects/eXtremeDB_8.0/supplements/netcore/src/netcore/exdbnet/DatabaseWrapper.cs

Classes

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Static Protected Member Functions

Member Enumeration Documentation

◆ session_state_t

Member Function Documentation

◆ AllocPrivateMemory()

◆ CheckError()

◆ Close()

◆ Close_impl()

◆ CloseCursor()

◆ CloseCursor_impl()

◆ CloseEngine()

◆ CloseEngine_impl()

◆ CloseResultSet()

◆ CloseResultSet_impl()

◆ CommitTransaction()

◆ CommitTransactionPhase()

◆ Connect()

◆ Connect_impl()

◆ ConnectDistributedEngine()

◆ ConnectEngine()

◆ convert_sql_server_session_info()

◆ database_open()

◆ DatabaseDetachDev()

◆ DatabaseExtendDev()

◆ Disconnect()

◆ Disconnect_impl()

◆ DiskFlush()

◆ error_handler()

◆ exdb_alloc_memory()

◆ exdb_allocate_device_array()

◆ exdb_create_distributed_sql_engine()

◆ exdb_create_remote_sql_engine()

◆ exdb_delete_distributed_sql_engine()

◆ exdb_delete_remote_sql_engine()

◆ exdb_distributed_engine_authenticate()

◆ exdb_distributed_engine_open()

◆ exdb_distributed_engine_open_ssl()

◆ exdb_engine_close()

◆ exdb_field_get_element_type()

◆ exdb_field_get_type()

◆ exdb_mco_get_runtime_info()

◆ exdb_mco_md_get_type()

◆ exdb_mcosql_server_create()

◆ exdb_mcosql_server_get_session_info()

◆ exdb_mcosql_server_start()

◆ exdb_mcosql_server_stop()

◆ exdb_rec_value()

◆ exdb_release_transaction()

◆ exdb_result_column_name()

◆ exdb_result_get_field()

◆ exdb_result_get_sql_cursor()

◆ exdb_result_is_remote()

◆ exdb_result_ncolumns()

◆ exdb_result_release()

◆ exdb_rsql_engine_authenticate()

◆ exdb_rsql_engine_open()

◆ exdb_rsql_engine_open_ssl()

◆ exdb_runtime_start()

◆ exdb_runtime_stop()

◆ exdb_set_conventional_memory_device()

◆ exdb_set_file_device()

◆ exdb_set_multifile_device()

◆ exdb_set_named_memory_device()

◆ exdb_set_raid_device()

◆ exdb_set_ws_limit()

◆ exdb_sql_create_engine()

◆ exdb_sql_destroy_engine()

◆ exdb_sql_has_next_impl()

◆ exdb_sql_next_record_impl()

◆ exdb_start_transaction()

◆ exdb_val_blob_available()

◆ exdb_val_blob_get()

◆ exdb_val_dbl()

◆ exdb_val_int()

◆ exdb_val_numeric()