The R Project SVN R-packages

Rev

Rev 3446 | Rev 3457 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 3446 Rev 3456
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
/* # of sql buffers */
9
/* # of sql buffers */
10
#define NBUFS 4
10
#define NBUFS 4
11
 
11
 
12
#ifdef __SQLITE_WORKSPACE__
12
#ifdef __SQLITE_WORKSPACE__
13
SEXP SDF_RowNamesSymbol;
13
SEXP SDF_RowNamesSymbol;
-
 
14
SEXP SDF_VectorTypeSymbol;
14
SEXP SDF_DimSymbol;
15
SEXP SDF_DimSymbol;
15
SEXP SDF_DimNamesSymbol;
16
SEXP SDF_DimNamesSymbol;
16
#else 
17
#else 
17
extern SEXP SDF_RowNamesSymbol;
18
extern SEXP SDF_RowNamesSymbol;
-
 
19
extern SEXP SDF_VectorTypeSymbol;
18
extern SEXP SDF_DimSymbol;
20
extern SEXP SDF_DimSymbol;
19
extern SEXP SDF_DimNamesSymbol;
21
extern SEXP SDF_DimNamesSymbol;
20
 
22
 
21
extern sqlite3 *g_workspace;
23
extern sqlite3 *g_workspace;
22
extern char *g_sql_buf[NBUFS];
24
extern char *g_sql_buf[NBUFS];
23
extern int g_sql_buf_sz[NBUFS];
25
extern int g_sql_buf_sz[NBUFS];
24
#endif
26
#endif
25
 
27
 
-
 
28
/* sdf type attributes */
-
 
29
#define GET_SDFVECTORTYPE(x) getAttrib(x, SDF_VectorTypeSymbol) 
-
 
30
#define SET_SDFVECTORTYPE(x,t) setAttrib(x, SDF_VectorTypeSymbol, t) 
-
 
31
#define TEST_SDFVECTORTYPE(x, t) (strcmp(CHAR(asChar(GET_SDFVECTORTYPE(x))), t) == 0)
-
 
32
#define GET_SDFROWNAMES(x) getAttrib(x, SDF_RowNamesSymbol)
-
 
33
 
26
#define WORKSPACE_COLUMNS 6
34
#define WORKSPACE_COLUMNS 6
27
#define MAX_ATTACHED 30     /* 31 including workspace.db */
35
#define MAX_ATTACHED 30     /* 31 including workspace.db */
28
 
36
 
29
/* utilities for checking characteristics of arg */
37
/* utilities for checking characteristics of arg */
30
int _is_r_sym(char *sym);
38
int _is_r_sym(char *sym);
31
int _file_exists(char *filename);
39
int _file_exists(char *filename);
32
int _sdf_exists2(char *iname);
40
int _sdf_exists2(char *iname);
33
 
41
 
34
/* sdf utilities */
42
/* sdf utilities */
35
int USE_SDF1(const char *iname, int exists, int protect);  /* call this before doing anything on an SDF */
43
int USE_SDF1(const char *iname, int exists, int protect);  /* call this before doing anything on an SDF */
36
int UNUSE_SDF2(const char *iname); /* somewhat like UNPROTECT */
44
int UNUSE_SDF2(const char *iname); /* somewhat like UNPROTECT */
37
SEXP _create_sdf_sexp(const char *iname);  /* create a SEXP for an SDF */
45
SEXP _create_sdf_sexp(const char *iname);  /* create a SEXP for an SDF */
38
int _add_sdf1(char *filename, char *internal_name); /* add SDF to workspace */
46
int _add_sdf1(char *filename, char *internal_name); /* add SDF to workspace */
39
void _delete_sdf2(const char *iname); /* remove SDF from workspace */
47
void _delete_sdf2(const char *iname); /* remove SDF from workspace */
40
int _get_factor_levels1(const char *iname, const char *varname, SEXP var);
48
int _get_factor_levels1(const char *iname, const char *varname, SEXP var);
41
int _get_row_count2(const char *table, int quote);
49
int _get_row_count2(const char *table, int quote);
42
SEXP _get_rownames(const char *sdf_iname);
50
SEXP _get_rownames(const char *sdf_iname);
43
char *_get_full_pathname2(char *relpath); /* get full path given relpath, used in workspace mgmt */
51
char *_get_full_pathname2(char *relpath); /* get full path given relpath, used in workspace mgmt */
44
int _is_factor2(const char *iname, const char *factor_type, const char *colname);
52
int _is_factor2(const char *iname, const char *factor_type, const char *colname);
45
SEXP _get_rownames2(const char *sdf_iname);
53
SEXP _get_rownames2(const char *sdf_iname);
46
 
54
 
47
/* utilities for creating SDF's */
55
/* utilities for creating SDF's */
48
char *_create_sdf_skeleton1(SEXP name, int *o_namelen, int protect);
56
char *_create_sdf_skeleton1(SEXP name, int *o_namelen, int protect);
49
int _copy_factor_levels2(const char *factor_type, const char *iname_src,
57
int _copy_factor_levels2(const char *factor_type, const char *iname_src,
50
        const char *colname_src, const char *iname_dst, const char *colname_dst);
58
        const char *colname_src, const char *iname_dst, const char *colname_dst);
51
int _create_factor_table2(const char *iname, const char *factor_type, 
59
int _create_factor_table2(const char *iname, const char *factor_type, 
52
        const char *colname);
60
        const char *colname);
53
char *_create_svector1(SEXP name, const char *type, int * _namelen, int protect);
61
char *_create_svector1(SEXP name, const char *type, int * _namelen, int protect);
54
 
62
 
55
/* R utilities */
63
/* R utilities */
56
SEXP _getListElement(SEXP list, char *varname);
64
SEXP _getListElement(SEXP list, char *varname);
57
SEXP _shrink_vector(SEXP vec, int len); /* shrink vector size */
65
SEXP _shrink_vector(SEXP vec, int len); /* shrink vector size */
58
 
66
 
59
/* sqlite utilities */
67
/* sqlite utilities */
60
int _empty_callback(void *data, int ncols, char **row, char **cols);
68
int _empty_callback(void *data, int ncols, char **row, char **cols);
61
int _sqlite_error_check(int res, const char *file, int line);
69
int _sqlite_error_check(int res, const char *file, int line);
62
const char *_get_column_type(const char *class, int type); /* get sqlite type corresponding to R class & type */
70
const char *_get_column_type(const char *class, int type); /* get sqlite type corresponding to R class & type */
63
sqlite3* _is_sqlitedb(char *filename);
71
sqlite3* _is_sqlitedb(char *filename);
64
 
72
 
65
/* global buffer (g_sql_buf) utilities */
73
/* global buffer (g_sql_buf) utilities */
66
int _expand_buf(int i, int size);  /* expand ith buf if size > buf[i].size */
74
int _expand_buf(int i, int size);  /* expand ith buf if size > buf[i].size */
67
 
75
 
68
 
76
 
69
/* workspace utilities */
77
/* workspace utilities */
70
int _prepare_attach2();  /* prepare workspace before attaching a sqlite db */
78
int _prepare_attach2();  /* prepare workspace before attaching a sqlite db */
71
 
79
 
72
/* misc utilities */
80
/* misc utilities */
73
char *_r2iname(char *internal_name, char *filename);
81
char *_r2iname(char *internal_name, char *filename);
74
char *_fixname(char *rname);
82
char *_fixname(char *rname);
75
char *_str_tolower(char *out, const char *ref);
83
char *_str_tolower(char *out, const char *ref);
76
 
84
 
77
/* register functions to sqlite */
85
/* register functions to sqlite */
78
void __register_vector_math();
86
void __register_vector_math();
79
 
87
 
80
#define _sqlite_exec(sql) sqlite3_exec(g_workspace, sql, _empty_callback, NULL, NULL)
88
#define _sqlite_exec(sql) sqlite3_exec(g_workspace, sql, _empty_callback, NULL, NULL)
81
#define _sqlite_error(res) _sqlite_error_check((res), __FILE__, __LINE__)
89
#define _sqlite_error(res) _sqlite_error_check((res), __FILE__, __LINE__)
82
 
90
 
83
#ifdef __SQLITE_DEBUG__
91
#ifdef __SQLITE_DEBUG__
84
#define _sqlite_begin  { _sqlite_error(_sqlite_exec("begin")); Rprintf("begin at "  __FILE__  " line %d\n",  __LINE__); }
92
#define _sqlite_begin  { _sqlite_error(_sqlite_exec("begin")); Rprintf("begin at "  __FILE__  " line %d\n",  __LINE__); }
85
#define _sqlite_commit  { _sqlite_error(_sqlite_exec("commit")); Rprintf("commit at "  __FILE__  " line %d\n",  __LINE__); }
93
#define _sqlite_commit  { _sqlite_error(_sqlite_exec("commit")); Rprintf("commit at "  __FILE__  " line %d\n",  __LINE__); }
86
#else
94
#else
87
#define _sqlite_begin  _sqlite_error(_sqlite_exec("begin")) 
95
#define _sqlite_begin  _sqlite_error(_sqlite_exec("begin")) 
88
#define _sqlite_commit _sqlite_error(_sqlite_exec("commit"))
96
#define _sqlite_commit _sqlite_error(_sqlite_exec("commit"))
89
#endif
97
#endif
90
 
98
 
91
#ifndef SET_ROWNAMES
99
#ifndef SET_ROWNAMES 
92
#define SET_ROWNAMES(x,n) setAttrib(x, SDF_RowNamesSymbol, n)
100
#define SET_ROWNAMES(x,n) setAttrib(x, SDF_RowNamesSymbol, n)
93
#endif
101
#endif
94
 
102
 
95
/* override R's, which does a GetRowNames which is different I believe */
-
 
96
#undef GET_ROWNAMES
-
 
97
#define GET_ROWNAMES(x) getAttrib(x, R_RowNamesSymbol)
-
 
98
 
103
 
99
/* R object accessors shortcuts */
104
/* R object accessors shortcuts */
100
#define CHAR_ELT(str, i) CHAR(STRING_ELT(str,i))
105
#define CHAR_ELT(str, i) CHAR(STRING_ELT(str,i))
101
 
106
 
102
/* SDF object accessors shortcuts */
107
/* SDF object accessors shortcuts */
103
#define SDF_INAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "iname"),0))
108
#define SDF_INAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "iname"),0))
104
#define SVEC_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))
109
#define SVEC_VARNAME(sdf) CHAR(STRING_ELT(_getListElement(sdf, "varname"),0))
105
 
110
 
106
/* possible var types when stored in sqlite as integer */
111
/* possible var types when stored in sqlite as integer */
107
#define VAR_INTEGER 0
112
#define VAR_INTEGER 0
108
#define VAR_FACTOR  1
113
#define VAR_FACTOR  1
109
#define VAR_ORDERED 2
114
#define VAR_ORDERED 2
110
 
115
 
111
/* detail constants (see _get_sdf_detail2 in sqlite_workspace.c) */
116
/* detail constants (see _get_sdf_detail2 in sqlite_workspace.c) */
112
#define SDF_DETAIL_EXISTS 0
117
#define SDF_DETAIL_EXISTS 0
113
#define SDF_DETAIL_FULLFILENAME 1
118
#define SDF_DETAIL_FULLFILENAME 1
114
 
119
 
115
/* R SXP type constants */
120
/* R SXP type constants */
116
#define FACTORSXP 11
121
#define FACTORSXP 11
117
#define ORDEREDSXP 12
122
#define ORDEREDSXP 12
118
 
123
 
119
 
124
 
120
 
125
 
121
/* top level functions */
126
/* top level functions */
122
/* sqlite_workspace.c */
127
/* sqlite_workspace.c */
123
SEXP sdf_init_workspace();
128
SEXP sdf_init_workspace();
124
SEXP sdf_finalize_workspace();
129
SEXP sdf_finalize_workspace();
125
SEXP sdf_list_sdfs(SEXP pattern);
130
SEXP sdf_list_sdfs(SEXP pattern);
126
SEXP sdf_get_sdf(SEXP name);
131
SEXP sdf_get_sdf(SEXP name);
127
SEXP sdf_attach_sdf(SEXP filename, SEXP internal_name);
132
SEXP sdf_attach_sdf(SEXP filename, SEXP internal_name);
128
SEXP sdf_detach_sdf(SEXP internal_name);
133
SEXP sdf_detach_sdf(SEXP internal_name);
129
SEXP sdf_rename_sdf(SEXP sdf, SEXP name);
134
SEXP sdf_rename_sdf(SEXP sdf, SEXP name);
130
 
135
 
131
/* sqlite_dataframe.c */
136
/* sqlite_dataframe.c */
132
SEXP sdf_create_sdf(SEXP df, SEXP name);
137
SEXP sdf_create_sdf(SEXP df, SEXP name);
133
SEXP sdf_get_names(SEXP sdf);
138
SEXP sdf_get_names(SEXP sdf);
134
SEXP sdf_get_length(SEXP sdf);
139
SEXP sdf_get_length(SEXP sdf);
135
SEXP sdf_get_row_count(SEXP sdf);
140
SEXP sdf_get_row_count(SEXP sdf);
136
SEXP sdf_import_table(SEXP _filename, SEXP _name, SEXP _sep, SEXP _quote, 
141
SEXP sdf_import_table(SEXP _filename, SEXP _name, SEXP _sep, SEXP _quote, 
137
        SEXP _rownames, SEXP _colnames);
142
        SEXP _rownames, SEXP _colnames);
138
SEXP sdf_get_index(SEXP sdf, SEXP row, SEXP col);
143
SEXP sdf_get_index(SEXP sdf, SEXP row, SEXP col);
139
SEXP sdf_rbind(SEXP sdf, SEXP data);
144
SEXP sdf_rbind(SEXP sdf, SEXP data);
140
SEXP sdf_get_iname(SEXP sdf);
145
SEXP sdf_get_iname(SEXP sdf);
141
 
146
 
142
/* sqlite_vector.c */
147
/* sqlite_vector.c */
143
SEXP sdf_get_variable(SEXP sdf, SEXP name);
148
SEXP sdf_get_variable(SEXP sdf, SEXP name);
144
SEXP sdf_get_variable_length(SEXP svec);
149
SEXP sdf_get_variable_length(SEXP svec);
145
SEXP sdf_get_variable_index(SEXP svec, SEXP idx);
150
SEXP sdf_get_variable_index(SEXP svec, SEXP idx);
146
/* SEXP sdf_set_variable_index(SEXP svec, SEXP idx, SEXP value); */
151
/* SEXP sdf_set_variable_index(SEXP svec, SEXP idx, SEXP value); */
147
SEXP sdf_variable_summary(SEXP svec, SEXP maxsum);
152
SEXP sdf_variable_summary(SEXP svec, SEXP maxsum);
148
SEXP sdf_do_variable_math(SEXP func, SEXP vector, SEXP other_args);
153
SEXP sdf_do_variable_math(SEXP func, SEXP vector, SEXP other_args);
149
SEXP sdf_do_variable_op(SEXP func, SEXP vector, SEXP op2, SEXP arg_reversed);
154
SEXP sdf_do_variable_op(SEXP func, SEXP vector, SEXP op2, SEXP arg_reversed);
150
SEXP sdf_do_variable_summary(SEXP func, SEXP vector, SEXP na_rm);
155
SEXP sdf_do_variable_summary(SEXP func, SEXP vector, SEXP na_rm);
151
SEXP sdf_sort_variable(SEXP svec, SEXP decreasing);
156
SEXP sdf_sort_variable(SEXP svec, SEXP decreasing);
152
 
157
 
153
/* sqlite_external.c */
158
/* sqlite_external.c */
154
SEXP sdf_import_sqlite_table(SEXP _dbfilename, SEXP _tblname, SEXP _sdfiname);
159
SEXP sdf_import_sqlite_table(SEXP _dbfilename, SEXP _tblname, SEXP _sdfiname);
155
 
160
 
156
/* sqlite_matrix.c */
161
/* sqlite_matrix.c */
157
SEXP sdf_as_matrix(SEXP sdf, SEXP name);
162
SEXP sdf_as_matrix(SEXP sdf, SEXP name);
158
#endif
163
#endif