base/drms/libs/api/drms_network.h File Reference

#include "db.h"
#include "drms_types.h"

Include dependency graph for drms_network.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Defines
#define	DRMS_ALLOC_RECNUM
#define	DRMS_BINQUERY
#define	DRMS_BINQUERY_ARRAY
#define	DRMS_BINQUERY_NTUPLE
#define	DRMS_BULK_INSERT_ARRAY
#define	DRMS_COMMIT
#define	DRMS_DISCONNECT
#define	DRMS_DMS
#define	DRMS_DMS_ARRAY
#define	DRMS_DROPSERIES
#define	DRMS_GETDBUSER
#define	DRMS_GETSUDIR
#define	DRMS_GETSUDIRS
#define	DRMS_GETSUINFO
#define	DRMS_GETTMPGUID
#define	DRMS_GETUNIT
#define	DRMS_GETUNITS
#define	DRMS_LOCALSITEINFO
#define	DRMS_MAKESESSIONWRITABLE
#define	DRMS_NEWSERIES
#define	DRMS_NEWSLOTS
#define	DRMS_RESERVED
#define	DRMS_ROLLBACK
#define	DRMS_SEQUENCE_CREATE
#define	DRMS_SEQUENCE_DROP
#define	DRMS_SEQUENCE_GETCURRENT
#define	DRMS_SEQUENCE_GETLAST
#define	DRMS_SEQUENCE_GETNEXT
#define	DRMS_SETRETENTION
#define	DRMS_SITEINFO
#define	DRMS_SLOT_SETSTATE
#define	DRMS_TXTQUERY
#define	kNOLOGSUDIR
FunctionsTitleTestFour
int	drms_bulk_insert_array (DRMS_Session_t *session, char *table, int n_rows, int n_args, DB_Type_t *intype, void **argin)
	Bulk insert.
int	drms_bulk_insertv (DRMS_Session_t *session, char *table, int n_rows, int n_cols,...)
	Bulk insert with parameters in variable argument list, calls drms_bulk_insert_array().
int	drms_client_isproduser (DRMS_Env_t *env, int *status)
DRMS_Session_t *	drms_connect (const char *host)
	Establish socket connection to server, receive from server session information.
DRMS_Session_t *	drms_connect_direct (const char *host, const char *user, const char *passwd, const char *dbname, const char *sessionns)
	Establish DB connection, initialize session information.
int	drms_create_series_fromprototype (DRMS_Record_t **prototype, const char *outSeriesName, int perms)
	Create a new series on-the-fly, using a series record prototype.
int	drms_dms (DRMS_Session_t *session, int *row_count, char *query)
	Execute a data manipulation statement (DMS).
int	drms_dms_array (DRMS_Session_t *session, int *row_count, char *query, int n_rows, int n_args, DB_Type_t *intype, void **argin)
	Same as drmm_dms() with DMS parameters.
int	drms_dmsv (DRMS_Session_t *session, int *row_count, char *query, int n_rows,...)
	Same as drms_dms() with DMS parameters in variable argument list, calls drms_dms_array().
int	drms_getsudir (DRMS_Env_t *env, DRMS_StorageUnit_t *su, int retrieve)
int	drms_getsudirs (DRMS_Env_t *env, DRMS_StorageUnit_t **su, int num, int retrieve, int dontwait)
int	drms_makewritable (DRMS_Env_t *env)
DB_Binary_Result_t *	drms_query_bin (DRMS_Session_t *session, char *query)
	Perform query and receive query results in DB_Binary_Result_t.
DB_Binary_Result_t *	drms_query_bin_array (DRMS_Session_t *session, char *query, int n_args, DB_Type_t *intype, void **argin)
	Same as drms_query_bin() with query parameters.
DB_Binary_Result_t **	drms_query_bin_ntuple (DRMS_Session_t *session, const char *stmnt, unsigned int nelems, unsigned int nargs, DB_Type_t *dbtypes, void **values)
DB_Binary_Result_t *	drms_query_binv (DRMS_Session_t *session, char *query,...)
	Same as drms_query_bin() with query parameters in variable argument list, calls drms_query_bin_array().
int	drms_query_tabexists (DRMS_Session_t *session, const char *ns, const char *tab, int *status)
DB_Text_Result_t *	drms_query_txt (DRMS_Session_t *session, char *query)
	Perform query and receive query results in DB_Text_Result_t.
int	drms_series_cancreaterecord (DRMS_Env_t *env, const char *series)
int	drms_series_candeleterecord (DRMS_Env_t *env, const char *series)
int	drms_series_canupdaterecord (DRMS_Env_t *env, const char *series)
int	drms_series_hastableprivs (DRMS_Env_t *env, const char *schema, const char *table, const char *priv)
int	drms_series_isdbowner (DRMS_Env_t *env, const char *series, int *status)
int	drms_setretention (DRMS_Env_t *env, int16_t newRetention, int nsus, long long *sunums)

---

Detailed Description

Definition in file drms_network.h.