blob: f47ece239656504faece6ae8efc976abe3a44e67 [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"
18
shaneeec556d2008-10-12 00:27:53 +000019#ifndef SQLITE_OMIT_DEPRECATED
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}
shaneeec556d2008-10-12 00:27:53 +000032#endif
drhd89bd002005-01-22 03:03:54 +000033
drhe30f4422007-08-21 16:15:55 +000034/*
drh413c3d32010-02-23 20:11:56 +000035** Check on a Vdbe to make sure it has not been finalized. Log
36** an error and return true if it has been finalized (or is otherwise
37** invalid). Return false if it is ok.
38*/
39static int vdbeSafety(Vdbe *p){
40 if( p->db==0 ){
41 sqlite3_log(SQLITE_MISUSE, "API called with finalized prepared statement");
42 return 1;
43 }else{
44 return 0;
45 }
46}
47static int vdbeSafetyNotNull(Vdbe *p){
48 if( p==0 ){
49 sqlite3_log(SQLITE_MISUSE, "API called with NULL prepared statement");
50 return 1;
51 }else{
52 return vdbeSafety(p);
53 }
54}
55
drh201e0c62015-07-14 14:48:50 +000056#ifndef SQLITE_OMIT_TRACE
57/*
58** Invoke the profile callback. This routine is only called if we already
59** know that the profile callback is defined and needs to be invoked.
60*/
61static SQLITE_NOINLINE void invokeProfileCallback(sqlite3 *db, Vdbe *p){
62 sqlite3_int64 iNow;
drh3d2a5292016-07-13 22:55:01 +000063 sqlite3_int64 iElapse;
drh201e0c62015-07-14 14:48:50 +000064 assert( p->startTime>0 );
drh04c67472018-12-04 14:33:02 +000065 assert( (db->mTrace & (SQLITE_TRACE_PROFILE|SQLITE_TRACE_XPROFILE))!=0 );
drh201e0c62015-07-14 14:48:50 +000066 assert( db->init.busy==0 );
67 assert( p->zSql!=0 );
68 sqlite3OsCurrentTimeInt64(db->pVfs, &iNow);
drh3d2a5292016-07-13 22:55:01 +000069 iElapse = (iNow - p->startTime)*1000000;
drh07891f02019-04-14 00:40:29 +000070#ifndef SQLITE_OMIT_DEPRECATED
drh3d2a5292016-07-13 22:55:01 +000071 if( db->xProfile ){
72 db->xProfile(db->pProfileArg, p->zSql, iElapse);
73 }
drh04c67472018-12-04 14:33:02 +000074#endif
drh3d2a5292016-07-13 22:55:01 +000075 if( db->mTrace & SQLITE_TRACE_PROFILE ){
drh08b92082020-08-10 14:18:00 +000076 db->trace.xV2(SQLITE_TRACE_PROFILE, db->pTraceArg, p, (void*)&iElapse);
drh3d2a5292016-07-13 22:55:01 +000077 }
drh201e0c62015-07-14 14:48:50 +000078 p->startTime = 0;
79}
80/*
81** The checkProfileCallback(DB,P) macro checks to see if a profile callback
82** is needed, and it invokes the callback if it is needed.
83*/
84# define checkProfileCallback(DB,P) \
85 if( ((P)->startTime)>0 ){ invokeProfileCallback(DB,P); }
86#else
87# define checkProfileCallback(DB,P) /*no-op*/
88#endif
89
drh413c3d32010-02-23 20:11:56 +000090/*
drhe30f4422007-08-21 16:15:55 +000091** The following routine destroys a virtual machine that is created by
92** the sqlite3_compile() routine. The integer returned is an SQLITE_
93** success/failure code that describes the result of executing the virtual
94** machine.
95**
96** This routine sets the error code and string returned by
97** sqlite3_errcode(), sqlite3_errmsg() and sqlite3_errmsg16().
98*/
99int sqlite3_finalize(sqlite3_stmt *pStmt){
100 int rc;
101 if( pStmt==0 ){
drh65bafa62010-09-29 01:54:00 +0000102 /* IMPLEMENTATION-OF: R-57228-12904 Invoking sqlite3_finalize() on a NULL
103 ** pointer is a harmless no-op. */
drhe30f4422007-08-21 16:15:55 +0000104 rc = SQLITE_OK;
105 }else{
106 Vdbe *v = (Vdbe*)pStmt;
danielk1977238746a2009-03-19 18:51:06 +0000107 sqlite3 *db = v->db;
drh413c3d32010-02-23 20:11:56 +0000108 if( vdbeSafety(v) ) return SQLITE_MISUSE_BKPT;
drh4245c402012-06-02 14:32:21 +0000109 sqlite3_mutex_enter(db->mutex);
drh201e0c62015-07-14 14:48:50 +0000110 checkProfileCallback(db, v);
drhe30f4422007-08-21 16:15:55 +0000111 rc = sqlite3VdbeFinalize(v);
danielk1977238746a2009-03-19 18:51:06 +0000112 rc = sqlite3ApiExit(db, rc);
drh4245c402012-06-02 14:32:21 +0000113 sqlite3LeaveMutexAndCloseZombie(db);
drhe30f4422007-08-21 16:15:55 +0000114 }
115 return rc;
116}
117
118/*
119** Terminate the current execution of an SQL statement and reset it
120** back to its starting state so that it can be reused. A success code from
121** the prior execution is returned.
122**
123** This routine sets the error code and string returned by
124** sqlite3_errcode(), sqlite3_errmsg() and sqlite3_errmsg16().
125*/
126int sqlite3_reset(sqlite3_stmt *pStmt){
127 int rc;
128 if( pStmt==0 ){
129 rc = SQLITE_OK;
130 }else{
131 Vdbe *v = (Vdbe*)pStmt;
drh201e0c62015-07-14 14:48:50 +0000132 sqlite3 *db = v->db;
133 sqlite3_mutex_enter(db->mutex);
134 checkProfileCallback(db, v);
drhc890fec2008-08-01 20:10:08 +0000135 rc = sqlite3VdbeReset(v);
drh124c0b42011-06-01 18:15:55 +0000136 sqlite3VdbeRewind(v);
drh201e0c62015-07-14 14:48:50 +0000137 assert( (rc & (db->errMask))==rc );
138 rc = sqlite3ApiExit(db, rc);
139 sqlite3_mutex_leave(db->mutex);
drhe30f4422007-08-21 16:15:55 +0000140 }
141 return rc;
142}
143
144/*
145** Set all the parameters in the compiled SQL statement to NULL.
146*/
147int sqlite3_clear_bindings(sqlite3_stmt *pStmt){
148 int i;
149 int rc = SQLITE_OK;
drh7297d1f2008-05-09 14:39:44 +0000150 Vdbe *p = (Vdbe*)pStmt;
drh18472fa2008-10-07 15:25:48 +0000151#if SQLITE_THREADSAFE
drh7e8b8482008-01-23 03:03:05 +0000152 sqlite3_mutex *mutex = ((Vdbe*)pStmt)->db->mutex;
153#endif
154 sqlite3_mutex_enter(mutex);
drh7297d1f2008-05-09 14:39:44 +0000155 for(i=0; i<p->nVar; i++){
156 sqlite3VdbeMemRelease(&p->aVar[i]);
157 p->aVar[i].flags = MEM_Null;
drhe30f4422007-08-21 16:15:55 +0000158 }
drh2c2f3922017-06-01 00:54:35 +0000159 assert( (p->prepFlags & SQLITE_PREPARE_SAVESQL)!=0 || p->expmask==0 );
danbda4cb82017-02-23 16:30:16 +0000160 if( p->expmask ){
danc94b8592009-10-20 07:01:24 +0000161 p->expired = 1;
162 }
drh7e8b8482008-01-23 03:03:05 +0000163 sqlite3_mutex_leave(mutex);
drhe30f4422007-08-21 16:15:55 +0000164 return rc;
165}
166
167
drh4f26d6c2004-05-26 23:25:30 +0000168/**************************** sqlite3_value_ *******************************
169** The following routines extract information from a Mem or sqlite3_value
170** structure.
171*/
172const void *sqlite3_value_blob(sqlite3_value *pVal){
173 Mem *p = (Mem*)pVal;
174 if( p->flags & (MEM_Blob|MEM_Str) ){
drhff535a22016-09-20 01:46:15 +0000175 if( ExpandBlob(p)!=SQLITE_OK ){
dana4d5ae82015-07-24 16:24:37 +0000176 assert( p->flags==MEM_Null && p->z==0 );
177 return 0;
178 }
drh1f0feef2007-05-15 13:27:07 +0000179 p->flags |= MEM_Blob;
drh42262532010-09-08 16:30:36 +0000180 return p->n ? p->z : 0;
drh4f26d6c2004-05-26 23:25:30 +0000181 }else{
182 return sqlite3_value_text(pVal);
183 }
184}
185int sqlite3_value_bytes(sqlite3_value *pVal){
drhb21c8cd2007-08-21 19:33:56 +0000186 return sqlite3ValueBytes(pVal, SQLITE_UTF8);
drh4f26d6c2004-05-26 23:25:30 +0000187}
188int sqlite3_value_bytes16(sqlite3_value *pVal){
drhb21c8cd2007-08-21 19:33:56 +0000189 return sqlite3ValueBytes(pVal, SQLITE_UTF16NATIVE);
drh4f26d6c2004-05-26 23:25:30 +0000190}
191double sqlite3_value_double(sqlite3_value *pVal){
drh6a6124e2004-06-27 01:56:33 +0000192 return sqlite3VdbeRealValue((Mem*)pVal);
drh4f26d6c2004-05-26 23:25:30 +0000193}
194int sqlite3_value_int(sqlite3_value *pVal){
drhb27b7f52008-12-10 18:03:45 +0000195 return (int)sqlite3VdbeIntValue((Mem*)pVal);
drh4f26d6c2004-05-26 23:25:30 +0000196}
drhefad9992004-06-22 12:13:55 +0000197sqlite_int64 sqlite3_value_int64(sqlite3_value *pVal){
drh6a6124e2004-06-27 01:56:33 +0000198 return sqlite3VdbeIntValue((Mem*)pVal);
drh4f26d6c2004-05-26 23:25:30 +0000199}
drhbcdf78a2015-09-10 20:34:56 +0000200unsigned int sqlite3_value_subtype(sqlite3_value *pVal){
dan5b6c8e42016-01-30 15:46:03 +0000201 Mem *pMem = (Mem*)pVal;
202 return ((pMem->flags & MEM_Subtype) ? pMem->eSubtype : 0);
drhbcdf78a2015-09-10 20:34:56 +0000203}
drhae3ec3f2017-07-17 00:40:19 +0000204void *sqlite3_value_pointer(sqlite3_value *pVal, const char *zPType){
drh3a96a5d2017-06-30 23:09:03 +0000205 Mem *p = (Mem*)pVal;
drha0024e62017-07-27 15:53:24 +0000206 if( (p->flags&(MEM_TypeMask|MEM_Term|MEM_Subtype)) ==
207 (MEM_Null|MEM_Term|MEM_Subtype)
drhae3ec3f2017-07-17 00:40:19 +0000208 && zPType!=0
drha0024e62017-07-27 15:53:24 +0000209 && p->eSubtype=='p'
drh22930062017-07-27 03:48:02 +0000210 && strcmp(p->u.zPType, zPType)==0
drhae3ec3f2017-07-17 00:40:19 +0000211 ){
drh22930062017-07-27 03:48:02 +0000212 return (void*)p->z;
drh3a96a5d2017-06-30 23:09:03 +0000213 }else{
214 return 0;
215 }
216}
drh4f26d6c2004-05-26 23:25:30 +0000217const unsigned char *sqlite3_value_text(sqlite3_value *pVal){
drhb21c8cd2007-08-21 19:33:56 +0000218 return (const unsigned char *)sqlite3ValueText(pVal, SQLITE_UTF8);
drh4f26d6c2004-05-26 23:25:30 +0000219}
drh6c626082004-11-14 21:56:29 +0000220#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +0000221const void *sqlite3_value_text16(sqlite3_value* pVal){
drhb21c8cd2007-08-21 19:33:56 +0000222 return sqlite3ValueText(pVal, SQLITE_UTF16NATIVE);
drh4f26d6c2004-05-26 23:25:30 +0000223}
danielk1977d8123362004-06-12 09:25:12 +0000224const void *sqlite3_value_text16be(sqlite3_value *pVal){
drhb21c8cd2007-08-21 19:33:56 +0000225 return sqlite3ValueText(pVal, SQLITE_UTF16BE);
danielk1977d8123362004-06-12 09:25:12 +0000226}
227const void *sqlite3_value_text16le(sqlite3_value *pVal){
drhb21c8cd2007-08-21 19:33:56 +0000228 return sqlite3ValueText(pVal, SQLITE_UTF16LE);
danielk1977d8123362004-06-12 09:25:12 +0000229}
drh6c626082004-11-14 21:56:29 +0000230#endif /* SQLITE_OMIT_UTF16 */
drh22ec1342015-02-27 00:33:15 +0000231/* EVIDENCE-OF: R-12793-43283 Every value in SQLite has one of five
232** fundamental datatypes: 64-bit signed integer 64-bit IEEE floating
233** point number string BLOB NULL
234*/
drh4f26d6c2004-05-26 23:25:30 +0000235int sqlite3_value_type(sqlite3_value* pVal){
drh1b27b8c2014-02-10 03:21:57 +0000236 static const u8 aType[] = {
drhf2566c42019-05-03 17:08:16 +0000237 SQLITE_BLOB, /* 0x00 (not possible) */
238 SQLITE_NULL, /* 0x01 NULL */
239 SQLITE_TEXT, /* 0x02 TEXT */
240 SQLITE_NULL, /* 0x03 (not possible) */
241 SQLITE_INTEGER, /* 0x04 INTEGER */
242 SQLITE_NULL, /* 0x05 (not possible) */
243 SQLITE_INTEGER, /* 0x06 INTEGER + TEXT */
244 SQLITE_NULL, /* 0x07 (not possible) */
245 SQLITE_FLOAT, /* 0x08 FLOAT */
246 SQLITE_NULL, /* 0x09 (not possible) */
247 SQLITE_FLOAT, /* 0x0a FLOAT + TEXT */
248 SQLITE_NULL, /* 0x0b (not possible) */
249 SQLITE_INTEGER, /* 0x0c (not possible) */
250 SQLITE_NULL, /* 0x0d (not possible) */
251 SQLITE_INTEGER, /* 0x0e (not possible) */
252 SQLITE_NULL, /* 0x0f (not possible) */
253 SQLITE_BLOB, /* 0x10 BLOB */
254 SQLITE_NULL, /* 0x11 (not possible) */
255 SQLITE_TEXT, /* 0x12 (not possible) */
256 SQLITE_NULL, /* 0x13 (not possible) */
257 SQLITE_INTEGER, /* 0x14 INTEGER + BLOB */
258 SQLITE_NULL, /* 0x15 (not possible) */
259 SQLITE_INTEGER, /* 0x16 (not possible) */
260 SQLITE_NULL, /* 0x17 (not possible) */
261 SQLITE_FLOAT, /* 0x18 FLOAT + BLOB */
262 SQLITE_NULL, /* 0x19 (not possible) */
263 SQLITE_FLOAT, /* 0x1a (not possible) */
264 SQLITE_NULL, /* 0x1b (not possible) */
265 SQLITE_INTEGER, /* 0x1c (not possible) */
266 SQLITE_NULL, /* 0x1d (not possible) */
267 SQLITE_INTEGER, /* 0x1e (not possible) */
268 SQLITE_NULL, /* 0x1f (not possible) */
269 SQLITE_FLOAT, /* 0x20 INTREAL */
270 SQLITE_NULL, /* 0x21 (not possible) */
271 SQLITE_TEXT, /* 0x22 INTREAL + TEXT */
272 SQLITE_NULL, /* 0x23 (not possible) */
273 SQLITE_FLOAT, /* 0x24 (not possible) */
274 SQLITE_NULL, /* 0x25 (not possible) */
275 SQLITE_FLOAT, /* 0x26 (not possible) */
276 SQLITE_NULL, /* 0x27 (not possible) */
277 SQLITE_FLOAT, /* 0x28 (not possible) */
278 SQLITE_NULL, /* 0x29 (not possible) */
279 SQLITE_FLOAT, /* 0x2a (not possible) */
280 SQLITE_NULL, /* 0x2b (not possible) */
281 SQLITE_FLOAT, /* 0x2c (not possible) */
282 SQLITE_NULL, /* 0x2d (not possible) */
283 SQLITE_FLOAT, /* 0x2e (not possible) */
284 SQLITE_NULL, /* 0x2f (not possible) */
285 SQLITE_BLOB, /* 0x30 (not possible) */
286 SQLITE_NULL, /* 0x31 (not possible) */
287 SQLITE_TEXT, /* 0x32 (not possible) */
288 SQLITE_NULL, /* 0x33 (not possible) */
289 SQLITE_FLOAT, /* 0x34 (not possible) */
290 SQLITE_NULL, /* 0x35 (not possible) */
291 SQLITE_FLOAT, /* 0x36 (not possible) */
292 SQLITE_NULL, /* 0x37 (not possible) */
293 SQLITE_FLOAT, /* 0x38 (not possible) */
294 SQLITE_NULL, /* 0x39 (not possible) */
295 SQLITE_FLOAT, /* 0x3a (not possible) */
296 SQLITE_NULL, /* 0x3b (not possible) */
297 SQLITE_FLOAT, /* 0x3c (not possible) */
298 SQLITE_NULL, /* 0x3d (not possible) */
299 SQLITE_FLOAT, /* 0x3e (not possible) */
300 SQLITE_NULL, /* 0x3f (not possible) */
drh1b27b8c2014-02-10 03:21:57 +0000301 };
drhde7109e2019-05-02 17:45:52 +0000302#ifdef SQLITE_DEBUG
303 {
304 int eType = SQLITE_BLOB;
305 if( pVal->flags & MEM_Null ){
306 eType = SQLITE_NULL;
drh169f0772019-05-02 21:36:26 +0000307 }else if( pVal->flags & (MEM_Real|MEM_IntReal) ){
drhde7109e2019-05-02 17:45:52 +0000308 eType = SQLITE_FLOAT;
drh169f0772019-05-02 21:36:26 +0000309 }else if( pVal->flags & MEM_Int ){
310 eType = SQLITE_INTEGER;
drhde7109e2019-05-02 17:45:52 +0000311 }else if( pVal->flags & MEM_Str ){
312 eType = SQLITE_TEXT;
313 }
314 assert( eType == aType[pVal->flags&MEM_AffMask] );
315 }
316#endif
mistachkinafc14f72014-03-05 01:29:18 +0000317 return aType[pVal->flags&MEM_AffMask];
drh4f26d6c2004-05-26 23:25:30 +0000318}
319
drhce2fbd12018-01-12 21:00:14 +0000320/* Return true if a parameter to xUpdate represents an unchanged column */
321int sqlite3_value_nochange(sqlite3_value *pVal){
322 return (pVal->flags&(MEM_Null|MEM_Zero))==(MEM_Null|MEM_Zero);
323}
324
drh57b1a3e2019-03-29 11:13:37 +0000325/* Return true if a parameter value originated from an sqlite3_bind() */
326int sqlite3_value_frombind(sqlite3_value *pVal){
327 return (pVal->flags&MEM_FromBind)!=0;
328}
329
drh4f03f412015-05-20 21:28:32 +0000330/* Make a copy of an sqlite3_value object
331*/
332sqlite3_value *sqlite3_value_dup(const sqlite3_value *pOrig){
333 sqlite3_value *pNew;
334 if( pOrig==0 ) return 0;
335 pNew = sqlite3_malloc( sizeof(*pNew) );
336 if( pNew==0 ) return 0;
337 memset(pNew, 0, sizeof(*pNew));
338 memcpy(pNew, pOrig, MEMCELLSIZE);
339 pNew->flags &= ~MEM_Dyn;
340 pNew->db = 0;
341 if( pNew->flags&(MEM_Str|MEM_Blob) ){
drh10ca5b42015-05-22 21:04:54 +0000342 pNew->flags &= ~(MEM_Static|MEM_Dyn);
343 pNew->flags |= MEM_Ephem;
344 if( sqlite3VdbeMemMakeWriteable(pNew)!=SQLITE_OK ){
345 sqlite3ValueFree(pNew);
346 pNew = 0;
drh4f03f412015-05-20 21:28:32 +0000347 }
drh83665292022-03-14 23:50:38 +0000348 }else if( pNew->flags & MEM_Null ){
349 /* Do not duplicate pointer values */
350 pNew->flags &= ~(MEM_Term|MEM_Subtype);
drh4f03f412015-05-20 21:28:32 +0000351 }
352 return pNew;
353}
354
355/* Destroy an sqlite3_value object previously obtained from
356** sqlite3_value_dup().
357*/
358void sqlite3_value_free(sqlite3_value *pOld){
359 sqlite3ValueFree(pOld);
360}
361
362
drh4f26d6c2004-05-26 23:25:30 +0000363/**************************** sqlite3_result_ *******************************
364** The following routines are used by user-defined functions to specify
365** the function result.
drh4c8555f2009-06-25 01:47:11 +0000366**
peter.d.reid60ec9142014-09-06 16:39:46 +0000367** The setStrOrError() function calls sqlite3VdbeMemSetStr() to store the
drhdbe349d2021-10-13 13:00:34 +0000368** result as a string or blob. Appropriate errors are set if the string/blob
369** is too big or if an OOM occurs.
drhda4ca9d2014-09-09 17:27:35 +0000370**
371** The invokeValueDestructor(P,X) routine invokes destructor function X()
372** on value P is not going to be used and need to be destroyed.
drh4f26d6c2004-05-26 23:25:30 +0000373*/
drh4c8555f2009-06-25 01:47:11 +0000374static void setResultStrOrError(
375 sqlite3_context *pCtx, /* Function context */
376 const char *z, /* String pointer */
377 int n, /* Bytes in string, or negative */
378 u8 enc, /* Encoding of z. 0 for BLOBs */
379 void (*xDel)(void*) /* Destructor function */
380){
drhfb92e072022-03-29 01:43:09 +0000381 Mem *pOut = pCtx->pOut;
382 int rc = sqlite3VdbeMemSetStr(pOut, z, n, enc, xDel);
drhdbe349d2021-10-13 13:00:34 +0000383 if( rc ){
384 if( rc==SQLITE_TOOBIG ){
385 sqlite3_result_error_toobig(pCtx);
386 }else{
387 /* The only errors possible from sqlite3VdbeMemSetStr are
388 ** SQLITE_TOOBIG and SQLITE_NOMEM */
389 assert( rc==SQLITE_NOMEM );
390 sqlite3_result_error_nomem(pCtx);
391 }
drhfb92e072022-03-29 01:43:09 +0000392 return;
393 }
drhc55b62d2022-03-29 22:57:00 +0000394 sqlite3VdbeChangeEncoding(pOut, ENC(pOut->db));
395 if( sqlite3VdbeMemTooBig(pOut) ){
396 sqlite3_result_error_toobig(pCtx);
drh4c8555f2009-06-25 01:47:11 +0000397 }
398}
drhda4ca9d2014-09-09 17:27:35 +0000399static int invokeValueDestructor(
400 const void *p, /* Value to destroy */
401 void (*xDel)(void*), /* The destructor */
402 sqlite3_context *pCtx /* Set a SQLITE_TOOBIG error if no NULL */
403){
drhfc59a952014-09-11 23:34:55 +0000404 assert( xDel!=SQLITE_DYNAMIC );
drhda4ca9d2014-09-09 17:27:35 +0000405 if( xDel==0 ){
406 /* noop */
407 }else if( xDel==SQLITE_TRANSIENT ){
408 /* noop */
drhda4ca9d2014-09-09 17:27:35 +0000409 }else{
410 xDel((void*)p);
411 }
drhd6228552021-06-09 14:45:02 +0000412 sqlite3_result_error_toobig(pCtx);
drhda4ca9d2014-09-09 17:27:35 +0000413 return SQLITE_TOOBIG;
414}
drh4f26d6c2004-05-26 23:25:30 +0000415void sqlite3_result_blob(
416 sqlite3_context *pCtx,
417 const void *z,
418 int n,
danielk1977d8123362004-06-12 09:25:12 +0000419 void (*xDel)(void *)
drh4f26d6c2004-05-26 23:25:30 +0000420){
drh5708d2d2005-06-22 10:53:59 +0000421 assert( n>=0 );
drh9bd038f2014-08-27 14:14:06 +0000422 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh4c8555f2009-06-25 01:47:11 +0000423 setResultStrOrError(pCtx, z, n, 0, xDel);
drh4f26d6c2004-05-26 23:25:30 +0000424}
drhda4ca9d2014-09-09 17:27:35 +0000425void sqlite3_result_blob64(
426 sqlite3_context *pCtx,
427 const void *z,
428 sqlite3_uint64 n,
429 void (*xDel)(void *)
430){
431 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drhfc59a952014-09-11 23:34:55 +0000432 assert( xDel!=SQLITE_DYNAMIC );
drhda4ca9d2014-09-09 17:27:35 +0000433 if( n>0x7fffffff ){
434 (void)invokeValueDestructor(z, xDel, pCtx);
435 }else{
436 setResultStrOrError(pCtx, z, (int)n, 0, xDel);
437 }
438}
drh4f26d6c2004-05-26 23:25:30 +0000439void sqlite3_result_double(sqlite3_context *pCtx, double rVal){
drh9bd038f2014-08-27 14:14:06 +0000440 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
441 sqlite3VdbeMemSetDouble(pCtx->pOut, rVal);
drh4f26d6c2004-05-26 23:25:30 +0000442}
443void sqlite3_result_error(sqlite3_context *pCtx, const char *z, int n){
drh9bd038f2014-08-27 14:14:06 +0000444 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh69544ec2008-02-06 14:11:34 +0000445 pCtx->isError = SQLITE_ERROR;
drh9bd038f2014-08-27 14:14:06 +0000446 sqlite3VdbeMemSetStr(pCtx->pOut, z, n, SQLITE_UTF8, SQLITE_TRANSIENT);
drh4f26d6c2004-05-26 23:25:30 +0000447}
danielk1977a1686c92006-01-23 07:52:37 +0000448#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +0000449void sqlite3_result_error16(sqlite3_context *pCtx, const void *z, int n){
drh9bd038f2014-08-27 14:14:06 +0000450 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh69544ec2008-02-06 14:11:34 +0000451 pCtx->isError = SQLITE_ERROR;
drh9bd038f2014-08-27 14:14:06 +0000452 sqlite3VdbeMemSetStr(pCtx->pOut, z, n, SQLITE_UTF16NATIVE, SQLITE_TRANSIENT);
drh4f26d6c2004-05-26 23:25:30 +0000453}
danielk1977a1686c92006-01-23 07:52:37 +0000454#endif
drhf4479502004-05-27 03:12:53 +0000455void sqlite3_result_int(sqlite3_context *pCtx, int iVal){
drh9bd038f2014-08-27 14:14:06 +0000456 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
457 sqlite3VdbeMemSetInt64(pCtx->pOut, (i64)iVal);
drh4f26d6c2004-05-26 23:25:30 +0000458}
459void sqlite3_result_int64(sqlite3_context *pCtx, i64 iVal){
drh9bd038f2014-08-27 14:14:06 +0000460 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
461 sqlite3VdbeMemSetInt64(pCtx->pOut, iVal);
drh4f26d6c2004-05-26 23:25:30 +0000462}
463void sqlite3_result_null(sqlite3_context *pCtx){
drh9bd038f2014-08-27 14:14:06 +0000464 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
465 sqlite3VdbeMemSetNull(pCtx->pOut);
drh4f26d6c2004-05-26 23:25:30 +0000466}
drh22930062017-07-27 03:48:02 +0000467void sqlite3_result_pointer(
468 sqlite3_context *pCtx,
469 void *pPtr,
470 const char *zPType,
471 void (*xDestructor)(void*)
472){
drh3a96a5d2017-06-30 23:09:03 +0000473 Mem *pOut = pCtx->pOut;
474 assert( sqlite3_mutex_held(pOut->db->mutex) );
drh526740b2017-08-24 13:55:46 +0000475 sqlite3VdbeMemRelease(pOut);
476 pOut->flags = MEM_Null;
drh22930062017-07-27 03:48:02 +0000477 sqlite3VdbeMemSetPointer(pOut, pPtr, zPType, xDestructor);
drh3a96a5d2017-06-30 23:09:03 +0000478}
drhbcdf78a2015-09-10 20:34:56 +0000479void sqlite3_result_subtype(sqlite3_context *pCtx, unsigned int eSubtype){
dan5b6c8e42016-01-30 15:46:03 +0000480 Mem *pOut = pCtx->pOut;
481 assert( sqlite3_mutex_held(pOut->db->mutex) );
482 pOut->eSubtype = eSubtype & 0xff;
483 pOut->flags |= MEM_Subtype;
drhbcdf78a2015-09-10 20:34:56 +0000484}
drh4f26d6c2004-05-26 23:25:30 +0000485void sqlite3_result_text(
486 sqlite3_context *pCtx,
487 const char *z,
488 int n,
danielk1977d8123362004-06-12 09:25:12 +0000489 void (*xDel)(void *)
drh4f26d6c2004-05-26 23:25:30 +0000490){
drh9bd038f2014-08-27 14:14:06 +0000491 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh4c8555f2009-06-25 01:47:11 +0000492 setResultStrOrError(pCtx, z, n, SQLITE_UTF8, xDel);
drh4f26d6c2004-05-26 23:25:30 +0000493}
drhbbf483f2014-09-09 20:30:24 +0000494void sqlite3_result_text64(
drhda4ca9d2014-09-09 17:27:35 +0000495 sqlite3_context *pCtx,
496 const char *z,
497 sqlite3_uint64 n,
498 void (*xDel)(void *),
499 unsigned char enc
500){
501 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drhfc59a952014-09-11 23:34:55 +0000502 assert( xDel!=SQLITE_DYNAMIC );
drh79f7af92014-10-03 16:00:51 +0000503 if( enc==SQLITE_UTF16 ) enc = SQLITE_UTF16NATIVE;
drhda4ca9d2014-09-09 17:27:35 +0000504 if( n>0x7fffffff ){
505 (void)invokeValueDestructor(z, xDel, pCtx);
506 }else{
507 setResultStrOrError(pCtx, z, (int)n, enc, xDel);
508 }
509}
drh6c626082004-11-14 21:56:29 +0000510#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +0000511void sqlite3_result_text16(
512 sqlite3_context *pCtx,
513 const void *z,
514 int n,
danielk1977d8123362004-06-12 09:25:12 +0000515 void (*xDel)(void *)
drh4f26d6c2004-05-26 23:25:30 +0000516){
drh9bd038f2014-08-27 14:14:06 +0000517 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh4c8555f2009-06-25 01:47:11 +0000518 setResultStrOrError(pCtx, z, n, SQLITE_UTF16NATIVE, xDel);
danielk1977d8123362004-06-12 09:25:12 +0000519}
520void sqlite3_result_text16be(
521 sqlite3_context *pCtx,
522 const void *z,
523 int n,
524 void (*xDel)(void *)
525){
drh9bd038f2014-08-27 14:14:06 +0000526 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh4c8555f2009-06-25 01:47:11 +0000527 setResultStrOrError(pCtx, z, n, SQLITE_UTF16BE, xDel);
danielk1977d8123362004-06-12 09:25:12 +0000528}
529void sqlite3_result_text16le(
530 sqlite3_context *pCtx,
531 const void *z,
532 int n,
533 void (*xDel)(void *)
534){
drh9bd038f2014-08-27 14:14:06 +0000535 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh4c8555f2009-06-25 01:47:11 +0000536 setResultStrOrError(pCtx, z, n, SQLITE_UTF16LE, xDel);
drh4f26d6c2004-05-26 23:25:30 +0000537}
drh6c626082004-11-14 21:56:29 +0000538#endif /* SQLITE_OMIT_UTF16 */
drh4f26d6c2004-05-26 23:25:30 +0000539void sqlite3_result_value(sqlite3_context *pCtx, sqlite3_value *pValue){
drhfb92e072022-03-29 01:43:09 +0000540 Mem *pOut = pCtx->pOut;
drh9bd038f2014-08-27 14:14:06 +0000541 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drhfb92e072022-03-29 01:43:09 +0000542 sqlite3VdbeMemCopy(pOut, pValue);
543 sqlite3VdbeChangeEncoding(pOut, ENC(pOut->db));
544 if( sqlite3VdbeMemTooBig(pOut) ){
545 sqlite3_result_error_toobig(pCtx);
546 }
drh4f26d6c2004-05-26 23:25:30 +0000547}
drhb026e052007-05-02 01:34:31 +0000548void sqlite3_result_zeroblob(sqlite3_context *pCtx, int n){
drhfb92e072022-03-29 01:43:09 +0000549 sqlite3_result_zeroblob64(pCtx, n>0 ? n : 0);
drhb026e052007-05-02 01:34:31 +0000550}
dana4d5ae82015-07-24 16:24:37 +0000551int sqlite3_result_zeroblob64(sqlite3_context *pCtx, u64 n){
552 Mem *pOut = pCtx->pOut;
553 assert( sqlite3_mutex_held(pOut->db->mutex) );
drh6bacdc22015-07-24 17:14:03 +0000554 if( n>(u64)pOut->db->aLimit[SQLITE_LIMIT_LENGTH] ){
drhfb92e072022-03-29 01:43:09 +0000555 sqlite3_result_error_toobig(pCtx);
dana4d5ae82015-07-24 16:24:37 +0000556 return SQLITE_TOOBIG;
557 }
dana32536b2021-11-08 19:35:26 +0000558#ifndef SQLITE_OMIT_INCRBLOB
dana4d5ae82015-07-24 16:24:37 +0000559 sqlite3VdbeMemSetZeroBlob(pCtx->pOut, (int)n);
560 return SQLITE_OK;
dana32536b2021-11-08 19:35:26 +0000561#else
562 return sqlite3VdbeMemSetZeroBlob(pCtx->pOut, (int)n);
563#endif
dana4d5ae82015-07-24 16:24:37 +0000564}
drh69544ec2008-02-06 14:11:34 +0000565void sqlite3_result_error_code(sqlite3_context *pCtx, int errCode){
drhf09ac0b2018-01-23 03:44:06 +0000566 pCtx->isError = errCode ? errCode : -1;
drh983b5ee2015-02-13 12:05:56 +0000567#ifdef SQLITE_DEBUG
drh96f4ad22015-03-12 21:02:36 +0000568 if( pCtx->pVdbe ) pCtx->pVdbe->rcApp = errCode;
drh983b5ee2015-02-13 12:05:56 +0000569#endif
drh9bd038f2014-08-27 14:14:06 +0000570 if( pCtx->pOut->flags & MEM_Null ){
drhfb92e072022-03-29 01:43:09 +0000571 setResultStrOrError(pCtx, sqlite3ErrStr(errCode), -1, SQLITE_UTF8,
572 SQLITE_STATIC);
drh51c7d862009-04-27 18:46:06 +0000573 }
drh69544ec2008-02-06 14:11:34 +0000574}
drh4f26d6c2004-05-26 23:25:30 +0000575
drha0206bc2007-05-08 15:15:02 +0000576/* Force an SQLITE_TOOBIG error. */
577void sqlite3_result_error_toobig(sqlite3_context *pCtx){
drh9bd038f2014-08-27 14:14:06 +0000578 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drhbb4957f2008-03-20 14:03:29 +0000579 pCtx->isError = SQLITE_TOOBIG;
drh9bd038f2014-08-27 14:14:06 +0000580 sqlite3VdbeMemSetStr(pCtx->pOut, "string or blob too big", -1,
drhbb4957f2008-03-20 14:03:29 +0000581 SQLITE_UTF8, SQLITE_STATIC);
drha0206bc2007-05-08 15:15:02 +0000582}
583
danielk1977a1644fd2007-08-29 12:31:25 +0000584/* An SQLITE_NOMEM error. */
585void sqlite3_result_error_nomem(sqlite3_context *pCtx){
drh9bd038f2014-08-27 14:14:06 +0000586 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
587 sqlite3VdbeMemSetNull(pCtx->pOut);
mistachkinfad30392016-02-13 23:43:46 +0000588 pCtx->isError = SQLITE_NOMEM_BKPT;
drh4a642b62016-02-05 01:55:27 +0000589 sqlite3OomFault(pCtx->pOut->db);
danielk1977a1644fd2007-08-29 12:31:25 +0000590}
drh4f26d6c2004-05-26 23:25:30 +0000591
drh0c8f4032019-05-03 21:17:28 +0000592#ifndef SQLITE_UNTESTABLE
593/* Force the INT64 value currently stored as the result to be
594** a MEM_IntReal value. See the SQLITE_TESTCTRL_RESULT_INTREAL
595** test-control.
596*/
597void sqlite3ResultIntReal(sqlite3_context *pCtx){
598 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
599 if( pCtx->pOut->flags & MEM_Int ){
600 pCtx->pOut->flags &= ~MEM_Int;
601 pCtx->pOut->flags |= MEM_IntReal;
602 }
603}
604#endif
605
606
dan5cf53532010-05-01 16:40:20 +0000607/*
608** This function is called after a transaction has been committed. It
609** invokes callbacks registered with sqlite3_wal_hook() as required.
610*/
drh7ed91f22010-04-29 22:34:07 +0000611static int doWalCallbacks(sqlite3 *db){
dan8d22a172010-04-19 18:03:51 +0000612 int rc = SQLITE_OK;
dan5cf53532010-05-01 16:40:20 +0000613#ifndef SQLITE_OMIT_WAL
614 int i;
dan8d22a172010-04-19 18:03:51 +0000615 for(i=0; i<db->nDb; i++){
616 Btree *pBt = db->aDb[i].pBt;
617 if( pBt ){
drhef15c6e2014-12-12 01:27:17 +0000618 int nEntry;
619 sqlite3BtreeEnter(pBt);
620 nEntry = sqlite3PagerWalCallback(sqlite3BtreePager(pBt));
621 sqlite3BtreeLeave(pBt);
drh59533aa2017-08-02 18:28:26 +0000622 if( nEntry>0 && db->xWalCallback && rc==SQLITE_OK ){
drh69c33822016-08-18 14:33:11 +0000623 rc = db->xWalCallback(db->pWalArg, db, db->aDb[i].zDbSName, nEntry);
dan8d22a172010-04-19 18:03:51 +0000624 }
625 }
626 }
dan5cf53532010-05-01 16:40:20 +0000627#endif
dan8d22a172010-04-19 18:03:51 +0000628 return rc;
629}
630
drh201e0c62015-07-14 14:48:50 +0000631
drh4f26d6c2004-05-26 23:25:30 +0000632/*
633** Execute the statement pStmt, either until a row of data is ready, the
634** statement is completely executed or an error occurs.
drhb900aaf2006-11-09 00:24:53 +0000635**
636** This routine implements the bulk of the logic behind the sqlite_step()
637** API. The only thing omitted is the automatic recompile if a
638** schema change has occurred. That detail is handled by the
639** outer sqlite3_step() wrapper procedure.
drh4f26d6c2004-05-26 23:25:30 +0000640*/
drhb900aaf2006-11-09 00:24:53 +0000641static int sqlite3Step(Vdbe *p){
drh9bb575f2004-09-06 17:24:11 +0000642 sqlite3 *db;
drh4f26d6c2004-05-26 23:25:30 +0000643 int rc;
644
danielk1977a185ddb2007-11-15 16:04:15 +0000645 assert(p);
drh17b74812021-02-03 18:32:25 +0000646 if( p->iVdbeMagic!=VDBE_MAGIC_RUN ){
drh3674bfd2010-04-17 12:53:19 +0000647 /* We used to require that sqlite3_reset() be called before retrying
drh602acb42011-01-17 17:42:37 +0000648 ** sqlite3_step() after any error or after SQLITE_DONE. But beginning
649 ** with version 3.7.0, we changed this so that sqlite3_reset() would
650 ** be called automatically instead of throwing the SQLITE_MISUSE error.
651 ** This "automatic-reset" change is not technically an incompatibility,
652 ** since any application that receives an SQLITE_MISUSE is broken by
653 ** definition.
654 **
655 ** Nevertheless, some published applications that were originally written
656 ** for version 3.6.23 or earlier do in fact depend on SQLITE_MISUSE
drhb8a45bb2011-12-31 21:51:55 +0000657 ** returns, and those were broken by the automatic-reset change. As a
drh602acb42011-01-17 17:42:37 +0000658 ** a work-around, the SQLITE_OMIT_AUTORESET compile-time restores the
659 ** legacy behavior of returning SQLITE_MISUSE for cases where the
660 ** previous sqlite3_step() returned something other than a SQLITE_LOCKED
661 ** or SQLITE_BUSY error.
drh3674bfd2010-04-17 12:53:19 +0000662 */
drh602acb42011-01-17 17:42:37 +0000663#ifdef SQLITE_OMIT_AUTORESET
drh983b5ee2015-02-13 12:05:56 +0000664 if( (rc = p->rc&0xff)==SQLITE_BUSY || rc==SQLITE_LOCKED ){
drh602acb42011-01-17 17:42:37 +0000665 sqlite3_reset((sqlite3_stmt*)p);
666 }else{
667 return SQLITE_MISUSE_BKPT;
668 }
669#else
drh3674bfd2010-04-17 12:53:19 +0000670 sqlite3_reset((sqlite3_stmt*)p);
drh602acb42011-01-17 17:42:37 +0000671#endif
drhf1bfe9a2007-10-17 01:44:20 +0000672 }
673
dan14d4cc42010-01-20 14:25:37 +0000674 /* Check that malloc() has not failed. If it has, return early. */
drh17435752007-08-16 04:30:38 +0000675 db = p->db;
drhc456e572008-08-11 18:44:58 +0000676 if( db->mallocFailed ){
dan14d4cc42010-01-20 14:25:37 +0000677 p->rc = SQLITE_NOMEM;
mistachkinfad30392016-02-13 23:43:46 +0000678 return SQLITE_NOMEM_BKPT;
drhc456e572008-08-11 18:44:58 +0000679 }
danielk1977261919c2005-12-06 12:52:59 +0000680
drhcfc07832018-12-11 12:51:46 +0000681 if( p->pc<0 && p->expired ){
drhbee80652010-02-25 21:27:58 +0000682 p->rc = SQLITE_SCHEMA;
drhb900aaf2006-11-09 00:24:53 +0000683 rc = SQLITE_ERROR;
drh5cbb4422020-06-29 13:12:42 +0000684 if( (p->prepFlags & SQLITE_PREPARE_SAVESQL)!=0 ){
685 /* If this statement was prepared using saved SQL and an
686 ** error has occurred, then return the error code in p->rc to the
687 ** caller. Set the error code in the database handle to the same value.
688 */
689 rc = sqlite3VdbeTransferError(p);
690 }
drhb900aaf2006-11-09 00:24:53 +0000691 goto end_of_step;
danielk1977a21c6b62005-01-24 10:25:59 +0000692 }
danielk19771d850a72004-05-31 08:26:49 +0000693 if( p->pc<0 ){
drh15ca1df2006-07-26 13:43:30 +0000694 /* If there are no other statements currently running, then
695 ** reset the interrupt flag. This prevents a call to sqlite3_interrupt
696 ** from interrupting a statement that has not yet started.
697 */
drh4f7d3a52013-06-27 23:54:02 +0000698 if( db->nVdbeActive==0 ){
dan892edb62020-03-30 13:35:05 +0000699 AtomicStore(&db->u1.isInterrupted, 0);
drh15ca1df2006-07-26 13:43:30 +0000700 }
701
drh888e16e2013-07-09 13:05:49 +0000702 assert( db->nVdbeWrite>0 || db->autoCommit==0
dancb3e4b72013-07-03 19:53:05 +0000703 || (db->nDeferredCons==0 && db->nDeferredImmCons==0)
704 );
dan1da40a32009-09-19 17:00:31 +0000705
drh19e2d372005-08-29 23:00:03 +0000706#ifndef SQLITE_OMIT_TRACE
drh04c67472018-12-04 14:33:02 +0000707 if( (db->mTrace & (SQLITE_TRACE_PROFILE|SQLITE_TRACE_XPROFILE))!=0
drh3d2a5292016-07-13 22:55:01 +0000708 && !db->init.busy && p->zSql ){
drhb7e8ea22010-05-03 14:32:30 +0000709 sqlite3OsCurrentTimeInt64(db->pVfs, &p->startTime);
drh201e0c62015-07-14 14:48:50 +0000710 }else{
711 assert( p->startTime==0 );
drh19e2d372005-08-29 23:00:03 +0000712 }
713#endif
drhc16a03b2004-09-15 13:38:10 +0000714
drh4f7d3a52013-06-27 23:54:02 +0000715 db->nVdbeActive++;
716 if( p->readOnly==0 ) db->nVdbeWrite++;
drh1713afb2013-06-28 01:24:57 +0000717 if( p->bIsReader ) db->nVdbeRead++;
danielk19771d850a72004-05-31 08:26:49 +0000718 p->pc = 0;
719 }
drh983b5ee2015-02-13 12:05:56 +0000720#ifdef SQLITE_DEBUG
721 p->rcApp = SQLITE_OK;
722#endif
drhb7f91642004-10-31 02:22:47 +0000723#ifndef SQLITE_OMIT_EXPLAIN
drh4f26d6c2004-05-26 23:25:30 +0000724 if( p->explain ){
725 rc = sqlite3VdbeList(p);
drhb7f91642004-10-31 02:22:47 +0000726 }else
727#endif /* SQLITE_OMIT_EXPLAIN */
728 {
drh4f7d3a52013-06-27 23:54:02 +0000729 db->nVdbeExec++;
drh4f26d6c2004-05-26 23:25:30 +0000730 rc = sqlite3VdbeExec(p);
drh4f7d3a52013-06-27 23:54:02 +0000731 db->nVdbeExec--;
drh4f26d6c2004-05-26 23:25:30 +0000732 }
733
drhb7de8272018-12-04 13:51:26 +0000734 if( rc!=SQLITE_ROW ){
drh19e2d372005-08-29 23:00:03 +0000735#ifndef SQLITE_OMIT_TRACE
drhb7de8272018-12-04 13:51:26 +0000736 /* If the statement completed successfully, invoke the profile callback */
737 checkProfileCallback(db, p);
drh19e2d372005-08-29 23:00:03 +0000738#endif
739
drhb7de8272018-12-04 13:51:26 +0000740 if( rc==SQLITE_DONE && db->autoCommit ){
741 assert( p->rc==SQLITE_OK );
742 p->rc = doWalCallbacks(db);
743 if( p->rc!=SQLITE_OK ){
744 rc = SQLITE_ERROR;
745 }
drh5cbb4422020-06-29 13:12:42 +0000746 }else if( rc!=SQLITE_DONE && (p->prepFlags & SQLITE_PREPARE_SAVESQL)!=0 ){
747 /* If this statement was prepared using saved SQL and an
748 ** error has occurred, then return the error code in p->rc to the
749 ** caller. Set the error code in the database handle to the same value.
750 */
751 rc = sqlite3VdbeTransferError(p);
dan8d22a172010-04-19 18:03:51 +0000752 }
753 }
754
drh80cc85b2008-07-23 21:07:25 +0000755 db->errCode = rc;
danielk1977357864e2009-03-25 15:43:08 +0000756 if( SQLITE_NOMEM==sqlite3ApiExit(p->db, p->rc) ){
mistachkinfad30392016-02-13 23:43:46 +0000757 p->rc = SQLITE_NOMEM_BKPT;
drh5cbb4422020-06-29 13:12:42 +0000758 if( (p->prepFlags & SQLITE_PREPARE_SAVESQL)!=0 ) rc = p->rc;
drhb900aaf2006-11-09 00:24:53 +0000759 }
danielk1977357864e2009-03-25 15:43:08 +0000760end_of_step:
drh5cbb4422020-06-29 13:12:42 +0000761 /* There are only a limited number of result codes allowed from the
762 ** statements prepared using the legacy sqlite3_prepare() interface */
763 assert( (p->prepFlags & SQLITE_PREPARE_SAVESQL)!=0
764 || rc==SQLITE_ROW || rc==SQLITE_DONE || rc==SQLITE_ERROR
drhcbd8db32015-08-20 17:18:32 +0000765 || (rc&0xff)==SQLITE_BUSY || rc==SQLITE_MISUSE
danielk1977357864e2009-03-25 15:43:08 +0000766 );
danielk1977357864e2009-03-25 15:43:08 +0000767 return (rc&db->errMask);
drhb900aaf2006-11-09 00:24:53 +0000768}
769
770/*
771** This is the top-level implementation of sqlite3_step(). Call
772** sqlite3Step() to do most of the work. If a schema error occurs,
773** call sqlite3Reprepare() and try again.
774*/
drhb900aaf2006-11-09 00:24:53 +0000775int sqlite3_step(sqlite3_stmt *pStmt){
drha6129fa2010-02-24 17:15:19 +0000776 int rc = SQLITE_OK; /* Result from sqlite3Step() */
drha6129fa2010-02-24 17:15:19 +0000777 Vdbe *v = (Vdbe*)pStmt; /* the prepared statement */
778 int cnt = 0; /* Counter to prevent infinite loop of reprepares */
779 sqlite3 *db; /* The database connection */
780
drh413c3d32010-02-23 20:11:56 +0000781 if( vdbeSafetyNotNull(v) ){
782 return SQLITE_MISUSE_BKPT;
danielk19778e556522007-11-13 10:30:24 +0000783 }
drh413c3d32010-02-23 20:11:56 +0000784 db = v->db;
785 sqlite3_mutex_enter(db->mutex);
drh37f58e92012-09-04 21:34:26 +0000786 v->doingRerun = 0;
drh413c3d32010-02-23 20:11:56 +0000787 while( (rc = sqlite3Step(v))==SQLITE_SCHEMA
drh2c7946a2014-08-19 20:27:40 +0000788 && cnt++ < SQLITE_MAX_SCHEMA_RETRY ){
789 int savedPc = v->pc;
drh754ee282017-08-02 19:04:37 +0000790 rc = sqlite3Reprepare(v);
791 if( rc!=SQLITE_OK ){
792 /* This case occurs after failing to recompile an sql statement.
793 ** The error message from the SQL compiler has already been loaded
794 ** into the database handle. This block copies the error message
795 ** from the database handle into the statement and sets the statement
796 ** program counter to 0 to ensure that when the statement is
797 ** finalized or reset the parser error message is available via
798 ** sqlite3_errmsg() and sqlite3_errcode().
799 */
800 const char *zErr = (const char *)sqlite3_value_text(db->pErr);
801 sqlite3DbFree(db, v->zErrMsg);
802 if( !db->mallocFailed ){
803 v->zErrMsg = sqlite3DbStrDup(db, zErr);
804 v->rc = rc = sqlite3ApiExit(db, rc);
805 } else {
806 v->zErrMsg = 0;
807 v->rc = rc = SQLITE_NOMEM_BKPT;
808 }
809 break;
810 }
drh413c3d32010-02-23 20:11:56 +0000811 sqlite3_reset(pStmt);
drh5f58ae72014-08-19 20:41:36 +0000812 if( savedPc>=0 ) v->doingRerun = 1;
dan08f5f4c2011-06-27 19:37:23 +0000813 assert( v->expired==0 );
drh413c3d32010-02-23 20:11:56 +0000814 }
drh413c3d32010-02-23 20:11:56 +0000815 sqlite3_mutex_leave(db->mutex);
danielk197776e8d1a2006-01-18 18:22:43 +0000816 return rc;
drh4f26d6c2004-05-26 23:25:30 +0000817}
818
drh95a7b3e2013-09-16 12:57:19 +0000819
drh4f26d6c2004-05-26 23:25:30 +0000820/*
drheb2e1762004-05-27 01:53:56 +0000821** Extract the user data from a sqlite3_context structure and return a
822** pointer to it.
823*/
824void *sqlite3_user_data(sqlite3_context *p){
825 assert( p && p->pFunc );
826 return p->pFunc->pUserData;
827}
828
829/*
drhfa4a4b92008-03-19 21:45:51 +0000830** Extract the user data from a sqlite3_context structure and return a
831** pointer to it.
drh9f129f42010-08-31 15:27:32 +0000832**
833** IMPLEMENTATION-OF: R-46798-50301 The sqlite3_context_db_handle() interface
834** returns a copy of the pointer to the database connection (the 1st
835** parameter) of the sqlite3_create_function() and
836** sqlite3_create_function16() routines that originally registered the
837** application defined function.
drhfa4a4b92008-03-19 21:45:51 +0000838*/
839sqlite3 *sqlite3_context_db_handle(sqlite3_context *p){
drha46a4a62015-09-08 21:12:53 +0000840 assert( p && p->pOut );
drh9bd038f2014-08-27 14:14:06 +0000841 return p->pOut->db;
drhfa4a4b92008-03-19 21:45:51 +0000842}
843
844/*
drh6f390be2018-01-11 17:04:26 +0000845** If this routine is invoked from within an xColumn method of a virtual
846** table, then it returns true if and only if the the call is during an
847** UPDATE operation and the value of the column will not be modified
848** by the UPDATE.
849**
850** If this routine is called from any context other than within the
851** xColumn method of a virtual table, then the return value is meaningless
852** and arbitrary.
853**
854** Virtual table implements might use this routine to optimize their
855** performance by substituting a NULL result, or some other light-weight
856** value, as a signal to the xUpdate routine that the column is unchanged.
857*/
858int sqlite3_vtab_nochange(sqlite3_context *p){
859 assert( p );
drhce2fbd12018-01-12 21:00:14 +0000860 return sqlite3_value_nochange(p->pOut);
drh6f390be2018-01-11 17:04:26 +0000861}
862
863/*
drh0fe7e7d2022-02-01 14:58:29 +0000864** Implementation of sqlite3_vtab_in_first() (if bNext==0) and
865** sqlite3_vtab_in_next() (if bNext!=0).
866*/
drh30e314e2022-02-02 14:36:58 +0000867static int valueFromValueList(
868 sqlite3_value *pVal, /* Pointer to the ValueList object */
869 sqlite3_value **ppOut, /* Store the next value from the list here */
870 int bNext /* 1 for _next(). 0 for _first() */
871){
drhb30298d2022-02-01 21:59:43 +0000872 int rc;
drh30e314e2022-02-02 14:36:58 +0000873 ValueList *pRhs;
874
drh0fe7e7d2022-02-01 14:58:29 +0000875 *ppOut = 0;
drhb30298d2022-02-01 21:59:43 +0000876 if( pVal==0 ) return SQLITE_MISUSE;
drh30e314e2022-02-02 14:36:58 +0000877 pRhs = (ValueList*)sqlite3_value_pointer(pVal, "ValueList");
878 if( pRhs==0 ) return SQLITE_MISUSE;
drhb30298d2022-02-01 21:59:43 +0000879 if( bNext ){
drh30e314e2022-02-02 14:36:58 +0000880 rc = sqlite3BtreeNext(pRhs->pCsr, 0);
drhb30298d2022-02-01 21:59:43 +0000881 }else{
882 int dummy = 0;
drh30e314e2022-02-02 14:36:58 +0000883 rc = sqlite3BtreeFirst(pRhs->pCsr, &dummy);
drh3d7a69e2022-02-02 16:24:01 +0000884 assert( rc==SQLITE_OK || sqlite3BtreeEof(pRhs->pCsr) );
885 if( sqlite3BtreeEof(pRhs->pCsr) ) rc = SQLITE_DONE;
drhb30298d2022-02-01 21:59:43 +0000886 }
887 if( rc==SQLITE_OK ){
drh30e314e2022-02-02 14:36:58 +0000888 u32 sz; /* Size of current row in bytes */
889 Mem sMem; /* Raw content of current row */
890 memset(&sMem, 0, sizeof(sMem));
891 sz = sqlite3BtreePayloadSize(pRhs->pCsr);
892 rc = sqlite3VdbeMemFromBtreeZeroOffset(pRhs->pCsr,(int)sz,&sMem);
893 if( rc==SQLITE_OK ){
894 u8 *zBuf = (u8*)sMem.z;
895 u32 iSerial;
896 sqlite3_value *pOut = pRhs->pOut;
897 int iOff = 1 + getVarint32(&zBuf[1], iSerial);
898 sqlite3VdbeSerialGet(&zBuf[iOff], iSerial, pOut);
drh38d1e442022-02-02 15:10:45 +0000899 pOut->enc = ENC(pOut->db);
drh30e314e2022-02-02 14:36:58 +0000900 if( (pOut->flags & MEM_Ephem)!=0 && sqlite3VdbeMemMakeWriteable(pOut) ){
901 rc = SQLITE_NOMEM;
902 }else{
903 *ppOut = pOut;
904 }
905 }
906 sqlite3VdbeMemRelease(&sMem);
drh0fe7e7d2022-02-01 14:58:29 +0000907 }
908 return rc;
909}
910
911/*
912** Set the iterator value pVal to point to the first value in the set.
913** Set (*ppOut) to point to this value before returning.
914*/
915int sqlite3_vtab_in_first(sqlite3_value *pVal, sqlite3_value **ppOut){
drh30e314e2022-02-02 14:36:58 +0000916 return valueFromValueList(pVal, ppOut, 0);
drh0fe7e7d2022-02-01 14:58:29 +0000917}
918
919/*
920** Set the iterator value pVal to point to the next value in the set.
921** Set (*ppOut) to point to this value before returning.
922*/
923int sqlite3_vtab_in_next(sqlite3_value *pVal, sqlite3_value **ppOut){
drh30e314e2022-02-02 14:36:58 +0000924 return valueFromValueList(pVal, ppOut, 1);
drh0fe7e7d2022-02-01 14:58:29 +0000925}
926
927/*
drha9e03b12015-03-12 06:46:52 +0000928** Return the current time for a statement. If the current time
929** is requested more than once within the same run of a single prepared
930** statement, the exact same time is returned for each invocation regardless
931** of the amount of time that elapses between invocations. In other words,
932** the time returned is always the time of the first call.
drh95a7b3e2013-09-16 12:57:19 +0000933*/
934sqlite3_int64 sqlite3StmtCurrentTime(sqlite3_context *p){
drh95a7b3e2013-09-16 12:57:19 +0000935 int rc;
drh175b8f02019-08-08 15:24:17 +0000936#ifndef SQLITE_ENABLE_STAT4
drh3df79a92015-03-12 23:48:27 +0000937 sqlite3_int64 *piTime = &p->pVdbe->iCurrentTime;
drha9e03b12015-03-12 06:46:52 +0000938 assert( p->pVdbe!=0 );
939#else
drh3df79a92015-03-12 23:48:27 +0000940 sqlite3_int64 iTime = 0;
drha9e03b12015-03-12 06:46:52 +0000941 sqlite3_int64 *piTime = p->pVdbe!=0 ? &p->pVdbe->iCurrentTime : &iTime;
drha9e03b12015-03-12 06:46:52 +0000942#endif
drh3df79a92015-03-12 23:48:27 +0000943 if( *piTime==0 ){
drha9e03b12015-03-12 06:46:52 +0000944 rc = sqlite3OsCurrentTimeInt64(p->pOut->db->pVfs, piTime);
945 if( rc ) *piTime = 0;
drh95a7b3e2013-09-16 12:57:19 +0000946 }
drha9e03b12015-03-12 06:46:52 +0000947 return *piTime;
drh95a7b3e2013-09-16 12:57:19 +0000948}
949
950/*
drh9de4a172014-08-23 18:17:19 +0000951** Create a new aggregate context for p and return a pointer to
952** its pMem->z element.
953*/
954static SQLITE_NOINLINE void *createAggContext(sqlite3_context *p, int nByte){
955 Mem *pMem = p->pMem;
956 assert( (pMem->flags & MEM_Agg)==0 );
957 if( nByte<=0 ){
drh0725cab2014-09-17 14:52:46 +0000958 sqlite3VdbeMemSetNull(pMem);
drh9de4a172014-08-23 18:17:19 +0000959 pMem->z = 0;
960 }else{
drh322f2852014-09-19 00:43:39 +0000961 sqlite3VdbeMemClearAndResize(pMem, nByte);
drh9de4a172014-08-23 18:17:19 +0000962 pMem->flags = MEM_Agg;
963 pMem->u.pDef = p->pFunc;
964 if( pMem->z ){
965 memset(pMem->z, 0, nByte);
966 }
967 }
968 return (void*)pMem->z;
969}
970
971/*
drheb2e1762004-05-27 01:53:56 +0000972** Allocate or return the aggregate context for a user function. A new
973** context is allocated on the first call. Subsequent calls return the
974** same context that was returned on prior calls.
drheb2e1762004-05-27 01:53:56 +0000975*/
976void *sqlite3_aggregate_context(sqlite3_context *p, int nByte){
drh2d801512016-01-14 22:19:58 +0000977 assert( p && p->pFunc && p->pFunc->xFinalize );
drh9bd038f2014-08-27 14:14:06 +0000978 assert( sqlite3_mutex_held(p->pOut->db->mutex) );
drhd68eee02009-12-11 03:44:18 +0000979 testcase( nByte<0 );
drh9de4a172014-08-23 18:17:19 +0000980 if( (p->pMem->flags & MEM_Agg)==0 ){
981 return createAggContext(p, nByte);
982 }else{
983 return (void*)p->pMem->z;
drheb2e1762004-05-27 01:53:56 +0000984 }
drheb2e1762004-05-27 01:53:56 +0000985}
986
987/*
peter.d.reid60ec9142014-09-06 16:39:46 +0000988** Return the auxiliary data pointer, if any, for the iArg'th argument to
danielk1977682f68b2004-06-05 10:22:17 +0000989** the user-function defined by pCtx.
drhf7fa4e72017-05-11 15:20:18 +0000990**
991** The left-most argument is 0.
992**
993** Undocumented behavior: If iArg is negative then access a cache of
994** auxiliary data pointers that is available to all functions within a
995** single prepared statement. The iArg values must match.
danielk1977682f68b2004-06-05 10:22:17 +0000996*/
997void *sqlite3_get_auxdata(sqlite3_context *pCtx, int iArg){
dan0c547792013-07-18 17:12:08 +0000998 AuxData *pAuxData;
drhb21c8cd2007-08-21 19:33:56 +0000999
drh9bd038f2014-08-27 14:14:06 +00001000 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh175b8f02019-08-08 15:24:17 +00001001#if SQLITE_ENABLE_STAT4
dan18bf8072015-03-11 20:06:40 +00001002 if( pCtx->pVdbe==0 ) return 0;
drha9e03b12015-03-12 06:46:52 +00001003#else
1004 assert( pCtx->pVdbe!=0 );
1005#endif
drhe6941392017-05-10 19:42:52 +00001006 for(pAuxData=pCtx->pVdbe->pAuxData; pAuxData; pAuxData=pAuxData->pNextAux){
drhf7fa4e72017-05-11 15:20:18 +00001007 if( pAuxData->iAuxArg==iArg && (pAuxData->iAuxOp==pCtx->iOp || iArg<0) ){
drhe6941392017-05-10 19:42:52 +00001008 return pAuxData->pAux;
1009 }
danielk1977682f68b2004-06-05 10:22:17 +00001010 }
drhe6941392017-05-10 19:42:52 +00001011 return 0;
danielk1977682f68b2004-06-05 10:22:17 +00001012}
1013
1014/*
peter.d.reid60ec9142014-09-06 16:39:46 +00001015** Set the auxiliary data pointer and delete function, for the iArg'th
danielk1977682f68b2004-06-05 10:22:17 +00001016** argument to the user-function defined by pCtx. Any previous value is
1017** deleted by calling the delete function specified when it was set.
drhf7fa4e72017-05-11 15:20:18 +00001018**
1019** The left-most argument is 0.
1020**
1021** Undocumented behavior: If iArg is negative then make the data available
1022** to all functions within the current prepared statement using iArg as an
1023** access code.
danielk1977682f68b2004-06-05 10:22:17 +00001024*/
1025void sqlite3_set_auxdata(
1026 sqlite3_context *pCtx,
1027 int iArg,
1028 void *pAux,
1029 void (*xDelete)(void*)
1030){
dan0c547792013-07-18 17:12:08 +00001031 AuxData *pAuxData;
1032 Vdbe *pVdbe = pCtx->pVdbe;
danielk1977682f68b2004-06-05 10:22:17 +00001033
drh9bd038f2014-08-27 14:14:06 +00001034 assert( sqlite3_mutex_held(pCtx->pOut->db->mutex) );
drh175b8f02019-08-08 15:24:17 +00001035#ifdef SQLITE_ENABLE_STAT4
dan18bf8072015-03-11 20:06:40 +00001036 if( pVdbe==0 ) goto failed;
drha9e03b12015-03-12 06:46:52 +00001037#else
1038 assert( pVdbe!=0 );
1039#endif
danielk1977682f68b2004-06-05 10:22:17 +00001040
drhe6941392017-05-10 19:42:52 +00001041 for(pAuxData=pVdbe->pAuxData; pAuxData; pAuxData=pAuxData->pNextAux){
drhf7fa4e72017-05-11 15:20:18 +00001042 if( pAuxData->iAuxArg==iArg && (pAuxData->iAuxOp==pCtx->iOp || iArg<0) ){
1043 break;
1044 }
dan0c547792013-07-18 17:12:08 +00001045 }
1046 if( pAuxData==0 ){
1047 pAuxData = sqlite3DbMallocZero(pVdbe->db, sizeof(AuxData));
1048 if( !pAuxData ) goto failed;
drhe6941392017-05-10 19:42:52 +00001049 pAuxData->iAuxOp = pCtx->iOp;
1050 pAuxData->iAuxArg = iArg;
1051 pAuxData->pNextAux = pVdbe->pAuxData;
dan0c547792013-07-18 17:12:08 +00001052 pVdbe->pAuxData = pAuxData;
drhf09ac0b2018-01-23 03:44:06 +00001053 if( pCtx->isError==0 ) pCtx->isError = -1;
drhe6941392017-05-10 19:42:52 +00001054 }else if( pAuxData->xDeleteAux ){
1055 pAuxData->xDeleteAux(pAuxData->pAux);
danielk1977682f68b2004-06-05 10:22:17 +00001056 }
dan0c547792013-07-18 17:12:08 +00001057
danielk1977682f68b2004-06-05 10:22:17 +00001058 pAuxData->pAux = pAux;
drhe6941392017-05-10 19:42:52 +00001059 pAuxData->xDeleteAux = xDelete;
danielk1977e0fc5262007-07-26 06:50:05 +00001060 return;
1061
1062failed:
1063 if( xDelete ){
1064 xDelete(pAux);
1065 }
danielk1977682f68b2004-06-05 10:22:17 +00001066}
1067
shaneeec556d2008-10-12 00:27:53 +00001068#ifndef SQLITE_OMIT_DEPRECATED
danielk1977682f68b2004-06-05 10:22:17 +00001069/*
peter.d.reid60ec9142014-09-06 16:39:46 +00001070** Return the number of times the Step function of an aggregate has been
drheb2e1762004-05-27 01:53:56 +00001071** called.
1072**
drhcf85a512006-02-09 18:35:29 +00001073** This function is deprecated. Do not use it for new code. It is
1074** provide only to avoid breaking legacy code. New aggregate function
1075** implementations should keep their own counts within their aggregate
1076** context.
drheb2e1762004-05-27 01:53:56 +00001077*/
1078int sqlite3_aggregate_count(sqlite3_context *p){
drh2d801512016-01-14 22:19:58 +00001079 assert( p && p->pMem && p->pFunc && p->pFunc->xFinalize );
drhabfcea22005-09-06 20:36:48 +00001080 return p->pMem->n;
drheb2e1762004-05-27 01:53:56 +00001081}
shaneeec556d2008-10-12 00:27:53 +00001082#endif
drheb2e1762004-05-27 01:53:56 +00001083
1084/*
drh4f26d6c2004-05-26 23:25:30 +00001085** Return the number of columns in the result set for the statement pStmt.
1086*/
1087int sqlite3_column_count(sqlite3_stmt *pStmt){
1088 Vdbe *pVm = (Vdbe *)pStmt;
drh1bcdb0c2004-08-28 14:49:46 +00001089 return pVm ? pVm->nResColumn : 0;
drh4f26d6c2004-05-26 23:25:30 +00001090}
1091
1092/*
1093** Return the number of values available from the current row of the
1094** currently executing statement pStmt.
1095*/
1096int sqlite3_data_count(sqlite3_stmt *pStmt){
1097 Vdbe *pVm = (Vdbe *)pStmt;
drhd4e70eb2008-01-02 00:34:36 +00001098 if( pVm==0 || pVm->pResultSet==0 ) return 0;
drh4f26d6c2004-05-26 23:25:30 +00001099 return pVm->nResColumn;
1100}
1101
dan46c47d42011-03-01 18:42:07 +00001102/*
1103** Return a pointer to static memory containing an SQL NULL value.
1104*/
1105static const Mem *columnNullValue(void){
1106 /* Even though the Mem structure contains an element
drhb1a1c292014-03-05 12:47:55 +00001107 ** of type i64, on certain architectures (x86) with certain compiler
dan46c47d42011-03-01 18:42:07 +00001108 ** switches (-Os), gcc may align this Mem object on a 4-byte boundary
1109 ** instead of an 8-byte one. This all works fine, except that when
1110 ** running with SQLITE_DEBUG defined the SQLite code sometimes assert()s
1111 ** that a Mem structure is located on an 8-byte boundary. To prevent
drhb1a1c292014-03-05 12:47:55 +00001112 ** these assert()s from failing, when building with SQLITE_DEBUG defined
1113 ** using gcc, we force nullMem to be 8-byte aligned using the magical
dan46c47d42011-03-01 18:42:07 +00001114 ** __attribute__((aligned(8))) macro. */
1115 static const Mem nullMem
1116#if defined(SQLITE_DEBUG) && defined(__GNUC__)
drhb1a1c292014-03-05 12:47:55 +00001117 __attribute__((aligned(8)))
dan46c47d42011-03-01 18:42:07 +00001118#endif
drh035e5632014-09-16 14:16:31 +00001119 = {
drh3329a632014-09-18 01:21:43 +00001120 /* .u = */ {0},
drhc9373e82022-02-28 03:25:13 +00001121 /* .z = */ (char*)0,
1122 /* .n = */ (int)0,
drh8faee872015-09-19 18:08:13 +00001123 /* .flags = */ (u16)MEM_Null,
1124 /* .enc = */ (u8)0,
1125 /* .eSubtype = */ (u8)0,
drhc9373e82022-02-28 03:25:13 +00001126 /* .db = */ (sqlite3*)0,
drh8faee872015-09-19 18:08:13 +00001127 /* .szMalloc = */ (int)0,
1128 /* .uTemp = */ (u32)0,
drhc9373e82022-02-28 03:25:13 +00001129 /* .zMalloc = */ (char*)0,
drh8faee872015-09-19 18:08:13 +00001130 /* .xDel = */ (void(*)(void*))0,
drhb1a1c292014-03-05 12:47:55 +00001131#ifdef SQLITE_DEBUG
drh8faee872015-09-19 18:08:13 +00001132 /* .pScopyFrom = */ (Mem*)0,
drh58773a52018-06-12 13:52:23 +00001133 /* .mScopyFlags= */ 0,
1134#endif
drh035e5632014-09-16 14:16:31 +00001135 };
dan46c47d42011-03-01 18:42:07 +00001136 return &nullMem;
1137}
drh4f26d6c2004-05-26 23:25:30 +00001138
1139/*
1140** Check to see if column iCol of the given statement is valid. If
1141** it is, return a pointer to the Mem for the value of that column.
1142** If iCol is not valid, return a pointer to a Mem which has a value
1143** of NULL.
1144*/
1145static Mem *columnMem(sqlite3_stmt *pStmt, int i){
drh32bc3f62007-08-21 20:25:39 +00001146 Vdbe *pVm;
drh32bc3f62007-08-21 20:25:39 +00001147 Mem *pOut;
1148
1149 pVm = (Vdbe *)pStmt;
drh28f17012016-09-22 21:37:18 +00001150 if( pVm==0 ) return (Mem*)columnNullValue();
1151 assert( pVm->db );
1152 sqlite3_mutex_enter(pVm->db->mutex);
1153 if( pVm->pResultSet!=0 && i<pVm->nResColumn && i>=0 ){
drhd4e70eb2008-01-02 00:34:36 +00001154 pOut = &pVm->pResultSet[i];
drh32bc3f62007-08-21 20:25:39 +00001155 }else{
drh28f17012016-09-22 21:37:18 +00001156 sqlite3Error(pVm->db, SQLITE_RANGE);
dan46c47d42011-03-01 18:42:07 +00001157 pOut = (Mem*)columnNullValue();
drh4f26d6c2004-05-26 23:25:30 +00001158 }
drh32bc3f62007-08-21 20:25:39 +00001159 return pOut;
drh4f26d6c2004-05-26 23:25:30 +00001160}
1161
danielk19772e588c72005-12-09 14:25:08 +00001162/*
1163** This function is called after invoking an sqlite3_value_XXX function on a
1164** column value (i.e. a value returned by evaluating an SQL expression in the
1165** select list of a SELECT statement) that may cause a malloc() failure. If
1166** malloc() has failed, the threads mallocFailed flag is cleared and the result
1167** code of statement pStmt set to SQLITE_NOMEM.
1168**
drh32bc3f62007-08-21 20:25:39 +00001169** Specifically, this is called from within:
danielk19772e588c72005-12-09 14:25:08 +00001170**
1171** sqlite3_column_int()
1172** sqlite3_column_int64()
1173** sqlite3_column_text()
1174** sqlite3_column_text16()
1175** sqlite3_column_real()
1176** sqlite3_column_bytes()
1177** sqlite3_column_bytes16()
drh42262532010-09-08 16:30:36 +00001178** sqiite3_column_blob()
danielk19772e588c72005-12-09 14:25:08 +00001179*/
1180static void columnMallocFailure(sqlite3_stmt *pStmt)
1181{
1182 /* If malloc() failed during an encoding conversion within an
1183 ** sqlite3_column_XXX API, then set the return code of the statement to
1184 ** SQLITE_NOMEM. The next call to _step() (if any) will return SQLITE_ERROR
1185 ** and _finalize() will return NOMEM.
1186 */
danielk197754f01982006-01-18 15:25:17 +00001187 Vdbe *p = (Vdbe *)pStmt;
drh32bc3f62007-08-21 20:25:39 +00001188 if( p ){
drh28f17012016-09-22 21:37:18 +00001189 assert( p->db!=0 );
1190 assert( sqlite3_mutex_held(p->db->mutex) );
drh32bc3f62007-08-21 20:25:39 +00001191 p->rc = sqlite3ApiExit(p->db, p->rc);
1192 sqlite3_mutex_leave(p->db->mutex);
1193 }
danielk19772e588c72005-12-09 14:25:08 +00001194}
1195
drh4f26d6c2004-05-26 23:25:30 +00001196/**************************** sqlite3_column_ *******************************
1197** The following routines are used to access elements of the current row
1198** in the result set.
1199*/
danielk1977c572ef72004-05-27 09:28:41 +00001200const void *sqlite3_column_blob(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001201 const void *val;
danielk19772e588c72005-12-09 14:25:08 +00001202 val = sqlite3_value_blob( columnMem(pStmt,i) );
danielk1977c9cf9012007-05-30 10:36:47 +00001203 /* Even though there is no encoding conversion, value_blob() might
1204 ** need to call malloc() to expand the result of a zeroblob()
1205 ** expression.
1206 */
1207 columnMallocFailure(pStmt);
danielk19772e588c72005-12-09 14:25:08 +00001208 return val;
danielk1977c572ef72004-05-27 09:28:41 +00001209}
drh4f26d6c2004-05-26 23:25:30 +00001210int sqlite3_column_bytes(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001211 int val = sqlite3_value_bytes( columnMem(pStmt,i) );
1212 columnMallocFailure(pStmt);
1213 return val;
drh4f26d6c2004-05-26 23:25:30 +00001214}
1215int sqlite3_column_bytes16(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001216 int val = sqlite3_value_bytes16( columnMem(pStmt,i) );
1217 columnMallocFailure(pStmt);
1218 return val;
drh4f26d6c2004-05-26 23:25:30 +00001219}
1220double sqlite3_column_double(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001221 double val = sqlite3_value_double( columnMem(pStmt,i) );
1222 columnMallocFailure(pStmt);
1223 return val;
drh4f26d6c2004-05-26 23:25:30 +00001224}
1225int sqlite3_column_int(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001226 int val = sqlite3_value_int( columnMem(pStmt,i) );
1227 columnMallocFailure(pStmt);
1228 return val;
drh4f26d6c2004-05-26 23:25:30 +00001229}
drhefad9992004-06-22 12:13:55 +00001230sqlite_int64 sqlite3_column_int64(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001231 sqlite_int64 val = sqlite3_value_int64( columnMem(pStmt,i) );
1232 columnMallocFailure(pStmt);
1233 return val;
drh4f26d6c2004-05-26 23:25:30 +00001234}
1235const unsigned char *sqlite3_column_text(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001236 const unsigned char *val = sqlite3_value_text( columnMem(pStmt,i) );
1237 columnMallocFailure(pStmt);
1238 return val;
drh4f26d6c2004-05-26 23:25:30 +00001239}
drhd1e47332005-06-26 17:55:33 +00001240sqlite3_value *sqlite3_column_value(sqlite3_stmt *pStmt, int i){
danielk1977d0ffa1e2008-10-13 10:37:49 +00001241 Mem *pOut = columnMem(pStmt, i);
1242 if( pOut->flags&MEM_Static ){
1243 pOut->flags &= ~MEM_Static;
1244 pOut->flags |= MEM_Ephem;
1245 }
drh32bc3f62007-08-21 20:25:39 +00001246 columnMallocFailure(pStmt);
danielk1977d0ffa1e2008-10-13 10:37:49 +00001247 return (sqlite3_value *)pOut;
drhd1e47332005-06-26 17:55:33 +00001248}
drh6c626082004-11-14 21:56:29 +00001249#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +00001250const void *sqlite3_column_text16(sqlite3_stmt *pStmt, int i){
danielk19772e588c72005-12-09 14:25:08 +00001251 const void *val = sqlite3_value_text16( columnMem(pStmt,i) );
1252 columnMallocFailure(pStmt);
1253 return val;
drh4f26d6c2004-05-26 23:25:30 +00001254}
drh6c626082004-11-14 21:56:29 +00001255#endif /* SQLITE_OMIT_UTF16 */
drh4f26d6c2004-05-26 23:25:30 +00001256int sqlite3_column_type(sqlite3_stmt *pStmt, int i){
drh32bc3f62007-08-21 20:25:39 +00001257 int iType = sqlite3_value_type( columnMem(pStmt,i) );
1258 columnMallocFailure(pStmt);
1259 return iType;
drh4f26d6c2004-05-26 23:25:30 +00001260}
1261
drh5e2517e2004-09-24 23:59:12 +00001262/*
1263** Convert the N-th element of pStmt->pColName[] into a string using
1264** xFunc() then return that string. If N is out of range, return 0.
drhe590fbd2005-05-20 19:36:01 +00001265**
1266** There are up to 5 names for each column. useType determines which
1267** name is returned. Here are the names:
1268**
1269** 0 The column name as it should be displayed for output
1270** 1 The datatype name for the column
1271** 2 The name of the database that the column derives from
1272** 3 The name of the table that the column derives from
1273** 4 The name of the table column that the result column derives from
1274**
1275** If the result is not a simple column reference (if it is an expression
1276** or a constant) then useTypes 2, 3, and 4 return NULL.
drh5e2517e2004-09-24 23:59:12 +00001277*/
1278static const void *columnName(
drh8cf92892019-02-20 18:13:57 +00001279 sqlite3_stmt *pStmt, /* The statement */
1280 int N, /* Which column to get the name for */
1281 int useUtf16, /* True to return the name as UTF16 */
1282 int useType /* What type of name */
drh5e2517e2004-09-24 23:59:12 +00001283){
drh9ca95732014-10-24 00:35:58 +00001284 const void *ret;
1285 Vdbe *p;
drh32bc3f62007-08-21 20:25:39 +00001286 int n;
drh9ca95732014-10-24 00:35:58 +00001287 sqlite3 *db;
1288#ifdef SQLITE_ENABLE_API_ARMOR
1289 if( pStmt==0 ){
1290 (void)SQLITE_MISUSE_BKPT;
1291 return 0;
1292 }
1293#endif
1294 ret = 0;
1295 p = (Vdbe *)pStmt;
1296 db = p->db;
drh9b4ea4a2009-04-10 20:32:00 +00001297 assert( db!=0 );
1298 n = sqlite3_column_count(pStmt);
1299 if( N<n && N>=0 ){
1300 N += useType*n;
1301 sqlite3_mutex_enter(db->mutex);
1302 assert( db->mallocFailed==0 );
dan4474e862019-03-04 07:15:57 +00001303#ifndef SQLITE_OMIT_UTF16
drh8cf92892019-02-20 18:13:57 +00001304 if( useUtf16 ){
1305 ret = sqlite3_value_text16((sqlite3_value*)&p->aColName[N]);
dan4474e862019-03-04 07:15:57 +00001306 }else
1307#endif
1308 {
drh8cf92892019-02-20 18:13:57 +00001309 ret = sqlite3_value_text((sqlite3_value*)&p->aColName[N]);
1310 }
1311 /* A malloc may have failed inside of the _text() call. If this
drh9b4ea4a2009-04-10 20:32:00 +00001312 ** is the case, clear the mallocFailed flag and return NULL.
1313 */
1314 if( db->mallocFailed ){
drh4a642b62016-02-05 01:55:27 +00001315 sqlite3OomClear(db);
drh9b4ea4a2009-04-10 20:32:00 +00001316 ret = 0;
drh32bc3f62007-08-21 20:25:39 +00001317 }
drh9b4ea4a2009-04-10 20:32:00 +00001318 sqlite3_mutex_leave(db->mutex);
drh5e2517e2004-09-24 23:59:12 +00001319 }
danielk197700fd9572005-12-07 06:27:43 +00001320 return ret;
drh5e2517e2004-09-24 23:59:12 +00001321}
1322
drh4f26d6c2004-05-26 23:25:30 +00001323/*
1324** Return the name of the Nth column of the result set returned by SQL
1325** statement pStmt.
1326*/
1327const char *sqlite3_column_name(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001328 return columnName(pStmt, N, 0, COLNAME_NAME);
drh4f26d6c2004-05-26 23:25:30 +00001329}
drhe590fbd2005-05-20 19:36:01 +00001330#ifndef SQLITE_OMIT_UTF16
1331const void *sqlite3_column_name16(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001332 return columnName(pStmt, N, 1, COLNAME_NAME);
drhe590fbd2005-05-20 19:36:01 +00001333}
1334#endif
drh4f26d6c2004-05-26 23:25:30 +00001335
1336/*
drh3f913572008-03-22 01:07:17 +00001337** Constraint: If you have ENABLE_COLUMN_METADATA then you must
1338** not define OMIT_DECLTYPE.
1339*/
1340#if defined(SQLITE_OMIT_DECLTYPE) && defined(SQLITE_ENABLE_COLUMN_METADATA)
1341# error "Must not define both SQLITE_OMIT_DECLTYPE \
1342 and SQLITE_ENABLE_COLUMN_METADATA"
1343#endif
1344
1345#ifndef SQLITE_OMIT_DECLTYPE
1346/*
drh6c626082004-11-14 21:56:29 +00001347** Return the column declaration type (if applicable) of the 'i'th column
drhe590fbd2005-05-20 19:36:01 +00001348** of the result set of SQL statement pStmt.
drh6c626082004-11-14 21:56:29 +00001349*/
1350const char *sqlite3_column_decltype(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001351 return columnName(pStmt, N, 0, COLNAME_DECLTYPE);
drh6c626082004-11-14 21:56:29 +00001352}
drh6c626082004-11-14 21:56:29 +00001353#ifndef SQLITE_OMIT_UTF16
danielk197776d505b2004-05-28 13:13:02 +00001354const void *sqlite3_column_decltype16(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001355 return columnName(pStmt, N, 1, COLNAME_DECLTYPE);
drh4f26d6c2004-05-26 23:25:30 +00001356}
drh6c626082004-11-14 21:56:29 +00001357#endif /* SQLITE_OMIT_UTF16 */
drh3f913572008-03-22 01:07:17 +00001358#endif /* SQLITE_OMIT_DECLTYPE */
drh4f26d6c2004-05-26 23:25:30 +00001359
danielk19774b1ae992006-02-10 03:06:10 +00001360#ifdef SQLITE_ENABLE_COLUMN_METADATA
drhe590fbd2005-05-20 19:36:01 +00001361/*
1362** Return the name of the database from which a result column derives.
1363** NULL is returned if the result column is an expression or constant or
peter.d.reid60ec9142014-09-06 16:39:46 +00001364** anything else which is not an unambiguous reference to a database column.
drhe590fbd2005-05-20 19:36:01 +00001365*/
1366const char *sqlite3_column_database_name(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001367 return columnName(pStmt, N, 0, COLNAME_DATABASE);
drhe590fbd2005-05-20 19:36:01 +00001368}
1369#ifndef SQLITE_OMIT_UTF16
1370const void *sqlite3_column_database_name16(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001371 return columnName(pStmt, N, 1, COLNAME_DATABASE);
drhe590fbd2005-05-20 19:36:01 +00001372}
1373#endif /* SQLITE_OMIT_UTF16 */
1374
1375/*
1376** Return the name of the table from which a result column derives.
1377** NULL is returned if the result column is an expression or constant or
peter.d.reid60ec9142014-09-06 16:39:46 +00001378** anything else which is not an unambiguous reference to a database column.
drhe590fbd2005-05-20 19:36:01 +00001379*/
1380const char *sqlite3_column_table_name(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001381 return columnName(pStmt, N, 0, COLNAME_TABLE);
drhe590fbd2005-05-20 19:36:01 +00001382}
1383#ifndef SQLITE_OMIT_UTF16
1384const void *sqlite3_column_table_name16(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001385 return columnName(pStmt, N, 1, COLNAME_TABLE);
drhe590fbd2005-05-20 19:36:01 +00001386}
1387#endif /* SQLITE_OMIT_UTF16 */
1388
1389/*
1390** Return the name of the table column from which a result column derives.
1391** NULL is returned if the result column is an expression or constant or
peter.d.reid60ec9142014-09-06 16:39:46 +00001392** anything else which is not an unambiguous reference to a database column.
drhe590fbd2005-05-20 19:36:01 +00001393*/
1394const char *sqlite3_column_origin_name(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001395 return columnName(pStmt, N, 0, COLNAME_COLUMN);
drhe590fbd2005-05-20 19:36:01 +00001396}
1397#ifndef SQLITE_OMIT_UTF16
1398const void *sqlite3_column_origin_name16(sqlite3_stmt *pStmt, int N){
drh8cf92892019-02-20 18:13:57 +00001399 return columnName(pStmt, N, 1, COLNAME_COLUMN);
drhe590fbd2005-05-20 19:36:01 +00001400}
1401#endif /* SQLITE_OMIT_UTF16 */
danielk19774b1ae992006-02-10 03:06:10 +00001402#endif /* SQLITE_ENABLE_COLUMN_METADATA */
drhe590fbd2005-05-20 19:36:01 +00001403
1404
drh4f26d6c2004-05-26 23:25:30 +00001405/******************************* sqlite3_bind_ ***************************
1406**
1407** Routines used to attach values to wildcards in a compiled SQL statement.
1408*/
1409/*
1410** Unbind the value bound to variable i in virtual machine p. This is the
1411** the same as binding a NULL value to the column. If the "i" parameter is
1412** out of range, then SQLITE_RANGE is returned. Othewise SQLITE_OK.
1413**
drh488e7b62008-10-06 12:46:43 +00001414** A successful evaluation of this routine acquires the mutex on p.
1415** the mutex is released if any kind of error occurs.
1416**
drh4f26d6c2004-05-26 23:25:30 +00001417** The error code stored in database p->db is overwritten with the return
1418** value in any case.
1419*/
1420static int vdbeUnbind(Vdbe *p, int i){
1421 Mem *pVar;
drh413c3d32010-02-23 20:11:56 +00001422 if( vdbeSafetyNotNull(p) ){
1423 return SQLITE_MISUSE_BKPT;
1424 }
drh488e7b62008-10-06 12:46:43 +00001425 sqlite3_mutex_enter(p->db->mutex);
drh17b74812021-02-03 18:32:25 +00001426 if( p->iVdbeMagic!=VDBE_MAGIC_RUN || p->pc>=0 ){
drh13f40da2014-08-22 18:00:11 +00001427 sqlite3Error(p->db, SQLITE_MISUSE);
drh488e7b62008-10-06 12:46:43 +00001428 sqlite3_mutex_leave(p->db->mutex);
drh413c3d32010-02-23 20:11:56 +00001429 sqlite3_log(SQLITE_MISUSE,
1430 "bind on a busy prepared statement: [%s]", p->zSql);
1431 return SQLITE_MISUSE_BKPT;
drh4f26d6c2004-05-26 23:25:30 +00001432 }
1433 if( i<1 || i>p->nVar ){
drh13f40da2014-08-22 18:00:11 +00001434 sqlite3Error(p->db, SQLITE_RANGE);
drh488e7b62008-10-06 12:46:43 +00001435 sqlite3_mutex_leave(p->db->mutex);
drh4f26d6c2004-05-26 23:25:30 +00001436 return SQLITE_RANGE;
1437 }
1438 i--;
drh290c1942004-08-21 17:54:45 +00001439 pVar = &p->aVar[i];
danielk1977d8123362004-06-12 09:25:12 +00001440 sqlite3VdbeMemRelease(pVar);
drh4f26d6c2004-05-26 23:25:30 +00001441 pVar->flags = MEM_Null;
drh368bfe82018-12-11 12:20:41 +00001442 p->db->errCode = SQLITE_OK;
dan937d0de2009-10-15 18:35:38 +00001443
dan1d2ce4f2009-10-19 18:11:09 +00001444 /* If the bit corresponding to this variable in Vdbe.expmask is set, then
1445 ** binding a new value to this variable invalidates the current query plan.
drha7044002010-09-14 18:22:59 +00001446 **
drhbbf6d432020-05-15 15:03:51 +00001447 ** IMPLEMENTATION-OF: R-57496-20354 If the specific value bound to a host
drha7044002010-09-14 18:22:59 +00001448 ** parameter in the WHERE clause might influence the choice of query plan
1449 ** for a statement, then the statement will be automatically recompiled,
1450 ** as if there had been a schema change, on the first sqlite3_step() call
1451 ** following any change to the bindings of that parameter.
dan1d2ce4f2009-10-19 18:11:09 +00001452 */
drh2c2f3922017-06-01 00:54:35 +00001453 assert( (p->prepFlags & SQLITE_PREPARE_SAVESQL)!=0 || p->expmask==0 );
drh29967962017-03-03 21:51:40 +00001454 if( p->expmask!=0 && (p->expmask & (i>=31 ? 0x80000000 : (u32)1<<i))!=0 ){
dan937d0de2009-10-15 18:35:38 +00001455 p->expired = 1;
1456 }
drh4f26d6c2004-05-26 23:25:30 +00001457 return SQLITE_OK;
1458}
1459
1460/*
drh5e2517e2004-09-24 23:59:12 +00001461** Bind a text or BLOB value.
drh4f26d6c2004-05-26 23:25:30 +00001462*/
drh5e2517e2004-09-24 23:59:12 +00001463static int bindText(
drh605264d2007-08-21 15:13:19 +00001464 sqlite3_stmt *pStmt, /* The statement to bind against */
1465 int i, /* Index of the parameter to bind */
1466 const void *zData, /* Pointer to the data to be bound */
drhd6228552021-06-09 14:45:02 +00001467 i64 nData, /* Number of bytes of data to be bound */
drh605264d2007-08-21 15:13:19 +00001468 void (*xDel)(void*), /* Destructor for the data */
drhb27b7f52008-12-10 18:03:45 +00001469 u8 encoding /* Encoding for the data */
drh4f26d6c2004-05-26 23:25:30 +00001470){
1471 Vdbe *p = (Vdbe *)pStmt;
1472 Mem *pVar;
1473 int rc;
1474
1475 rc = vdbeUnbind(p, i);
drh488e7b62008-10-06 12:46:43 +00001476 if( rc==SQLITE_OK ){
1477 if( zData!=0 ){
1478 pVar = &p->aVar[i-1];
1479 rc = sqlite3VdbeMemSetStr(pVar, zData, nData, encoding, xDel);
1480 if( rc==SQLITE_OK && encoding!=0 ){
1481 rc = sqlite3VdbeChangeEncoding(pVar, ENC(p->db));
1482 }
drhe70d01f2017-05-29 22:44:18 +00001483 if( rc ){
1484 sqlite3Error(p->db, rc);
1485 rc = sqlite3ApiExit(p->db, rc);
1486 }
drh27641702007-08-22 02:56:42 +00001487 }
drh488e7b62008-10-06 12:46:43 +00001488 sqlite3_mutex_leave(p->db->mutex);
drh94bb2ba2010-10-14 01:16:32 +00001489 }else if( xDel!=SQLITE_STATIC && xDel!=SQLITE_TRANSIENT ){
drh6fec9ee2010-10-12 02:13:32 +00001490 xDel((void*)zData);
drh4f26d6c2004-05-26 23:25:30 +00001491 }
drh605264d2007-08-21 15:13:19 +00001492 return rc;
drh4f26d6c2004-05-26 23:25:30 +00001493}
drh5e2517e2004-09-24 23:59:12 +00001494
1495
1496/*
1497** Bind a blob value to an SQL statement variable.
1498*/
1499int sqlite3_bind_blob(
1500 sqlite3_stmt *pStmt,
1501 int i,
1502 const void *zData,
1503 int nData,
1504 void (*xDel)(void*)
1505){
drh5b081d82016-02-18 01:29:12 +00001506#ifdef SQLITE_ENABLE_API_ARMOR
1507 if( nData<0 ) return SQLITE_MISUSE_BKPT;
1508#endif
drh5e2517e2004-09-24 23:59:12 +00001509 return bindText(pStmt, i, zData, nData, xDel, 0);
1510}
drhda4ca9d2014-09-09 17:27:35 +00001511int sqlite3_bind_blob64(
1512 sqlite3_stmt *pStmt,
1513 int i,
1514 const void *zData,
1515 sqlite3_uint64 nData,
1516 void (*xDel)(void*)
1517){
drhfc59a952014-09-11 23:34:55 +00001518 assert( xDel!=SQLITE_DYNAMIC );
drhd6228552021-06-09 14:45:02 +00001519 return bindText(pStmt, i, zData, nData, xDel, 0);
drhda4ca9d2014-09-09 17:27:35 +00001520}
drh4f26d6c2004-05-26 23:25:30 +00001521int sqlite3_bind_double(sqlite3_stmt *pStmt, int i, double rValue){
1522 int rc;
1523 Vdbe *p = (Vdbe *)pStmt;
drh4f26d6c2004-05-26 23:25:30 +00001524 rc = vdbeUnbind(p, i);
1525 if( rc==SQLITE_OK ){
drh290c1942004-08-21 17:54:45 +00001526 sqlite3VdbeMemSetDouble(&p->aVar[i-1], rValue);
drh488e7b62008-10-06 12:46:43 +00001527 sqlite3_mutex_leave(p->db->mutex);
drh4f26d6c2004-05-26 23:25:30 +00001528 }
danielk1977f4618892004-06-28 13:09:11 +00001529 return rc;
drh4f26d6c2004-05-26 23:25:30 +00001530}
1531int sqlite3_bind_int(sqlite3_stmt *p, int i, int iValue){
drhefad9992004-06-22 12:13:55 +00001532 return sqlite3_bind_int64(p, i, (i64)iValue);
drh4f26d6c2004-05-26 23:25:30 +00001533}
drhefad9992004-06-22 12:13:55 +00001534int sqlite3_bind_int64(sqlite3_stmt *pStmt, int i, sqlite_int64 iValue){
drh4f26d6c2004-05-26 23:25:30 +00001535 int rc;
1536 Vdbe *p = (Vdbe *)pStmt;
1537 rc = vdbeUnbind(p, i);
1538 if( rc==SQLITE_OK ){
drh290c1942004-08-21 17:54:45 +00001539 sqlite3VdbeMemSetInt64(&p->aVar[i-1], iValue);
drh488e7b62008-10-06 12:46:43 +00001540 sqlite3_mutex_leave(p->db->mutex);
drh4f26d6c2004-05-26 23:25:30 +00001541 }
1542 return rc;
1543}
drh605264d2007-08-21 15:13:19 +00001544int sqlite3_bind_null(sqlite3_stmt *pStmt, int i){
1545 int rc;
1546 Vdbe *p = (Vdbe*)pStmt;
drh605264d2007-08-21 15:13:19 +00001547 rc = vdbeUnbind(p, i);
drh488e7b62008-10-06 12:46:43 +00001548 if( rc==SQLITE_OK ){
1549 sqlite3_mutex_leave(p->db->mutex);
1550 }
drh605264d2007-08-21 15:13:19 +00001551 return rc;
drh4f26d6c2004-05-26 23:25:30 +00001552}
drh22930062017-07-27 03:48:02 +00001553int sqlite3_bind_pointer(
1554 sqlite3_stmt *pStmt,
1555 int i,
1556 void *pPtr,
1557 const char *zPTtype,
1558 void (*xDestructor)(void*)
1559){
drh3a96a5d2017-06-30 23:09:03 +00001560 int rc;
1561 Vdbe *p = (Vdbe*)pStmt;
1562 rc = vdbeUnbind(p, i);
1563 if( rc==SQLITE_OK ){
drh22930062017-07-27 03:48:02 +00001564 sqlite3VdbeMemSetPointer(&p->aVar[i-1], pPtr, zPTtype, xDestructor);
drh3a96a5d2017-06-30 23:09:03 +00001565 sqlite3_mutex_leave(p->db->mutex);
drh34fcf362017-07-27 16:42:36 +00001566 }else if( xDestructor ){
1567 xDestructor(pPtr);
drh3a96a5d2017-06-30 23:09:03 +00001568 }
1569 return rc;
1570}
drh4f26d6c2004-05-26 23:25:30 +00001571int sqlite3_bind_text(
1572 sqlite3_stmt *pStmt,
1573 int i,
1574 const char *zData,
1575 int nData,
danielk1977d8123362004-06-12 09:25:12 +00001576 void (*xDel)(void*)
drh4f26d6c2004-05-26 23:25:30 +00001577){
drh5e2517e2004-09-24 23:59:12 +00001578 return bindText(pStmt, i, zData, nData, xDel, SQLITE_UTF8);
drh4f26d6c2004-05-26 23:25:30 +00001579}
drhbbf483f2014-09-09 20:30:24 +00001580int sqlite3_bind_text64(
drhda4ca9d2014-09-09 17:27:35 +00001581 sqlite3_stmt *pStmt,
1582 int i,
1583 const char *zData,
1584 sqlite3_uint64 nData,
1585 void (*xDel)(void*),
1586 unsigned char enc
1587){
drhfc59a952014-09-11 23:34:55 +00001588 assert( xDel!=SQLITE_DYNAMIC );
drhd6228552021-06-09 14:45:02 +00001589 if( enc==SQLITE_UTF16 ) enc = SQLITE_UTF16NATIVE;
1590 return bindText(pStmt, i, zData, nData, xDel, enc);
drhda4ca9d2014-09-09 17:27:35 +00001591}
drh6c626082004-11-14 21:56:29 +00001592#ifndef SQLITE_OMIT_UTF16
drh4f26d6c2004-05-26 23:25:30 +00001593int sqlite3_bind_text16(
1594 sqlite3_stmt *pStmt,
1595 int i,
1596 const void *zData,
1597 int nData,
danielk1977d8123362004-06-12 09:25:12 +00001598 void (*xDel)(void*)
drh4f26d6c2004-05-26 23:25:30 +00001599){
drh5e2517e2004-09-24 23:59:12 +00001600 return bindText(pStmt, i, zData, nData, xDel, SQLITE_UTF16NATIVE);
drh4f26d6c2004-05-26 23:25:30 +00001601}
drh6c626082004-11-14 21:56:29 +00001602#endif /* SQLITE_OMIT_UTF16 */
danielk197726e41442006-06-14 15:16:35 +00001603int sqlite3_bind_value(sqlite3_stmt *pStmt, int i, const sqlite3_value *pValue){
1604 int rc;
drh1b27b8c2014-02-10 03:21:57 +00001605 switch( sqlite3_value_type((sqlite3_value*)pValue) ){
drh29def562009-04-14 12:43:33 +00001606 case SQLITE_INTEGER: {
1607 rc = sqlite3_bind_int64(pStmt, i, pValue->u.i);
1608 break;
1609 }
1610 case SQLITE_FLOAT: {
dan63a47332022-02-11 16:10:18 +00001611 assert( pValue->flags & (MEM_Real|MEM_IntReal) );
1612 rc = sqlite3_bind_double(pStmt, i,
1613 (pValue->flags & MEM_Real) ? pValue->u.r : (double)pValue->u.i
1614 );
drh29def562009-04-14 12:43:33 +00001615 break;
1616 }
1617 case SQLITE_BLOB: {
1618 if( pValue->flags & MEM_Zero ){
1619 rc = sqlite3_bind_zeroblob(pStmt, i, pValue->u.nZero);
1620 }else{
1621 rc = sqlite3_bind_blob(pStmt, i, pValue->z, pValue->n,SQLITE_TRANSIENT);
1622 }
1623 break;
1624 }
1625 case SQLITE_TEXT: {
drhac80db72009-04-14 12:58:20 +00001626 rc = bindText(pStmt,i, pValue->z, pValue->n, SQLITE_TRANSIENT,
1627 pValue->enc);
1628 break;
1629 }
1630 default: {
1631 rc = sqlite3_bind_null(pStmt, i);
drh29def562009-04-14 12:43:33 +00001632 break;
1633 }
danielk197726e41442006-06-14 15:16:35 +00001634 }
1635 return rc;
1636}
drhb026e052007-05-02 01:34:31 +00001637int sqlite3_bind_zeroblob(sqlite3_stmt *pStmt, int i, int n){
1638 int rc;
1639 Vdbe *p = (Vdbe *)pStmt;
1640 rc = vdbeUnbind(p, i);
1641 if( rc==SQLITE_OK ){
dana32536b2021-11-08 19:35:26 +00001642#ifndef SQLITE_OMIT_INCRBLOB
drhb026e052007-05-02 01:34:31 +00001643 sqlite3VdbeMemSetZeroBlob(&p->aVar[i-1], n);
dana32536b2021-11-08 19:35:26 +00001644#else
1645 rc = sqlite3VdbeMemSetZeroBlob(&p->aVar[i-1], n);
1646#endif
drh488e7b62008-10-06 12:46:43 +00001647 sqlite3_mutex_leave(p->db->mutex);
drhb026e052007-05-02 01:34:31 +00001648 }
1649 return rc;
1650}
dan80c03022015-07-24 17:36:34 +00001651int sqlite3_bind_zeroblob64(sqlite3_stmt *pStmt, int i, sqlite3_uint64 n){
1652 int rc;
1653 Vdbe *p = (Vdbe *)pStmt;
1654 sqlite3_mutex_enter(p->db->mutex);
1655 if( n>(u64)p->db->aLimit[SQLITE_LIMIT_LENGTH] ){
1656 rc = SQLITE_TOOBIG;
1657 }else{
1658 assert( (n & 0x7FFFFFFF)==n );
1659 rc = sqlite3_bind_zeroblob(pStmt, i, n);
1660 }
1661 rc = sqlite3ApiExit(p->db, rc);
1662 sqlite3_mutex_leave(p->db->mutex);
1663 return rc;
1664}
drh75f6a032004-07-15 14:15:00 +00001665
1666/*
1667** Return the number of wildcards that can be potentially bound to.
1668** This routine is added to support DBD::SQLite.
drh75f6a032004-07-15 14:15:00 +00001669*/
1670int sqlite3_bind_parameter_count(sqlite3_stmt *pStmt){
drh92febd92004-08-20 18:34:20 +00001671 Vdbe *p = (Vdbe*)pStmt;
1672 return p ? p->nVar : 0;
drh75f6a032004-07-15 14:15:00 +00001673}
drh895d7472004-08-20 16:02:39 +00001674
1675/*
drhfa6bc002004-09-07 16:19:52 +00001676** Return the name of a wildcard parameter. Return NULL if the index
1677** is out of range or if the wildcard is unnamed.
1678**
1679** The result is always UTF-8.
1680*/
1681const char *sqlite3_bind_parameter_name(sqlite3_stmt *pStmt, int i){
1682 Vdbe *p = (Vdbe*)pStmt;
drh9bf755c2016-12-23 03:59:31 +00001683 if( p==0 ) return 0;
1684 return sqlite3VListNumToName(p->pVList, i);
drh895d7472004-08-20 16:02:39 +00001685}
drhfa6bc002004-09-07 16:19:52 +00001686
1687/*
1688** Given a wildcard parameter name, return the index of the variable
1689** with that name. If there is no variable with the given name,
1690** return 0.
1691*/
drh5f18a222009-11-26 14:01:53 +00001692int sqlite3VdbeParameterIndex(Vdbe *p, const char *zName, int nName){
drh9bf755c2016-12-23 03:59:31 +00001693 if( p==0 || zName==0 ) return 0;
1694 return sqlite3VListNameToNum(p->pVList, zName, nName);
drhfa6bc002004-09-07 16:19:52 +00001695}
drh5f18a222009-11-26 14:01:53 +00001696int sqlite3_bind_parameter_index(sqlite3_stmt *pStmt, const char *zName){
1697 return sqlite3VdbeParameterIndex((Vdbe*)pStmt, zName, sqlite3Strlen30(zName));
1698}
drhf8db1bc2005-04-22 02:38:37 +00001699
drh51942bc2005-06-12 22:01:42 +00001700/*
drhf8db1bc2005-04-22 02:38:37 +00001701** Transfer all bindings from the first statement over to the second.
drhf8db1bc2005-04-22 02:38:37 +00001702*/
shane145834a2008-09-04 12:03:42 +00001703int sqlite3TransferBindings(sqlite3_stmt *pFromStmt, sqlite3_stmt *pToStmt){
drhf8db1bc2005-04-22 02:38:37 +00001704 Vdbe *pFrom = (Vdbe*)pFromStmt;
1705 Vdbe *pTo = (Vdbe*)pToStmt;
drh0f5ea0b2009-04-09 14:02:44 +00001706 int i;
1707 assert( pTo->db==pFrom->db );
1708 assert( pTo->nVar==pFrom->nVar );
drh27641702007-08-22 02:56:42 +00001709 sqlite3_mutex_enter(pTo->db->mutex);
drh0f5ea0b2009-04-09 14:02:44 +00001710 for(i=0; i<pFrom->nVar; i++){
drh643167f2008-01-22 21:30:53 +00001711 sqlite3VdbeMemMove(&pTo->aVar[i], &pFrom->aVar[i]);
drhf8db1bc2005-04-22 02:38:37 +00001712 }
drh27641702007-08-22 02:56:42 +00001713 sqlite3_mutex_leave(pTo->db->mutex);
drh0f5ea0b2009-04-09 14:02:44 +00001714 return SQLITE_OK;
drhf8db1bc2005-04-22 02:38:37 +00001715}
drh51942bc2005-06-12 22:01:42 +00001716
shaneeec556d2008-10-12 00:27:53 +00001717#ifndef SQLITE_OMIT_DEPRECATED
drh51942bc2005-06-12 22:01:42 +00001718/*
shane145834a2008-09-04 12:03:42 +00001719** Deprecated external interface. Internal/core SQLite code
1720** should call sqlite3TransferBindings.
drh0f5ea0b2009-04-09 14:02:44 +00001721**
peter.d.reid60ec9142014-09-06 16:39:46 +00001722** It is misuse to call this routine with statements from different
drh0f5ea0b2009-04-09 14:02:44 +00001723** database connections. But as this is a deprecated interface, we
1724** will not bother to check for that condition.
1725**
1726** If the two statements contain a different number of bindings, then
1727** an SQLITE_ERROR is returned. Nothing else can go wrong, so otherwise
1728** SQLITE_OK is returned.
shane145834a2008-09-04 12:03:42 +00001729*/
1730int sqlite3_transfer_bindings(sqlite3_stmt *pFromStmt, sqlite3_stmt *pToStmt){
drh0f5ea0b2009-04-09 14:02:44 +00001731 Vdbe *pFrom = (Vdbe*)pFromStmt;
1732 Vdbe *pTo = (Vdbe*)pToStmt;
1733 if( pFrom->nVar!=pTo->nVar ){
1734 return SQLITE_ERROR;
1735 }
drh2c2f3922017-06-01 00:54:35 +00001736 assert( (pTo->prepFlags & SQLITE_PREPARE_SAVESQL)!=0 || pTo->expmask==0 );
danbda4cb82017-02-23 16:30:16 +00001737 if( pTo->expmask ){
danc94b8592009-10-20 07:01:24 +00001738 pTo->expired = 1;
1739 }
drh2c2f3922017-06-01 00:54:35 +00001740 assert( (pFrom->prepFlags & SQLITE_PREPARE_SAVESQL)!=0 || pFrom->expmask==0 );
danbda4cb82017-02-23 16:30:16 +00001741 if( pFrom->expmask ){
danc94b8592009-10-20 07:01:24 +00001742 pFrom->expired = 1;
1743 }
shane145834a2008-09-04 12:03:42 +00001744 return sqlite3TransferBindings(pFromStmt, pToStmt);
1745}
shaneeec556d2008-10-12 00:27:53 +00001746#endif
shane145834a2008-09-04 12:03:42 +00001747
1748/*
drh51942bc2005-06-12 22:01:42 +00001749** Return the sqlite3* database handle to which the prepared statement given
1750** in the argument belongs. This is the same database handle that was
1751** the first argument to the sqlite3_prepare() that was used to create
1752** the statement in the first place.
1753*/
1754sqlite3 *sqlite3_db_handle(sqlite3_stmt *pStmt){
1755 return pStmt ? ((Vdbe*)pStmt)->db : 0;
1756}
drhbb5a9c32008-06-19 02:52:25 +00001757
1758/*
drhf03d9cc2010-11-16 23:10:25 +00001759** Return true if the prepared statement is guaranteed to not modify the
1760** database.
1761*/
1762int sqlite3_stmt_readonly(sqlite3_stmt *pStmt){
1763 return pStmt ? ((Vdbe*)pStmt)->readOnly : 1;
1764}
1765
1766/*
drh39c5c4a2019-03-06 14:53:27 +00001767** Return 1 if the statement is an EXPLAIN and return 2 if the
1768** statement is an EXPLAIN QUERY PLAN
1769*/
1770int sqlite3_stmt_isexplain(sqlite3_stmt *pStmt){
1771 return pStmt ? ((Vdbe*)pStmt)->explain : 0;
1772}
1773
1774/*
drh2fb66932011-11-25 17:21:47 +00001775** Return true if the prepared statement is in need of being reset.
1776*/
1777int sqlite3_stmt_busy(sqlite3_stmt *pStmt){
1778 Vdbe *v = (Vdbe*)pStmt;
drh17b74812021-02-03 18:32:25 +00001779 return v!=0 && v->iVdbeMagic==VDBE_MAGIC_RUN && v->pc>=0;
drh2fb66932011-11-25 17:21:47 +00001780}
1781
1782/*
drhbb5a9c32008-06-19 02:52:25 +00001783** Return a pointer to the next prepared statement after pStmt associated
1784** with database connection pDb. If pStmt is NULL, return the first
1785** prepared statement for the database connection. Return NULL if there
1786** are no more.
1787*/
1788sqlite3_stmt *sqlite3_next_stmt(sqlite3 *pDb, sqlite3_stmt *pStmt){
1789 sqlite3_stmt *pNext;
drh9ca95732014-10-24 00:35:58 +00001790#ifdef SQLITE_ENABLE_API_ARMOR
1791 if( !sqlite3SafetyCheckOk(pDb) ){
1792 (void)SQLITE_MISUSE_BKPT;
1793 return 0;
1794 }
1795#endif
drhbb5a9c32008-06-19 02:52:25 +00001796 sqlite3_mutex_enter(pDb->mutex);
1797 if( pStmt==0 ){
1798 pNext = (sqlite3_stmt*)pDb->pVdbe;
1799 }else{
1800 pNext = (sqlite3_stmt*)((Vdbe*)pStmt)->pNext;
1801 }
1802 sqlite3_mutex_leave(pDb->mutex);
1803 return pNext;
1804}
drhd1d38482008-10-07 23:46:38 +00001805
1806/*
1807** Return the value of a status counter for a prepared statement
1808*/
1809int sqlite3_stmt_status(sqlite3_stmt *pStmt, int op, int resetFlag){
1810 Vdbe *pVdbe = (Vdbe*)pStmt;
drh9ca95732014-10-24 00:35:58 +00001811 u32 v;
1812#ifdef SQLITE_ENABLE_API_ARMOR
dan68cf69e2018-03-14 08:27:39 +00001813 if( !pStmt
1814 || (op!=SQLITE_STMTSTATUS_MEMUSED && (op<0||op>=ArraySize(pVdbe->aCounter)))
1815 ){
drh9ca95732014-10-24 00:35:58 +00001816 (void)SQLITE_MISUSE_BKPT;
1817 return 0;
1818 }
1819#endif
drh3528f6b2017-05-31 16:21:54 +00001820 if( op==SQLITE_STMTSTATUS_MEMUSED ){
1821 sqlite3 *db = pVdbe->db;
1822 sqlite3_mutex_enter(db->mutex);
1823 v = 0;
1824 db->pnBytesFreed = (int*)&v;
1825 sqlite3VdbeClearObject(db, pVdbe);
1826 sqlite3DbFree(db, pVdbe);
1827 db->pnBytesFreed = 0;
1828 sqlite3_mutex_leave(db->mutex);
1829 }else{
1830 v = pVdbe->aCounter[op];
1831 if( resetFlag ) pVdbe->aCounter[op] = 0;
1832 }
drh9b47ee32013-08-20 03:13:51 +00001833 return (int)v;
drhd1d38482008-10-07 23:46:38 +00001834}
dan46c47d42011-03-01 18:42:07 +00001835
drh557341e2016-07-23 02:07:26 +00001836/*
1837** Return the SQL associated with a prepared statement
1838*/
1839const char *sqlite3_sql(sqlite3_stmt *pStmt){
1840 Vdbe *p = (Vdbe *)pStmt;
1841 return p ? p->zSql : 0;
1842}
1843
1844/*
1845** Return the SQL associated with a prepared statement with
1846** bound parameters expanded. Space to hold the returned string is
1847** obtained from sqlite3_malloc(). The caller is responsible for
1848** freeing the returned string by passing it to sqlite3_free().
1849**
1850** The SQLITE_TRACE_SIZE_LIMIT puts an upper bound on the size of
1851** expanded bound parameters.
1852*/
1853char *sqlite3_expanded_sql(sqlite3_stmt *pStmt){
1854#ifdef SQLITE_OMIT_TRACE
1855 return 0;
1856#else
1857 char *z = 0;
1858 const char *zSql = sqlite3_sql(pStmt);
1859 if( zSql ){
1860 Vdbe *p = (Vdbe *)pStmt;
1861 sqlite3_mutex_enter(p->db->mutex);
1862 z = sqlite3VdbeExpandSql(p, zSql);
1863 sqlite3_mutex_leave(p->db->mutex);
1864 }
1865 return z;
1866#endif
1867}
1868
mistachkin8bee11a2018-10-29 17:53:23 +00001869#ifdef SQLITE_ENABLE_NORMALIZE
1870/*
1871** Return the normalized SQL associated with a prepared statement.
1872*/
1873const char *sqlite3_normalized_sql(sqlite3_stmt *pStmt){
1874 Vdbe *p = (Vdbe *)pStmt;
drh707821f2018-12-05 13:39:06 +00001875 if( p==0 ) return 0;
drh1a6c2b12018-12-10 20:01:40 +00001876 if( p->zNormSql==0 && ALWAYS(p->zSql!=0) ){
drh1f169fe2018-12-06 01:08:58 +00001877 sqlite3_mutex_enter(p->db->mutex);
drh1a6c2b12018-12-10 20:01:40 +00001878 p->zNormSql = sqlite3Normalize(p, p->zSql);
drh1f169fe2018-12-06 01:08:58 +00001879 sqlite3_mutex_leave(p->db->mutex);
drh707821f2018-12-05 13:39:06 +00001880 }
1881 return p->zNormSql;
mistachkin8bee11a2018-10-29 17:53:23 +00001882}
1883#endif /* SQLITE_ENABLE_NORMALIZE */
1884
drh9b1c62d2011-03-30 21:04:43 +00001885#ifdef SQLITE_ENABLE_PREUPDATE_HOOK
dan37db03b2011-03-16 19:59:18 +00001886/*
dan93bca692011-09-14 19:41:44 +00001887** Allocate and populate an UnpackedRecord structure based on the serialized
1888** record in nKey/pKey. Return a pointer to the new UnpackedRecord structure
1889** if successful, or a NULL pointer if an OOM error is encountered.
1890*/
1891static UnpackedRecord *vdbeUnpackRecord(
1892 KeyInfo *pKeyInfo,
1893 int nKey,
1894 const void *pKey
1895){
dan93bca692011-09-14 19:41:44 +00001896 UnpackedRecord *pRet; /* Return value */
1897
drha582b012016-12-21 19:45:54 +00001898 pRet = sqlite3VdbeAllocUnpackedRecord(pKeyInfo);
dan93bca692011-09-14 19:41:44 +00001899 if( pRet ){
drha485ad12017-08-02 22:43:14 +00001900 memset(pRet->aMem, 0, sizeof(Mem)*(pKeyInfo->nKeyField+1));
dan93bca692011-09-14 19:41:44 +00001901 sqlite3VdbeRecordUnpack(pKeyInfo, nKey, pKey, pRet);
1902 }
1903 return pRet;
1904}
1905
1906/*
dan37db03b2011-03-16 19:59:18 +00001907** This function is called from within a pre-update callback to retrieve
1908** a field of the row currently being updated or deleted.
1909*/
dan46c47d42011-03-01 18:42:07 +00001910int sqlite3_preupdate_old(sqlite3 *db, int iIdx, sqlite3_value **ppValue){
1911 PreUpdate *p = db->pPreUpdate;
dan7271d7a2017-01-25 18:53:27 +00001912 Mem *pMem;
dan46c47d42011-03-01 18:42:07 +00001913 int rc = SQLITE_OK;
1914
dan37db03b2011-03-16 19:59:18 +00001915 /* Test that this call is being made from within an SQLITE_DELETE or
1916 ** SQLITE_UPDATE pre-update callback, and that iIdx is within range. */
dan46c47d42011-03-01 18:42:07 +00001917 if( !p || p->op==SQLITE_INSERT ){
1918 rc = SQLITE_MISUSE_BKPT;
1919 goto preupdate_old_out;
1920 }
dancb9a3642017-01-30 19:44:53 +00001921 if( p->pPk ){
drhb9bcf7c2019-10-19 13:29:10 +00001922 iIdx = sqlite3TableColumnToIndex(p->pPk, iIdx);
dancb9a3642017-01-30 19:44:53 +00001923 }
dan46c47d42011-03-01 18:42:07 +00001924 if( iIdx>=p->pCsr->nField || iIdx<0 ){
1925 rc = SQLITE_RANGE;
1926 goto preupdate_old_out;
1927 }
1928
dan37db03b2011-03-16 19:59:18 +00001929 /* If the old.* record has not yet been loaded into memory, do so now. */
dan46c47d42011-03-01 18:42:07 +00001930 if( p->pUnpacked==0 ){
dan12ca0b52011-03-21 16:17:42 +00001931 u32 nRec;
1932 u8 *aRec;
dan46c47d42011-03-01 18:42:07 +00001933
drh3ab4ffc2021-11-11 11:23:08 +00001934 assert( p->pCsr->eCurType==CURTYPE_BTREE );
drha7c90c42016-06-04 20:37:10 +00001935 nRec = sqlite3BtreePayloadSize(p->pCsr->uc.pCursor);
dan12ca0b52011-03-21 16:17:42 +00001936 aRec = sqlite3DbMallocRaw(db, nRec);
1937 if( !aRec ) goto preupdate_old_out;
drhcb3cabd2016-11-25 19:18:28 +00001938 rc = sqlite3BtreePayload(p->pCsr->uc.pCursor, 0, nRec, aRec);
dan12ca0b52011-03-21 16:17:42 +00001939 if( rc==SQLITE_OK ){
dan93bca692011-09-14 19:41:44 +00001940 p->pUnpacked = vdbeUnpackRecord(&p->keyinfo, nRec, aRec);
dan12ca0b52011-03-21 16:17:42 +00001941 if( !p->pUnpacked ) rc = SQLITE_NOMEM;
1942 }
dan46c47d42011-03-01 18:42:07 +00001943 if( rc!=SQLITE_OK ){
dan12ca0b52011-03-21 16:17:42 +00001944 sqlite3DbFree(db, aRec);
dan46c47d42011-03-01 18:42:07 +00001945 goto preupdate_old_out;
1946 }
dan12ca0b52011-03-21 16:17:42 +00001947 p->aRecord = aRec;
dan46c47d42011-03-01 18:42:07 +00001948 }
1949
dan7271d7a2017-01-25 18:53:27 +00001950 pMem = *ppValue = &p->pUnpacked->aMem[iIdx];
1951 if( iIdx==p->pTab->iPKey ){
1952 sqlite3VdbeMemSetInt64(pMem, p->iKey1);
1953 }else if( iIdx>=p->pUnpacked->nField ){
dan46c47d42011-03-01 18:42:07 +00001954 *ppValue = (sqlite3_value *)columnNullValue();
dan7271d7a2017-01-25 18:53:27 +00001955 }else if( p->pTab->aCol[iIdx].affinity==SQLITE_AFF_REAL ){
drh169f0772019-05-02 21:36:26 +00001956 if( pMem->flags & (MEM_Int|MEM_IntReal) ){
drh3242c692019-05-04 01:29:13 +00001957 testcase( pMem->flags & MEM_Int );
1958 testcase( pMem->flags & MEM_IntReal );
dan7271d7a2017-01-25 18:53:27 +00001959 sqlite3VdbeMemRealify(pMem);
dan319eeb72011-03-19 08:38:50 +00001960 }
dan46c47d42011-03-01 18:42:07 +00001961 }
1962
1963 preupdate_old_out:
drhe1ed0b02014-08-26 02:15:07 +00001964 sqlite3Error(db, rc);
dan46c47d42011-03-01 18:42:07 +00001965 return sqlite3ApiExit(db, rc);
1966}
drh9b1c62d2011-03-30 21:04:43 +00001967#endif /* SQLITE_ENABLE_PREUPDATE_HOOK */
dan46c47d42011-03-01 18:42:07 +00001968
drh9b1c62d2011-03-30 21:04:43 +00001969#ifdef SQLITE_ENABLE_PREUPDATE_HOOK
dan37db03b2011-03-16 19:59:18 +00001970/*
1971** This function is called from within a pre-update callback to retrieve
1972** the number of columns in the row being updated, deleted or inserted.
1973*/
dan46c47d42011-03-01 18:42:07 +00001974int sqlite3_preupdate_count(sqlite3 *db){
1975 PreUpdate *p = db->pPreUpdate;
drha485ad12017-08-02 22:43:14 +00001976 return (p ? p->keyinfo.nKeyField : 0);
dan46c47d42011-03-01 18:42:07 +00001977}
drh9b1c62d2011-03-30 21:04:43 +00001978#endif /* SQLITE_ENABLE_PREUPDATE_HOOK */
dan46c47d42011-03-01 18:42:07 +00001979
drh9b1c62d2011-03-30 21:04:43 +00001980#ifdef SQLITE_ENABLE_PREUPDATE_HOOK
dan37db03b2011-03-16 19:59:18 +00001981/*
dan1e7a2d42011-03-22 18:45:29 +00001982** This function is designed to be called from within a pre-update callback
1983** only. It returns zero if the change that caused the callback was made
1984** immediately by a user SQL statement. Or, if the change was made by a
1985** trigger program, it returns the number of trigger programs currently
1986** on the stack (1 for a top-level trigger, 2 for a trigger fired by a
1987** top-level trigger etc.).
1988**
1989** For the purposes of the previous paragraph, a foreign key CASCADE, SET NULL
1990** or SET DEFAULT action is considered a trigger.
1991*/
1992int sqlite3_preupdate_depth(sqlite3 *db){
1993 PreUpdate *p = db->pPreUpdate;
1994 return (p ? p->v->nFrame : 0);
1995}
drh9b1c62d2011-03-30 21:04:43 +00001996#endif /* SQLITE_ENABLE_PREUPDATE_HOOK */
dan1e7a2d42011-03-22 18:45:29 +00001997
drh9b1c62d2011-03-30 21:04:43 +00001998#ifdef SQLITE_ENABLE_PREUPDATE_HOOK
dan1e7a2d42011-03-22 18:45:29 +00001999/*
dana23a8732021-04-21 20:52:17 +00002000** This function is designed to be called from within a pre-update callback
2001** only.
2002*/
2003int sqlite3_preupdate_blobwrite(sqlite3 *db){
2004 PreUpdate *p = db->pPreUpdate;
2005 return (p ? p->iBlobWrite : -1);
2006}
2007#endif
2008
2009#ifdef SQLITE_ENABLE_PREUPDATE_HOOK
2010/*
dan37db03b2011-03-16 19:59:18 +00002011** This function is called from within a pre-update callback to retrieve
2012** a field of the row currently being updated or inserted.
2013*/
2014int sqlite3_preupdate_new(sqlite3 *db, int iIdx, sqlite3_value **ppValue){
dan46c47d42011-03-01 18:42:07 +00002015 PreUpdate *p = db->pPreUpdate;
2016 int rc = SQLITE_OK;
dan37db03b2011-03-16 19:59:18 +00002017 Mem *pMem;
dan46c47d42011-03-01 18:42:07 +00002018
dan37db03b2011-03-16 19:59:18 +00002019 if( !p || p->op==SQLITE_DELETE ){
dan46c47d42011-03-01 18:42:07 +00002020 rc = SQLITE_MISUSE_BKPT;
dan37db03b2011-03-16 19:59:18 +00002021 goto preupdate_new_out;
dan46c47d42011-03-01 18:42:07 +00002022 }
dancb9a3642017-01-30 19:44:53 +00002023 if( p->pPk && p->op!=SQLITE_UPDATE ){
drhb9bcf7c2019-10-19 13:29:10 +00002024 iIdx = sqlite3TableColumnToIndex(p->pPk, iIdx);
dancb9a3642017-01-30 19:44:53 +00002025 }
dan46c47d42011-03-01 18:42:07 +00002026 if( iIdx>=p->pCsr->nField || iIdx<0 ){
2027 rc = SQLITE_RANGE;
dan37db03b2011-03-16 19:59:18 +00002028 goto preupdate_new_out;
dan46c47d42011-03-01 18:42:07 +00002029 }
dan46c47d42011-03-01 18:42:07 +00002030
dan37db03b2011-03-16 19:59:18 +00002031 if( p->op==SQLITE_INSERT ){
2032 /* For an INSERT, memory cell p->iNewReg contains the serialized record
2033 ** that is being inserted. Deserialize it. */
2034 UnpackedRecord *pUnpack = p->pNewUnpacked;
2035 if( !pUnpack ){
2036 Mem *pData = &p->v->aMem[p->iNewReg];
drhff535a22016-09-20 01:46:15 +00002037 rc = ExpandBlob(pData);
dan37db03b2011-03-16 19:59:18 +00002038 if( rc!=SQLITE_OK ) goto preupdate_new_out;
dan93bca692011-09-14 19:41:44 +00002039 pUnpack = vdbeUnpackRecord(&p->keyinfo, pData->n, pData->z);
dan37db03b2011-03-16 19:59:18 +00002040 if( !pUnpack ){
2041 rc = SQLITE_NOMEM;
2042 goto preupdate_new_out;
2043 }
2044 p->pNewUnpacked = pUnpack;
2045 }
dan2a86c192017-01-25 17:44:13 +00002046 pMem = &pUnpack->aMem[iIdx];
2047 if( iIdx==p->pTab->iPKey ){
2048 sqlite3VdbeMemSetInt64(pMem, p->iKey2);
2049 }else if( iIdx>=pUnpack->nField ){
dan37db03b2011-03-16 19:59:18 +00002050 pMem = (sqlite3_value *)columnNullValue();
dan37db03b2011-03-16 19:59:18 +00002051 }
2052 }else{
2053 /* For an UPDATE, memory cell (p->iNewReg+1+iIdx) contains the required
2054 ** value. Make a copy of the cell contents and return a pointer to it.
2055 ** It is not safe to return a pointer to the memory cell itself as the
2056 ** caller may modify the value text encoding.
2057 */
2058 assert( p->op==SQLITE_UPDATE );
2059 if( !p->aNew ){
2060 p->aNew = (Mem *)sqlite3DbMallocZero(db, sizeof(Mem) * p->pCsr->nField);
2061 if( !p->aNew ){
2062 rc = SQLITE_NOMEM;
2063 goto preupdate_new_out;
2064 }
2065 }
drh304637c2011-03-18 16:47:27 +00002066 assert( iIdx>=0 && iIdx<p->pCsr->nField );
dan37db03b2011-03-16 19:59:18 +00002067 pMem = &p->aNew[iIdx];
2068 if( pMem->flags==0 ){
dane43635a2016-10-21 21:21:45 +00002069 if( iIdx==p->pTab->iPKey ){
dan319eeb72011-03-19 08:38:50 +00002070 sqlite3VdbeMemSetInt64(pMem, p->iKey2);
2071 }else{
2072 rc = sqlite3VdbeMemCopy(pMem, &p->v->aMem[p->iNewReg+1+iIdx]);
2073 if( rc!=SQLITE_OK ) goto preupdate_new_out;
2074 }
dan37db03b2011-03-16 19:59:18 +00002075 }
2076 }
2077 *ppValue = pMem;
2078
2079 preupdate_new_out:
drhe1ed0b02014-08-26 02:15:07 +00002080 sqlite3Error(db, rc);
dan46c47d42011-03-01 18:42:07 +00002081 return sqlite3ApiExit(db, rc);
2082}
drh9b1c62d2011-03-30 21:04:43 +00002083#endif /* SQLITE_ENABLE_PREUPDATE_HOOK */
drh04e8a582014-11-18 21:20:57 +00002084
dan6f9702e2014-11-01 20:38:06 +00002085#ifdef SQLITE_ENABLE_STMT_SCANSTATUS
dan04489b62014-10-31 20:11:32 +00002086/*
2087** Return status data for a single loop within query pStmt.
2088*/
2089int sqlite3_stmt_scanstatus(
drhd1a1c232014-11-03 16:35:55 +00002090 sqlite3_stmt *pStmt, /* Prepared statement being queried */
dan04489b62014-10-31 20:11:32 +00002091 int idx, /* Index of loop to report on */
drhd1a1c232014-11-03 16:35:55 +00002092 int iScanStatusOp, /* Which metric to return */
2093 void *pOut /* OUT: Write the answer here */
dan04489b62014-10-31 20:11:32 +00002094){
2095 Vdbe *p = (Vdbe*)pStmt;
dan037b5322014-11-03 11:25:32 +00002096 ScanStatus *pScan;
dan6f9702e2014-11-01 20:38:06 +00002097 if( idx<0 || idx>=p->nScan ) return 1;
2098 pScan = &p->aScan[idx];
drhd1a1c232014-11-03 16:35:55 +00002099 switch( iScanStatusOp ){
2100 case SQLITE_SCANSTAT_NLOOP: {
2101 *(sqlite3_int64*)pOut = p->anExec[pScan->addrLoop];
2102 break;
2103 }
2104 case SQLITE_SCANSTAT_NVISIT: {
2105 *(sqlite3_int64*)pOut = p->anExec[pScan->addrVisit];
2106 break;
2107 }
2108 case SQLITE_SCANSTAT_EST: {
drh518140e2014-11-06 03:55:10 +00002109 double r = 1.0;
2110 LogEst x = pScan->nEst;
2111 while( x<100 ){
2112 x += 10;
2113 r *= 0.5;
2114 }
2115 *(double*)pOut = r*sqlite3LogEstToInt(x);
drhd1a1c232014-11-03 16:35:55 +00002116 break;
2117 }
2118 case SQLITE_SCANSTAT_NAME: {
dand72219d2014-11-03 16:39:37 +00002119 *(const char**)pOut = pScan->zName;
drhd1a1c232014-11-03 16:35:55 +00002120 break;
2121 }
2122 case SQLITE_SCANSTAT_EXPLAIN: {
2123 if( pScan->addrExplain ){
2124 *(const char**)pOut = p->aOp[ pScan->addrExplain ].p4.z;
2125 }else{
2126 *(const char**)pOut = 0;
2127 }
2128 break;
2129 }
drhc6652b12014-11-06 04:42:20 +00002130 case SQLITE_SCANSTAT_SELECTID: {
2131 if( pScan->addrExplain ){
2132 *(int*)pOut = p->aOp[ pScan->addrExplain ].p1;
2133 }else{
2134 *(int*)pOut = -1;
2135 }
2136 break;
2137 }
drhd1a1c232014-11-03 16:35:55 +00002138 default: {
2139 return 1;
dan6f9702e2014-11-01 20:38:06 +00002140 }
2141 }
dan04489b62014-10-31 20:11:32 +00002142 return 0;
2143}
2144
2145/*
2146** Zero all counters associated with the sqlite3_stmt_scanstatus() data.
2147*/
2148void sqlite3_stmt_scanstatus_reset(sqlite3_stmt *pStmt){
2149 Vdbe *p = (Vdbe*)pStmt;
dan6f9702e2014-11-01 20:38:06 +00002150 memset(p->anExec, 0, p->nOp * sizeof(i64));
dan04489b62014-10-31 20:11:32 +00002151}
dan6f9702e2014-11-01 20:38:06 +00002152#endif /* SQLITE_ENABLE_STMT_SCANSTATUS */