The R Project SVN – R-packages – Diff – /trunk/SQLiteDF/src/sqlite_dataframe.h


#include "R.h"
#include "Rdefines.h"
#include "Rinternals.h"
#include "sqlite3.h"
#include "exports.h"
 
#ifndef __SQLITE_DATAFRAME__
#define __SQLITE_DATAFRAME__
 
/* # of sql buffers */
#define NBUFS 4
 
#ifdef __SQLITE_WORKSPACE__
SEXP SDF_RowNamesSymbol;
SEXP SDF_VectorTypeSymbol;
SEXP SDF_DimSymbol;
SEXP SDF_DimNamesSymbol;
#else 
extern SEXP SDF_RowNamesSymbol;
extern SEXP SDF_VectorTypeSymbol;
extern SEXP SDF_DimSymbol;
extern SEXP SDF_DimNamesSymbol;
 
extern sqlite3 *g_workspace;
extern char *g_sql_buf[NBUFS];
extern int g_sql_buf_sz[NBUFS];
#endif
 
/* sdf type attributes */
#define GET_SDFVECTORTYPE(x) getAttrib(x, SDF_VectorTypeSymbol) 
#define SET_SDFVECTORTYPE(x,t) setAttrib(x, SDF_VectorTypeSymbol, t) 
#define TEST_SDFVECTORTYPE(x, t) (strcmp(CHAR(asChar(GET_SDFVECTORTYPE(x))), t) == 0)
#define GET_SDFROWNAMES(x) getAttrib(x, SDF_RowNamesSymbol)
#define SET_SDFROWNAMES(x, r) setAttrib(x, SDF_RowNamesSymbol, r)
 
#ifndef SET_ROWNAMES
#define SET_ROWNAMES(x, r) setAttrib(x, R_RowNamesSymbol, r)
#endif
 
#define WORKSPACE_COLUMNS 6
#define MAX_ATTACHED 30     /* 31 including workspace.db */
 
/* utilities for checking characteristics of arg */
int _is_r_sym(const char *sym);
int _file_exists(char *filename);
int _sdf_exists2(const char *iname);
 
/* sdf utilities */
int USE_SDF1(const char *iname, int exists, int protect);  /* call this before doing anything on an SDF */
int UNUSE_SDF2(const char *iname); /* somewhat like UNPROTECT */
SEXP _create_sdf_sexp(const char *iname);  /* create a SEXP for an SDF */
int _add_sdf1(const char *filename, const char *internal_name); /* add SDF to workspace */
void _delete_sdf2(const char *iname); /* remove SDF from workspace */
int _get_factor_levels1(const char *iname, const char *varname, SEXP var, int set_class);
int _get_row_count2(const char *table, int quote);
SEXP _get_rownames(const char *sdf_iname);
char *_get_full_pathname2(const char *relpath); /* get full path given relpath, used in workspace mgmt */
int _is_factor2(const char *iname, const char *factor_type, const char *colname);
SEXP _get_rownames2(const char *sdf_iname);
 
/* utilities for creating SDFs */
char *_create_sdf_skeleton1(SEXP name, int *o_namelen, int protect);
int _copy_factor_levels2(const char *factor_type, const char *iname_src,
        const char *colname_src, const char *iname_dst, const char *colname_dst);
int _create_factor_table2(const char *iname, const char *factor_type, 
        const char *colname);
char *_create_svector1(SEXP name, const char *type, int * _namelen, int protect);
 
/* utilities for creating SVecs */
int _get_vector_index_typed_result(sqlite3_stmt *stmt, SEXP *ret, int colidx, 
        int idx_or_len, int *coltype);
 
/* R utilities */
SEXP _getListElement(SEXP list, const char *varname);
SEXP _shrink_vector(SEXP vec, int len); /* shrink vector size */
 
/* sqlite utilities */
int _empty_callback(void *data, int ncols, char **row, char **cols);
int _sqlite_error_check(int res, const char *file, int line);
const char *_get_column_type(const char *class, int type); /* get sqlite type corresponding to R class & type */
int _get_r_type(const char *decl_type);                   /* get r type based on sqlite decltype */
sqlite3* _is_sqlitedb(const char *filename);
void _init_sqlite_function_accumulator();
int *_make_row_index(SEXP idx, int *plen);
 
/* global buffer (g_sql_buf) utilities */
R_INLINE void _expand_buf(int i, int size);  /* expand ith buf if size > buf[i].size */
 
 
/* workspace utilities */
int _prepare_attach2();  /* prepare workspace before attaching a sqlite db */
 
/* sqlite vector utilities */
SEXP _create_svector_sexp(const char *iname, const char *tblname, const char *varname, const char *type);
 
/* misc utilities */
char *_r2iname(char *internal_name, char *filename);
char *_fixname(char *rname);
char *_str_tolower(char *out, const char *ref);
 
/* register functions to sqlite */
void __register_vector_math();
 
#define _sqlite_exec(sql) sqlite3_exec(g_workspace, sql, NULL, NULL, NULL)
#define _sqlite_error(res) _sqlite_error_check((res), __FILE__, __LINE__)
 
#ifdef __SQLITE_DEBUG__
#define _sqlite_begin  { _sqlite_error(_sqlite_exec("begin")); Rprintf("begin at "  __FILE__  " line %d\n",  __LINE__); }
#define _sqlite_commit  { _sqlite_error(_sqlite_exec("commit")); Rprintf("commit at "  __FILE__  " line %d\n",  __LINE__); }
#else
#define _sqlite_begin  _sqlite_error(_sqlite_exec("begin")) 
#define _sqlite_commit _sqlite_error(_sqlite_exec("commit"))
#endif
 
/* R object accessors shortcuts */
#define CHAR_ELT(str, i) CHAR(STRING_ELT(str,i))
 
/* SDF object accessors shortcuts */
#define SDF_INAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "iname"),0))
#define SVEC_TBLNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "tblname"),0))
#define SVEC_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))
 
/* possible var types when stored in sqlite as integer */
#define VAR_INTEGER 0
#define VAR_FACTOR  1
#define VAR_ORDERED 2
 
/* detail constants (see _get_sdf_detail2 in sqlite_workspace.c) */
#define SDF_DETAIL_EXISTS 0
#define SDF_DETAIL_FULLFILENAME 1
 
/* R SXP type constants */
#define FACTORSXP 11
#define ORDEREDSXP 12
 
/* additional column types */
#define SQLITEDF_BIT 100
 
#endif

The R Project SVN R-packages

(root)/trunk/SQLiteDF/src/sqlite_dataframe.h – Rev 4590 → 4798

Rev 4590		Rev 4798
1	`#include "R.h"`	1	`#include "R.h"`
2	`#include "Rdefines.h"`	2	`#include "Rdefines.h"`
3	`#include "Rinternals.h"`	3	`#include "Rinternals.h"`
4	`#include "sqlite3.h"`	4	`#include "sqlite3.h"`
5	`#include "exports.h"`	5	`#include "exports.h"`
6		6
7	`#ifndef __SQLITE_DATAFRAME__`	7	`#ifndef __SQLITE_DATAFRAME__`
8	`#define __SQLITE_DATAFRAME__`	8	`#define __SQLITE_DATAFRAME__`
9		9
10	`/* # of sql buffers */`	10	`/* # of sql buffers */`
11	`#define NBUFS 4`	11	`#define NBUFS 4`
12		12
13	`#ifdef __SQLITE_WORKSPACE__`	13	`#ifdef __SQLITE_WORKSPACE__`
14	`SEXP SDF_RowNamesSymbol;`	14	`SEXP SDF_RowNamesSymbol;`
15	`SEXP SDF_VectorTypeSymbol;`	15	`SEXP SDF_VectorTypeSymbol;`
16	`SEXP SDF_DimSymbol;`	16	`SEXP SDF_DimSymbol;`
17	`SEXP SDF_DimNamesSymbol;`	17	`SEXP SDF_DimNamesSymbol;`
18	`#else`	18	`#else`
19	`extern SEXP SDF_RowNamesSymbol;`	19	`extern SEXP SDF_RowNamesSymbol;`
20	`extern SEXP SDF_VectorTypeSymbol;`	20	`extern SEXP SDF_VectorTypeSymbol;`
21	`extern SEXP SDF_DimSymbol;`	21	`extern SEXP SDF_DimSymbol;`
22	`extern SEXP SDF_DimNamesSymbol;`	22	`extern SEXP SDF_DimNamesSymbol;`
23		23
24	`extern sqlite3 *g_workspace;`	24	`extern sqlite3 *g_workspace;`
25	`extern char *g_sql_buf[NBUFS];`	25	`extern char *g_sql_buf[NBUFS];`
26	`extern int g_sql_buf_sz[NBUFS];`	26	`extern int g_sql_buf_sz[NBUFS];`
27	`#endif`	27	`#endif`
28		28
29	`/* sdf type attributes */`	29	`/* sdf type attributes */`
30	`#define GET_SDFVECTORTYPE(x) getAttrib(x, SDF_VectorTypeSymbol)`	30	`#define GET_SDFVECTORTYPE(x) getAttrib(x, SDF_VectorTypeSymbol)`
31	`#define SET_SDFVECTORTYPE(x,t) setAttrib(x, SDF_VectorTypeSymbol, t)`	31	`#define SET_SDFVECTORTYPE(x,t) setAttrib(x, SDF_VectorTypeSymbol, t)`
32	`#define TEST_SDFVECTORTYPE(x, t) (strcmp(CHAR(asChar(GET_SDFVECTORTYPE(x))), t) == 0)`	32	`#define TEST_SDFVECTORTYPE(x, t) (strcmp(CHAR(asChar(GET_SDFVECTORTYPE(x))), t) == 0)`
33	`#define GET_SDFROWNAMES(x) getAttrib(x, SDF_RowNamesSymbol)`	33	`#define GET_SDFROWNAMES(x) getAttrib(x, SDF_RowNamesSymbol)`
34	`#define SET_SDFROWNAMES(x, r) setAttrib(x, SDF_RowNamesSymbol, r)`	34	`#define SET_SDFROWNAMES(x, r) setAttrib(x, SDF_RowNamesSymbol, r)`
35		35
36	`#ifndef SET_ROWNAMES`	36	`#ifndef SET_ROWNAMES`
37	`#define SET_ROWNAMES(x, r) setAttrib(x, R_RowNamesSymbol, r)`	37	`#define SET_ROWNAMES(x, r) setAttrib(x, R_RowNamesSymbol, r)`
38	`#endif`	38	`#endif`
39		39
40	`#define WORKSPACE_COLUMNS 6`	40	`#define WORKSPACE_COLUMNS 6`
41	`#define MAX_ATTACHED 30 /* 31 including workspace.db */`	41	`#define MAX_ATTACHED 30 /* 31 including workspace.db */`
42		42
43	`/* utilities for checking characteristics of arg */`	43	`/* utilities for checking characteristics of arg */`
44	`int _is_r_sym(char *sym);`	44	`int _is_r_sym(const char *sym);`
45	`int _file_exists(char *filename);`	45	`int _file_exists(char *filename);`
46	`int _sdf_exists2(char *iname);`	46	`int _sdf_exists2(const char *iname);`
47		47
48	`/* sdf utilities */`	48	`/* sdf utilities */`
49	`int USE_SDF1(const char iname, int exists, int protect); / call this before doing anything on an SDF */`	49	`int USE_SDF1(const char iname, int exists, int protect); / call this before doing anything on an SDF */`
50	`int UNUSE_SDF2(const char iname); / somewhat like UNPROTECT */`	50	`int UNUSE_SDF2(const char iname); / somewhat like UNPROTECT */`
51	`SEXP _create_sdf_sexp(const char iname); / create a SEXP for an SDF */`	51	`SEXP _create_sdf_sexp(const char iname); / create a SEXP for an SDF */`
52	`int _add_sdf1(char filename, char internal_name); /* add SDF to workspace */`	52	`int _add_sdf1(const char filename, const char internal_name); /* add SDF to workspace */`
53	`void _delete_sdf2(const char iname); / remove SDF from workspace */`	53	`void _delete_sdf2(const char iname); / remove SDF from workspace */`
54	`int _get_factor_levels1(const char iname, const char varname, SEXP var, int set_class);`	54	`int _get_factor_levels1(const char iname, const char varname, SEXP var, int set_class);`
55	`int _get_row_count2(const char *table, int quote);`	55	`int _get_row_count2(const char *table, int quote);`
56	`SEXP _get_rownames(const char *sdf_iname);`	56	`SEXP _get_rownames(const char *sdf_iname);`
57	`char _get_full_pathname2(char relpath); /* get full path given relpath, used in workspace mgmt */`	57	`char _get_full_pathname2(const char relpath); /* get full path given relpath, used in workspace mgmt */`
58	`int _is_factor2(const char iname, const char factor_type, const char *colname);`	58	`int _is_factor2(const char iname, const char factor_type, const char *colname);`
59	`SEXP _get_rownames2(const char *sdf_iname);`	59	`SEXP _get_rownames2(const char *sdf_iname);`
60		60
61	`/* utilities for creating SDFs */`	61	`/* utilities for creating SDFs */`
62	`char _create_sdf_skeleton1(SEXP name, int o_namelen, int protect);`	62	`char _create_sdf_skeleton1(SEXP name, int o_namelen, int protect);`
63	`int _copy_factor_levels2(const char factor_type, const char iname_src,`	63	`int _copy_factor_levels2(const char factor_type, const char iname_src,`
64	`const char colname_src, const char iname_dst, const char *colname_dst);`	64	`const char colname_src, const char iname_dst, const char *colname_dst);`
65	`int _create_factor_table2(const char iname, const char factor_type,`	65	`int _create_factor_table2(const char iname, const char factor_type,`
66	`const char *colname);`	66	`const char *colname);`
67	`char _create_svector1(SEXP name, const char type, int * _namelen, int protect);`	67	`char _create_svector1(SEXP name, const char type, int * _namelen, int protect);`
68		68
69	`/* utilities for creating SVecs */`	69	`/* utilities for creating SVecs */`
70	`int _get_vector_index_typed_result(sqlite3_stmt stmt, SEXP ret, int colidx,`	70	`int _get_vector_index_typed_result(sqlite3_stmt stmt, SEXP ret, int colidx,`
71	`int idx_or_len, int *coltype);`	71	`int idx_or_len, int *coltype);`
72		72
73	`/* R utilities */`	73	`/* R utilities */`
74	`SEXP _getListElement(SEXP list, char *varname);`	74	`SEXP _getListElement(SEXP list, const char *varname);`
75	`SEXP _shrink_vector(SEXP vec, int len); /* shrink vector size */`	75	`SEXP _shrink_vector(SEXP vec, int len); /* shrink vector size */`
76		76
77	`/* sqlite utilities */`	77	`/* sqlite utilities */`
78	`int _empty_callback(void data, int ncols, char row, char *cols);`	78	`int _empty_callback(void data, int ncols, char row, char *cols);`
79	`int _sqlite_error_check(int res, const char *file, int line);`	79	`int _sqlite_error_check(int res, const char *file, int line);`
80	`const char _get_column_type(const char class, int type); /* get sqlite type corresponding to R class & type */`	80	`const char _get_column_type(const char class, int type); /* get sqlite type corresponding to R class & type */`
81	`int _get_r_type(const char decl_type); / get r type based on sqlite decltype */`	81	`int _get_r_type(const char decl_type); / get r type based on sqlite decltype */`
82	`sqlite3* _is_sqlitedb(char *filename);`	82	`sqlite3* _is_sqlitedb(const char *filename);`
83	`void _init_sqlite_function_accumulator();`	83	`void _init_sqlite_function_accumulator();`
84	`int _make_row_index(SEXP idx, int plen);`	84	`int _make_row_index(SEXP idx, int plen);`
85		85
86	`/* global buffer (g_sql_buf) utilities */`	86	`/* global buffer (g_sql_buf) utilities */`
87	`R_INLINE void _expand_buf(int i, int size); /* expand ith buf if size > buf[i].size */`	87	`R_INLINE void _expand_buf(int i, int size); /* expand ith buf if size > buf[i].size */`
88		88
89		89
90	`/* workspace utilities */`	90	`/* workspace utilities */`
91	`int _prepare_attach2(); /* prepare workspace before attaching a sqlite db */`	91	`int _prepare_attach2(); /* prepare workspace before attaching a sqlite db */`
92		92
93	`/* sqlite vector utilities */`	93	`/* sqlite vector utilities */`
94	`SEXP _create_svector_sexp(const char iname, const char tblname, const char varname, const char type);`	94	`SEXP _create_svector_sexp(const char iname, const char tblname, const char varname, const char type);`
95		95
96	`/* misc utilities */`	96	`/* misc utilities */`
97	`char _r2iname(char internal_name, char *filename);`	97	`char _r2iname(char internal_name, char *filename);`
98	`char _fixname(char rname);`	98	`char _fixname(char rname);`
99	`char _str_tolower(char out, const char *ref);`	99	`char _str_tolower(char out, const char *ref);`
100		100
101	`/* register functions to sqlite */`	101	`/* register functions to sqlite */`
102	`void __register_vector_math();`	102	`void __register_vector_math();`
103		103
104	`#define _sqlite_exec(sql) sqlite3_exec(g_workspace, sql, NULL, NULL, NULL)`	104	`#define _sqlite_exec(sql) sqlite3_exec(g_workspace, sql, NULL, NULL, NULL)`
105	`#define _sqlite_error(res) _sqlite_error_check((res), __FILE__, __LINE__)`	105	`#define _sqlite_error(res) _sqlite_error_check((res), __FILE__, __LINE__)`
106		106
107	`#ifdef __SQLITE_DEBUG__`	107	`#ifdef __SQLITE_DEBUG__`
108	`#define _sqlite_begin { _sqlite_error(_sqlite_exec("begin")); Rprintf("begin at " __FILE__ " line %d\n", __LINE__); }`	108	`#define _sqlite_begin { _sqlite_error(_sqlite_exec("begin")); Rprintf("begin at " __FILE__ " line %d\n", __LINE__); }`
109	`#define _sqlite_commit { _sqlite_error(_sqlite_exec("commit")); Rprintf("commit at " __FILE__ " line %d\n", __LINE__); }`	109	`#define _sqlite_commit { _sqlite_error(_sqlite_exec("commit")); Rprintf("commit at " __FILE__ " line %d\n", __LINE__); }`
110	`#else`	110	`#else`
111	`#define _sqlite_begin _sqlite_error(_sqlite_exec("begin"))`	111	`#define _sqlite_begin _sqlite_error(_sqlite_exec("begin"))`
112	`#define _sqlite_commit _sqlite_error(_sqlite_exec("commit"))`	112	`#define _sqlite_commit _sqlite_error(_sqlite_exec("commit"))`
113	`#endif`	113	`#endif`
114		114
115	`/* R object accessors shortcuts */`	115	`/* R object accessors shortcuts */`
116	`#define CHAR_ELT(str, i) CHAR(STRING_ELT(str,i))`	116	`#define CHAR_ELT(str, i) CHAR(STRING_ELT(str,i))`
117		117
118	`/* SDF object accessors shortcuts */`	118	`/* SDF object accessors shortcuts */`
119	`#define SDF_INAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "iname"),0))`	119	`#define SDF_INAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "iname"),0))`
120	`#define SVEC_TBLNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "tblname"),0))`	120	`#define SVEC_TBLNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "tblname"),0))`
121	`#define SVEC_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))`	121	`#define SVEC_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))`
122		122
123	`/* possible var types when stored in sqlite as integer */`	123	`/* possible var types when stored in sqlite as integer */`
124	`#define VAR_INTEGER 0`	124	`#define VAR_INTEGER 0`
125	`#define VAR_FACTOR 1`	125	`#define VAR_FACTOR 1`
126	`#define VAR_ORDERED 2`	126	`#define VAR_ORDERED 2`
127		127
128	`/* detail constants (see _get_sdf_detail2 in sqlite_workspace.c) */`	128	`/* detail constants (see _get_sdf_detail2 in sqlite_workspace.c) */`
129	`#define SDF_DETAIL_EXISTS 0`	129	`#define SDF_DETAIL_EXISTS 0`
130	`#define SDF_DETAIL_FULLFILENAME 1`	130	`#define SDF_DETAIL_FULLFILENAME 1`
131		131
132	`/* R SXP type constants */`	132	`/* R SXP type constants */`
133	`#define FACTORSXP 11`	133	`#define FACTORSXP 11`
134	`#define ORDEREDSXP 12`	134	`#define ORDEREDSXP 12`
135		135
136	`/* additional column types */`	136	`/* additional column types */`
137	`#define SQLITEDF_BIT 100`	137	`#define SQLITEDF_BIT 100`
138		138
139	`#endif`	139	`#endif`