OLD | NEW |
| (Empty) |
1 /* | |
2 ** 2014-11-10 | |
3 ** | |
4 ** The author disclaims copyright to this source code. In place of | |
5 ** a legal notice, here is a blessing: | |
6 ** | |
7 ** May you do good and not evil. | |
8 ** May you find forgiveness for yourself and forgive others. | |
9 ** May you share freely, never taking more than you give. | |
10 ** | |
11 ****************************************************************************** | |
12 ** | |
13 ** This SQLite extension implements SQL function eval() which runs | |
14 ** SQL statements recursively. | |
15 */ | |
16 #include "sqlite3ext.h" | |
17 SQLITE_EXTENSION_INIT1 | |
18 #include <string.h> | |
19 | |
20 /* | |
21 ** Structure used to accumulate the output | |
22 */ | |
23 struct EvalResult { | |
24 char *z; /* Accumulated output */ | |
25 const char *zSep; /* Separator */ | |
26 int szSep; /* Size of the separator string */ | |
27 sqlite3_int64 nAlloc; /* Number of bytes allocated for z[] */ | |
28 sqlite3_int64 nUsed; /* Number of bytes of z[] actually used */ | |
29 }; | |
30 | |
31 /* | |
32 ** Callback from sqlite_exec() for the eval() function. | |
33 */ | |
34 static int callback(void *pCtx, int argc, char **argv, char **colnames){ | |
35 struct EvalResult *p = (struct EvalResult*)pCtx; | |
36 int i; | |
37 for(i=0; i<argc; i++){ | |
38 const char *z = argv[i] ? argv[i] : ""; | |
39 size_t sz = strlen(z); | |
40 if( (sqlite3_int64)sz+p->nUsed+p->szSep+1 > p->nAlloc ){ | |
41 char *zNew; | |
42 p->nAlloc = p->nAlloc*2 + sz + p->szSep + 1; | |
43 /* Using sqlite3_realloc64() would be better, but it is a recent | |
44 ** addition and will cause a segfault if loaded by an older version | |
45 ** of SQLite. */ | |
46 zNew = p->nAlloc<=0x7fffffff ? sqlite3_realloc(p->z, (int)p->nAlloc) : 0; | |
47 if( zNew==0 ){ | |
48 sqlite3_free(p->z); | |
49 memset(p, 0, sizeof(*p)); | |
50 return 1; | |
51 } | |
52 p->z = zNew; | |
53 } | |
54 if( p->nUsed>0 ){ | |
55 memcpy(&p->z[p->nUsed], p->zSep, p->szSep); | |
56 p->nUsed += p->szSep; | |
57 } | |
58 memcpy(&p->z[p->nUsed], z, sz); | |
59 p->nUsed += sz; | |
60 } | |
61 return 0; | |
62 } | |
63 | |
64 /* | |
65 ** Implementation of the eval(X) and eval(X,Y) SQL functions. | |
66 ** | |
67 ** Evaluate the SQL text in X. Return the results, using string | |
68 ** Y as the separator. If Y is omitted, use a single space character. | |
69 */ | |
70 static void sqlEvalFunc( | |
71 sqlite3_context *context, | |
72 int argc, | |
73 sqlite3_value **argv | |
74 ){ | |
75 const char *zSql; | |
76 sqlite3 *db; | |
77 char *zErr = 0; | |
78 int rc; | |
79 struct EvalResult x; | |
80 | |
81 memset(&x, 0, sizeof(x)); | |
82 x.zSep = " "; | |
83 zSql = (const char*)sqlite3_value_text(argv[0]); | |
84 if( zSql==0 ) return; | |
85 if( argc>1 ){ | |
86 x.zSep = (const char*)sqlite3_value_text(argv[1]); | |
87 if( x.zSep==0 ) return; | |
88 } | |
89 x.szSep = (int)strlen(x.zSep); | |
90 db = sqlite3_context_db_handle(context); | |
91 rc = sqlite3_exec(db, zSql, callback, &x, &zErr); | |
92 if( rc!=SQLITE_OK ){ | |
93 sqlite3_result_error(context, zErr, -1); | |
94 sqlite3_free(zErr); | |
95 }else if( x.zSep==0 ){ | |
96 sqlite3_result_error_nomem(context); | |
97 sqlite3_free(x.z); | |
98 }else{ | |
99 sqlite3_result_text(context, x.z, (int)x.nUsed, sqlite3_free); | |
100 } | |
101 } | |
102 | |
103 | |
104 #ifdef _WIN32 | |
105 __declspec(dllexport) | |
106 #endif | |
107 int sqlite3_eval_init( | |
108 sqlite3 *db, | |
109 char **pzErrMsg, | |
110 const sqlite3_api_routines *pApi | |
111 ){ | |
112 int rc = SQLITE_OK; | |
113 SQLITE_EXTENSION_INIT2(pApi); | |
114 (void)pzErrMsg; /* Unused parameter */ | |
115 rc = sqlite3_create_function(db, "eval", 1, SQLITE_UTF8, 0, | |
116 sqlEvalFunc, 0, 0); | |
117 if( rc==SQLITE_OK ){ | |
118 rc = sqlite3_create_function(db, "eval", 2, SQLITE_UTF8, 0, | |
119 sqlEvalFunc, 0, 0); | |
120 } | |
121 return rc; | |
122 } | |
OLD | NEW |