The R Project SVN R-packages

Rev

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

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