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"
 
#ifndef __SQLITE_DATAFRAME__
#define __SQLITE_DATAFRAME__
 
#define WORKSPACE_COLUMNS 6
#ifndef WIN32
#define MAX_ATTACHED 30     /* 31 including workspace.db */
#else
#define MAX_ATTACHED 10     /* set to 10 until I have recompiled it to 30 */
#endif
 
/* utilities for checking characteristics of arg */
int _is_r_sym(char *sym);
int _file_exists(char *filename);
int _sdf_exists2(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(char *filename, 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 _get_row_count2(const char *table, int quote);
SEXP _get_rownames(const char *sdf_iname);
char *_get_full_pathname2(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 SDF's */
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);
 
/* R utilities */
SEXP _getListElement(SEXP list, 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 */
sqlite3* _is_sqlitedb(char *filename);
 
/* global buffer (g_sql_buf) utilities */
int _expand_buf(int i, int size);  /* expand ith buf if size > buf[i].size */
 
 
/* sqlite.vector utilities */
SEXP sdf_get_variable(SEXP sdf, SEXP name);
SEXP sdf_detach_sdf(SEXP internal_name);
 
/* workspace utilities */
int _prepare_attach2();  /* prepare workspace before attaching a sqlite db */
 
/* 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, _empty_callback, 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
 
#ifndef SET_ROWNAMES
#define SET_ROWNAMES(x,n) setAttrib(x, R_RowNamesSymbol, n)
#endif
 
/* override R's, which does a GetRowNames which is different I believe */
#undef GET_ROWNAMES
#define GET_ROWNAMES(x) getAttrib(x, R_RowNamesSymbol)
 
/* 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_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))
 
/* # of sql buffers */
#define NBUFS 4
 
/* 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
 
#ifndef __SQLITE_WORKSPACE__
extern sqlite3 *g_workspace;
extern char *g_sql_buf[NBUFS];
extern int g_sql_buf_sz[NBUFS];
#endif
 
#endif

Rev 3397	Rev 3419
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		5
6	`#ifndef __SQLITE_DATAFRAME__`	6	`#ifndef __SQLITE_DATAFRAME__`
7	`#define __SQLITE_DATAFRAME__`	7	`#define __SQLITE_DATAFRAME__`
8		8
9	`#define WORKSPACE_COLUMNS 5`	9	`#define WORKSPACE_COLUMNS 6`
10	`#ifndef WIN32`	10	`#ifndef WIN32`
11	`#define MAX_ATTACHED 30 /* 31 including workspace.db */`	11	`#define MAX_ATTACHED 30 /* 31 including workspace.db */`
12	`#else`	12	`#else`
13	`#define MAX_ATTACHED 10 /* set to 10 until I have recompiled it to 30 */`	13	`#define MAX_ATTACHED 10 /* set to 10 until I have recompiled it to 30 */`
14	`#endif`	14	`#endif`
15		15
16	`/* utilities for checking characteristics of arg */`	16	`/* utilities for checking characteristics of arg */`
17	`int _is_r_sym(char *sym);`	17	`int _is_r_sym(char *sym);`
18	`int _file_exists(char *filename);`	18	`int _file_exists(char *filename);`
19	`int _sdf_exists2(char *iname);`	19	`int _sdf_exists2(char *iname);`
20		20
21	`/* sdf utilities */`	21	`/* sdf utilities */`
22	`int USE_SDF1(const char iname, int exists); / call this before doing anything on an SDF */`	22	`int USE_SDF1(const char iname, int exists, int protect); / call this before doing anything on an SDF */`
-		23	`int UNUSE_SDF2(const char iname); / somewhat like UNPROTECT */`
23	`SEXP _create_sdf_sexp(const char iname); / create a SEXP for an SDF */`	24	`SEXP _create_sdf_sexp(const char iname); / create a SEXP for an SDF */`
24	`int _add_sdf1(char filename, char internal_name); /* add SDF to workspace */`	25	`int _add_sdf1(char filename, char internal_name); /* add SDF to workspace */`
25	`void _delete_sdf2(const char iname); / remove SDF from workspace */`	26	`void _delete_sdf2(const char iname); / remove SDF from workspace */`
26	`int _get_factor_levels1(const char iname, const char varname, SEXP var);`	27	`int _get_factor_levels1(const char iname, const char varname, SEXP var);`
27	`int _get_row_count2(const char *table, int quote);`	28	`int _get_row_count2(const char *table, int quote);`
28	`SEXP _get_rownames(const char *sdf_iname);`	29	`SEXP _get_rownames(const char *sdf_iname);`
29	`char _get_full_pathname2(char relpath); /* get full path given relpath, used in workspace mgmt */`	30	`char _get_full_pathname2(char relpath); /* get full path given relpath, used in workspace mgmt */`
-		31	`int _is_factor2(const char iname, const char factor_type, const char *colname);`
-		32	`SEXP _get_rownames2(const char *sdf_iname);`
30		33
31	`/* utilities for creating SDF's */`	34	`/* utilities for creating SDF's */`
32	`char _create_sdf_skeleton1(SEXP name, int o_namelen);`	35	`char _create_sdf_skeleton1(SEXP name, int o_namelen, int protect);`
33	`int _copy_factor_levels2(const char factor_type, const char iname_src,`	36	`int _copy_factor_levels2(const char factor_type, const char iname_src,`
34	`const char colname_src, const char iname_dst, const char *colname_dst);`	37	`const char colname_src, const char iname_dst, const char *colname_dst);`
35	`int _create_factor_table2(const char iname, const char factor_type,`	38	`int _create_factor_table2(const char iname, const char factor_type,`
36	`const char *colname);`	39	`const char *colname);`
-		40	`char _create_svector1(SEXP name, const char type, int * _namelen, int protect);`
37		41
38	`/* R utilities */`	42	`/* R utilities */`
39	`SEXP _getListElement(SEXP list, char *varname);`	43	`SEXP _getListElement(SEXP list, char *varname);`
40	`SEXP _shrink_vector(SEXP vec, int len); /* shrink vector size */`	44	`SEXP _shrink_vector(SEXP vec, int len); /* shrink vector size */`
41		45
42	`/* sqlite utilities */`	46	`/* sqlite utilities */`
43	`int _empty_callback(void data, int ncols, char row, char *cols);`	47	`int _empty_callback(void data, int ncols, char row, char *cols);`
44	`int _sqlite_error_check(int res, const char *file, int line);`	48	`int _sqlite_error_check(int res, const char *file, int line);`
45	`const char _get_column_type(const char class, int type); /* get sqlite type corresponding to R class & type */`	49	`const char _get_column_type(const char class, int type); /* get sqlite type corresponding to R class & type */`
46	`sqlite3* _is_sqlitedb(char *filename);`	50	`sqlite3* _is_sqlitedb(char *filename);`
47		51
48	`/* global buffer (g_sql_buf) utilities */`	52	`/* global buffer (g_sql_buf) utilities */`
49	`int _expand_buf(int i, int size); /* expand ith buf if size > buf[i].size */`	53	`int _expand_buf(int i, int size); /* expand ith buf if size > buf[i].size */`
50		54
51		55
52	`/* sqlite.vector utilities */`	56	`/* sqlite.vector utilities */`
53	`SEXP sdf_get_variable(SEXP sdf, SEXP name);`	57	`SEXP sdf_get_variable(SEXP sdf, SEXP name);`
54	`SEXP sdf_detach_sdf(SEXP internal_name);`	58	`SEXP sdf_detach_sdf(SEXP internal_name);`
55		59
56	`/* workspace utilities */`	60	`/* workspace utilities */`
57	`int _prepare_attach2(); /* prepare workspace before attaching a sqlite db */`	61	`int _prepare_attach2(); /* prepare workspace before attaching a sqlite db */`
58		62
59	`/* misc utilities */`	63	`/* misc utilities */`
60	`char _r2iname(char internal_name, char *filename);`	64	`char _r2iname(char internal_name, char *filename);`
61	`char _fixname(char rname);`	65	`char _fixname(char rname);`
62	`char _str_tolower(char out, const char *ref);`	66	`char _str_tolower(char out, const char *ref);`
63		67
64	`/* register functions to sqlite */`	68	`/* register functions to sqlite */`
65	`void __register_vector_math();`	69	`void __register_vector_math();`
66		70
67	`#define _sqlite_exec(sql) sqlite3_exec(g_workspace, sql, _empty_callback, NULL, NULL)`	71	`#define _sqlite_exec(sql) sqlite3_exec(g_workspace, sql, _empty_callback, NULL, NULL)`
68	`#define _sqlite_error(sql) _sqlite_error_check((sql), __FILE__, __LINE__)`	72	`#define _sqlite_error(res) _sqlite_error_check((res), __FILE__, __LINE__)`
-		73
-		74	`#ifdef __SQLITE_DEBUG__`
-		75	`#define _sqlite_begin { _sqlite_error(_sqlite_exec("begin")); Rprintf("begin at " __FILE__ " line %d\n", __LINE__); }`
-		76	`#define _sqlite_commit { _sqlite_error(_sqlite_exec("commit")); Rprintf("commit at " __FILE__ " line %d\n", __LINE__); }`
-		77	`#else`
-		78	`#define _sqlite_begin _sqlite_error(_sqlite_exec("begin"))`
-		79	`#define _sqlite_commit _sqlite_error(_sqlite_exec("commit"))`
-		80	`#endif`
-		81
69	`#ifndef SET_ROWNAMES`	82	`#ifndef SET_ROWNAMES`
70	`#define SET_ROWNAMES(x,n) setAttrib(x, R_RowNamesSymbol, n)`	83	`#define SET_ROWNAMES(x,n) setAttrib(x, R_RowNamesSymbol, n)`
71	`#endif`	84	`#endif`
72		85
73	`/* override R's, which does a GetRowNames which is different I believe */`	86	`/* override R's, which does a GetRowNames which is different I believe */`
74	`#undef GET_ROWNAMES`	87	`#undef GET_ROWNAMES`
75	`#define GET_ROWNAMES(x) getAttrib(x, R_RowNamesSymbol)`	88	`#define GET_ROWNAMES(x) getAttrib(x, R_RowNamesSymbol)`
76		89
77	`/* R object accessors shortcuts */`	90	`/* R object accessors shortcuts */`
78	`#define CHAR_ELT(str, i) CHAR(STRING_ELT(str,i))`	91	`#define CHAR_ELT(str, i) CHAR(STRING_ELT(str,i))`
79		92
80	`/* SDF object accessors shortcuts */`	93	`/* SDF object accessors shortcuts */`
81	`#define SDF_INAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "iname"),0))`	94	`#define SDF_INAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "iname"),0))`
82	`#define SVEC_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))`	95	`#define SVEC_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))`
83		96
84	`/* # of sql buffers */`	97	`/* # of sql buffers */`
85	`#define NBUFS 4`	98	`#define NBUFS 4`
86		99
87	`/* possible var types when stored in sqlite as integer */`	100	`/* possible var types when stored in sqlite as integer */`
88	`#define VAR_INTEGER 0`	101	`#define VAR_INTEGER 0`
89	`#define VAR_FACTOR 1`	102	`#define VAR_FACTOR 1`
90	`#define VAR_ORDERED 2`	103	`#define VAR_ORDERED 2`
91		104
92	`/* detail constants (see _get_sdf_detail2 in sqlite_workspace.c) */`	105	`/* detail constants (see _get_sdf_detail2 in sqlite_workspace.c) */`
93	`#define SDF_DETAIL_EXISTS 0`	106	`#define SDF_DETAIL_EXISTS 0`
94	`#define SDF_DETAIL_FULLFILENAME 1`	107	`#define SDF_DETAIL_FULLFILENAME 1`
95		108
96	`/* R SXP type constants */`	109	`/* R SXP type constants */`
97	`#define FACTORSXP 11`	110	`#define FACTORSXP 11`
98	`#define ORDEREDSXP 12`	111	`#define ORDEREDSXP 12`
99		112
100	`#ifndef __SQLITE_WORKSPACE__`	113	`#ifndef __SQLITE_WORKSPACE__`
101	`extern sqlite3 *g_workspace;`	114	`extern sqlite3 *g_workspace;`
102	`extern char *g_sql_buf[NBUFS];`	115	`extern char *g_sql_buf[NBUFS];`
103	`extern int g_sql_buf_sz[NBUFS];`	116	`extern int g_sql_buf_sz[NBUFS];`
104	`#endif`	117	`#endif`
105		118
106	`#endif`	119	`#endif`

The R Project SVN R-packages

(root)/trunk/SQLiteDF/src/sqlite_dataframe.h – Rev 3397 → 3419