blob: e40fdad55a8ea113751f252d069f54732189ba65 [file] [log] [blame]
drhdc04c582002-02-24 01:55:15 +00001/*
2** 2002 February 23
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** This file contains the C functions that implement various SQL
13** functions of SQLite.
14**
15** There is only one exported symbol in this file - the function
16** sqliteRegisterBuildinFunctions() found at the bottom of the file.
17** All other code has file scope.
drhdc04c582002-02-24 01:55:15 +000018*/
drhb659e9b2005-01-28 01:29:08 +000019#include "sqliteInt.h"
drhd3a149e2002-02-24 17:12:53 +000020#include <stdlib.h>
drh0bce8352002-02-28 00:41:10 +000021#include <assert.h>
danielk197788208052004-05-25 01:13:20 +000022#include "vdbeInt.h"
drh0bce8352002-02-28 00:41:10 +000023
drh55ef4d92005-08-14 01:20:37 +000024/*
25** Return the collating function associated with a function.
26*/
danielk1977dc1bdc42004-06-11 10:51:27 +000027static CollSeq *sqlite3GetFuncCollSeq(sqlite3_context *context){
28 return context->pColl;
29}
30
drh0bce8352002-02-28 00:41:10 +000031/*
drh7a957892012-02-02 17:35:43 +000032** Indicate that the accumulator load should be skipped on this
33** iteration of the aggregate loop.
34*/
35static void sqlite3SkipAccumulatorLoad(sqlite3_context *context){
36 context->skipFlag = 1;
37}
38
39/*
drh0bce8352002-02-28 00:41:10 +000040** Implementation of the non-aggregate min() and max() functions
41*/
drhf9b596e2004-05-26 16:54:42 +000042static void minmaxFunc(
43 sqlite3_context *context,
44 int argc,
45 sqlite3_value **argv
46){
drh0bce8352002-02-28 00:41:10 +000047 int i;
drh268380c2004-02-25 13:47:31 +000048 int mask; /* 0 for min() or 0xffffffff for max() */
drhf9b596e2004-05-26 16:54:42 +000049 int iBest;
danielk1977dc1bdc42004-06-11 10:51:27 +000050 CollSeq *pColl;
drh0bce8352002-02-28 00:41:10 +000051
drh65595cd2009-02-02 16:32:55 +000052 assert( argc>1 );
drhc44af712004-09-02 15:53:56 +000053 mask = sqlite3_user_data(context)==0 ? 0 : -1;
danielk1977dc1bdc42004-06-11 10:51:27 +000054 pColl = sqlite3GetFuncCollSeq(context);
55 assert( pColl );
danielk1977c572ef72004-05-27 09:28:41 +000056 assert( mask==-1 || mask==0 );
drhf9b596e2004-05-26 16:54:42 +000057 iBest = 0;
drh9c054832004-05-31 18:51:57 +000058 if( sqlite3_value_type(argv[0])==SQLITE_NULL ) return;
drhf9b596e2004-05-26 16:54:42 +000059 for(i=1; i<argc; i++){
drh9c054832004-05-31 18:51:57 +000060 if( sqlite3_value_type(argv[i])==SQLITE_NULL ) return;
danielk1977dc1bdc42004-06-11 10:51:27 +000061 if( (sqlite3MemCompare(argv[iBest], argv[i], pColl)^mask)>=0 ){
drh65595cd2009-02-02 16:32:55 +000062 testcase( mask==0 );
drhf9b596e2004-05-26 16:54:42 +000063 iBest = i;
drh0bce8352002-02-28 00:41:10 +000064 }
65 }
drhf4479502004-05-27 03:12:53 +000066 sqlite3_result_value(context, argv[iBest]);
drh0bce8352002-02-28 00:41:10 +000067}
drh0bce8352002-02-28 00:41:10 +000068
drh268380c2004-02-25 13:47:31 +000069/*
70** Return the type of the argument.
71*/
drhf9b596e2004-05-26 16:54:42 +000072static void typeofFunc(
73 sqlite3_context *context,
danielk197762c14b32008-11-19 09:05:26 +000074 int NotUsed,
drhf9b596e2004-05-26 16:54:42 +000075 sqlite3_value **argv
76){
danielk197735bb9d02004-05-24 12:55:54 +000077 const char *z = 0;
danielk197762c14b32008-11-19 09:05:26 +000078 UNUSED_PARAMETER(NotUsed);
danielk197735bb9d02004-05-24 12:55:54 +000079 switch( sqlite3_value_type(argv[0]) ){
drh9c054832004-05-31 18:51:57 +000080 case SQLITE_INTEGER: z = "integer"; break;
81 case SQLITE_TEXT: z = "text"; break;
82 case SQLITE_FLOAT: z = "real"; break;
83 case SQLITE_BLOB: z = "blob"; break;
drh65595cd2009-02-02 16:32:55 +000084 default: z = "null"; break;
danielk197735bb9d02004-05-24 12:55:54 +000085 }
danielk1977d8123362004-06-12 09:25:12 +000086 sqlite3_result_text(context, z, -1, SQLITE_STATIC);
drh0bce8352002-02-28 00:41:10 +000087}
88
drh5708d2d2005-06-22 10:53:59 +000089
90/*
drh0bce8352002-02-28 00:41:10 +000091** Implementation of the length() function
92*/
drhf9b596e2004-05-26 16:54:42 +000093static void lengthFunc(
94 sqlite3_context *context,
95 int argc,
96 sqlite3_value **argv
97){
drh0bce8352002-02-28 00:41:10 +000098 int len;
99
100 assert( argc==1 );
danielk1977f3d3c272008-11-19 16:52:44 +0000101 UNUSED_PARAMETER(argc);
drhf9b596e2004-05-26 16:54:42 +0000102 switch( sqlite3_value_type(argv[0]) ){
drh9c054832004-05-31 18:51:57 +0000103 case SQLITE_BLOB:
104 case SQLITE_INTEGER:
105 case SQLITE_FLOAT: {
drhf4479502004-05-27 03:12:53 +0000106 sqlite3_result_int(context, sqlite3_value_bytes(argv[0]));
drhf9b596e2004-05-26 16:54:42 +0000107 break;
108 }
drh9c054832004-05-31 18:51:57 +0000109 case SQLITE_TEXT: {
drh2646da72005-12-09 20:02:05 +0000110 const unsigned char *z = sqlite3_value_text(argv[0]);
drh7a521cf2007-04-25 18:23:52 +0000111 if( z==0 ) return;
drh4a919112007-05-15 11:55:09 +0000112 len = 0;
113 while( *z ){
114 len++;
115 SQLITE_SKIP_UTF8(z);
116 }
drhf4479502004-05-27 03:12:53 +0000117 sqlite3_result_int(context, len);
drhf9b596e2004-05-26 16:54:42 +0000118 break;
119 }
120 default: {
121 sqlite3_result_null(context);
122 break;
123 }
124 }
drh0bce8352002-02-28 00:41:10 +0000125}
126
127/*
drh2ba3ccc2009-12-08 02:06:08 +0000128** Implementation of the abs() function.
129**
130** IMP: R-23979-26855 The abs(X) function returns the absolute value of
131** the numeric argument X.
drh0bce8352002-02-28 00:41:10 +0000132*/
danielk19770ae8b832004-05-25 12:05:56 +0000133static void absFunc(sqlite3_context *context, int argc, sqlite3_value **argv){
drh0bce8352002-02-28 00:41:10 +0000134 assert( argc==1 );
danielk1977f3d3c272008-11-19 16:52:44 +0000135 UNUSED_PARAMETER(argc);
drhf9b596e2004-05-26 16:54:42 +0000136 switch( sqlite3_value_type(argv[0]) ){
drh9c054832004-05-31 18:51:57 +0000137 case SQLITE_INTEGER: {
danielk1977f93bbbe2004-05-27 10:30:52 +0000138 i64 iVal = sqlite3_value_int64(argv[0]);
drh52fc8492006-02-23 21:43:55 +0000139 if( iVal<0 ){
140 if( (iVal<<1)==0 ){
drh2ba3ccc2009-12-08 02:06:08 +0000141 /* IMP: R-35460-15084 If X is the integer -9223372036854775807 then
142 ** abs(X) throws an integer overflow error since there is no
143 ** equivalent positive 64-bit two complement value. */
drh52fc8492006-02-23 21:43:55 +0000144 sqlite3_result_error(context, "integer overflow", -1);
145 return;
146 }
147 iVal = -iVal;
148 }
danielk1977f93bbbe2004-05-27 10:30:52 +0000149 sqlite3_result_int64(context, iVal);
drhf9b596e2004-05-26 16:54:42 +0000150 break;
151 }
drh9c054832004-05-31 18:51:57 +0000152 case SQLITE_NULL: {
drh2ba3ccc2009-12-08 02:06:08 +0000153 /* IMP: R-37434-19929 Abs(X) returns NULL if X is NULL. */
drhf9b596e2004-05-26 16:54:42 +0000154 sqlite3_result_null(context);
155 break;
156 }
157 default: {
drh2ba3ccc2009-12-08 02:06:08 +0000158 /* Because sqlite3_value_double() returns 0.0 if the argument is not
159 ** something that can be converted into a number, we have:
160 ** IMP: R-57326-31541 Abs(X) return 0.0 if X is a string or blob that
161 ** cannot be converted to a numeric value.
162 */
danielk1977f93bbbe2004-05-27 10:30:52 +0000163 double rVal = sqlite3_value_double(argv[0]);
drh52fc8492006-02-23 21:43:55 +0000164 if( rVal<0 ) rVal = -rVal;
danielk1977f93bbbe2004-05-27 10:30:52 +0000165 sqlite3_result_double(context, rVal);
drhf9b596e2004-05-26 16:54:42 +0000166 break;
167 }
168 }
drh0bce8352002-02-28 00:41:10 +0000169}
170
171/*
drhd55e0722012-10-25 03:07:29 +0000172** Implementation of the instr() function.
173**
174** instr(haystack,needle) finds the first occurrence of needle
175** in haystack and returns the number of previous characters plus 1,
176** or 0 if needle does not occur within haystack.
177**
178** If both haystack and needle are BLOBs, then the result is one more than
179** the number of bytes in haystack prior to the first occurrence of needle,
180** or 0 if needle never occurs in haystack.
181*/
182static void instrFunc(
183 sqlite3_context *context,
184 int argc,
185 sqlite3_value **argv
186){
187 const unsigned char *zHaystack;
188 const unsigned char *zNeedle;
189 int nHaystack;
190 int nNeedle;
191 int typeHaystack, typeNeedle;
192 int N = 1;
193 int isText;
194
drh68c804b2012-12-04 11:03:11 +0000195 UNUSED_PARAMETER(argc);
drhd55e0722012-10-25 03:07:29 +0000196 typeHaystack = sqlite3_value_type(argv[0]);
197 typeNeedle = sqlite3_value_type(argv[1]);
198 if( typeHaystack==SQLITE_NULL || typeNeedle==SQLITE_NULL ) return;
199 nHaystack = sqlite3_value_bytes(argv[0]);
200 nNeedle = sqlite3_value_bytes(argv[1]);
201 if( typeHaystack==SQLITE_BLOB && typeNeedle==SQLITE_BLOB ){
202 zHaystack = sqlite3_value_blob(argv[0]);
203 zNeedle = sqlite3_value_blob(argv[1]);
204 isText = 0;
205 }else{
206 zHaystack = sqlite3_value_text(argv[0]);
207 zNeedle = sqlite3_value_text(argv[1]);
208 isText = 1;
209 }
210 while( nNeedle<=nHaystack && memcmp(zHaystack, zNeedle, nNeedle)!=0 ){
211 N++;
212 do{
213 nHaystack--;
214 zHaystack++;
215 }while( isText && (zHaystack[0]&0xc0)==0x80 );
216 }
217 if( nNeedle>nHaystack ) N = 0;
218 sqlite3_result_int(context, N);
219}
220
221/*
drhf764e6f2007-05-15 01:13:47 +0000222** Implementation of the substr() function.
223**
224** substr(x,p1,p2) returns p2 characters of x[] beginning with p1.
225** p1 is 1-indexed. So substr(x,1,1) returns the first character
226** of x. If x is text, then we actually count UTF-8 characters.
227** If x is a blob, then we count bytes.
228**
229** If p1 is negative, then we begin abs(p1) from the end of x[].
shaneh779b8f12009-11-12 05:04:50 +0000230**
231** If p2 is negative, return the p2 characters preceeding p1.
drh0bce8352002-02-28 00:41:10 +0000232*/
drhf9b596e2004-05-26 16:54:42 +0000233static void substrFunc(
234 sqlite3_context *context,
235 int argc,
236 sqlite3_value **argv
237){
drh2646da72005-12-09 20:02:05 +0000238 const unsigned char *z;
239 const unsigned char *z2;
drh023ae032007-05-08 12:12:16 +0000240 int len;
drhf764e6f2007-05-15 01:13:47 +0000241 int p0type;
drh023ae032007-05-08 12:12:16 +0000242 i64 p1, p2;
drh65595cd2009-02-02 16:32:55 +0000243 int negP2 = 0;
drhf9b596e2004-05-26 16:54:42 +0000244
drh64f31512007-10-12 19:11:55 +0000245 assert( argc==3 || argc==2 );
drh8198d252009-02-01 19:42:37 +0000246 if( sqlite3_value_type(argv[1])==SQLITE_NULL
247 || (argc==3 && sqlite3_value_type(argv[2])==SQLITE_NULL)
248 ){
249 return;
250 }
drhf764e6f2007-05-15 01:13:47 +0000251 p0type = sqlite3_value_type(argv[0]);
drh4adc4cb2009-11-11 20:53:31 +0000252 p1 = sqlite3_value_int(argv[1]);
drhf764e6f2007-05-15 01:13:47 +0000253 if( p0type==SQLITE_BLOB ){
254 len = sqlite3_value_bytes(argv[0]);
255 z = sqlite3_value_blob(argv[0]);
256 if( z==0 ) return;
drh1f0feef2007-05-15 13:27:07 +0000257 assert( len==sqlite3_value_bytes(argv[0]) );
drhf764e6f2007-05-15 01:13:47 +0000258 }else{
259 z = sqlite3_value_text(argv[0]);
260 if( z==0 ) return;
drh4a919112007-05-15 11:55:09 +0000261 len = 0;
drh4adc4cb2009-11-11 20:53:31 +0000262 if( p1<0 ){
263 for(z2=z; *z2; len++){
264 SQLITE_SKIP_UTF8(z2);
265 }
drh4a919112007-05-15 11:55:09 +0000266 }
drhf764e6f2007-05-15 01:13:47 +0000267 }
drh64f31512007-10-12 19:11:55 +0000268 if( argc==3 ){
269 p2 = sqlite3_value_int(argv[2]);
drh65595cd2009-02-02 16:32:55 +0000270 if( p2<0 ){
271 p2 = -p2;
272 negP2 = 1;
273 }
drh64f31512007-10-12 19:11:55 +0000274 }else{
drhbb4957f2008-03-20 14:03:29 +0000275 p2 = sqlite3_context_db_handle(context)->aLimit[SQLITE_LIMIT_LENGTH];
drh64f31512007-10-12 19:11:55 +0000276 }
drh0bce8352002-02-28 00:41:10 +0000277 if( p1<0 ){
drh89425d52002-02-28 03:04:48 +0000278 p1 += len;
drh653bc752002-02-28 03:31:10 +0000279 if( p1<0 ){
280 p2 += p1;
drh65595cd2009-02-02 16:32:55 +0000281 if( p2<0 ) p2 = 0;
drh653bc752002-02-28 03:31:10 +0000282 p1 = 0;
283 }
drh0bce8352002-02-28 00:41:10 +0000284 }else if( p1>0 ){
285 p1--;
drh65595cd2009-02-02 16:32:55 +0000286 }else if( p2>0 ){
287 p2--;
drh0bce8352002-02-28 00:41:10 +0000288 }
drh65595cd2009-02-02 16:32:55 +0000289 if( negP2 ){
290 p1 -= p2;
drh4e79c592009-02-01 19:23:32 +0000291 if( p1<0 ){
292 p2 += p1;
293 p1 = 0;
294 }
295 }
drh65595cd2009-02-02 16:32:55 +0000296 assert( p1>=0 && p2>=0 );
drhf764e6f2007-05-15 01:13:47 +0000297 if( p0type!=SQLITE_BLOB ){
drh4a919112007-05-15 11:55:09 +0000298 while( *z && p1 ){
299 SQLITE_SKIP_UTF8(z);
300 p1--;
drhf764e6f2007-05-15 01:13:47 +0000301 }
drh4a919112007-05-15 11:55:09 +0000302 for(z2=z; *z2 && p2; p2--){
303 SQLITE_SKIP_UTF8(z2);
drhf764e6f2007-05-15 01:13:47 +0000304 }
drh1bd10f82008-12-10 21:19:56 +0000305 sqlite3_result_text(context, (char*)z, (int)(z2-z), SQLITE_TRANSIENT);
drhf764e6f2007-05-15 01:13:47 +0000306 }else{
drh4adc4cb2009-11-11 20:53:31 +0000307 if( p1+p2>len ){
308 p2 = len-p1;
309 if( p2<0 ) p2 = 0;
310 }
drh1bd10f82008-12-10 21:19:56 +0000311 sqlite3_result_blob(context, (char*)&z[p1], (int)p2, SQLITE_TRANSIENT);
drh0bce8352002-02-28 00:41:10 +0000312 }
drh0bce8352002-02-28 00:41:10 +0000313}
314
315/*
316** Implementation of the round() function
317*/
shanefbd60f82009-02-04 03:59:25 +0000318#ifndef SQLITE_OMIT_FLOATING_POINT
danielk19770ae8b832004-05-25 12:05:56 +0000319static void roundFunc(sqlite3_context *context, int argc, sqlite3_value **argv){
danielk197751ad0ec2004-05-24 12:39:02 +0000320 int n = 0;
drh0bce8352002-02-28 00:41:10 +0000321 double r;
drh50d654d2009-06-03 01:24:54 +0000322 char *zBuf;
drh0bce8352002-02-28 00:41:10 +0000323 assert( argc==1 || argc==2 );
danielk197751ad0ec2004-05-24 12:39:02 +0000324 if( argc==2 ){
drh9c054832004-05-31 18:51:57 +0000325 if( SQLITE_NULL==sqlite3_value_type(argv[1]) ) return;
danielk197751ad0ec2004-05-24 12:39:02 +0000326 n = sqlite3_value_int(argv[1]);
327 if( n>30 ) n = 30;
328 if( n<0 ) n = 0;
329 }
drhd589a922006-03-02 03:02:48 +0000330 if( sqlite3_value_type(argv[0])==SQLITE_NULL ) return;
drh4f26d6c2004-05-26 23:25:30 +0000331 r = sqlite3_value_double(argv[0]);
shaneh147e1762010-02-17 04:19:27 +0000332 /* If Y==0 and X will fit in a 64-bit int,
333 ** handle the rounding directly,
334 ** otherwise use printf.
335 */
336 if( n==0 && r>=0 && r<LARGEST_INT64-1 ){
337 r = (double)((sqlite_int64)(r+0.5));
338 }else if( n==0 && r<0 && (-r)<LARGEST_INT64-1 ){
339 r = -(double)((sqlite_int64)((-r)+0.5));
drh50d654d2009-06-03 01:24:54 +0000340 }else{
shaneh147e1762010-02-17 04:19:27 +0000341 zBuf = sqlite3_mprintf("%.*f",n,r);
342 if( zBuf==0 ){
343 sqlite3_result_error_nomem(context);
344 return;
345 }
drh9339da12010-09-30 00:50:49 +0000346 sqlite3AtoF(zBuf, &r, sqlite3Strlen30(zBuf), SQLITE_UTF8);
drh50d654d2009-06-03 01:24:54 +0000347 sqlite3_free(zBuf);
drh50d654d2009-06-03 01:24:54 +0000348 }
shaneh147e1762010-02-17 04:19:27 +0000349 sqlite3_result_double(context, r);
drh0bce8352002-02-28 00:41:10 +0000350}
shanefbd60f82009-02-04 03:59:25 +0000351#endif
drhdc04c582002-02-24 01:55:15 +0000352
danielk197726783a52007-08-29 14:06:22 +0000353/*
354** Allocate nByte bytes of space using sqlite3_malloc(). If the
355** allocation fails, call sqlite3_result_error_nomem() to notify
drh27e62db2009-04-02 10:16:17 +0000356** the database handle that malloc() has failed and return NULL.
357** If nByte is larger than the maximum string or blob length, then
358** raise an SQLITE_TOOBIG exception and return NULL.
danielk197726783a52007-08-29 14:06:22 +0000359*/
drhb1a6c3c2008-03-20 16:30:17 +0000360static void *contextMalloc(sqlite3_context *context, i64 nByte){
drhbb4957f2008-03-20 14:03:29 +0000361 char *z;
drh27e62db2009-04-02 10:16:17 +0000362 sqlite3 *db = sqlite3_context_db_handle(context);
drhef31c6a2009-04-02 09:07:12 +0000363 assert( nByte>0 );
drh27e62db2009-04-02 10:16:17 +0000364 testcase( nByte==db->aLimit[SQLITE_LIMIT_LENGTH] );
365 testcase( nByte==db->aLimit[SQLITE_LIMIT_LENGTH]+1 );
366 if( nByte>db->aLimit[SQLITE_LIMIT_LENGTH] ){
drhbb4957f2008-03-20 14:03:29 +0000367 sqlite3_result_error_toobig(context);
368 z = 0;
369 }else{
drh1bd10f82008-12-10 21:19:56 +0000370 z = sqlite3Malloc((int)nByte);
drhef31c6a2009-04-02 09:07:12 +0000371 if( !z ){
drhbb4957f2008-03-20 14:03:29 +0000372 sqlite3_result_error_nomem(context);
373 }
danielk1977a1644fd2007-08-29 12:31:25 +0000374 }
375 return z;
376}
377
drhdc04c582002-02-24 01:55:15 +0000378/*
379** Implementation of the upper() and lower() SQL functions.
380*/
danielk19770ae8b832004-05-25 12:05:56 +0000381static void upperFunc(sqlite3_context *context, int argc, sqlite3_value **argv){
drh7a521cf2007-04-25 18:23:52 +0000382 char *z1;
383 const char *z2;
drh9310ef22007-04-27 17:16:20 +0000384 int i, n;
drh1d34fde2009-02-03 15:50:33 +0000385 UNUSED_PARAMETER(argc);
drh7a521cf2007-04-25 18:23:52 +0000386 z2 = (char*)sqlite3_value_text(argv[0]);
drh1f0feef2007-05-15 13:27:07 +0000387 n = sqlite3_value_bytes(argv[0]);
388 /* Verify that the call to _bytes() does not invalidate the _text() pointer */
389 assert( z2==(char*)sqlite3_value_text(argv[0]) );
drh7a521cf2007-04-25 18:23:52 +0000390 if( z2 ){
drhb1a6c3c2008-03-20 16:30:17 +0000391 z1 = contextMalloc(context, ((i64)n)+1);
drh7a521cf2007-04-25 18:23:52 +0000392 if( z1 ){
drhdf901d32011-10-13 18:00:11 +0000393 for(i=0; i<n; i++){
394 z1[i] = (char)sqlite3Toupper(z2[i]);
drh7a521cf2007-04-25 18:23:52 +0000395 }
drhdf901d32011-10-13 18:00:11 +0000396 sqlite3_result_text(context, z1, n, sqlite3_free);
drh7a521cf2007-04-25 18:23:52 +0000397 }
drhdc04c582002-02-24 01:55:15 +0000398 }
399}
danielk19770ae8b832004-05-25 12:05:56 +0000400static void lowerFunc(sqlite3_context *context, int argc, sqlite3_value **argv){
drhdf901d32011-10-13 18:00:11 +0000401 char *z1;
drh7a521cf2007-04-25 18:23:52 +0000402 const char *z2;
drh9310ef22007-04-27 17:16:20 +0000403 int i, n;
drh1d34fde2009-02-03 15:50:33 +0000404 UNUSED_PARAMETER(argc);
drh7a521cf2007-04-25 18:23:52 +0000405 z2 = (char*)sqlite3_value_text(argv[0]);
drh1f0feef2007-05-15 13:27:07 +0000406 n = sqlite3_value_bytes(argv[0]);
407 /* Verify that the call to _bytes() does not invalidate the _text() pointer */
408 assert( z2==(char*)sqlite3_value_text(argv[0]) );
drh7a521cf2007-04-25 18:23:52 +0000409 if( z2 ){
drhb1a6c3c2008-03-20 16:30:17 +0000410 z1 = contextMalloc(context, ((i64)n)+1);
drh7a521cf2007-04-25 18:23:52 +0000411 if( z1 ){
drhdf901d32011-10-13 18:00:11 +0000412 for(i=0; i<n; i++){
413 z1[i] = sqlite3Tolower(z2[i]);
drh7a521cf2007-04-25 18:23:52 +0000414 }
drhdf901d32011-10-13 18:00:11 +0000415 sqlite3_result_text(context, z1, n, sqlite3_free);
drh7a521cf2007-04-25 18:23:52 +0000416 }
drhdc04c582002-02-24 01:55:15 +0000417 }
418}
419
drhae6bb952009-11-11 00:24:31 +0000420/*
drh0fdbdbe2012-09-10 15:02:32 +0000421** The COALESCE() and IFNULL() functions are implemented as VDBE code so
422** that unused argument values do not have to be computed. However, we
423** still need some kind of function implementation for this routines in
424** the function table. That function implementation will never be called
425** so it doesn't matter what the implementation is. We might as well use
426** the "version()" function as a substitute.
drhae6bb952009-11-11 00:24:31 +0000427*/
drhae6bb952009-11-11 00:24:31 +0000428#define ifnullFunc versionFunc /* Substitute function - never called */
drh3212e182002-02-28 00:46:26 +0000429
430/*
drhf9ffac92002-03-02 19:00:31 +0000431** Implementation of random(). Return a random integer.
432*/
drhf9b596e2004-05-26 16:54:42 +0000433static void randomFunc(
434 sqlite3_context *context,
danielk197762c14b32008-11-19 09:05:26 +0000435 int NotUsed,
436 sqlite3_value **NotUsed2
drhf9b596e2004-05-26 16:54:42 +0000437){
drh52fc8492006-02-23 21:43:55 +0000438 sqlite_int64 r;
danielk197762c14b32008-11-19 09:05:26 +0000439 UNUSED_PARAMETER2(NotUsed, NotUsed2);
drh2fa18682008-03-19 14:15:34 +0000440 sqlite3_randomness(sizeof(r), &r);
drh3034e3d2009-04-02 14:05:21 +0000441 if( r<0 ){
442 /* We need to prevent a random number of 0x8000000000000000
443 ** (or -9223372036854775808) since when you do abs() of that
444 ** number of you get the same value back again. To do this
445 ** in a way that is testable, mask the sign bit off of negative
446 ** values, resulting in a positive value. Then take the
447 ** 2s complement of that positive value. The end result can
448 ** therefore be no less than -9223372036854775807.
449 */
drhaf8001b2012-02-11 19:53:24 +0000450 r = -(r & LARGEST_INT64);
drh3034e3d2009-04-02 14:05:21 +0000451 }
drh52fc8492006-02-23 21:43:55 +0000452 sqlite3_result_int64(context, r);
drhf9ffac92002-03-02 19:00:31 +0000453}
454
455/*
drh137c7282007-01-29 17:58:28 +0000456** Implementation of randomblob(N). Return a random blob
457** that is N bytes long.
drh63cf66f2007-01-29 15:50:05 +0000458*/
drh137c7282007-01-29 17:58:28 +0000459static void randomBlob(
drh63cf66f2007-01-29 15:50:05 +0000460 sqlite3_context *context,
461 int argc,
462 sqlite3_value **argv
463){
drh137c7282007-01-29 17:58:28 +0000464 int n;
465 unsigned char *p;
drh63cf66f2007-01-29 15:50:05 +0000466 assert( argc==1 );
danielk1977f3d3c272008-11-19 16:52:44 +0000467 UNUSED_PARAMETER(argc);
drh63cf66f2007-01-29 15:50:05 +0000468 n = sqlite3_value_int(argv[0]);
drh023ae032007-05-08 12:12:16 +0000469 if( n<1 ){
470 n = 1;
471 }
danielk1977a1644fd2007-08-29 12:31:25 +0000472 p = contextMalloc(context, n);
drh02d85832007-05-07 19:31:15 +0000473 if( p ){
drh2fa18682008-03-19 14:15:34 +0000474 sqlite3_randomness(n, p);
drh17435752007-08-16 04:30:38 +0000475 sqlite3_result_blob(context, (char*)p, n, sqlite3_free);
drh02d85832007-05-07 19:31:15 +0000476 }
drh63cf66f2007-01-29 15:50:05 +0000477}
478
479/*
drh6ed41ad2002-04-06 14:10:47 +0000480** Implementation of the last_insert_rowid() SQL function. The return
danielk197724b03fd2004-05-10 10:34:34 +0000481** value is the same as the sqlite3_last_insert_rowid() API function.
drh6ed41ad2002-04-06 14:10:47 +0000482*/
danielk197751ad0ec2004-05-24 12:39:02 +0000483static void last_insert_rowid(
danielk19770ae8b832004-05-25 12:05:56 +0000484 sqlite3_context *context,
danielk197762c14b32008-11-19 09:05:26 +0000485 int NotUsed,
486 sqlite3_value **NotUsed2
danielk197751ad0ec2004-05-24 12:39:02 +0000487){
drhfa4a4b92008-03-19 21:45:51 +0000488 sqlite3 *db = sqlite3_context_db_handle(context);
danielk197762c14b32008-11-19 09:05:26 +0000489 UNUSED_PARAMETER2(NotUsed, NotUsed2);
drhab2f1f92010-01-11 18:26:42 +0000490 /* IMP: R-51513-12026 The last_insert_rowid() SQL function is a
491 ** wrapper around the sqlite3_last_insert_rowid() C/C++ interface
492 ** function. */
drhf9b596e2004-05-26 16:54:42 +0000493 sqlite3_result_int64(context, sqlite3_last_insert_rowid(db));
drh6ed41ad2002-04-06 14:10:47 +0000494}
495
rdcf146a772004-02-25 22:51:06 +0000496/*
drhab2f1f92010-01-11 18:26:42 +0000497** Implementation of the changes() SQL function.
498**
499** IMP: R-62073-11209 The changes() SQL function is a wrapper
500** around the sqlite3_changes() C/C++ function and hence follows the same
501** rules for counting changes.
rdcf146a772004-02-25 22:51:06 +0000502*/
danielk1977b28af712004-06-21 06:50:26 +0000503static void changes(
drhf9b596e2004-05-26 16:54:42 +0000504 sqlite3_context *context,
danielk197762c14b32008-11-19 09:05:26 +0000505 int NotUsed,
506 sqlite3_value **NotUsed2
drhf9b596e2004-05-26 16:54:42 +0000507){
drhfa4a4b92008-03-19 21:45:51 +0000508 sqlite3 *db = sqlite3_context_db_handle(context);
danielk197762c14b32008-11-19 09:05:26 +0000509 UNUSED_PARAMETER2(NotUsed, NotUsed2);
drhf4479502004-05-27 03:12:53 +0000510 sqlite3_result_int(context, sqlite3_changes(db));
rdcb0c374f2004-02-20 22:53:38 +0000511}
rdcf146a772004-02-25 22:51:06 +0000512
513/*
danielk1977b28af712004-06-21 06:50:26 +0000514** Implementation of the total_changes() SQL function. The return value is
515** the same as the sqlite3_total_changes() API function.
rdcf146a772004-02-25 22:51:06 +0000516*/
danielk1977b28af712004-06-21 06:50:26 +0000517static void total_changes(
518 sqlite3_context *context,
danielk197762c14b32008-11-19 09:05:26 +0000519 int NotUsed,
520 sqlite3_value **NotUsed2
danielk197751ad0ec2004-05-24 12:39:02 +0000521){
drhfa4a4b92008-03-19 21:45:51 +0000522 sqlite3 *db = sqlite3_context_db_handle(context);
danielk197762c14b32008-11-19 09:05:26 +0000523 UNUSED_PARAMETER2(NotUsed, NotUsed2);
drhab2f1f92010-01-11 18:26:42 +0000524 /* IMP: R-52756-41993 This function is a wrapper around the
525 ** sqlite3_total_changes() C/C++ interface. */
danielk1977b28af712004-06-21 06:50:26 +0000526 sqlite3_result_int(context, sqlite3_total_changes(db));
rdcb0c374f2004-02-20 22:53:38 +0000527}
528
drh6ed41ad2002-04-06 14:10:47 +0000529/*
drh4e5ffc52004-08-31 00:52:37 +0000530** A structure defining how to do GLOB-style comparisons.
danielk1977d02eb1f2004-06-06 09:44:03 +0000531*/
drh4e5ffc52004-08-31 00:52:37 +0000532struct compareInfo {
533 u8 matchAll;
534 u8 matchOne;
535 u8 matchSet;
536 u8 noCase;
danielk1977d02eb1f2004-06-06 09:44:03 +0000537};
drh55ef4d92005-08-14 01:20:37 +0000538
drhb9175ae2007-12-07 18:39:04 +0000539/*
540** For LIKE and GLOB matching on EBCDIC machines, assume that every
541** character is exactly one byte in size. Also, all characters are
542** able to participate in upper-case-to-lower-case mappings in EBCDIC
543** whereas only characters less than 0x80 do in ASCII.
544*/
545#if defined(SQLITE_EBCDIC)
drh42610962012-09-17 18:56:32 +0000546# define sqlite3Utf8Read(A) (*((*A)++))
drh0a32fa62011-06-13 12:19:21 +0000547# define GlogUpperToLower(A) A = sqlite3UpperToLower[A]
drhb9175ae2007-12-07 18:39:04 +0000548#else
drh0a32fa62011-06-13 12:19:21 +0000549# define GlogUpperToLower(A) if( !((A)&~0x7f) ){ A = sqlite3UpperToLower[A]; }
drhb9175ae2007-12-07 18:39:04 +0000550#endif
551
drh4e5ffc52004-08-31 00:52:37 +0000552static const struct compareInfo globInfo = { '*', '?', '[', 0 };
drh55ef4d92005-08-14 01:20:37 +0000553/* The correct SQL-92 behavior is for the LIKE operator to ignore
554** case. Thus 'a' LIKE 'A' would be true. */
555static const struct compareInfo likeInfoNorm = { '%', '_', 0, 1 };
556/* If SQLITE_CASE_SENSITIVE_LIKE is defined, then the LIKE operator
557** is case sensitive causing 'a' LIKE 'A' to be false */
558static const struct compareInfo likeInfoAlt = { '%', '_', 0, 0 };
danielk1977d02eb1f2004-06-06 09:44:03 +0000559
560/*
drh4e5ffc52004-08-31 00:52:37 +0000561** Compare two UTF-8 strings for equality where the first string can
562** potentially be a "glob" expression. Return true (1) if they
563** are the same and false (0) if they are different.
drh0ac65892002-04-20 14:24:41 +0000564**
drh4e5ffc52004-08-31 00:52:37 +0000565** Globbing rules:
drh0ac65892002-04-20 14:24:41 +0000566**
drh4e5ffc52004-08-31 00:52:37 +0000567** '*' Matches any sequence of zero or more characters.
danielk1977d02eb1f2004-06-06 09:44:03 +0000568**
drh4e5ffc52004-08-31 00:52:37 +0000569** '?' Matches exactly one character.
570**
571** [...] Matches one character from the enclosed list of
572** characters.
573**
574** [^...] Matches one character not in the enclosed list.
575**
576** With the [...] and [^...] matching, a ']' character can be included
577** in the list by making it the first character after '[' or '^'. A
578** range of characters can be specified using '-'. Example:
579** "[a-z]" matches any single lower-case letter. To match a '-', make
580** it the last character in the list.
581**
582** This routine is usually quick, but can be N**2 in the worst case.
583**
584** Hints: to match '*' or '?', put them in "[]". Like this:
585**
586** abc[*]xyz Matches "abc*xyz" only
drh0ac65892002-04-20 14:24:41 +0000587*/
danielk19777c6303c2004-11-17 16:41:29 +0000588static int patternCompare(
drh4e5ffc52004-08-31 00:52:37 +0000589 const u8 *zPattern, /* The glob pattern */
590 const u8 *zString, /* The string to compare against the glob */
danielk19777c6303c2004-11-17 16:41:29 +0000591 const struct compareInfo *pInfo, /* Information about how to do the compare */
drh0a32fa62011-06-13 12:19:21 +0000592 u32 esc /* The escape character */
danielk197751ad0ec2004-05-24 12:39:02 +0000593){
drh0a32fa62011-06-13 12:19:21 +0000594 u32 c, c2;
drh4e5ffc52004-08-31 00:52:37 +0000595 int invert;
596 int seen;
drh4e5ffc52004-08-31 00:52:37 +0000597 u8 matchOne = pInfo->matchOne;
598 u8 matchAll = pInfo->matchAll;
599 u8 matchSet = pInfo->matchSet;
600 u8 noCase = pInfo->noCase;
danielk19777c6303c2004-11-17 16:41:29 +0000601 int prevEscape = 0; /* True if the previous character was 'escape' */
danielk1977d02eb1f2004-06-06 09:44:03 +0000602
drh42610962012-09-17 18:56:32 +0000603 while( (c = sqlite3Utf8Read(&zPattern))!=0 ){
604 if( c==matchAll && !prevEscape ){
605 while( (c=sqlite3Utf8Read(&zPattern)) == matchAll
drh66150952007-07-23 19:12:41 +0000606 || c == matchOne ){
drh42610962012-09-17 18:56:32 +0000607 if( c==matchOne && sqlite3Utf8Read(&zString)==0 ){
drh66150952007-07-23 19:12:41 +0000608 return 0;
drh4e5ffc52004-08-31 00:52:37 +0000609 }
danielk1977ad7dd422004-06-06 12:41:49 +0000610 }
drh66150952007-07-23 19:12:41 +0000611 if( c==0 ){
612 return 1;
613 }else if( c==esc ){
drh42610962012-09-17 18:56:32 +0000614 c = sqlite3Utf8Read(&zPattern);
drh66150952007-07-23 19:12:41 +0000615 if( c==0 ){
616 return 0;
617 }
618 }else if( c==matchSet ){
619 assert( esc==0 ); /* This is GLOB, not LIKE */
620 assert( matchSet<0x80 ); /* '[' is a single-byte character */
621 while( *zString && patternCompare(&zPattern[-1],zString,pInfo,esc)==0 ){
drh4a919112007-05-15 11:55:09 +0000622 SQLITE_SKIP_UTF8(zString);
drh4e5ffc52004-08-31 00:52:37 +0000623 }
624 return *zString!=0;
drh66150952007-07-23 19:12:41 +0000625 }
drh42610962012-09-17 18:56:32 +0000626 while( (c2 = sqlite3Utf8Read(&zString))!=0 ){
drh66150952007-07-23 19:12:41 +0000627 if( noCase ){
drh6ed4b782007-12-10 18:07:20 +0000628 GlogUpperToLower(c2);
629 GlogUpperToLower(c);
drh66150952007-07-23 19:12:41 +0000630 while( c2 != 0 && c2 != c ){
drh42610962012-09-17 18:56:32 +0000631 c2 = sqlite3Utf8Read(&zString);
drh6ed4b782007-12-10 18:07:20 +0000632 GlogUpperToLower(c2);
drh4e5ffc52004-08-31 00:52:37 +0000633 }
drh66150952007-07-23 19:12:41 +0000634 }else{
635 while( c2 != 0 && c2 != c ){
drh42610962012-09-17 18:56:32 +0000636 c2 = sqlite3Utf8Read(&zString);
drh66150952007-07-23 19:12:41 +0000637 }
drh4e5ffc52004-08-31 00:52:37 +0000638 }
drh66150952007-07-23 19:12:41 +0000639 if( c2==0 ) return 0;
640 if( patternCompare(zPattern,zString,pInfo,esc) ) return 1;
641 }
642 return 0;
drh42610962012-09-17 18:56:32 +0000643 }else if( c==matchOne && !prevEscape ){
644 if( sqlite3Utf8Read(&zString)==0 ){
drh4e5ffc52004-08-31 00:52:37 +0000645 return 0;
danielk1977d02eb1f2004-06-06 09:44:03 +0000646 }
drh4e5ffc52004-08-31 00:52:37 +0000647 }else if( c==matchSet ){
drh1aa4f3e2011-06-15 12:43:36 +0000648 u32 prior_c = 0;
danielk19777c6303c2004-11-17 16:41:29 +0000649 assert( esc==0 ); /* This only occurs for GLOB, not LIKE */
drh4e5ffc52004-08-31 00:52:37 +0000650 seen = 0;
651 invert = 0;
drh42610962012-09-17 18:56:32 +0000652 c = sqlite3Utf8Read(&zString);
drh4e5ffc52004-08-31 00:52:37 +0000653 if( c==0 ) return 0;
drh42610962012-09-17 18:56:32 +0000654 c2 = sqlite3Utf8Read(&zPattern);
drh66150952007-07-23 19:12:41 +0000655 if( c2=='^' ){
656 invert = 1;
drh42610962012-09-17 18:56:32 +0000657 c2 = sqlite3Utf8Read(&zPattern);
drh66150952007-07-23 19:12:41 +0000658 }
drh4e5ffc52004-08-31 00:52:37 +0000659 if( c2==']' ){
660 if( c==']' ) seen = 1;
drh42610962012-09-17 18:56:32 +0000661 c2 = sqlite3Utf8Read(&zPattern);
drh4e5ffc52004-08-31 00:52:37 +0000662 }
drh66150952007-07-23 19:12:41 +0000663 while( c2 && c2!=']' ){
664 if( c2=='-' && zPattern[0]!=']' && zPattern[0]!=0 && prior_c>0 ){
drh42610962012-09-17 18:56:32 +0000665 c2 = sqlite3Utf8Read(&zPattern);
drh4e5ffc52004-08-31 00:52:37 +0000666 if( c>=prior_c && c<=c2 ) seen = 1;
667 prior_c = 0;
drh4e5ffc52004-08-31 00:52:37 +0000668 }else{
drh66150952007-07-23 19:12:41 +0000669 if( c==c2 ){
670 seen = 1;
671 }
drh4e5ffc52004-08-31 00:52:37 +0000672 prior_c = c2;
673 }
drh42610962012-09-17 18:56:32 +0000674 c2 = sqlite3Utf8Read(&zPattern);
drh4e5ffc52004-08-31 00:52:37 +0000675 }
drh66150952007-07-23 19:12:41 +0000676 if( c2==0 || (seen ^ invert)==0 ){
677 return 0;
678 }
679 }else if( esc==c && !prevEscape ){
danielk19777c6303c2004-11-17 16:41:29 +0000680 prevEscape = 1;
drh4e5ffc52004-08-31 00:52:37 +0000681 }else{
drh42610962012-09-17 18:56:32 +0000682 c2 = sqlite3Utf8Read(&zString);
drh4e5ffc52004-08-31 00:52:37 +0000683 if( noCase ){
drh6ed4b782007-12-10 18:07:20 +0000684 GlogUpperToLower(c);
685 GlogUpperToLower(c2);
drh4e5ffc52004-08-31 00:52:37 +0000686 }
drh66150952007-07-23 19:12:41 +0000687 if( c!=c2 ){
688 return 0;
689 }
danielk19777c6303c2004-11-17 16:41:29 +0000690 prevEscape = 0;
danielk1977d02eb1f2004-06-06 09:44:03 +0000691 }
danielk197751ad0ec2004-05-24 12:39:02 +0000692 }
drh4e5ffc52004-08-31 00:52:37 +0000693 return *zString==0;
drh0ac65892002-04-20 14:24:41 +0000694}
drh4e5ffc52004-08-31 00:52:37 +0000695
drh55ef4d92005-08-14 01:20:37 +0000696/*
drh56282a52013-04-10 16:13:38 +0000697** The sqlite3_strglob() interface.
698*/
699int sqlite3_strglob(const char *zGlobPattern, const char *zString){
700 return patternCompare((u8*)zGlobPattern, (u8*)zString, &globInfo, 0)==0;
701}
702
703/*
drh55ef4d92005-08-14 01:20:37 +0000704** Count the number of times that the LIKE operator (or GLOB which is
705** just a variation of LIKE) gets called. This is used for testing
706** only.
707*/
708#ifdef SQLITE_TEST
709int sqlite3_like_count = 0;
710#endif
711
danielk19773f6b0872004-06-17 05:36:44 +0000712
713/*
714** Implementation of the like() SQL function. This function implements
715** the build-in LIKE operator. The first argument to the function is the
716** pattern and the second argument is the string. So, the SQL statements:
717**
718** A LIKE B
719**
720** is implemented as like(B,A).
721**
drh55ef4d92005-08-14 01:20:37 +0000722** This same function (with a different compareInfo structure) computes
723** the GLOB operator.
danielk19773f6b0872004-06-17 05:36:44 +0000724*/
725static void likeFunc(
726 sqlite3_context *context,
727 int argc,
728 sqlite3_value **argv
729){
drhbeb818d2007-05-08 15:34:47 +0000730 const unsigned char *zA, *zB;
drh0a32fa62011-06-13 12:19:21 +0000731 u32 escape = 0;
drh27e62db2009-04-02 10:16:17 +0000732 int nPat;
drhbb4957f2008-03-20 14:03:29 +0000733 sqlite3 *db = sqlite3_context_db_handle(context);
drhbeb818d2007-05-08 15:34:47 +0000734
drh1f0feef2007-05-15 13:27:07 +0000735 zB = sqlite3_value_text(argv[0]);
736 zA = sqlite3_value_text(argv[1]);
737
drhbeb818d2007-05-08 15:34:47 +0000738 /* Limit the length of the LIKE or GLOB pattern to avoid problems
739 ** of deep recursion and N*N behavior in patternCompare().
740 */
drh27e62db2009-04-02 10:16:17 +0000741 nPat = sqlite3_value_bytes(argv[0]);
742 testcase( nPat==db->aLimit[SQLITE_LIMIT_LIKE_PATTERN_LENGTH] );
743 testcase( nPat==db->aLimit[SQLITE_LIMIT_LIKE_PATTERN_LENGTH]+1 );
744 if( nPat > db->aLimit[SQLITE_LIMIT_LIKE_PATTERN_LENGTH] ){
drhbeb818d2007-05-08 15:34:47 +0000745 sqlite3_result_error(context, "LIKE or GLOB pattern too complex", -1);
746 return;
747 }
drh1f0feef2007-05-15 13:27:07 +0000748 assert( zB==sqlite3_value_text(argv[0]) ); /* Encoding did not change */
drhbeb818d2007-05-08 15:34:47 +0000749
danielk19777c6303c2004-11-17 16:41:29 +0000750 if( argc==3 ){
751 /* The escape character string must consist of a single UTF-8 character.
752 ** Otherwise, return an error.
753 */
754 const unsigned char *zEsc = sqlite3_value_text(argv[2]);
drh7a521cf2007-04-25 18:23:52 +0000755 if( zEsc==0 ) return;
drhee858132007-05-08 20:37:38 +0000756 if( sqlite3Utf8CharLen((char*)zEsc, -1)!=1 ){
danielk19777c6303c2004-11-17 16:41:29 +0000757 sqlite3_result_error(context,
758 "ESCAPE expression must be a single character", -1);
759 return;
760 }
drh42610962012-09-17 18:56:32 +0000761 escape = sqlite3Utf8Read(&zEsc);
danielk19777c6303c2004-11-17 16:41:29 +0000762 }
danielk19773f6b0872004-06-17 05:36:44 +0000763 if( zA && zB ){
drh55ef4d92005-08-14 01:20:37 +0000764 struct compareInfo *pInfo = sqlite3_user_data(context);
765#ifdef SQLITE_TEST
766 sqlite3_like_count++;
767#endif
drhbeb818d2007-05-08 15:34:47 +0000768
danielk1977b56fe1f2007-05-09 08:24:44 +0000769 sqlite3_result_int(context, patternCompare(zB, zA, pInfo, escape));
danielk197751ad0ec2004-05-24 12:39:02 +0000770 }
drh8912d102002-05-26 21:34:58 +0000771}
772
773/*
774** Implementation of the NULLIF(x,y) function. The result is the first
775** argument if the arguments are different. The result is NULL if the
776** arguments are equal to each other.
777*/
drhf9b596e2004-05-26 16:54:42 +0000778static void nullifFunc(
779 sqlite3_context *context,
danielk197762c14b32008-11-19 09:05:26 +0000780 int NotUsed,
drhf9b596e2004-05-26 16:54:42 +0000781 sqlite3_value **argv
782){
danielk1977dc1bdc42004-06-11 10:51:27 +0000783 CollSeq *pColl = sqlite3GetFuncCollSeq(context);
danielk197762c14b32008-11-19 09:05:26 +0000784 UNUSED_PARAMETER(NotUsed);
danielk1977dc1bdc42004-06-11 10:51:27 +0000785 if( sqlite3MemCompare(argv[0], argv[1], pColl)!=0 ){
drhf4479502004-05-27 03:12:53 +0000786 sqlite3_result_value(context, argv[0]);
drh8912d102002-05-26 21:34:58 +0000787 }
drh0ac65892002-04-20 14:24:41 +0000788}
789
drh647cb0e2002-11-04 19:32:25 +0000790/*
drh47baebc2009-08-14 16:01:24 +0000791** Implementation of the sqlite_version() function. The result is the version
drh647cb0e2002-11-04 19:32:25 +0000792** of the SQLite library that is running.
793*/
drhf9b596e2004-05-26 16:54:42 +0000794static void versionFunc(
795 sqlite3_context *context,
danielk197762c14b32008-11-19 09:05:26 +0000796 int NotUsed,
797 sqlite3_value **NotUsed2
drhf9b596e2004-05-26 16:54:42 +0000798){
danielk197762c14b32008-11-19 09:05:26 +0000799 UNUSED_PARAMETER2(NotUsed, NotUsed2);
drhab2f1f92010-01-11 18:26:42 +0000800 /* IMP: R-48699-48617 This function is an SQL wrapper around the
801 ** sqlite3_libversion() C-interface. */
802 sqlite3_result_text(context, sqlite3_libversion(), -1, SQLITE_STATIC);
drh647cb0e2002-11-04 19:32:25 +0000803}
804
drh47baebc2009-08-14 16:01:24 +0000805/*
806** Implementation of the sqlite_source_id() function. The result is a string
807** that identifies the particular version of the source code used to build
808** SQLite.
809*/
810static void sourceidFunc(
811 sqlite3_context *context,
812 int NotUsed,
813 sqlite3_value **NotUsed2
814){
815 UNUSED_PARAMETER2(NotUsed, NotUsed2);
drhab2f1f92010-01-11 18:26:42 +0000816 /* IMP: R-24470-31136 This function is an SQL wrapper around the
817 ** sqlite3_sourceid() C interface. */
818 sqlite3_result_text(context, sqlite3_sourceid(), -1, SQLITE_STATIC);
drh47baebc2009-08-14 16:01:24 +0000819}
820
shanehbdea6d12010-02-23 04:19:54 +0000821/*
drh3ca84ef2011-04-25 18:03:10 +0000822** Implementation of the sqlite_log() function. This is a wrapper around
823** sqlite3_log(). The return value is NULL. The function exists purely for
824** its side-effects.
825*/
drh840561f2011-04-27 18:08:42 +0000826static void errlogFunc(
drh3ca84ef2011-04-25 18:03:10 +0000827 sqlite3_context *context,
828 int argc,
829 sqlite3_value **argv
830){
831 UNUSED_PARAMETER(argc);
832 UNUSED_PARAMETER(context);
833 sqlite3_log(sqlite3_value_int(argv[0]), "%s", sqlite3_value_text(argv[1]));
834}
835
836/*
shanehdc97a8c2010-02-23 20:08:35 +0000837** Implementation of the sqlite_compileoption_used() function.
838** The result is an integer that identifies if the compiler option
839** was used to build SQLite.
shanehbdea6d12010-02-23 04:19:54 +0000840*/
shanehdc97a8c2010-02-23 20:08:35 +0000841#ifndef SQLITE_OMIT_COMPILEOPTION_DIAGS
842static void compileoptionusedFunc(
shanehbdea6d12010-02-23 04:19:54 +0000843 sqlite3_context *context,
shanehdc97a8c2010-02-23 20:08:35 +0000844 int argc,
845 sqlite3_value **argv
shanehbdea6d12010-02-23 04:19:54 +0000846){
shanehdc97a8c2010-02-23 20:08:35 +0000847 const char *zOptName;
848 assert( argc==1 );
849 UNUSED_PARAMETER(argc);
drha3e414c2010-08-03 18:06:25 +0000850 /* IMP: R-39564-36305 The sqlite_compileoption_used() SQL
851 ** function is a wrapper around the sqlite3_compileoption_used() C/C++
852 ** function.
853 */
drh264a2d42010-02-25 15:28:41 +0000854 if( (zOptName = (const char*)sqlite3_value_text(argv[0]))!=0 ){
shanehdc97a8c2010-02-23 20:08:35 +0000855 sqlite3_result_int(context, sqlite3_compileoption_used(zOptName));
shanehdc97a8c2010-02-23 20:08:35 +0000856 }
shanehbdea6d12010-02-23 04:19:54 +0000857}
shanehdc97a8c2010-02-23 20:08:35 +0000858#endif /* SQLITE_OMIT_COMPILEOPTION_DIAGS */
859
860/*
861** Implementation of the sqlite_compileoption_get() function.
862** The result is a string that identifies the compiler options
863** used to build SQLite.
864*/
865#ifndef SQLITE_OMIT_COMPILEOPTION_DIAGS
866static void compileoptiongetFunc(
867 sqlite3_context *context,
868 int argc,
869 sqlite3_value **argv
870){
871 int n;
872 assert( argc==1 );
873 UNUSED_PARAMETER(argc);
drha3e414c2010-08-03 18:06:25 +0000874 /* IMP: R-04922-24076 The sqlite_compileoption_get() SQL function
875 ** is a wrapper around the sqlite3_compileoption_get() C/C++ function.
876 */
shanehdc97a8c2010-02-23 20:08:35 +0000877 n = sqlite3_value_int(argv[0]);
878 sqlite3_result_text(context, sqlite3_compileoption_get(n), -1, SQLITE_STATIC);
879}
880#endif /* SQLITE_OMIT_COMPILEOPTION_DIAGS */
shanehbdea6d12010-02-23 04:19:54 +0000881
drh137c7282007-01-29 17:58:28 +0000882/* Array for converting from half-bytes (nybbles) into ASCII hex
883** digits. */
884static const char hexdigits[] = {
885 '0', '1', '2', '3', '4', '5', '6', '7',
886 '8', '9', 'A', 'B', 'C', 'D', 'E', 'F'
887};
danielk1977d641d642004-11-18 15:44:29 +0000888
drh47394702003-08-20 01:03:33 +0000889/*
890** EXPERIMENTAL - This is not an official function. The interface may
891** change. This function may disappear. Do not write code that depends
892** on this function.
893**
894** Implementation of the QUOTE() function. This function takes a single
895** argument. If the argument is numeric, the return value is the same as
896** the argument. If the argument is NULL, the return value is the string
897** "NULL". Otherwise, the argument is enclosed in single quotes with
898** single-quote escapes.
899*/
danielk19770ae8b832004-05-25 12:05:56 +0000900static void quoteFunc(sqlite3_context *context, int argc, sqlite3_value **argv){
drha0df4cc2009-02-02 17:29:59 +0000901 assert( argc==1 );
drh1d34fde2009-02-03 15:50:33 +0000902 UNUSED_PARAMETER(argc);
drhf9b596e2004-05-26 16:54:42 +0000903 switch( sqlite3_value_type(argv[0]) ){
drh9c054832004-05-31 18:51:57 +0000904 case SQLITE_FLOAT: {
drh72b3fbc2012-06-19 03:11:25 +0000905 double r1, r2;
drh72b3fbc2012-06-19 03:11:25 +0000906 char zBuf[50];
mistachkin2b434a72012-06-19 04:36:48 +0000907 r1 = sqlite3_value_double(argv[0]);
drh72b3fbc2012-06-19 03:11:25 +0000908 sqlite3_snprintf(sizeof(zBuf), zBuf, "%!.15g", r1);
909 sqlite3AtoF(zBuf, &r2, 20, SQLITE_UTF8);
910 if( r1!=r2 ){
911 sqlite3_snprintf(sizeof(zBuf), zBuf, "%!.20e", r1);
912 }
913 sqlite3_result_text(context, zBuf, -1, SQLITE_TRANSIENT);
914 break;
915 }
916 case SQLITE_INTEGER: {
drhf4479502004-05-27 03:12:53 +0000917 sqlite3_result_value(context, argv[0]);
drhf9b596e2004-05-26 16:54:42 +0000918 break;
919 }
danielk19773f41e972004-06-08 00:39:01 +0000920 case SQLITE_BLOB: {
danielk19773f41e972004-06-08 00:39:01 +0000921 char *zText = 0;
danielk19773f41e972004-06-08 00:39:01 +0000922 char const *zBlob = sqlite3_value_blob(argv[0]);
drh1f0feef2007-05-15 13:27:07 +0000923 int nBlob = sqlite3_value_bytes(argv[0]);
924 assert( zBlob==sqlite3_value_blob(argv[0]) ); /* No encoding change */
drhb1a6c3c2008-03-20 16:30:17 +0000925 zText = (char *)contextMalloc(context, (2*(i64)nBlob)+4);
danielk1977a1644fd2007-08-29 12:31:25 +0000926 if( zText ){
danielk19773f41e972004-06-08 00:39:01 +0000927 int i;
928 for(i=0; i<nBlob; i++){
929 zText[(i*2)+2] = hexdigits[(zBlob[i]>>4)&0x0F];
930 zText[(i*2)+3] = hexdigits[(zBlob[i])&0x0F];
931 }
932 zText[(nBlob*2)+2] = '\'';
933 zText[(nBlob*2)+3] = '\0';
934 zText[0] = 'X';
935 zText[1] = '\'';
danielk1977d8123362004-06-12 09:25:12 +0000936 sqlite3_result_text(context, zText, -1, SQLITE_TRANSIENT);
drh17435752007-08-16 04:30:38 +0000937 sqlite3_free(zText);
danielk19773f41e972004-06-08 00:39:01 +0000938 }
939 break;
940 }
drh9c054832004-05-31 18:51:57 +0000941 case SQLITE_TEXT: {
drh023ae032007-05-08 12:12:16 +0000942 int i,j;
943 u64 n;
drh2646da72005-12-09 20:02:05 +0000944 const unsigned char *zArg = sqlite3_value_text(argv[0]);
drhf9b596e2004-05-26 16:54:42 +0000945 char *z;
946
drh7a521cf2007-04-25 18:23:52 +0000947 if( zArg==0 ) return;
drh023ae032007-05-08 12:12:16 +0000948 for(i=0, n=0; zArg[i]; i++){ if( zArg[i]=='\'' ) n++; }
drhb1a6c3c2008-03-20 16:30:17 +0000949 z = contextMalloc(context, ((i64)i)+((i64)n)+3);
danielk1977a1644fd2007-08-29 12:31:25 +0000950 if( z ){
951 z[0] = '\'';
952 for(i=0, j=1; zArg[i]; i++){
953 z[j++] = zArg[i];
954 if( zArg[i]=='\'' ){
955 z[j++] = '\'';
956 }
drhf9b596e2004-05-26 16:54:42 +0000957 }
danielk1977a1644fd2007-08-29 12:31:25 +0000958 z[j++] = '\'';
959 z[j] = 0;
960 sqlite3_result_text(context, z, j, sqlite3_free);
drhf9b596e2004-05-26 16:54:42 +0000961 }
drha0df4cc2009-02-02 17:29:59 +0000962 break;
963 }
964 default: {
965 assert( sqlite3_value_type(argv[0])==SQLITE_NULL );
966 sqlite3_result_text(context, "NULL", 4, SQLITE_STATIC);
967 break;
drhf9b596e2004-05-26 16:54:42 +0000968 }
drh47394702003-08-20 01:03:33 +0000969 }
970}
971
drh137c7282007-01-29 17:58:28 +0000972/*
drhd495d8c2013-02-22 19:34:25 +0000973** The unicode() function. Return the integer unicode code-point value
974** for the first character of the input string.
975*/
976static void unicodeFunc(
977 sqlite3_context *context,
978 int argc,
979 sqlite3_value **argv
980){
981 const unsigned char *z = sqlite3_value_text(argv[0]);
drh1d59d032013-03-01 23:40:26 +0000982 (void)argc;
drhd495d8c2013-02-22 19:34:25 +0000983 if( z && z[0] ) sqlite3_result_int(context, sqlite3Utf8Read(&z));
984}
985
986/*
987** The char() function takes zero or more arguments, each of which is
988** an integer. It constructs a string where each character of the string
989** is the unicode character for the corresponding integer argument.
990*/
991static void charFunc(
992 sqlite3_context *context,
993 int argc,
994 sqlite3_value **argv
995){
996 unsigned char *z, *zOut;
997 int i;
998 zOut = z = sqlite3_malloc( argc*4 );
999 if( z==0 ){
1000 sqlite3_result_error_nomem(context);
1001 return;
1002 }
1003 for(i=0; i<argc; i++){
mistachkinc9545442013-02-26 05:42:30 +00001004 sqlite3_int64 x;
drhd495d8c2013-02-22 19:34:25 +00001005 unsigned c;
1006 x = sqlite3_value_int64(argv[i]);
1007 if( x<0 || x>0x10ffff ) x = 0xfffd;
1008 c = (unsigned)(x & 0x1fffff);
drhfe7a5d12013-03-07 14:00:04 +00001009 if( c<0x00080 ){
1010 *zOut++ = (u8)(c&0xFF);
1011 }else if( c<0x00800 ){
1012 *zOut++ = 0xC0 + (u8)((c>>6)&0x1F);
1013 *zOut++ = 0x80 + (u8)(c & 0x3F);
1014 }else if( c<0x10000 ){
1015 *zOut++ = 0xE0 + (u8)((c>>12)&0x0F);
1016 *zOut++ = 0x80 + (u8)((c>>6) & 0x3F);
1017 *zOut++ = 0x80 + (u8)(c & 0x3F);
drhd495d8c2013-02-22 19:34:25 +00001018 }else{
drhfe7a5d12013-03-07 14:00:04 +00001019 *zOut++ = 0xF0 + (u8)((c>>18) & 0x07);
1020 *zOut++ = 0x80 + (u8)((c>>12) & 0x3F);
1021 *zOut++ = 0x80 + (u8)((c>>6) & 0x3F);
1022 *zOut++ = 0x80 + (u8)(c & 0x3F);
1023 } \
drhd495d8c2013-02-22 19:34:25 +00001024 }
drhfe7a5d12013-03-07 14:00:04 +00001025 sqlite3_result_text(context, (char*)z, (int)(zOut-z), sqlite3_free);
drhd495d8c2013-02-22 19:34:25 +00001026}
1027
1028/*
drh137c7282007-01-29 17:58:28 +00001029** The hex() function. Interpret the argument as a blob. Return
1030** a hexadecimal rendering as text.
1031*/
1032static void hexFunc(
1033 sqlite3_context *context,
1034 int argc,
1035 sqlite3_value **argv
1036){
1037 int i, n;
1038 const unsigned char *pBlob;
1039 char *zHex, *z;
1040 assert( argc==1 );
danielk1977f3d3c272008-11-19 16:52:44 +00001041 UNUSED_PARAMETER(argc);
drh1f0feef2007-05-15 13:27:07 +00001042 pBlob = sqlite3_value_blob(argv[0]);
drh137c7282007-01-29 17:58:28 +00001043 n = sqlite3_value_bytes(argv[0]);
drh1f0feef2007-05-15 13:27:07 +00001044 assert( pBlob==sqlite3_value_blob(argv[0]) ); /* No encoding change */
drhb1a6c3c2008-03-20 16:30:17 +00001045 z = zHex = contextMalloc(context, ((i64)n)*2 + 1);
danielk1977a1644fd2007-08-29 12:31:25 +00001046 if( zHex ){
1047 for(i=0; i<n; i++, pBlob++){
1048 unsigned char c = *pBlob;
1049 *(z++) = hexdigits[(c>>4)&0xf];
1050 *(z++) = hexdigits[c&0xf];
1051 }
1052 *z = 0;
1053 sqlite3_result_text(context, zHex, n*2, sqlite3_free);
drh137c7282007-01-29 17:58:28 +00001054 }
drh137c7282007-01-29 17:58:28 +00001055}
1056
drh26b6d902007-03-17 13:27:54 +00001057/*
drh8cff3822007-05-02 02:08:28 +00001058** The zeroblob(N) function returns a zero-filled blob of size N bytes.
1059*/
1060static void zeroblobFunc(
1061 sqlite3_context *context,
1062 int argc,
1063 sqlite3_value **argv
1064){
drh98640a32007-06-07 19:08:32 +00001065 i64 n;
drh27e62db2009-04-02 10:16:17 +00001066 sqlite3 *db = sqlite3_context_db_handle(context);
drh8cff3822007-05-02 02:08:28 +00001067 assert( argc==1 );
danielk1977f3d3c272008-11-19 16:52:44 +00001068 UNUSED_PARAMETER(argc);
drh98640a32007-06-07 19:08:32 +00001069 n = sqlite3_value_int64(argv[0]);
drh27e62db2009-04-02 10:16:17 +00001070 testcase( n==db->aLimit[SQLITE_LIMIT_LENGTH] );
1071 testcase( n==db->aLimit[SQLITE_LIMIT_LENGTH]+1 );
1072 if( n>db->aLimit[SQLITE_LIMIT_LENGTH] ){
drh98640a32007-06-07 19:08:32 +00001073 sqlite3_result_error_toobig(context);
1074 }else{
drhab2f1f92010-01-11 18:26:42 +00001075 sqlite3_result_zeroblob(context, (int)n); /* IMP: R-00293-64994 */
drh98640a32007-06-07 19:08:32 +00001076 }
drh8cff3822007-05-02 02:08:28 +00001077}
1078
1079/*
drh26b6d902007-03-17 13:27:54 +00001080** The replace() function. Three arguments are all strings: call
1081** them A, B, and C. The result is also a string which is derived
1082** from A by replacing every occurance of B with C. The match
1083** must be exact. Collating sequences are not used.
1084*/
1085static void replaceFunc(
1086 sqlite3_context *context,
1087 int argc,
1088 sqlite3_value **argv
1089){
1090 const unsigned char *zStr; /* The input string A */
1091 const unsigned char *zPattern; /* The pattern string B */
1092 const unsigned char *zRep; /* The replacement string C */
1093 unsigned char *zOut; /* The output */
1094 int nStr; /* Size of zStr */
1095 int nPattern; /* Size of zPattern */
1096 int nRep; /* Size of zRep */
drh2e6400b2007-05-08 15:46:18 +00001097 i64 nOut; /* Maximum size of zOut */
drh26b6d902007-03-17 13:27:54 +00001098 int loopLimit; /* Last zStr[] that might match zPattern[] */
1099 int i, j; /* Loop counters */
1100
1101 assert( argc==3 );
danielk1977f3d3c272008-11-19 16:52:44 +00001102 UNUSED_PARAMETER(argc);
drh26b6d902007-03-17 13:27:54 +00001103 zStr = sqlite3_value_text(argv[0]);
drh7a521cf2007-04-25 18:23:52 +00001104 if( zStr==0 ) return;
drh1f0feef2007-05-15 13:27:07 +00001105 nStr = sqlite3_value_bytes(argv[0]);
1106 assert( zStr==sqlite3_value_text(argv[0]) ); /* No encoding change */
drh26b6d902007-03-17 13:27:54 +00001107 zPattern = sqlite3_value_text(argv[1]);
drha605fe82009-02-01 18:08:40 +00001108 if( zPattern==0 ){
drh23336062009-02-03 13:19:12 +00001109 assert( sqlite3_value_type(argv[1])==SQLITE_NULL
1110 || sqlite3_context_db_handle(context)->mallocFailed );
drha605fe82009-02-01 18:08:40 +00001111 return;
1112 }
1113 if( zPattern[0]==0 ){
1114 assert( sqlite3_value_type(argv[1])!=SQLITE_NULL );
1115 sqlite3_result_value(context, argv[0]);
1116 return;
1117 }
drh1f0feef2007-05-15 13:27:07 +00001118 nPattern = sqlite3_value_bytes(argv[1]);
1119 assert( zPattern==sqlite3_value_text(argv[1]) ); /* No encoding change */
drh26b6d902007-03-17 13:27:54 +00001120 zRep = sqlite3_value_text(argv[2]);
drh7a521cf2007-04-25 18:23:52 +00001121 if( zRep==0 ) return;
drh1f0feef2007-05-15 13:27:07 +00001122 nRep = sqlite3_value_bytes(argv[2]);
1123 assert( zRep==sqlite3_value_text(argv[2]) );
drh2e6400b2007-05-08 15:46:18 +00001124 nOut = nStr + 1;
1125 assert( nOut<SQLITE_MAX_LENGTH );
drhb1a6c3c2008-03-20 16:30:17 +00001126 zOut = contextMalloc(context, (i64)nOut);
drh2e6400b2007-05-08 15:46:18 +00001127 if( zOut==0 ){
1128 return;
drh26b6d902007-03-17 13:27:54 +00001129 }
drh26b6d902007-03-17 13:27:54 +00001130 loopLimit = nStr - nPattern;
1131 for(i=j=0; i<=loopLimit; i++){
1132 if( zStr[i]!=zPattern[0] || memcmp(&zStr[i], zPattern, nPattern) ){
1133 zOut[j++] = zStr[i];
1134 }else{
drh4a50aac2007-08-23 02:47:53 +00001135 u8 *zOld;
drhbb4957f2008-03-20 14:03:29 +00001136 sqlite3 *db = sqlite3_context_db_handle(context);
drh2e6400b2007-05-08 15:46:18 +00001137 nOut += nRep - nPattern;
drh27e62db2009-04-02 10:16:17 +00001138 testcase( nOut-1==db->aLimit[SQLITE_LIMIT_LENGTH] );
1139 testcase( nOut-2==db->aLimit[SQLITE_LIMIT_LENGTH] );
1140 if( nOut-1>db->aLimit[SQLITE_LIMIT_LENGTH] ){
drha0206bc2007-05-08 15:15:02 +00001141 sqlite3_result_error_toobig(context);
drhb9755982010-07-24 16:34:37 +00001142 sqlite3_free(zOut);
danielk197717374e82007-05-08 14:39:04 +00001143 return;
1144 }
drh4a50aac2007-08-23 02:47:53 +00001145 zOld = zOut;
drh2e6400b2007-05-08 15:46:18 +00001146 zOut = sqlite3_realloc(zOut, (int)nOut);
1147 if( zOut==0 ){
danielk1977a1644fd2007-08-29 12:31:25 +00001148 sqlite3_result_error_nomem(context);
drhb9755982010-07-24 16:34:37 +00001149 sqlite3_free(zOld);
drh2e6400b2007-05-08 15:46:18 +00001150 return;
1151 }
drh26b6d902007-03-17 13:27:54 +00001152 memcpy(&zOut[j], zRep, nRep);
1153 j += nRep;
1154 i += nPattern-1;
1155 }
1156 }
drh2e6400b2007-05-08 15:46:18 +00001157 assert( j+nStr-i+1==nOut );
drh26b6d902007-03-17 13:27:54 +00001158 memcpy(&zOut[j], &zStr[i], nStr-i);
1159 j += nStr - i;
1160 assert( j<=nOut );
1161 zOut[j] = 0;
1162 sqlite3_result_text(context, (char*)zOut, j, sqlite3_free);
1163}
1164
drh309b3382007-03-17 17:52:42 +00001165/*
1166** Implementation of the TRIM(), LTRIM(), and RTRIM() functions.
1167** The userdata is 0x1 for left trim, 0x2 for right trim, 0x3 for both.
1168*/
1169static void trimFunc(
1170 sqlite3_context *context,
1171 int argc,
1172 sqlite3_value **argv
1173){
1174 const unsigned char *zIn; /* Input string */
1175 const unsigned char *zCharSet; /* Set of characters to trim */
1176 int nIn; /* Number of bytes in input */
drh7209c692008-04-27 18:40:11 +00001177 int flags; /* 1: trimleft 2: trimright 3: trim */
drhd1e3a612007-04-27 21:59:52 +00001178 int i; /* Loop counter */
drh1bd10f82008-12-10 21:19:56 +00001179 unsigned char *aLen = 0; /* Length of each character in zCharSet */
1180 unsigned char **azChar = 0; /* Individual characters in zCharSet */
drhd1e3a612007-04-27 21:59:52 +00001181 int nChar; /* Number of characters in zCharSet */
1182
drh309b3382007-03-17 17:52:42 +00001183 if( sqlite3_value_type(argv[0])==SQLITE_NULL ){
1184 return;
1185 }
1186 zIn = sqlite3_value_text(argv[0]);
drh7a521cf2007-04-25 18:23:52 +00001187 if( zIn==0 ) return;
drh1f0feef2007-05-15 13:27:07 +00001188 nIn = sqlite3_value_bytes(argv[0]);
1189 assert( zIn==sqlite3_value_text(argv[0]) );
drh309b3382007-03-17 17:52:42 +00001190 if( argc==1 ){
drhd1e3a612007-04-27 21:59:52 +00001191 static const unsigned char lenOne[] = { 1 };
danielk1977a4de4532008-09-02 15:44:08 +00001192 static unsigned char * const azOne[] = { (u8*)" " };
drhd1e3a612007-04-27 21:59:52 +00001193 nChar = 1;
drh8cff3822007-05-02 02:08:28 +00001194 aLen = (u8*)lenOne;
danielk1977bc67da42007-12-11 04:23:19 +00001195 azChar = (unsigned char **)azOne;
drhd1e3a612007-04-27 21:59:52 +00001196 zCharSet = 0;
drh7a521cf2007-04-25 18:23:52 +00001197 }else if( (zCharSet = sqlite3_value_text(argv[1]))==0 ){
drh309b3382007-03-17 17:52:42 +00001198 return;
drhd1e3a612007-04-27 21:59:52 +00001199 }else{
1200 const unsigned char *z;
1201 for(z=zCharSet, nChar=0; *z; nChar++){
drh4a919112007-05-15 11:55:09 +00001202 SQLITE_SKIP_UTF8(z);
drhd1e3a612007-04-27 21:59:52 +00001203 }
1204 if( nChar>0 ){
drhb1a6c3c2008-03-20 16:30:17 +00001205 azChar = contextMalloc(context, ((i64)nChar)*(sizeof(char*)+1));
drhd1e3a612007-04-27 21:59:52 +00001206 if( azChar==0 ){
1207 return;
1208 }
1209 aLen = (unsigned char*)&azChar[nChar];
1210 for(z=zCharSet, nChar=0; *z; nChar++){
danielk1977bc67da42007-12-11 04:23:19 +00001211 azChar[nChar] = (unsigned char *)z;
drh4a919112007-05-15 11:55:09 +00001212 SQLITE_SKIP_UTF8(z);
drh3abbd392008-12-10 23:04:13 +00001213 aLen[nChar] = (u8)(z - azChar[nChar]);
drhd1e3a612007-04-27 21:59:52 +00001214 }
1215 }
drh309b3382007-03-17 17:52:42 +00001216 }
drhd1e3a612007-04-27 21:59:52 +00001217 if( nChar>0 ){
shane1fc41292008-07-08 22:28:48 +00001218 flags = SQLITE_PTR_TO_INT(sqlite3_user_data(context));
drh309b3382007-03-17 17:52:42 +00001219 if( flags & 1 ){
drhd1e3a612007-04-27 21:59:52 +00001220 while( nIn>0 ){
drh1bd10f82008-12-10 21:19:56 +00001221 int len = 0;
drhd1e3a612007-04-27 21:59:52 +00001222 for(i=0; i<nChar; i++){
1223 len = aLen[i];
drh27e62db2009-04-02 10:16:17 +00001224 if( len<=nIn && memcmp(zIn, azChar[i], len)==0 ) break;
drhd1e3a612007-04-27 21:59:52 +00001225 }
1226 if( i>=nChar ) break;
1227 zIn += len;
1228 nIn -= len;
drh309b3382007-03-17 17:52:42 +00001229 }
1230 }
1231 if( flags & 2 ){
drhd1e3a612007-04-27 21:59:52 +00001232 while( nIn>0 ){
drh1bd10f82008-12-10 21:19:56 +00001233 int len = 0;
drhd1e3a612007-04-27 21:59:52 +00001234 for(i=0; i<nChar; i++){
1235 len = aLen[i];
1236 if( len<=nIn && memcmp(&zIn[nIn-len],azChar[i],len)==0 ) break;
1237 }
1238 if( i>=nChar ) break;
1239 nIn -= len;
drh309b3382007-03-17 17:52:42 +00001240 }
1241 }
drhd1e3a612007-04-27 21:59:52 +00001242 if( zCharSet ){
1243 sqlite3_free(azChar);
1244 }
drh309b3382007-03-17 17:52:42 +00001245 }
1246 sqlite3_result_text(context, (char*)zIn, nIn, SQLITE_TRANSIENT);
1247}
drh26b6d902007-03-17 13:27:54 +00001248
danielk1977a4de4532008-09-02 15:44:08 +00001249
drh2ba3ccc2009-12-08 02:06:08 +00001250/* IMP: R-25361-16150 This function is omitted from SQLite by default. It
1251** is only available if the SQLITE_SOUNDEX compile-time option is used
1252** when SQLite is built.
1253*/
drhd24cc422003-03-27 12:51:24 +00001254#ifdef SQLITE_SOUNDEX
1255/*
1256** Compute the soundex encoding of a word.
drh2ba3ccc2009-12-08 02:06:08 +00001257**
1258** IMP: R-59782-00072 The soundex(X) function returns a string that is the
1259** soundex encoding of the string X.
drhd24cc422003-03-27 12:51:24 +00001260*/
drh137c7282007-01-29 17:58:28 +00001261static void soundexFunc(
1262 sqlite3_context *context,
1263 int argc,
1264 sqlite3_value **argv
1265){
drhd24cc422003-03-27 12:51:24 +00001266 char zResult[8];
drh4c755c02004-08-08 20:22:17 +00001267 const u8 *zIn;
drhd24cc422003-03-27 12:51:24 +00001268 int i, j;
1269 static const unsigned char iCode[] = {
1270 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
1271 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
1272 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
1273 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
1274 0, 0, 1, 2, 3, 0, 1, 2, 0, 0, 2, 2, 4, 5, 5, 0,
1275 1, 2, 6, 2, 3, 0, 1, 0, 2, 0, 2, 0, 0, 0, 0, 0,
1276 0, 0, 1, 2, 3, 0, 1, 2, 0, 0, 2, 2, 4, 5, 5, 0,
1277 1, 2, 6, 2, 3, 0, 1, 0, 2, 0, 2, 0, 0, 0, 0, 0,
1278 };
1279 assert( argc==1 );
drh4c755c02004-08-08 20:22:17 +00001280 zIn = (u8*)sqlite3_value_text(argv[0]);
drhbdf67e02006-08-19 11:34:01 +00001281 if( zIn==0 ) zIn = (u8*)"";
drhdc86e2b2009-01-24 11:30:42 +00001282 for(i=0; zIn[i] && !sqlite3Isalpha(zIn[i]); i++){}
drhd24cc422003-03-27 12:51:24 +00001283 if( zIn[i] ){
drhbdf67e02006-08-19 11:34:01 +00001284 u8 prevcode = iCode[zIn[i]&0x7f];
danielk197778ca0e72009-01-20 16:53:39 +00001285 zResult[0] = sqlite3Toupper(zIn[i]);
drhd24cc422003-03-27 12:51:24 +00001286 for(j=1; j<4 && zIn[i]; i++){
1287 int code = iCode[zIn[i]&0x7f];
1288 if( code>0 ){
drhbdf67e02006-08-19 11:34:01 +00001289 if( code!=prevcode ){
1290 prevcode = code;
1291 zResult[j++] = code + '0';
1292 }
1293 }else{
1294 prevcode = 0;
drhd24cc422003-03-27 12:51:24 +00001295 }
1296 }
1297 while( j<4 ){
1298 zResult[j++] = '0';
1299 }
1300 zResult[j] = 0;
danielk1977d8123362004-06-12 09:25:12 +00001301 sqlite3_result_text(context, zResult, 4, SQLITE_TRANSIENT);
drhd24cc422003-03-27 12:51:24 +00001302 }else{
drh2ba3ccc2009-12-08 02:06:08 +00001303 /* IMP: R-64894-50321 The string "?000" is returned if the argument
1304 ** is NULL or contains no ASCII alphabetic characters. */
danielk1977d8123362004-06-12 09:25:12 +00001305 sqlite3_result_text(context, "?000", 4, SQLITE_STATIC);
drhd24cc422003-03-27 12:51:24 +00001306 }
1307}
drh2ba3ccc2009-12-08 02:06:08 +00001308#endif /* SQLITE_SOUNDEX */
drhd24cc422003-03-27 12:51:24 +00001309
drhfdb83b22006-06-17 14:12:47 +00001310#ifndef SQLITE_OMIT_LOAD_EXTENSION
1311/*
1312** A function that loads a shared-library extension then returns NULL.
1313*/
1314static void loadExt(sqlite3_context *context, int argc, sqlite3_value **argv){
danielk197765fd59f2006-06-24 11:51:33 +00001315 const char *zFile = (const char *)sqlite3_value_text(argv[0]);
drh7a521cf2007-04-25 18:23:52 +00001316 const char *zProc;
drhfa4a4b92008-03-19 21:45:51 +00001317 sqlite3 *db = sqlite3_context_db_handle(context);
drhfdb83b22006-06-17 14:12:47 +00001318 char *zErrMsg = 0;
1319
1320 if( argc==2 ){
danielk197765fd59f2006-06-24 11:51:33 +00001321 zProc = (const char *)sqlite3_value_text(argv[1]);
drh7a521cf2007-04-25 18:23:52 +00001322 }else{
1323 zProc = 0;
drhfdb83b22006-06-17 14:12:47 +00001324 }
drh7a521cf2007-04-25 18:23:52 +00001325 if( zFile && sqlite3_load_extension(db, zFile, zProc, &zErrMsg) ){
drhfdb83b22006-06-17 14:12:47 +00001326 sqlite3_result_error(context, zErrMsg, -1);
1327 sqlite3_free(zErrMsg);
1328 }
1329}
1330#endif
1331
danielk197701427a62005-01-11 13:02:33 +00001332
drh0ac65892002-04-20 14:24:41 +00001333/*
drhd3a149e2002-02-24 17:12:53 +00001334** An instance of the following structure holds the context of a
drhdd5baa92002-02-27 19:50:59 +00001335** sum() or avg() aggregate computation.
1336*/
1337typedef struct SumCtx SumCtx;
1338struct SumCtx {
drh8c08e862006-02-11 17:34:00 +00001339 double rSum; /* Floating point sum */
1340 i64 iSum; /* Integer sum */
1341 i64 cnt; /* Number of elements summed */
1342 u8 overflow; /* True if integer overflow seen */
1343 u8 approx; /* True if non-integer value was input to the sum */
drhdd5baa92002-02-27 19:50:59 +00001344};
1345
1346/*
drha97fdd32006-01-12 22:17:50 +00001347** Routines used to compute the sum, average, and total.
1348**
1349** The SUM() function follows the (broken) SQL standard which means
1350** that it returns NULL if it sums over no inputs. TOTAL returns
1351** 0.0 in that case. In addition, TOTAL always returns a float where
1352** SUM might return an integer if it never encounters a floating point
drhc806d852006-05-11 13:25:39 +00001353** value. TOTAL never fails, but SUM might through an exception if
1354** it overflows an integer.
drhdd5baa92002-02-27 19:50:59 +00001355*/
danielk19770ae8b832004-05-25 12:05:56 +00001356static void sumStep(sqlite3_context *context, int argc, sqlite3_value **argv){
drhdd5baa92002-02-27 19:50:59 +00001357 SumCtx *p;
drh3d1d95e2005-09-08 10:37:01 +00001358 int type;
drh3f219f42005-09-08 19:45:57 +00001359 assert( argc==1 );
danielk1977f3d3c272008-11-19 16:52:44 +00001360 UNUSED_PARAMETER(argc);
drh4f26d6c2004-05-26 23:25:30 +00001361 p = sqlite3_aggregate_context(context, sizeof(*p));
drh29d72102006-02-09 22:13:41 +00001362 type = sqlite3_value_numeric_type(argv[0]);
drh3d1d95e2005-09-08 10:37:01 +00001363 if( p && type!=SQLITE_NULL ){
drh739105c2002-05-29 23:22:23 +00001364 p->cnt++;
drh29d72102006-02-09 22:13:41 +00001365 if( type==SQLITE_INTEGER ){
drh8c08e862006-02-11 17:34:00 +00001366 i64 v = sqlite3_value_int64(argv[0]);
1367 p->rSum += v;
drh158b9cb2011-03-05 20:59:46 +00001368 if( (p->approx|p->overflow)==0 && sqlite3AddInt64(&p->iSum, v) ){
1369 p->overflow = 1;
drh29d72102006-02-09 22:13:41 +00001370 }
1371 }else{
drh8c08e862006-02-11 17:34:00 +00001372 p->rSum += sqlite3_value_double(argv[0]);
drh29d72102006-02-09 22:13:41 +00001373 p->approx = 1;
drh3f219f42005-09-08 19:45:57 +00001374 }
drh739105c2002-05-29 23:22:23 +00001375 }
drhdd5baa92002-02-27 19:50:59 +00001376}
danielk19770ae8b832004-05-25 12:05:56 +00001377static void sumFinalize(sqlite3_context *context){
drhdd5baa92002-02-27 19:50:59 +00001378 SumCtx *p;
drhabfcea22005-09-06 20:36:48 +00001379 p = sqlite3_aggregate_context(context, 0);
drhc2bd9132005-09-08 20:37:43 +00001380 if( p && p->cnt>0 ){
drh8c08e862006-02-11 17:34:00 +00001381 if( p->overflow ){
1382 sqlite3_result_error(context,"integer overflow",-1);
1383 }else if( p->approx ){
1384 sqlite3_result_double(context, p->rSum);
drhc2bd9132005-09-08 20:37:43 +00001385 }else{
drh8c08e862006-02-11 17:34:00 +00001386 sqlite3_result_int64(context, p->iSum);
drhc2bd9132005-09-08 20:37:43 +00001387 }
drh3d1d95e2005-09-08 10:37:01 +00001388 }
drhdd5baa92002-02-27 19:50:59 +00001389}
danielk19770ae8b832004-05-25 12:05:56 +00001390static void avgFinalize(sqlite3_context *context){
drhdd5baa92002-02-27 19:50:59 +00001391 SumCtx *p;
drhabfcea22005-09-06 20:36:48 +00001392 p = sqlite3_aggregate_context(context, 0);
drh739105c2002-05-29 23:22:23 +00001393 if( p && p->cnt>0 ){
drh8c08e862006-02-11 17:34:00 +00001394 sqlite3_result_double(context, p->rSum/(double)p->cnt);
drhdd5baa92002-02-27 19:50:59 +00001395 }
1396}
drha97fdd32006-01-12 22:17:50 +00001397static void totalFinalize(sqlite3_context *context){
1398 SumCtx *p;
1399 p = sqlite3_aggregate_context(context, 0);
shanefbd60f82009-02-04 03:59:25 +00001400 /* (double)0 In case of SQLITE_OMIT_FLOATING_POINT... */
1401 sqlite3_result_double(context, p ? p->rSum : (double)0);
drha97fdd32006-01-12 22:17:50 +00001402}
drhdd5baa92002-02-27 19:50:59 +00001403
1404/*
drh0bce8352002-02-28 00:41:10 +00001405** The following structure keeps track of state information for the
1406** count() aggregate function.
1407*/
1408typedef struct CountCtx CountCtx;
1409struct CountCtx {
drhfc6ad392006-02-09 13:38:19 +00001410 i64 n;
drh0bce8352002-02-28 00:41:10 +00001411};
drhdd5baa92002-02-27 19:50:59 +00001412
drh0bce8352002-02-28 00:41:10 +00001413/*
1414** Routines to implement the count() aggregate function.
1415*/
danielk19770ae8b832004-05-25 12:05:56 +00001416static void countStep(sqlite3_context *context, int argc, sqlite3_value **argv){
drh0bce8352002-02-28 00:41:10 +00001417 CountCtx *p;
drh4f26d6c2004-05-26 23:25:30 +00001418 p = sqlite3_aggregate_context(context, sizeof(*p));
drh9c054832004-05-31 18:51:57 +00001419 if( (argc==0 || SQLITE_NULL!=sqlite3_value_type(argv[0])) && p ){
drh0bce8352002-02-28 00:41:10 +00001420 p->n++;
1421 }
drh2e79c3d2009-04-08 23:04:14 +00001422
drhd3264c72009-04-15 13:39:47 +00001423#ifndef SQLITE_OMIT_DEPRECATED
drh2e79c3d2009-04-08 23:04:14 +00001424 /* The sqlite3_aggregate_count() function is deprecated. But just to make
1425 ** sure it still operates correctly, verify that its count agrees with our
1426 ** internal count when using count(*) and when the total count can be
1427 ** expressed as a 32-bit integer. */
1428 assert( argc==1 || p==0 || p->n>0x7fffffff
1429 || p->n==sqlite3_aggregate_count(context) );
drhd3264c72009-04-15 13:39:47 +00001430#endif
drh0bce8352002-02-28 00:41:10 +00001431}
danielk19770ae8b832004-05-25 12:05:56 +00001432static void countFinalize(sqlite3_context *context){
drh0bce8352002-02-28 00:41:10 +00001433 CountCtx *p;
drhabfcea22005-09-06 20:36:48 +00001434 p = sqlite3_aggregate_context(context, 0);
drhfc6ad392006-02-09 13:38:19 +00001435 sqlite3_result_int64(context, p ? p->n : 0);
drh0bce8352002-02-28 00:41:10 +00001436}
1437
1438/*
drh0bce8352002-02-28 00:41:10 +00001439** Routines to implement min() and max() aggregate functions.
1440*/
danielk197762c14b32008-11-19 09:05:26 +00001441static void minmaxStep(
1442 sqlite3_context *context,
1443 int NotUsed,
1444 sqlite3_value **argv
1445){
danielk197788208052004-05-25 01:13:20 +00001446 Mem *pArg = (Mem *)argv[0];
drh9eb516c2004-07-18 20:52:32 +00001447 Mem *pBest;
danielk197762c14b32008-11-19 09:05:26 +00001448 UNUSED_PARAMETER(NotUsed);
drh9eb516c2004-07-18 20:52:32 +00001449
drh9eb516c2004-07-18 20:52:32 +00001450 pBest = (Mem *)sqlite3_aggregate_context(context, sizeof(*pBest));
danielk19773aeab9e2004-06-24 00:20:04 +00001451 if( !pBest ) return;
drh268380c2004-02-25 13:47:31 +00001452
drh94a6d992012-02-02 18:42:09 +00001453 if( sqlite3_value_type(argv[0])==SQLITE_NULL ){
1454 if( pBest->flags ) sqlite3SkipAccumulatorLoad(context);
1455 }else if( pBest->flags ){
drh9eb516c2004-07-18 20:52:32 +00001456 int max;
1457 int cmp;
danielk1977dc1bdc42004-06-11 10:51:27 +00001458 CollSeq *pColl = sqlite3GetFuncCollSeq(context);
danielk19777e18c252004-05-25 11:47:24 +00001459 /* This step function is used for both the min() and max() aggregates,
1460 ** the only difference between the two being that the sense of the
1461 ** comparison is inverted. For the max() aggregate, the
1462 ** sqlite3_user_data() function returns (void *)-1. For min() it
1463 ** returns (void *)db, where db is the sqlite3* database pointer.
1464 ** Therefore the next statement sets variable 'max' to 1 for the max()
1465 ** aggregate, or 0 for min().
1466 */
drh309b3382007-03-17 17:52:42 +00001467 max = sqlite3_user_data(context)!=0;
danielk1977dc1bdc42004-06-11 10:51:27 +00001468 cmp = sqlite3MemCompare(pBest, pArg, pColl);
danielk197788208052004-05-25 01:13:20 +00001469 if( (max && cmp<0) || (!max && cmp>0) ){
drhb21c8cd2007-08-21 19:33:56 +00001470 sqlite3VdbeMemCopy(pBest, pArg);
drh7a957892012-02-02 17:35:43 +00001471 }else{
1472 sqlite3SkipAccumulatorLoad(context);
danielk197788208052004-05-25 01:13:20 +00001473 }
drh268380c2004-02-25 13:47:31 +00001474 }else{
drhb21c8cd2007-08-21 19:33:56 +00001475 sqlite3VdbeMemCopy(pBest, pArg);
drh0bce8352002-02-28 00:41:10 +00001476 }
1477}
danielk19770ae8b832004-05-25 12:05:56 +00001478static void minMaxFinalize(sqlite3_context *context){
danielk197788208052004-05-25 01:13:20 +00001479 sqlite3_value *pRes;
drhabfcea22005-09-06 20:36:48 +00001480 pRes = (sqlite3_value *)sqlite3_aggregate_context(context, 0);
1481 if( pRes ){
drh94a6d992012-02-02 18:42:09 +00001482 if( pRes->flags ){
drhabfcea22005-09-06 20:36:48 +00001483 sqlite3_result_value(context, pRes);
1484 }
1485 sqlite3VdbeMemRelease(pRes);
drh0bce8352002-02-28 00:41:10 +00001486 }
1487}
drhdd5baa92002-02-27 19:50:59 +00001488
drhb0689692007-11-01 17:38:30 +00001489/*
1490** group_concat(EXPR, ?SEPARATOR?)
1491*/
1492static void groupConcatStep(
1493 sqlite3_context *context,
1494 int argc,
1495 sqlite3_value **argv
1496){
1497 const char *zVal;
drhade86482007-11-28 22:36:40 +00001498 StrAccum *pAccum;
drhb0689692007-11-01 17:38:30 +00001499 const char *zSep;
drh07d31172009-02-02 21:57:05 +00001500 int nVal, nSep;
1501 assert( argc==1 || argc==2 );
1502 if( sqlite3_value_type(argv[0])==SQLITE_NULL ) return;
drhade86482007-11-28 22:36:40 +00001503 pAccum = (StrAccum*)sqlite3_aggregate_context(context, sizeof(*pAccum));
1504
1505 if( pAccum ){
drhbb4957f2008-03-20 14:03:29 +00001506 sqlite3 *db = sqlite3_context_db_handle(context);
drh8bfd7192009-06-19 16:44:41 +00001507 int firstTerm = pAccum->useMalloc==0;
drhb9755982010-07-24 16:34:37 +00001508 pAccum->useMalloc = 2;
drhbb4957f2008-03-20 14:03:29 +00001509 pAccum->mxAlloc = db->aLimit[SQLITE_LIMIT_LENGTH];
drh8bfd7192009-06-19 16:44:41 +00001510 if( !firstTerm ){
drh07d31172009-02-02 21:57:05 +00001511 if( argc==2 ){
1512 zSep = (char*)sqlite3_value_text(argv[1]);
1513 nSep = sqlite3_value_bytes(argv[1]);
drhb0689692007-11-01 17:38:30 +00001514 }else{
1515 zSep = ",";
drhade86482007-11-28 22:36:40 +00001516 nSep = 1;
drhb0689692007-11-01 17:38:30 +00001517 }
drhade86482007-11-28 22:36:40 +00001518 sqlite3StrAccumAppend(pAccum, zSep, nSep);
drhb0689692007-11-01 17:38:30 +00001519 }
drh07d31172009-02-02 21:57:05 +00001520 zVal = (char*)sqlite3_value_text(argv[0]);
1521 nVal = sqlite3_value_bytes(argv[0]);
1522 sqlite3StrAccumAppend(pAccum, zVal, nVal);
drhb0689692007-11-01 17:38:30 +00001523 }
1524}
1525static void groupConcatFinalize(sqlite3_context *context){
drhade86482007-11-28 22:36:40 +00001526 StrAccum *pAccum;
1527 pAccum = sqlite3_aggregate_context(context, 0);
1528 if( pAccum ){
1529 if( pAccum->tooBig ){
1530 sqlite3_result_error_toobig(context);
1531 }else if( pAccum->mallocFailed ){
1532 sqlite3_result_error_nomem(context);
1533 }else{
1534 sqlite3_result_text(context, sqlite3StrAccumFinish(pAccum), -1,
1535 sqlite3_free);
1536 }
drhb0689692007-11-01 17:38:30 +00001537 }
1538}
drh4e5ffc52004-08-31 00:52:37 +00001539
drhd3a149e2002-02-24 17:12:53 +00001540/*
drha4741842010-04-25 20:58:37 +00001541** This routine does per-connection function registration. Most
1542** of the built-in functions above are part of the global function set.
1543** This routine only deals with those that are not global.
drhdc04c582002-02-24 01:55:15 +00001544*/
drh9bb575f2004-09-06 17:24:11 +00001545void sqlite3RegisterBuiltinFunctions(sqlite3 *db){
drha4741842010-04-25 20:58:37 +00001546 int rc = sqlite3_overload_function(db, "MATCH", 2);
1547 assert( rc==SQLITE_NOMEM || rc==SQLITE_OK );
1548 if( rc==SQLITE_NOMEM ){
1549 db->mallocFailed = 1;
danielk1977832a58a2007-06-22 15:21:15 +00001550 }
drh55ef4d92005-08-14 01:20:37 +00001551}
1552
1553/*
1554** Set the LIKEOPT flag on the 2-argument function with the given name.
1555*/
drh1bd10f82008-12-10 21:19:56 +00001556static void setLikeOptFlag(sqlite3 *db, const char *zName, u8 flagVal){
drh55ef4d92005-08-14 01:20:37 +00001557 FuncDef *pDef;
drhea678832008-12-10 19:26:22 +00001558 pDef = sqlite3FindFunction(db, zName, sqlite3Strlen30(zName),
1559 2, SQLITE_UTF8, 0);
drhd27135a2009-04-02 13:36:37 +00001560 if( ALWAYS(pDef) ){
drhd64fe2f2005-08-28 17:00:23 +00001561 pDef->flags = flagVal;
drh55ef4d92005-08-14 01:20:37 +00001562 }
1563}
1564
1565/*
1566** Register the built-in LIKE and GLOB functions. The caseSensitive
1567** parameter determines whether or not the LIKE operator is case
1568** sensitive. GLOB is always case sensitive.
1569*/
1570void sqlite3RegisterLikeFunctions(sqlite3 *db, int caseSensitive){
1571 struct compareInfo *pInfo;
1572 if( caseSensitive ){
1573 pInfo = (struct compareInfo*)&likeInfoAlt;
1574 }else{
1575 pInfo = (struct compareInfo*)&likeInfoNorm;
1576 }
drh901e9942010-12-15 18:54:37 +00001577 sqlite3CreateFunc(db, "like", 2, SQLITE_UTF8, pInfo, likeFunc, 0, 0, 0);
1578 sqlite3CreateFunc(db, "like", 3, SQLITE_UTF8, pInfo, likeFunc, 0, 0, 0);
1579 sqlite3CreateFunc(db, "glob", 2, SQLITE_UTF8,
dand2199f02010-08-27 17:48:52 +00001580 (struct compareInfo*)&globInfo, likeFunc, 0, 0, 0);
drhd64fe2f2005-08-28 17:00:23 +00001581 setLikeOptFlag(db, "glob", SQLITE_FUNC_LIKE | SQLITE_FUNC_CASE);
1582 setLikeOptFlag(db, "like",
1583 caseSensitive ? (SQLITE_FUNC_LIKE | SQLITE_FUNC_CASE) : SQLITE_FUNC_LIKE);
drh55ef4d92005-08-14 01:20:37 +00001584}
1585
1586/*
1587** pExpr points to an expression which implements a function. If
1588** it is appropriate to apply the LIKE optimization to that function
1589** then set aWc[0] through aWc[2] to the wildcard characters and
1590** return TRUE. If the function is not a LIKE-style function then
1591** return FALSE.
1592*/
drhd64fe2f2005-08-28 17:00:23 +00001593int sqlite3IsLikeFunction(sqlite3 *db, Expr *pExpr, int *pIsNocase, char *aWc){
drh55ef4d92005-08-14 01:20:37 +00001594 FuncDef *pDef;
danielk19776ab3a2e2009-02-19 14:39:25 +00001595 if( pExpr->op!=TK_FUNCTION
1596 || !pExpr->x.pList
1597 || pExpr->x.pList->nExpr!=2
1598 ){
drh55ef4d92005-08-14 01:20:37 +00001599 return 0;
1600 }
danielk19776ab3a2e2009-02-19 14:39:25 +00001601 assert( !ExprHasProperty(pExpr, EP_xIsSelect) );
drh33e619f2009-05-28 01:00:55 +00001602 pDef = sqlite3FindFunction(db, pExpr->u.zToken,
1603 sqlite3Strlen30(pExpr->u.zToken),
drhb7916a72009-05-27 10:31:29 +00001604 2, SQLITE_UTF8, 0);
drhd27135a2009-04-02 13:36:37 +00001605 if( NEVER(pDef==0) || (pDef->flags & SQLITE_FUNC_LIKE)==0 ){
drh55ef4d92005-08-14 01:20:37 +00001606 return 0;
1607 }
1608
1609 /* The memcpy() statement assumes that the wildcard characters are
1610 ** the first three statements in the compareInfo structure. The
1611 ** asserts() that follow verify that assumption
1612 */
1613 memcpy(aWc, pDef->pUserData, 3);
1614 assert( (char*)&likeInfoAlt == (char*)&likeInfoAlt.matchAll );
1615 assert( &((char*)&likeInfoAlt)[1] == (char*)&likeInfoAlt.matchOne );
1616 assert( &((char*)&likeInfoAlt)[2] == (char*)&likeInfoAlt.matchSet );
drhd64fe2f2005-08-28 17:00:23 +00001617 *pIsNocase = (pDef->flags & SQLITE_FUNC_CASE)==0;
drh55ef4d92005-08-14 01:20:37 +00001618 return 1;
drhdc04c582002-02-24 01:55:15 +00001619}
danielk19778c0a7912008-08-20 14:49:23 +00001620
drh70a8ca32008-08-21 18:49:27 +00001621/*
drh777c5382008-08-21 20:21:34 +00001622** All all of the FuncDef structures in the aBuiltinFunc[] array above
1623** to the global function hash table. This occurs at start-time (as
1624** a consequence of calling sqlite3_initialize()).
1625**
1626** After this routine runs
drh70a8ca32008-08-21 18:49:27 +00001627*/
1628void sqlite3RegisterGlobalFunctions(void){
danielk197793ce7412008-09-01 19:14:02 +00001629 /*
1630 ** The following array holds FuncDef structures for all of the functions
1631 ** defined in this file.
1632 **
1633 ** The array cannot be constant since changes are made to the
1634 ** FuncDef.pHash elements at start-time. The elements of this array
1635 ** are read-only after initialization is complete.
1636 */
1637 static SQLITE_WSD FuncDef aBuiltinFunc[] = {
1638 FUNCTION(ltrim, 1, 1, 0, trimFunc ),
1639 FUNCTION(ltrim, 2, 1, 0, trimFunc ),
1640 FUNCTION(rtrim, 1, 2, 0, trimFunc ),
1641 FUNCTION(rtrim, 2, 2, 0, trimFunc ),
1642 FUNCTION(trim, 1, 3, 0, trimFunc ),
1643 FUNCTION(trim, 2, 3, 0, trimFunc ),
1644 FUNCTION(min, -1, 0, 1, minmaxFunc ),
1645 FUNCTION(min, 0, 0, 1, 0 ),
1646 AGGREGATE(min, 1, 0, 1, minmaxStep, minMaxFinalize ),
1647 FUNCTION(max, -1, 1, 1, minmaxFunc ),
1648 FUNCTION(max, 0, 1, 1, 0 ),
1649 AGGREGATE(max, 1, 1, 1, minmaxStep, minMaxFinalize ),
drha748fdc2012-03-28 01:34:47 +00001650 FUNCTION2(typeof, 1, 0, 0, typeofFunc, SQLITE_FUNC_TYPEOF),
1651 FUNCTION2(length, 1, 0, 0, lengthFunc, SQLITE_FUNC_LENGTH),
drhd55e0722012-10-25 03:07:29 +00001652 FUNCTION(instr, 2, 0, 0, instrFunc ),
danielk197793ce7412008-09-01 19:14:02 +00001653 FUNCTION(substr, 2, 0, 0, substrFunc ),
1654 FUNCTION(substr, 3, 0, 0, substrFunc ),
drhd495d8c2013-02-22 19:34:25 +00001655 FUNCTION(unicode, 1, 0, 0, unicodeFunc ),
1656 FUNCTION(char, -1, 0, 0, charFunc ),
danielk197793ce7412008-09-01 19:14:02 +00001657 FUNCTION(abs, 1, 0, 0, absFunc ),
shanefbd60f82009-02-04 03:59:25 +00001658#ifndef SQLITE_OMIT_FLOATING_POINT
danielk197793ce7412008-09-01 19:14:02 +00001659 FUNCTION(round, 1, 0, 0, roundFunc ),
1660 FUNCTION(round, 2, 0, 0, roundFunc ),
shanefbd60f82009-02-04 03:59:25 +00001661#endif
danielk197793ce7412008-09-01 19:14:02 +00001662 FUNCTION(upper, 1, 0, 0, upperFunc ),
1663 FUNCTION(lower, 1, 0, 0, lowerFunc ),
1664 FUNCTION(coalesce, 1, 0, 0, 0 ),
danielk197793ce7412008-09-01 19:14:02 +00001665 FUNCTION(coalesce, 0, 0, 0, 0 ),
drha748fdc2012-03-28 01:34:47 +00001666 FUNCTION2(coalesce, -1, 0, 0, ifnullFunc, SQLITE_FUNC_COALESCE),
danielk197793ce7412008-09-01 19:14:02 +00001667 FUNCTION(hex, 1, 0, 0, hexFunc ),
drha748fdc2012-03-28 01:34:47 +00001668 FUNCTION2(ifnull, 2, 0, 0, ifnullFunc, SQLITE_FUNC_COALESCE),
drh9373b012009-02-02 01:50:39 +00001669 FUNCTION(random, 0, 0, 0, randomFunc ),
danielk197793ce7412008-09-01 19:14:02 +00001670 FUNCTION(randomblob, 1, 0, 0, randomBlob ),
1671 FUNCTION(nullif, 2, 0, 1, nullifFunc ),
1672 FUNCTION(sqlite_version, 0, 0, 0, versionFunc ),
drh47baebc2009-08-14 16:01:24 +00001673 FUNCTION(sqlite_source_id, 0, 0, 0, sourceidFunc ),
drh840561f2011-04-27 18:08:42 +00001674 FUNCTION(sqlite_log, 2, 0, 0, errlogFunc ),
shanehdc97a8c2010-02-23 20:08:35 +00001675#ifndef SQLITE_OMIT_COMPILEOPTION_DIAGS
drh8bb76d32010-02-26 16:37:47 +00001676 FUNCTION(sqlite_compileoption_used,1, 0, 0, compileoptionusedFunc ),
1677 FUNCTION(sqlite_compileoption_get, 1, 0, 0, compileoptiongetFunc ),
shanehdc97a8c2010-02-23 20:08:35 +00001678#endif /* SQLITE_OMIT_COMPILEOPTION_DIAGS */
danielk197793ce7412008-09-01 19:14:02 +00001679 FUNCTION(quote, 1, 0, 0, quoteFunc ),
1680 FUNCTION(last_insert_rowid, 0, 0, 0, last_insert_rowid),
1681 FUNCTION(changes, 0, 0, 0, changes ),
1682 FUNCTION(total_changes, 0, 0, 0, total_changes ),
1683 FUNCTION(replace, 3, 0, 0, replaceFunc ),
1684 FUNCTION(zeroblob, 1, 0, 0, zeroblobFunc ),
1685 #ifdef SQLITE_SOUNDEX
1686 FUNCTION(soundex, 1, 0, 0, soundexFunc ),
1687 #endif
1688 #ifndef SQLITE_OMIT_LOAD_EXTENSION
1689 FUNCTION(load_extension, 1, 0, 0, loadExt ),
1690 FUNCTION(load_extension, 2, 0, 0, loadExt ),
1691 #endif
1692 AGGREGATE(sum, 1, 0, 0, sumStep, sumFinalize ),
1693 AGGREGATE(total, 1, 0, 0, sumStep, totalFinalize ),
1694 AGGREGATE(avg, 1, 0, 0, sumStep, avgFinalize ),
danielk1977a5533162009-02-24 10:01:51 +00001695 /* AGGREGATE(count, 0, 0, 0, countStep, countFinalize ), */
drh6ac78a02010-09-28 14:26:36 +00001696 {0,SQLITE_UTF8,SQLITE_FUNC_COUNT,0,0,0,countStep,countFinalize,"count",0,0},
danielk197793ce7412008-09-01 19:14:02 +00001697 AGGREGATE(count, 1, 0, 0, countStep, countFinalize ),
drh07d31172009-02-02 21:57:05 +00001698 AGGREGATE(group_concat, 1, 0, 0, groupConcatStep, groupConcatFinalize),
1699 AGGREGATE(group_concat, 2, 0, 0, groupConcatStep, groupConcatFinalize),
danielk197793ce7412008-09-01 19:14:02 +00001700
1701 LIKEFUNC(glob, 2, &globInfo, SQLITE_FUNC_LIKE|SQLITE_FUNC_CASE),
1702 #ifdef SQLITE_CASE_SENSITIVE_LIKE
1703 LIKEFUNC(like, 2, &likeInfoAlt, SQLITE_FUNC_LIKE|SQLITE_FUNC_CASE),
1704 LIKEFUNC(like, 3, &likeInfoAlt, SQLITE_FUNC_LIKE|SQLITE_FUNC_CASE),
1705 #else
1706 LIKEFUNC(like, 2, &likeInfoNorm, SQLITE_FUNC_LIKE),
1707 LIKEFUNC(like, 3, &likeInfoNorm, SQLITE_FUNC_LIKE),
1708 #endif
1709 };
1710
drh70a8ca32008-08-21 18:49:27 +00001711 int i;
danielk197793ce7412008-09-01 19:14:02 +00001712 FuncDefHash *pHash = &GLOBAL(FuncDefHash, sqlite3GlobalFunctions);
drh106cee52008-09-03 17:11:16 +00001713 FuncDef *aFunc = (FuncDef*)&GLOBAL(FuncDef, aBuiltinFunc);
danielk197793ce7412008-09-01 19:14:02 +00001714
drh70a8ca32008-08-21 18:49:27 +00001715 for(i=0; i<ArraySize(aBuiltinFunc); i++){
danielk197793ce7412008-09-01 19:14:02 +00001716 sqlite3FuncDefInsert(pHash, &aFunc[i]);
drh70a8ca32008-08-21 18:49:27 +00001717 }
drh777c5382008-08-21 20:21:34 +00001718 sqlite3RegisterDateTimeFunctions();
drh545f5872010-04-24 14:02:59 +00001719#ifndef SQLITE_OMIT_ALTERTABLE
1720 sqlite3AlterFunctions();
1721#endif
drh70a8ca32008-08-21 18:49:27 +00001722}