blob: 594ebc0736b7d9efdc8138535c7655b4b880b2c0 [file] [log] [blame]
drh4f26d6c2004-05-26 23:25:30 +00001/*
2** 2004 May 26
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 file contains code use to implement APIs that are part of the
14** VDBE.
15*/
16#include "sqliteInt.h"
17#include "vdbeInt.h"
drh19e2d372005-08-29 23:00:03 +000018#include "os.h"
drh4f26d6c2004-05-26 23:25:30 +000019
drhd89bd002005-01-22 03:03:54 +000020/*
21** Return TRUE (non-zero) of the statement supplied as an argument needs
22** to be recompiled. A statement needs to be recompiled whenever the
23** execution environment changes in a way that would alter the program
24** that sqlite3_prepare() generates. For example, if new functions or
25** collating sequences are registered or if an authorizer function is
26** added or changed.
drhd89bd002005-01-22 03:03:54 +000027*/
28int sqlite3_expired(sqlite3_stmt *pStmt){
29 Vdbe *p = (Vdbe*)pStmt;
30 return p==0 || p->expired;
31}
32
drh4f26d6c2004-05-26 23:25:30 +000033/**************************** sqlite3_value_ *******************************
34** The following routines extract information from a Mem or sqlite3_value
35** structure.
36*/
37const void *sqlite3_value_blob(sqlite3_value *pVal){
38 Mem *p = (Mem*)pVal;
39 if( p->flags & (MEM_Blob|MEM_Str) ){
40 return p->z;
41 }else{
42 return sqlite3_value_text(pVal);
43 }
44}
45int sqlite3_value_bytes(sqlite3_value *pVal){
danielk197713073932004-06-30 11:54:06 +000046 return sqlite3ValueBytes(pVal, SQLITE_UTF8);
drh4f26d6c2004-05-26 23:25:30 +000047}
48int sqlite3_value_bytes16(sqlite3_value *pVal){
danielk197713073932004-06-30 11:54:06 +000049 return sqlite3ValueBytes(pVal, SQLITE_UTF16NATIVE);
drh4f26d6c2004-05-26 23:25:30 +000050}
51double sqlite3_value_double(sqlite3_value *pVal){
drh6a6124e2004-06-27 01:56:33 +000052 return sqlite3VdbeRealValue((Mem*)pVal);
drh4f26d6c2004-05-26 23:25:30 +000053}
54int sqlite3_value_int(sqlite3_value *pVal){
drh6a6124e2004-06-27 01:56:33 +000055 return sqlite3VdbeIntValue((Mem*)pVal);
drh4f26d6c2004-05-26 23:25:30 +000056}
drhefad9992004-06-22 12:13:55 +000057sqlite_int64 sqlite3_value_int64(sqlite3_value *pVal){
drh6a6124e2004-06-27 01:56:33 +000058 return sqlite3VdbeIntValue((Mem*)pVal);
drh4f26d6c2004-05-26 23:25:30 +000059}
60const unsigned char *sqlite3_value_text(sqlite3_value *pVal){
danielk197700fd9572005-12-07 06:27:43 +000061 return (const unsigned char *)sqlite3ValueText(pVal, SQLITE_UTF8);
drh4f26d6c2004-05-26 23:25:30 +000062}
drh6c626082004-11-14 21:56:29 +000063#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +000064const void *sqlite3_value_text16(sqlite3_value* pVal){
danielk1977dc8453f2004-06-12 00:42:34 +000065 return sqlite3ValueText(pVal, SQLITE_UTF16NATIVE);
drh4f26d6c2004-05-26 23:25:30 +000066}
danielk1977d8123362004-06-12 09:25:12 +000067const void *sqlite3_value_text16be(sqlite3_value *pVal){
68 return sqlite3ValueText(pVal, SQLITE_UTF16BE);
69}
70const void *sqlite3_value_text16le(sqlite3_value *pVal){
71 return sqlite3ValueText(pVal, SQLITE_UTF16LE);
72}
drh6c626082004-11-14 21:56:29 +000073#endif /* SQLITE_OMIT_UTF16 */
drh4f26d6c2004-05-26 23:25:30 +000074int sqlite3_value_type(sqlite3_value* pVal){
drhf4479502004-05-27 03:12:53 +000075 return pVal->type;
drh4f26d6c2004-05-26 23:25:30 +000076}
drh29d72102006-02-09 22:13:41 +000077/* sqlite3_value_numeric_type() defined in vdbe.c */
drh4f26d6c2004-05-26 23:25:30 +000078
79/**************************** sqlite3_result_ *******************************
80** The following routines are used by user-defined functions to specify
81** the function result.
82*/
83void sqlite3_result_blob(
84 sqlite3_context *pCtx,
85 const void *z,
86 int n,
danielk1977d8123362004-06-12 09:25:12 +000087 void (*xDel)(void *)
drh4f26d6c2004-05-26 23:25:30 +000088){
drh5708d2d2005-06-22 10:53:59 +000089 assert( n>=0 );
danielk1977d8123362004-06-12 09:25:12 +000090 sqlite3VdbeMemSetStr(&pCtx->s, z, n, 0, xDel);
drh4f26d6c2004-05-26 23:25:30 +000091}
92void sqlite3_result_double(sqlite3_context *pCtx, double rVal){
93 sqlite3VdbeMemSetDouble(&pCtx->s, rVal);
94}
95void sqlite3_result_error(sqlite3_context *pCtx, const char *z, int n){
96 pCtx->isError = 1;
danielk1977d8123362004-06-12 09:25:12 +000097 sqlite3VdbeMemSetStr(&pCtx->s, z, n, SQLITE_UTF8, SQLITE_TRANSIENT);
drh4f26d6c2004-05-26 23:25:30 +000098}
danielk1977a1686c92006-01-23 07:52:37 +000099#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +0000100void sqlite3_result_error16(sqlite3_context *pCtx, const void *z, int n){
101 pCtx->isError = 1;
danielk1977d8123362004-06-12 09:25:12 +0000102 sqlite3VdbeMemSetStr(&pCtx->s, z, n, SQLITE_UTF16NATIVE, SQLITE_TRANSIENT);
drh4f26d6c2004-05-26 23:25:30 +0000103}
danielk1977a1686c92006-01-23 07:52:37 +0000104#endif
drhf4479502004-05-27 03:12:53 +0000105void sqlite3_result_int(sqlite3_context *pCtx, int iVal){
drh4f26d6c2004-05-26 23:25:30 +0000106 sqlite3VdbeMemSetInt64(&pCtx->s, (i64)iVal);
107}
108void sqlite3_result_int64(sqlite3_context *pCtx, i64 iVal){
109 sqlite3VdbeMemSetInt64(&pCtx->s, iVal);
110}
111void sqlite3_result_null(sqlite3_context *pCtx){
drhf4479502004-05-27 03:12:53 +0000112 sqlite3VdbeMemSetNull(&pCtx->s);
drh4f26d6c2004-05-26 23:25:30 +0000113}
114void sqlite3_result_text(
115 sqlite3_context *pCtx,
116 const char *z,
117 int n,
danielk1977d8123362004-06-12 09:25:12 +0000118 void (*xDel)(void *)
drh4f26d6c2004-05-26 23:25:30 +0000119){
danielk1977d8123362004-06-12 09:25:12 +0000120 sqlite3VdbeMemSetStr(&pCtx->s, z, n, SQLITE_UTF8, xDel);
drh4f26d6c2004-05-26 23:25:30 +0000121}
drh6c626082004-11-14 21:56:29 +0000122#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +0000123void sqlite3_result_text16(
124 sqlite3_context *pCtx,
125 const void *z,
126 int n,
danielk1977d8123362004-06-12 09:25:12 +0000127 void (*xDel)(void *)
drh4f26d6c2004-05-26 23:25:30 +0000128){
danielk1977d8123362004-06-12 09:25:12 +0000129 sqlite3VdbeMemSetStr(&pCtx->s, z, n, SQLITE_UTF16NATIVE, xDel);
130}
131void sqlite3_result_text16be(
132 sqlite3_context *pCtx,
133 const void *z,
134 int n,
135 void (*xDel)(void *)
136){
137 sqlite3VdbeMemSetStr(&pCtx->s, z, n, SQLITE_UTF16BE, xDel);
138}
139void sqlite3_result_text16le(
140 sqlite3_context *pCtx,
141 const void *z,
142 int n,
143 void (*xDel)(void *)
144){
145 sqlite3VdbeMemSetStr(&pCtx->s, z, n, SQLITE_UTF16LE, xDel);
drh4f26d6c2004-05-26 23:25:30 +0000146}
drh6c626082004-11-14 21:56:29 +0000147#endif /* SQLITE_OMIT_UTF16 */
drh4f26d6c2004-05-26 23:25:30 +0000148void sqlite3_result_value(sqlite3_context *pCtx, sqlite3_value *pValue){
149 sqlite3VdbeMemCopy(&pCtx->s, pValue);
150}
151
152
153/*
154** Execute the statement pStmt, either until a row of data is ready, the
155** statement is completely executed or an error occurs.
drhb900aaf2006-11-09 00:24:53 +0000156**
157** This routine implements the bulk of the logic behind the sqlite_step()
158** API. The only thing omitted is the automatic recompile if a
159** schema change has occurred. That detail is handled by the
160** outer sqlite3_step() wrapper procedure.
drh4f26d6c2004-05-26 23:25:30 +0000161*/
drhb900aaf2006-11-09 00:24:53 +0000162static int sqlite3Step(Vdbe *p){
drh9bb575f2004-09-06 17:24:11 +0000163 sqlite3 *db;
drh4f26d6c2004-05-26 23:25:30 +0000164 int rc;
165
danielk1977efaaf572006-01-16 11:29:19 +0000166 /* Assert that malloc() has not failed */
danielk19779e128002006-01-18 16:51:35 +0000167 assert( !sqlite3MallocFailed() );
danielk1977261919c2005-12-06 12:52:59 +0000168
drh1bcdb0c2004-08-28 14:49:46 +0000169 if( p==0 || p->magic!=VDBE_MAGIC_RUN ){
drh4f26d6c2004-05-26 23:25:30 +0000170 return SQLITE_MISUSE;
171 }
drh91b48aa2004-06-30 11:14:18 +0000172 if( p->aborted ){
173 return SQLITE_ABORT;
174 }
danielk1977a21c6b62005-01-24 10:25:59 +0000175 if( p->pc<=0 && p->expired ){
176 if( p->rc==SQLITE_OK ){
177 p->rc = SQLITE_SCHEMA;
178 }
drhb900aaf2006-11-09 00:24:53 +0000179 rc = SQLITE_ERROR;
180 goto end_of_step;
danielk1977a21c6b62005-01-24 10:25:59 +0000181 }
drh4f26d6c2004-05-26 23:25:30 +0000182 db = p->db;
183 if( sqlite3SafetyOn(db) ){
184 p->rc = SQLITE_MISUSE;
185 return SQLITE_MISUSE;
186 }
danielk19771d850a72004-05-31 08:26:49 +0000187 if( p->pc<0 ){
drh15ca1df2006-07-26 13:43:30 +0000188 /* If there are no other statements currently running, then
189 ** reset the interrupt flag. This prevents a call to sqlite3_interrupt
190 ** from interrupting a statement that has not yet started.
191 */
192 if( db->activeVdbeCnt==0 ){
193 db->u1.isInterrupted = 0;
194 }
195
drh19e2d372005-08-29 23:00:03 +0000196#ifndef SQLITE_OMIT_TRACE
drhc16a03b2004-09-15 13:38:10 +0000197 /* Invoke the trace callback if there is one
198 */
drh19e2d372005-08-29 23:00:03 +0000199 if( db->xTrace && !db->init.busy ){
drhc16a03b2004-09-15 13:38:10 +0000200 assert( p->nOp>0 );
201 assert( p->aOp[p->nOp-1].opcode==OP_Noop );
202 assert( p->aOp[p->nOp-1].p3!=0 );
203 assert( p->aOp[p->nOp-1].p3type==P3_DYNAMIC );
204 sqlite3SafetyOff(db);
205 db->xTrace(db->pTraceArg, p->aOp[p->nOp-1].p3);
206 if( sqlite3SafetyOn(db) ){
207 p->rc = SQLITE_MISUSE;
208 return SQLITE_MISUSE;
209 }
210 }
drh19e2d372005-08-29 23:00:03 +0000211 if( db->xProfile && !db->init.busy ){
212 double rNow;
drh66560ad2006-01-06 14:32:19 +0000213 sqlite3OsCurrentTime(&rNow);
drh19e2d372005-08-29 23:00:03 +0000214 p->startTime = (rNow - (int)rNow)*3600.0*24.0*1000000000.0;
215 }
216#endif
drhc16a03b2004-09-15 13:38:10 +0000217
218 /* Print a copy of SQL as it is executed if the SQL_TRACE pragma is turned
219 ** on in debugging mode.
220 */
221#ifdef SQLITE_DEBUG
222 if( (db->flags & SQLITE_SqlTrace)!=0 ){
223 sqlite3DebugPrintf("SQL-trace: %s\n", p->aOp[p->nOp-1].p3);
224 }
225#endif /* SQLITE_DEBUG */
226
danielk19771d850a72004-05-31 08:26:49 +0000227 db->activeVdbeCnt++;
228 p->pc = 0;
229 }
drhb7f91642004-10-31 02:22:47 +0000230#ifndef SQLITE_OMIT_EXPLAIN
drh4f26d6c2004-05-26 23:25:30 +0000231 if( p->explain ){
232 rc = sqlite3VdbeList(p);
drhb7f91642004-10-31 02:22:47 +0000233 }else
234#endif /* SQLITE_OMIT_EXPLAIN */
235 {
drh4f26d6c2004-05-26 23:25:30 +0000236 rc = sqlite3VdbeExec(p);
237 }
238
239 if( sqlite3SafetyOff(db) ){
240 rc = SQLITE_MISUSE;
241 }
242
drh19e2d372005-08-29 23:00:03 +0000243#ifndef SQLITE_OMIT_TRACE
244 /* Invoke the profile callback if there is one
245 */
246 if( rc!=SQLITE_ROW && db->xProfile && !db->init.busy ){
247 double rNow;
248 u64 elapseTime;
249
drh66560ad2006-01-06 14:32:19 +0000250 sqlite3OsCurrentTime(&rNow);
drh19e2d372005-08-29 23:00:03 +0000251 elapseTime = (rNow - (int)rNow)*3600.0*24.0*1000000000.0 - p->startTime;
252 assert( p->nOp>0 );
253 assert( p->aOp[p->nOp-1].opcode==OP_Noop );
254 assert( p->aOp[p->nOp-1].p3!=0 );
255 assert( p->aOp[p->nOp-1].p3type==P3_DYNAMIC );
256 db->xProfile(db->pProfileArg, p->aOp[p->nOp-1].p3, elapseTime);
257 }
258#endif
259
danielk197797a227c2006-01-20 16:32:04 +0000260 sqlite3Error(p->db, rc, 0);
danielk197776e8d1a2006-01-18 18:22:43 +0000261 p->rc = sqlite3ApiExit(p->db, p->rc);
drhb900aaf2006-11-09 00:24:53 +0000262end_of_step:
drh4ac285a2006-09-15 07:28:50 +0000263 assert( (rc&0xff)==rc );
drhb900aaf2006-11-09 00:24:53 +0000264 if( p->zSql && (rc&0xff)<SQLITE_ROW ){
265 /* This behavior occurs if sqlite3_prepare_v2() was used to build
266 ** the prepared statement. Return error codes directly */
267 return p->rc;
268 }else{
269 /* This is for legacy sqlite3_prepare() builds and when the code
270 ** is SQLITE_ROW or SQLITE_DONE */
271 return rc;
272 }
273}
274
275/*
276** This is the top-level implementation of sqlite3_step(). Call
277** sqlite3Step() to do most of the work. If a schema error occurs,
278** call sqlite3Reprepare() and try again.
279*/
280#ifdef SQLITE_OMIT_PARSER
281int sqlite3_step(sqlite3_stmt *pStmt){
282 return sqlite3Step((Vdbe*)pStmt);
283}
284#else
285int sqlite3_step(sqlite3_stmt *pStmt){
286 int cnt = 0;
287 int rc;
288 Vdbe *v = (Vdbe*)pStmt;
289 while( (rc = sqlite3Step(v))==SQLITE_SCHEMA
290 && cnt++ < 5
291 && sqlite3Reprepare(v) ){
292 sqlite3_reset(pStmt);
293 v->expired = 0;
294 }
danielk197776e8d1a2006-01-18 18:22:43 +0000295 return rc;
drh4f26d6c2004-05-26 23:25:30 +0000296}
drhb900aaf2006-11-09 00:24:53 +0000297#endif
drh4f26d6c2004-05-26 23:25:30 +0000298
299/*
drheb2e1762004-05-27 01:53:56 +0000300** Extract the user data from a sqlite3_context structure and return a
301** pointer to it.
302*/
303void *sqlite3_user_data(sqlite3_context *p){
304 assert( p && p->pFunc );
305 return p->pFunc->pUserData;
306}
307
308/*
drhb7481e72006-09-16 21:45:14 +0000309** The following is the implementation of an SQL function that always
310** fails with an error message stating that the function is used in the
311** wrong context. The sqlite3_overload_function() API might construct
312** SQL function that use this routine so that the functions will exist
313** for name resolution but are actually overloaded by the xFindFunction
314** method of virtual tables.
315*/
316void sqlite3InvalidFunction(
317 sqlite3_context *context, /* The function calling context */
318 int argc, /* Number of arguments to the function */
319 sqlite3_value **argv /* Value of each argument */
320){
321 const char *zName = context->pFunc->zName;
322 char *zErr;
323 zErr = sqlite3MPrintf(
324 "unable to use function %s in the requested context", zName);
325 sqlite3_result_error(context, zErr, -1);
326 sqliteFree(zErr);
327}
328
329/*
drheb2e1762004-05-27 01:53:56 +0000330** Allocate or return the aggregate context for a user function. A new
331** context is allocated on the first call. Subsequent calls return the
332** same context that was returned on prior calls.
drheb2e1762004-05-27 01:53:56 +0000333*/
334void *sqlite3_aggregate_context(sqlite3_context *p, int nByte){
drhabfcea22005-09-06 20:36:48 +0000335 Mem *pMem = p->pMem;
drh825c6622005-09-08 19:01:05 +0000336 assert( p && p->pFunc && p->pFunc->xStep );
drha10a34b2005-09-07 22:09:48 +0000337 if( (pMem->flags & MEM_Agg)==0 ){
338 if( nByte==0 ){
339 assert( pMem->flags==MEM_Null );
340 pMem->z = 0;
drheb2e1762004-05-27 01:53:56 +0000341 }else{
drha10a34b2005-09-07 22:09:48 +0000342 pMem->flags = MEM_Agg;
drh5360ad32005-09-08 00:13:27 +0000343 pMem->xDel = sqlite3FreeX;
drh3c024d62007-03-30 11:23:45 +0000344 pMem->u.pDef = p->pFunc;
drha10a34b2005-09-07 22:09:48 +0000345 if( nByte<=NBFS ){
346 pMem->z = pMem->zShort;
347 memset(pMem->z, 0, nByte);
348 }else{
349 pMem->z = sqliteMalloc( nByte );
350 }
drheb2e1762004-05-27 01:53:56 +0000351 }
352 }
drhabfcea22005-09-06 20:36:48 +0000353 return (void*)pMem->z;
drheb2e1762004-05-27 01:53:56 +0000354}
355
356/*
danielk1977682f68b2004-06-05 10:22:17 +0000357** Return the auxilary data pointer, if any, for the iArg'th argument to
358** the user-function defined by pCtx.
359*/
360void *sqlite3_get_auxdata(sqlite3_context *pCtx, int iArg){
361 VdbeFunc *pVdbeFunc = pCtx->pVdbeFunc;
362 if( !pVdbeFunc || iArg>=pVdbeFunc->nAux || iArg<0 ){
363 return 0;
364 }
drhf92c7ff2004-06-19 15:40:23 +0000365 return pVdbeFunc->apAux[iArg].pAux;
danielk1977682f68b2004-06-05 10:22:17 +0000366}
367
368/*
369** Set the auxilary data pointer and delete function, for the iArg'th
370** argument to the user-function defined by pCtx. Any previous value is
371** deleted by calling the delete function specified when it was set.
372*/
373void sqlite3_set_auxdata(
374 sqlite3_context *pCtx,
375 int iArg,
376 void *pAux,
377 void (*xDelete)(void*)
378){
379 struct AuxData *pAuxData;
drhf92c7ff2004-06-19 15:40:23 +0000380 VdbeFunc *pVdbeFunc;
danielk1977682f68b2004-06-05 10:22:17 +0000381 if( iArg<0 ) return;
382
drhf92c7ff2004-06-19 15:40:23 +0000383 pVdbeFunc = pCtx->pVdbeFunc;
384 if( !pVdbeFunc || pVdbeFunc->nAux<=iArg ){
385 int nMalloc = sizeof(VdbeFunc) + sizeof(struct AuxData)*iArg;
drh53f733c2005-09-16 02:38:09 +0000386 pVdbeFunc = sqliteRealloc(pVdbeFunc, nMalloc);
drh998da3a2004-06-19 15:22:56 +0000387 if( !pVdbeFunc ) return;
drh53f733c2005-09-16 02:38:09 +0000388 pCtx->pVdbeFunc = pVdbeFunc;
drh0e3d7472004-06-19 17:33:07 +0000389 memset(&pVdbeFunc->apAux[pVdbeFunc->nAux], 0,
390 sizeof(struct AuxData)*(iArg+1-pVdbeFunc->nAux));
drh998da3a2004-06-19 15:22:56 +0000391 pVdbeFunc->nAux = iArg+1;
392 pVdbeFunc->pFunc = pCtx->pFunc;
danielk1977682f68b2004-06-05 10:22:17 +0000393 }
394
drhf92c7ff2004-06-19 15:40:23 +0000395 pAuxData = &pVdbeFunc->apAux[iArg];
danielk1977682f68b2004-06-05 10:22:17 +0000396 if( pAuxData->pAux && pAuxData->xDelete ){
397 pAuxData->xDelete(pAuxData->pAux);
398 }
399 pAuxData->pAux = pAux;
400 pAuxData->xDelete = xDelete;
401}
402
403/*
drheb2e1762004-05-27 01:53:56 +0000404** Return the number of times the Step function of a aggregate has been
405** called.
406**
drhcf85a512006-02-09 18:35:29 +0000407** This function is deprecated. Do not use it for new code. It is
408** provide only to avoid breaking legacy code. New aggregate function
409** implementations should keep their own counts within their aggregate
410** context.
drheb2e1762004-05-27 01:53:56 +0000411*/
412int sqlite3_aggregate_count(sqlite3_context *p){
413 assert( p && p->pFunc && p->pFunc->xStep );
drhabfcea22005-09-06 20:36:48 +0000414 return p->pMem->n;
drheb2e1762004-05-27 01:53:56 +0000415}
416
417/*
drh4f26d6c2004-05-26 23:25:30 +0000418** Return the number of columns in the result set for the statement pStmt.
419*/
420int sqlite3_column_count(sqlite3_stmt *pStmt){
421 Vdbe *pVm = (Vdbe *)pStmt;
drh1bcdb0c2004-08-28 14:49:46 +0000422 return pVm ? pVm->nResColumn : 0;
drh4f26d6c2004-05-26 23:25:30 +0000423}
424
425/*
426** Return the number of values available from the current row of the
427** currently executing statement pStmt.
428*/
429int sqlite3_data_count(sqlite3_stmt *pStmt){
430 Vdbe *pVm = (Vdbe *)pStmt;
drh1bcdb0c2004-08-28 14:49:46 +0000431 if( pVm==0 || !pVm->resOnStack ) return 0;
drh4f26d6c2004-05-26 23:25:30 +0000432 return pVm->nResColumn;
433}
434
435
436/*
437** Check to see if column iCol of the given statement is valid. If
438** it is, return a pointer to the Mem for the value of that column.
439** If iCol is not valid, return a pointer to a Mem which has a value
440** of NULL.
441*/
442static Mem *columnMem(sqlite3_stmt *pStmt, int i){
443 Vdbe *pVm = (Vdbe *)pStmt;
444 int vals = sqlite3_data_count(pStmt);
445 if( i>=vals || i<0 ){
drh4f0c5872007-03-26 22:05:01 +0000446 static const Mem nullMem = {{0,}, 0.0, "", 0, MEM_Null, MEM_Null };
drh4f26d6c2004-05-26 23:25:30 +0000447 sqlite3Error(pVm->db, SQLITE_RANGE, 0);
drh0f7eb612006-08-08 13:51:43 +0000448 return (Mem*)&nullMem;
drh4f26d6c2004-05-26 23:25:30 +0000449 }
450 return &pVm->pTos[(1-vals)+i];
451}
452
danielk19772e588c72005-12-09 14:25:08 +0000453/*
454** This function is called after invoking an sqlite3_value_XXX function on a
455** column value (i.e. a value returned by evaluating an SQL expression in the
456** select list of a SELECT statement) that may cause a malloc() failure. If
457** malloc() has failed, the threads mallocFailed flag is cleared and the result
458** code of statement pStmt set to SQLITE_NOMEM.
459**
460** Specificly, this is called from within:
461**
462** sqlite3_column_int()
463** sqlite3_column_int64()
464** sqlite3_column_text()
465** sqlite3_column_text16()
466** sqlite3_column_real()
467** sqlite3_column_bytes()
468** sqlite3_column_bytes16()
469**
470** But not for sqlite3_column_blob(), which never calls malloc().
471*/
472static void columnMallocFailure(sqlite3_stmt *pStmt)
473{
474 /* If malloc() failed during an encoding conversion within an
475 ** sqlite3_column_XXX API, then set the return code of the statement to
476 ** SQLITE_NOMEM. The next call to _step() (if any) will return SQLITE_ERROR
477 ** and _finalize() will return NOMEM.
478 */
danielk197754f01982006-01-18 15:25:17 +0000479 Vdbe *p = (Vdbe *)pStmt;
480 p->rc = sqlite3ApiExit(0, p->rc);
danielk19772e588c72005-12-09 14:25:08 +0000481}
482
drh4f26d6c2004-05-26 23:25:30 +0000483/**************************** sqlite3_column_ *******************************
484** The following routines are used to access elements of the current row
485** in the result set.
486*/
danielk1977c572ef72004-05-27 09:28:41 +0000487const void *sqlite3_column_blob(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000488 const void *val;
489 sqlite3MallocDisallow();
490 val = sqlite3_value_blob( columnMem(pStmt,i) );
491 sqlite3MallocAllow();
492 return val;
danielk1977c572ef72004-05-27 09:28:41 +0000493}
drh4f26d6c2004-05-26 23:25:30 +0000494int sqlite3_column_bytes(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000495 int val = sqlite3_value_bytes( columnMem(pStmt,i) );
496 columnMallocFailure(pStmt);
497 return val;
drh4f26d6c2004-05-26 23:25:30 +0000498}
499int sqlite3_column_bytes16(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000500 int val = sqlite3_value_bytes16( columnMem(pStmt,i) );
501 columnMallocFailure(pStmt);
502 return val;
drh4f26d6c2004-05-26 23:25:30 +0000503}
504double sqlite3_column_double(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000505 double val = sqlite3_value_double( columnMem(pStmt,i) );
506 columnMallocFailure(pStmt);
507 return val;
drh4f26d6c2004-05-26 23:25:30 +0000508}
509int sqlite3_column_int(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000510 int val = sqlite3_value_int( columnMem(pStmt,i) );
511 columnMallocFailure(pStmt);
512 return val;
drh4f26d6c2004-05-26 23:25:30 +0000513}
drhefad9992004-06-22 12:13:55 +0000514sqlite_int64 sqlite3_column_int64(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000515 sqlite_int64 val = sqlite3_value_int64( columnMem(pStmt,i) );
516 columnMallocFailure(pStmt);
517 return val;
drh4f26d6c2004-05-26 23:25:30 +0000518}
519const unsigned char *sqlite3_column_text(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000520 const unsigned char *val = sqlite3_value_text( columnMem(pStmt,i) );
521 columnMallocFailure(pStmt);
522 return val;
drh4f26d6c2004-05-26 23:25:30 +0000523}
drhd1e47332005-06-26 17:55:33 +0000524sqlite3_value *sqlite3_column_value(sqlite3_stmt *pStmt, int i){
525 return columnMem(pStmt, i);
526}
drh6c626082004-11-14 21:56:29 +0000527#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +0000528const void *sqlite3_column_text16(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +0000529 const void *val = sqlite3_value_text16( columnMem(pStmt,i) );
530 columnMallocFailure(pStmt);
531 return val;
drh4f26d6c2004-05-26 23:25:30 +0000532}
drh6c626082004-11-14 21:56:29 +0000533#endif /* SQLITE_OMIT_UTF16 */
drh4f26d6c2004-05-26 23:25:30 +0000534int sqlite3_column_type(sqlite3_stmt *pStmt, int i){
535 return sqlite3_value_type( columnMem(pStmt,i) );
536}
537
drh29d72102006-02-09 22:13:41 +0000538/* The following function is experimental and subject to change or
539** removal */
540/*int sqlite3_column_numeric_type(sqlite3_stmt *pStmt, int i){
541** return sqlite3_value_numeric_type( columnMem(pStmt,i) );
542**}
543*/
544
drh5e2517e2004-09-24 23:59:12 +0000545/*
546** Convert the N-th element of pStmt->pColName[] into a string using
547** xFunc() then return that string. If N is out of range, return 0.
drhe590fbd2005-05-20 19:36:01 +0000548**
549** There are up to 5 names for each column. useType determines which
550** name is returned. Here are the names:
551**
552** 0 The column name as it should be displayed for output
553** 1 The datatype name for the column
554** 2 The name of the database that the column derives from
555** 3 The name of the table that the column derives from
556** 4 The name of the table column that the result column derives from
557**
558** If the result is not a simple column reference (if it is an expression
559** or a constant) then useTypes 2, 3, and 4 return NULL.
drh5e2517e2004-09-24 23:59:12 +0000560*/
561static const void *columnName(
562 sqlite3_stmt *pStmt,
563 int N,
564 const void *(*xFunc)(Mem*),
565 int useType
566){
danielk197700fd9572005-12-07 06:27:43 +0000567 const void *ret;
drh5e2517e2004-09-24 23:59:12 +0000568 Vdbe *p = (Vdbe *)pStmt;
569 int n = sqlite3_column_count(pStmt);
570
571 if( p==0 || N>=n || N<0 ){
572 return 0;
573 }
drhe590fbd2005-05-20 19:36:01 +0000574 N += useType*n;
danielk197700fd9572005-12-07 06:27:43 +0000575 ret = xFunc(&p->aColName[N]);
576
577 /* A malloc may have failed inside of the xFunc() call. If this is the case,
578 ** clear the mallocFailed flag and return NULL.
579 */
danielk197754f01982006-01-18 15:25:17 +0000580 sqlite3ApiExit(0, 0);
danielk197700fd9572005-12-07 06:27:43 +0000581 return ret;
drh5e2517e2004-09-24 23:59:12 +0000582}
583
drh4f26d6c2004-05-26 23:25:30 +0000584/*
585** Return the name of the Nth column of the result set returned by SQL
586** statement pStmt.
587*/
588const char *sqlite3_column_name(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000589 return columnName(
590 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text, COLNAME_NAME);
drh4f26d6c2004-05-26 23:25:30 +0000591}
drhe590fbd2005-05-20 19:36:01 +0000592#ifndef SQLITE_OMIT_UTF16
593const void *sqlite3_column_name16(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000594 return columnName(
595 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text16, COLNAME_NAME);
drhe590fbd2005-05-20 19:36:01 +0000596}
597#endif
drh4f26d6c2004-05-26 23:25:30 +0000598
599/*
drh6c626082004-11-14 21:56:29 +0000600** Return the column declaration type (if applicable) of the 'i'th column
drhe590fbd2005-05-20 19:36:01 +0000601** of the result set of SQL statement pStmt.
drh6c626082004-11-14 21:56:29 +0000602*/
603const char *sqlite3_column_decltype(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000604 return columnName(
605 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text, COLNAME_DECLTYPE);
drh6c626082004-11-14 21:56:29 +0000606}
drh6c626082004-11-14 21:56:29 +0000607#ifndef SQLITE_OMIT_UTF16
danielk197776d505b2004-05-28 13:13:02 +0000608const void *sqlite3_column_decltype16(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000609 return columnName(
610 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text16, COLNAME_DECLTYPE);
drh4f26d6c2004-05-26 23:25:30 +0000611}
drh6c626082004-11-14 21:56:29 +0000612#endif /* SQLITE_OMIT_UTF16 */
drh4f26d6c2004-05-26 23:25:30 +0000613
danielk19774b1ae992006-02-10 03:06:10 +0000614#ifdef SQLITE_ENABLE_COLUMN_METADATA
drhe590fbd2005-05-20 19:36:01 +0000615/*
616** Return the name of the database from which a result column derives.
617** NULL is returned if the result column is an expression or constant or
618** anything else which is not an unabiguous reference to a database column.
619*/
620const char *sqlite3_column_database_name(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000621 return columnName(
622 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text, COLNAME_DATABASE);
drhe590fbd2005-05-20 19:36:01 +0000623}
624#ifndef SQLITE_OMIT_UTF16
625const void *sqlite3_column_database_name16(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000626 return columnName(
627 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text16, COLNAME_DATABASE);
drhe590fbd2005-05-20 19:36:01 +0000628}
629#endif /* SQLITE_OMIT_UTF16 */
630
631/*
632** Return the name of the table from which a result column derives.
633** NULL is returned if the result column is an expression or constant or
634** anything else which is not an unabiguous reference to a database column.
635*/
636const char *sqlite3_column_table_name(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000637 return columnName(
638 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text, COLNAME_TABLE);
drhe590fbd2005-05-20 19:36:01 +0000639}
640#ifndef SQLITE_OMIT_UTF16
641const void *sqlite3_column_table_name16(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000642 return columnName(
643 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text16, COLNAME_TABLE);
drhe590fbd2005-05-20 19:36:01 +0000644}
645#endif /* SQLITE_OMIT_UTF16 */
646
647/*
648** Return the name of the table column from which a result column derives.
649** NULL is returned if the result column is an expression or constant or
650** anything else which is not an unabiguous reference to a database column.
651*/
652const char *sqlite3_column_origin_name(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000653 return columnName(
654 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text, COLNAME_COLUMN);
drhe590fbd2005-05-20 19:36:01 +0000655}
656#ifndef SQLITE_OMIT_UTF16
657const void *sqlite3_column_origin_name16(sqlite3_stmt *pStmt, int N){
danielk1977955de522006-02-10 02:27:42 +0000658 return columnName(
659 pStmt, N, (const void*(*)(Mem*))sqlite3_value_text16, COLNAME_COLUMN);
drhe590fbd2005-05-20 19:36:01 +0000660}
661#endif /* SQLITE_OMIT_UTF16 */
danielk19774b1ae992006-02-10 03:06:10 +0000662#endif /* SQLITE_ENABLE_COLUMN_METADATA */
drhe590fbd2005-05-20 19:36:01 +0000663
664
drh4f26d6c2004-05-26 23:25:30 +0000665/******************************* sqlite3_bind_ ***************************
666**
667** Routines used to attach values to wildcards in a compiled SQL statement.
668*/
669/*
670** Unbind the value bound to variable i in virtual machine p. This is the
671** the same as binding a NULL value to the column. If the "i" parameter is
672** out of range, then SQLITE_RANGE is returned. Othewise SQLITE_OK.
673**
674** The error code stored in database p->db is overwritten with the return
675** value in any case.
676*/
677static int vdbeUnbind(Vdbe *p, int i){
678 Mem *pVar;
drh1bcdb0c2004-08-28 14:49:46 +0000679 if( p==0 || p->magic!=VDBE_MAGIC_RUN || p->pc>=0 ){
drh473d1792005-06-06 17:54:55 +0000680 if( p ) sqlite3Error(p->db, SQLITE_MISUSE, 0);
drh4f26d6c2004-05-26 23:25:30 +0000681 return SQLITE_MISUSE;
682 }
683 if( i<1 || i>p->nVar ){
684 sqlite3Error(p->db, SQLITE_RANGE, 0);
685 return SQLITE_RANGE;
686 }
687 i--;
drh290c1942004-08-21 17:54:45 +0000688 pVar = &p->aVar[i];
danielk1977d8123362004-06-12 09:25:12 +0000689 sqlite3VdbeMemRelease(pVar);
drh4f26d6c2004-05-26 23:25:30 +0000690 pVar->flags = MEM_Null;
691 sqlite3Error(p->db, SQLITE_OK, 0);
692 return SQLITE_OK;
693}
694
695/*
drh5e2517e2004-09-24 23:59:12 +0000696** Bind a text or BLOB value.
drh4f26d6c2004-05-26 23:25:30 +0000697*/
drh5e2517e2004-09-24 23:59:12 +0000698static int bindText(
drhf4479502004-05-27 03:12:53 +0000699 sqlite3_stmt *pStmt,
drh4f26d6c2004-05-26 23:25:30 +0000700 int i,
701 const void *zData,
702 int nData,
drh5e2517e2004-09-24 23:59:12 +0000703 void (*xDel)(void*),
704 int encoding
drh4f26d6c2004-05-26 23:25:30 +0000705){
706 Vdbe *p = (Vdbe *)pStmt;
707 Mem *pVar;
708 int rc;
709
710 rc = vdbeUnbind(p, i);
drhfeac5f82004-08-01 00:10:45 +0000711 if( rc || zData==0 ){
drh4f26d6c2004-05-26 23:25:30 +0000712 return rc;
713 }
drh290c1942004-08-21 17:54:45 +0000714 pVar = &p->aVar[i-1];
drh5e2517e2004-09-24 23:59:12 +0000715 rc = sqlite3VdbeMemSetStr(pVar, zData, nData, encoding, xDel);
drh5e2517e2004-09-24 23:59:12 +0000716 if( rc==SQLITE_OK && encoding!=0 ){
danielk197714db2662006-01-09 16:12:04 +0000717 rc = sqlite3VdbeChangeEncoding(pVar, ENC(p->db));
drh5e2517e2004-09-24 23:59:12 +0000718 }
danielk197754f01982006-01-18 15:25:17 +0000719
danielk1977771151b2006-01-17 13:21:40 +0000720 sqlite3Error(((Vdbe *)pStmt)->db, rc, 0);
danielk197754f01982006-01-18 15:25:17 +0000721 return sqlite3ApiExit(((Vdbe *)pStmt)->db, rc);
drh4f26d6c2004-05-26 23:25:30 +0000722}
drh5e2517e2004-09-24 23:59:12 +0000723
724
725/*
726** Bind a blob value to an SQL statement variable.
727*/
728int sqlite3_bind_blob(
729 sqlite3_stmt *pStmt,
730 int i,
731 const void *zData,
732 int nData,
733 void (*xDel)(void*)
734){
735 return bindText(pStmt, i, zData, nData, xDel, 0);
736}
drh4f26d6c2004-05-26 23:25:30 +0000737int sqlite3_bind_double(sqlite3_stmt *pStmt, int i, double rValue){
738 int rc;
739 Vdbe *p = (Vdbe *)pStmt;
drh4f26d6c2004-05-26 23:25:30 +0000740 rc = vdbeUnbind(p, i);
741 if( rc==SQLITE_OK ){
drh290c1942004-08-21 17:54:45 +0000742 sqlite3VdbeMemSetDouble(&p->aVar[i-1], rValue);
drh4f26d6c2004-05-26 23:25:30 +0000743 }
danielk1977f4618892004-06-28 13:09:11 +0000744 return rc;
drh4f26d6c2004-05-26 23:25:30 +0000745}
746int sqlite3_bind_int(sqlite3_stmt *p, int i, int iValue){
drhefad9992004-06-22 12:13:55 +0000747 return sqlite3_bind_int64(p, i, (i64)iValue);
drh4f26d6c2004-05-26 23:25:30 +0000748}
drhefad9992004-06-22 12:13:55 +0000749int sqlite3_bind_int64(sqlite3_stmt *pStmt, int i, sqlite_int64 iValue){
drh4f26d6c2004-05-26 23:25:30 +0000750 int rc;
751 Vdbe *p = (Vdbe *)pStmt;
752 rc = vdbeUnbind(p, i);
753 if( rc==SQLITE_OK ){
drh290c1942004-08-21 17:54:45 +0000754 sqlite3VdbeMemSetInt64(&p->aVar[i-1], iValue);
drh4f26d6c2004-05-26 23:25:30 +0000755 }
756 return rc;
757}
758int sqlite3_bind_null(sqlite3_stmt* p, int i){
759 return vdbeUnbind((Vdbe *)p, i);
760}
761int sqlite3_bind_text(
762 sqlite3_stmt *pStmt,
763 int i,
764 const char *zData,
765 int nData,
danielk1977d8123362004-06-12 09:25:12 +0000766 void (*xDel)(void*)
drh4f26d6c2004-05-26 23:25:30 +0000767){
drh5e2517e2004-09-24 23:59:12 +0000768 return bindText(pStmt, i, zData, nData, xDel, SQLITE_UTF8);
drh4f26d6c2004-05-26 23:25:30 +0000769}
drh6c626082004-11-14 21:56:29 +0000770#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +0000771int sqlite3_bind_text16(
772 sqlite3_stmt *pStmt,
773 int i,
774 const void *zData,
775 int nData,
danielk1977d8123362004-06-12 09:25:12 +0000776 void (*xDel)(void*)
drh4f26d6c2004-05-26 23:25:30 +0000777){
drh5e2517e2004-09-24 23:59:12 +0000778 return bindText(pStmt, i, zData, nData, xDel, SQLITE_UTF16NATIVE);
drh4f26d6c2004-05-26 23:25:30 +0000779}
drh6c626082004-11-14 21:56:29 +0000780#endif /* SQLITE_OMIT_UTF16 */
danielk197726e41442006-06-14 15:16:35 +0000781int sqlite3_bind_value(sqlite3_stmt *pStmt, int i, const sqlite3_value *pValue){
782 int rc;
783 Vdbe *p = (Vdbe *)pStmt;
784 rc = vdbeUnbind(p, i);
785 if( rc==SQLITE_OK ){
786 sqlite3VdbeMemCopy(&p->aVar[i-1], pValue);
787 }
788 return rc;
789}
drh75f6a032004-07-15 14:15:00 +0000790
791/*
792** Return the number of wildcards that can be potentially bound to.
793** This routine is added to support DBD::SQLite.
drh75f6a032004-07-15 14:15:00 +0000794*/
795int sqlite3_bind_parameter_count(sqlite3_stmt *pStmt){
drh92febd92004-08-20 18:34:20 +0000796 Vdbe *p = (Vdbe*)pStmt;
797 return p ? p->nVar : 0;
drh75f6a032004-07-15 14:15:00 +0000798}
drh895d7472004-08-20 16:02:39 +0000799
800/*
drhfa6bc002004-09-07 16:19:52 +0000801** Create a mapping from variable numbers to variable names
802** in the Vdbe.azVar[] array, if such a mapping does not already
803** exist.
drh895d7472004-08-20 16:02:39 +0000804*/
drhfa6bc002004-09-07 16:19:52 +0000805static void createVarMap(Vdbe *p){
drh895d7472004-08-20 16:02:39 +0000806 if( !p->okVar ){
807 int j;
808 Op *pOp;
809 for(j=0, pOp=p->aOp; j<p->nOp; j++, pOp++){
810 if( pOp->opcode==OP_Variable ){
811 assert( pOp->p1>0 && pOp->p1<=p->nVar );
812 p->azVar[pOp->p1-1] = pOp->p3;
813 }
814 }
815 p->okVar = 1;
816 }
drhfa6bc002004-09-07 16:19:52 +0000817}
818
819/*
820** Return the name of a wildcard parameter. Return NULL if the index
821** is out of range or if the wildcard is unnamed.
822**
823** The result is always UTF-8.
824*/
825const char *sqlite3_bind_parameter_name(sqlite3_stmt *pStmt, int i){
826 Vdbe *p = (Vdbe*)pStmt;
827 if( p==0 || i<1 || i>p->nVar ){
828 return 0;
829 }
830 createVarMap(p);
drh895d7472004-08-20 16:02:39 +0000831 return p->azVar[i-1];
832}
drhfa6bc002004-09-07 16:19:52 +0000833
834/*
835** Given a wildcard parameter name, return the index of the variable
836** with that name. If there is no variable with the given name,
837** return 0.
838*/
839int sqlite3_bind_parameter_index(sqlite3_stmt *pStmt, const char *zName){
840 Vdbe *p = (Vdbe*)pStmt;
841 int i;
842 if( p==0 ){
843 return 0;
844 }
845 createVarMap(p);
drh6a8903c2004-12-10 18:00:04 +0000846 if( zName ){
847 for(i=0; i<p->nVar; i++){
848 const char *z = p->azVar[i];
849 if( z && strcmp(z,zName)==0 ){
850 return i+1;
851 }
drhfa6bc002004-09-07 16:19:52 +0000852 }
853 }
854 return 0;
855}
drhf8db1bc2005-04-22 02:38:37 +0000856
drh51942bc2005-06-12 22:01:42 +0000857/*
drhf8db1bc2005-04-22 02:38:37 +0000858** Transfer all bindings from the first statement over to the second.
859** If the two statements contain a different number of bindings, then
860** an SQLITE_ERROR is returned.
861*/
862int sqlite3_transfer_bindings(sqlite3_stmt *pFromStmt, sqlite3_stmt *pToStmt){
863 Vdbe *pFrom = (Vdbe*)pFromStmt;
864 Vdbe *pTo = (Vdbe*)pToStmt;
865 int i, rc = SQLITE_OK;
866 if( (pFrom->magic!=VDBE_MAGIC_RUN && pFrom->magic!=VDBE_MAGIC_HALT)
867 || (pTo->magic!=VDBE_MAGIC_RUN && pTo->magic!=VDBE_MAGIC_HALT) ){
868 return SQLITE_MISUSE;
869 }
870 if( pFrom->nVar!=pTo->nVar ){
871 return SQLITE_ERROR;
872 }
873 for(i=0; rc==SQLITE_OK && i<pFrom->nVar; i++){
danielk1977950f0542006-01-18 05:51:57 +0000874 sqlite3MallocDisallow();
drhf8db1bc2005-04-22 02:38:37 +0000875 rc = sqlite3VdbeMemMove(&pTo->aVar[i], &pFrom->aVar[i]);
danielk1977950f0542006-01-18 05:51:57 +0000876 sqlite3MallocAllow();
drhf8db1bc2005-04-22 02:38:37 +0000877 }
drh4ac285a2006-09-15 07:28:50 +0000878 assert( rc==SQLITE_OK || rc==SQLITE_NOMEM );
drhf8db1bc2005-04-22 02:38:37 +0000879 return rc;
880}
drh51942bc2005-06-12 22:01:42 +0000881
882/*
883** Return the sqlite3* database handle to which the prepared statement given
884** in the argument belongs. This is the same database handle that was
885** the first argument to the sqlite3_prepare() that was used to create
886** the statement in the first place.
887*/
888sqlite3 *sqlite3_db_handle(sqlite3_stmt *pStmt){
889 return pStmt ? ((Vdbe*)pStmt)->db : 0;
890}