xref: /sqlite-3.40.0/src/callback.c (revision e501b89a)
1fd9a0a45Sdanielk1977 /*
2fd9a0a45Sdanielk1977 ** 2005 May 23
3fd9a0a45Sdanielk1977 **
4fd9a0a45Sdanielk1977 ** The author disclaims copyright to this source code.  In place of
5fd9a0a45Sdanielk1977 ** a legal notice, here is a blessing:
6fd9a0a45Sdanielk1977 **
7fd9a0a45Sdanielk1977 **    May you do good and not evil.
8fd9a0a45Sdanielk1977 **    May you find forgiveness for yourself and forgive others.
9fd9a0a45Sdanielk1977 **    May you share freely, never taking more than you give.
10fd9a0a45Sdanielk1977 **
11fd9a0a45Sdanielk1977 *************************************************************************
12fd9a0a45Sdanielk1977 **
13fd9a0a45Sdanielk1977 ** This file contains functions used to access the internal hash tables
14fd9a0a45Sdanielk1977 ** of user defined functions and collation sequences.
15fd9a0a45Sdanielk1977 **
16*e501b89aSdanielk1977 ** $Id: callback.c,v 1.8 2006/01/09 06:29:48 danielk1977 Exp $
17fd9a0a45Sdanielk1977 */
18fd9a0a45Sdanielk1977 
19fd9a0a45Sdanielk1977 #include "sqliteInt.h"
20fd9a0a45Sdanielk1977 
21fd9a0a45Sdanielk1977 /*
224dade037Sdanielk1977 ** Invoke the 'collation needed' callback to request a collation sequence
234dade037Sdanielk1977 ** in the database text encoding of name zName, length nName.
244dade037Sdanielk1977 ** If the collation sequence
254dade037Sdanielk1977 */
264dade037Sdanielk1977 static void callCollNeeded(sqlite3 *db, const char *zName, int nName){
274dade037Sdanielk1977   assert( !db->xCollNeeded || !db->xCollNeeded16 );
284dade037Sdanielk1977   if( nName<0 ) nName = strlen(zName);
294dade037Sdanielk1977   if( db->xCollNeeded ){
304dade037Sdanielk1977     char *zExternal = sqliteStrNDup(zName, nName);
314dade037Sdanielk1977     if( !zExternal ) return;
324dade037Sdanielk1977     db->xCollNeeded(db->pCollNeededArg, db, (int)db->enc, zExternal);
334dade037Sdanielk1977     sqliteFree(zExternal);
344dade037Sdanielk1977   }
354dade037Sdanielk1977 #ifndef SQLITE_OMIT_UTF16
364dade037Sdanielk1977   if( db->xCollNeeded16 ){
374dade037Sdanielk1977     char const *zExternal;
3826abcb1eSdrh     sqlite3_value *pTmp = sqlite3ValueNew();
39268803a9Sdrh     sqlite3ValueSetStr(pTmp, nName, zName, SQLITE_UTF8, SQLITE_STATIC);
404dade037Sdanielk1977     zExternal = sqlite3ValueText(pTmp, SQLITE_UTF16NATIVE);
4126abcb1eSdrh     if( zExternal ){
424dade037Sdanielk1977       db->xCollNeeded16(db->pCollNeededArg, db, (int)db->enc, zExternal);
434dade037Sdanielk1977     }
4426abcb1eSdrh     sqlite3ValueFree(pTmp);
4526abcb1eSdrh   }
464dade037Sdanielk1977 #endif
474dade037Sdanielk1977 }
484dade037Sdanielk1977 
494dade037Sdanielk1977 /*
504dade037Sdanielk1977 ** This routine is called if the collation factory fails to deliver a
514dade037Sdanielk1977 ** collation function in the best encoding but there may be other versions
524dade037Sdanielk1977 ** of this collation function (for other text encodings) available. Use one
534dade037Sdanielk1977 ** of these instead if they exist. Avoid a UTF-8 <-> UTF-16 conversion if
544dade037Sdanielk1977 ** possible.
554dade037Sdanielk1977 */
564dade037Sdanielk1977 static int synthCollSeq(sqlite3 *db, CollSeq *pColl){
574dade037Sdanielk1977   CollSeq *pColl2;
584dade037Sdanielk1977   char *z = pColl->zName;
594dade037Sdanielk1977   int n = strlen(z);
604dade037Sdanielk1977   int i;
614dade037Sdanielk1977   static const u8 aEnc[] = { SQLITE_UTF16BE, SQLITE_UTF16LE, SQLITE_UTF8 };
624dade037Sdanielk1977   for(i=0; i<3; i++){
634dade037Sdanielk1977     pColl2 = sqlite3FindCollSeq(db, aEnc[i], z, n, 0);
644dade037Sdanielk1977     if( pColl2->xCmp!=0 ){
654dade037Sdanielk1977       memcpy(pColl, pColl2, sizeof(CollSeq));
664dade037Sdanielk1977       return SQLITE_OK;
674dade037Sdanielk1977     }
684dade037Sdanielk1977   }
694dade037Sdanielk1977   return SQLITE_ERROR;
704dade037Sdanielk1977 }
714dade037Sdanielk1977 
724dade037Sdanielk1977 /*
734dade037Sdanielk1977 ** This function is responsible for invoking the collation factory callback
744dade037Sdanielk1977 ** or substituting a collation sequence of a different encoding when the
754dade037Sdanielk1977 ** requested collation sequence is not available in the database native
764dade037Sdanielk1977 ** encoding.
774dade037Sdanielk1977 **
784dade037Sdanielk1977 ** If it is not NULL, then pColl must point to the database native encoding
794dade037Sdanielk1977 ** collation sequence with name zName, length nName.
804dade037Sdanielk1977 **
814dade037Sdanielk1977 ** The return value is either the collation sequence to be used in database
824dade037Sdanielk1977 ** db for collation type name zName, length nName, or NULL, if no collation
834dade037Sdanielk1977 ** sequence can be found.
844dade037Sdanielk1977 */
854dade037Sdanielk1977 CollSeq *sqlite3GetCollSeq(
864dade037Sdanielk1977   sqlite3* db,
874dade037Sdanielk1977   CollSeq *pColl,
884dade037Sdanielk1977   const char *zName,
894dade037Sdanielk1977   int nName
904dade037Sdanielk1977 ){
914dade037Sdanielk1977   CollSeq *p;
924dade037Sdanielk1977 
934dade037Sdanielk1977   p = pColl;
944dade037Sdanielk1977   if( !p ){
954dade037Sdanielk1977     p = sqlite3FindCollSeq(db, db->enc, zName, nName, 0);
964dade037Sdanielk1977   }
974dade037Sdanielk1977   if( !p || !p->xCmp ){
984dade037Sdanielk1977     /* No collation sequence of this type for this encoding is registered.
994dade037Sdanielk1977     ** Call the collation factory to see if it can supply us with one.
1004dade037Sdanielk1977     */
1014dade037Sdanielk1977     callCollNeeded(db, zName, nName);
1024dade037Sdanielk1977     p = sqlite3FindCollSeq(db, db->enc, zName, nName, 0);
1034dade037Sdanielk1977   }
1044dade037Sdanielk1977   if( p && !p->xCmp && synthCollSeq(db, p) ){
1054dade037Sdanielk1977     p = 0;
1064dade037Sdanielk1977   }
1074dade037Sdanielk1977   assert( !p || p->xCmp );
1084dade037Sdanielk1977   return p;
1094dade037Sdanielk1977 }
1104dade037Sdanielk1977 
1114dade037Sdanielk1977 /*
1124dade037Sdanielk1977 ** This routine is called on a collation sequence before it is used to
1134dade037Sdanielk1977 ** check that it is defined. An undefined collation sequence exists when
1144dade037Sdanielk1977 ** a database is loaded that contains references to collation sequences
1154dade037Sdanielk1977 ** that have not been defined by sqlite3_create_collation() etc.
1164dade037Sdanielk1977 **
1174dade037Sdanielk1977 ** If required, this routine calls the 'collation needed' callback to
1184dade037Sdanielk1977 ** request a definition of the collating sequence. If this doesn't work,
1194dade037Sdanielk1977 ** an equivalent collating sequence that uses a text encoding different
1204dade037Sdanielk1977 ** from the main database is substituted, if one is available.
1214dade037Sdanielk1977 */
1224dade037Sdanielk1977 int sqlite3CheckCollSeq(Parse *pParse, CollSeq *pColl){
1234dade037Sdanielk1977   if( pColl ){
1244dade037Sdanielk1977     const char *zName = pColl->zName;
1254dade037Sdanielk1977     CollSeq *p = sqlite3GetCollSeq(pParse->db, pColl, zName, -1);
1264dade037Sdanielk1977     if( !p ){
1274dade037Sdanielk1977       if( pParse->nErr==0 ){
1284dade037Sdanielk1977         sqlite3ErrorMsg(pParse, "no such collation sequence: %s", zName);
1294dade037Sdanielk1977       }
1304dade037Sdanielk1977       pParse->nErr++;
1314dade037Sdanielk1977       return SQLITE_ERROR;
1324dade037Sdanielk1977     }
1334dade037Sdanielk1977   }
1344dade037Sdanielk1977   return SQLITE_OK;
1354dade037Sdanielk1977 }
1364dade037Sdanielk1977 
1374dade037Sdanielk1977 
1384dade037Sdanielk1977 
1394dade037Sdanielk1977 /*
140fd9a0a45Sdanielk1977 ** Locate and return an entry from the db.aCollSeq hash table. If the entry
141fd9a0a45Sdanielk1977 ** specified by zName and nName is not found and parameter 'create' is
142fd9a0a45Sdanielk1977 ** true, then create a new entry. Otherwise return NULL.
143fd9a0a45Sdanielk1977 **
144fd9a0a45Sdanielk1977 ** Each pointer stored in the sqlite3.aCollSeq hash table contains an
145fd9a0a45Sdanielk1977 ** array of three CollSeq structures. The first is the collation sequence
146fd9a0a45Sdanielk1977 ** prefferred for UTF-8, the second UTF-16le, and the third UTF-16be.
147fd9a0a45Sdanielk1977 **
148fd9a0a45Sdanielk1977 ** Stored immediately after the three collation sequences is a copy of
149fd9a0a45Sdanielk1977 ** the collation sequence name. A pointer to this string is stored in
150fd9a0a45Sdanielk1977 ** each collation sequence structure.
151fd9a0a45Sdanielk1977 */
152fd9a0a45Sdanielk1977 static CollSeq *findCollSeqEntry(
153fd9a0a45Sdanielk1977   sqlite3 *db,
154fd9a0a45Sdanielk1977   const char *zName,
155fd9a0a45Sdanielk1977   int nName,
156fd9a0a45Sdanielk1977   int create
157fd9a0a45Sdanielk1977 ){
158fd9a0a45Sdanielk1977   CollSeq *pColl;
159fd9a0a45Sdanielk1977   if( nName<0 ) nName = strlen(zName);
160fd9a0a45Sdanielk1977   pColl = sqlite3HashFind(&db->aCollSeq, zName, nName);
161fd9a0a45Sdanielk1977 
162fd9a0a45Sdanielk1977   if( 0==pColl && create ){
163fd9a0a45Sdanielk1977     pColl = sqliteMalloc( 3*sizeof(*pColl) + nName + 1 );
164fd9a0a45Sdanielk1977     if( pColl ){
165fd9a0a45Sdanielk1977       CollSeq *pDel = 0;
166fd9a0a45Sdanielk1977       pColl[0].zName = (char*)&pColl[3];
167fd9a0a45Sdanielk1977       pColl[0].enc = SQLITE_UTF8;
168fd9a0a45Sdanielk1977       pColl[1].zName = (char*)&pColl[3];
169fd9a0a45Sdanielk1977       pColl[1].enc = SQLITE_UTF16LE;
170fd9a0a45Sdanielk1977       pColl[2].zName = (char*)&pColl[3];
171fd9a0a45Sdanielk1977       pColl[2].enc = SQLITE_UTF16BE;
172fd9a0a45Sdanielk1977       memcpy(pColl[0].zName, zName, nName);
173fd9a0a45Sdanielk1977       pColl[0].zName[nName] = 0;
174fd9a0a45Sdanielk1977       pDel = sqlite3HashInsert(&db->aCollSeq, pColl[0].zName, nName, pColl);
175fd9a0a45Sdanielk1977 
176fd9a0a45Sdanielk1977       /* If a malloc() failure occured in sqlite3HashInsert(), it will
177fd9a0a45Sdanielk1977       ** return the pColl pointer to be deleted (because it wasn't added
178fd9a0a45Sdanielk1977       ** to the hash table).
179fd9a0a45Sdanielk1977       */
180*e501b89aSdanielk1977       assert( !pDel || (sqlite3ThreadData()->mallocFailed && pDel==pColl) );
181fd9a0a45Sdanielk1977       sqliteFree(pDel);
182fd9a0a45Sdanielk1977     }
183fd9a0a45Sdanielk1977   }
184fd9a0a45Sdanielk1977   return pColl;
185fd9a0a45Sdanielk1977 }
186fd9a0a45Sdanielk1977 
187fd9a0a45Sdanielk1977 /*
188fd9a0a45Sdanielk1977 ** Parameter zName points to a UTF-8 encoded string nName bytes long.
189fd9a0a45Sdanielk1977 ** Return the CollSeq* pointer for the collation sequence named zName
190fd9a0a45Sdanielk1977 ** for the encoding 'enc' from the database 'db'.
191fd9a0a45Sdanielk1977 **
192fd9a0a45Sdanielk1977 ** If the entry specified is not found and 'create' is true, then create a
193fd9a0a45Sdanielk1977 ** new entry.  Otherwise return NULL.
194fd9a0a45Sdanielk1977 */
195fd9a0a45Sdanielk1977 CollSeq *sqlite3FindCollSeq(
196fd9a0a45Sdanielk1977   sqlite3 *db,
197fd9a0a45Sdanielk1977   u8 enc,
198fd9a0a45Sdanielk1977   const char *zName,
199fd9a0a45Sdanielk1977   int nName,
200fd9a0a45Sdanielk1977   int create
201fd9a0a45Sdanielk1977 ){
202fd9a0a45Sdanielk1977   CollSeq *pColl = findCollSeqEntry(db, zName, nName, create);
203fd9a0a45Sdanielk1977   assert( SQLITE_UTF8==1 && SQLITE_UTF16LE==2 && SQLITE_UTF16BE==3 );
204fd9a0a45Sdanielk1977   assert( enc>=SQLITE_UTF8 && enc<=SQLITE_UTF16BE );
205fd9a0a45Sdanielk1977   if( pColl ) pColl += enc-1;
206fd9a0a45Sdanielk1977   return pColl;
207fd9a0a45Sdanielk1977 }
208fd9a0a45Sdanielk1977 
209fd9a0a45Sdanielk1977 /*
210fd9a0a45Sdanielk1977 ** Locate a user function given a name, a number of arguments and a flag
211fd9a0a45Sdanielk1977 ** indicating whether the function prefers UTF-16 over UTF-8.  Return a
212fd9a0a45Sdanielk1977 ** pointer to the FuncDef structure that defines that function, or return
213fd9a0a45Sdanielk1977 ** NULL if the function does not exist.
214fd9a0a45Sdanielk1977 **
215fd9a0a45Sdanielk1977 ** If the createFlag argument is true, then a new (blank) FuncDef
216fd9a0a45Sdanielk1977 ** structure is created and liked into the "db" structure if a
217fd9a0a45Sdanielk1977 ** no matching function previously existed.  When createFlag is true
218fd9a0a45Sdanielk1977 ** and the nArg parameter is -1, then only a function that accepts
219fd9a0a45Sdanielk1977 ** any number of arguments will be returned.
220fd9a0a45Sdanielk1977 **
221fd9a0a45Sdanielk1977 ** If createFlag is false and nArg is -1, then the first valid
222fd9a0a45Sdanielk1977 ** function found is returned.  A function is valid if either xFunc
223fd9a0a45Sdanielk1977 ** or xStep is non-zero.
224fd9a0a45Sdanielk1977 **
225fd9a0a45Sdanielk1977 ** If createFlag is false, then a function with the required name and
226fd9a0a45Sdanielk1977 ** number of arguments may be returned even if the eTextRep flag does not
227fd9a0a45Sdanielk1977 ** match that requested.
228fd9a0a45Sdanielk1977 */
229fd9a0a45Sdanielk1977 FuncDef *sqlite3FindFunction(
230fd9a0a45Sdanielk1977   sqlite3 *db,       /* An open database */
231fd9a0a45Sdanielk1977   const char *zName, /* Name of the function.  Not null-terminated */
232fd9a0a45Sdanielk1977   int nName,         /* Number of characters in the name */
233fd9a0a45Sdanielk1977   int nArg,          /* Number of arguments.  -1 means any number */
234fd9a0a45Sdanielk1977   u8 enc,            /* Preferred text encoding */
235fd9a0a45Sdanielk1977   int createFlag     /* Create new entry if true and does not otherwise exist */
236fd9a0a45Sdanielk1977 ){
237fd9a0a45Sdanielk1977   FuncDef *p;         /* Iterator variable */
238fd9a0a45Sdanielk1977   FuncDef *pFirst;    /* First function with this name */
239fd9a0a45Sdanielk1977   FuncDef *pBest = 0; /* Best match found so far */
240fd9a0a45Sdanielk1977   int bestmatch = 0;
241fd9a0a45Sdanielk1977 
242fd9a0a45Sdanielk1977 
243fd9a0a45Sdanielk1977   assert( enc==SQLITE_UTF8 || enc==SQLITE_UTF16LE || enc==SQLITE_UTF16BE );
244fd9a0a45Sdanielk1977   if( nArg<-1 ) nArg = -1;
245fd9a0a45Sdanielk1977 
246fd9a0a45Sdanielk1977   pFirst = (FuncDef*)sqlite3HashFind(&db->aFunc, zName, nName);
247fd9a0a45Sdanielk1977   for(p=pFirst; p; p=p->pNext){
248fd9a0a45Sdanielk1977     /* During the search for the best function definition, bestmatch is set
249fd9a0a45Sdanielk1977     ** as follows to indicate the quality of the match with the definition
250fd9a0a45Sdanielk1977     ** pointed to by pBest:
251fd9a0a45Sdanielk1977     **
252fd9a0a45Sdanielk1977     ** 0: pBest is NULL. No match has been found.
253fd9a0a45Sdanielk1977     ** 1: A variable arguments function that prefers UTF-8 when a UTF-16
254fd9a0a45Sdanielk1977     **    encoding is requested, or vice versa.
255fd9a0a45Sdanielk1977     ** 2: A variable arguments function that uses UTF-16BE when UTF-16LE is
256fd9a0a45Sdanielk1977     **    requested, or vice versa.
257fd9a0a45Sdanielk1977     ** 3: A variable arguments function using the same text encoding.
258fd9a0a45Sdanielk1977     ** 4: A function with the exact number of arguments requested that
259fd9a0a45Sdanielk1977     **    prefers UTF-8 when a UTF-16 encoding is requested, or vice versa.
260fd9a0a45Sdanielk1977     ** 5: A function with the exact number of arguments requested that
261fd9a0a45Sdanielk1977     **    prefers UTF-16LE when UTF-16BE is requested, or vice versa.
262fd9a0a45Sdanielk1977     ** 6: An exact match.
263fd9a0a45Sdanielk1977     **
264fd9a0a45Sdanielk1977     ** A larger value of 'matchqual' indicates a more desirable match.
265fd9a0a45Sdanielk1977     */
266fd9a0a45Sdanielk1977     if( p->nArg==-1 || p->nArg==nArg || nArg==-1 ){
267fd9a0a45Sdanielk1977       int match = 1;          /* Quality of this match */
268fd9a0a45Sdanielk1977       if( p->nArg==nArg || nArg==-1 ){
269fd9a0a45Sdanielk1977         match = 4;
270fd9a0a45Sdanielk1977       }
271fd9a0a45Sdanielk1977       if( enc==p->iPrefEnc ){
272fd9a0a45Sdanielk1977         match += 2;
273fd9a0a45Sdanielk1977       }
274fd9a0a45Sdanielk1977       else if( (enc==SQLITE_UTF16LE && p->iPrefEnc==SQLITE_UTF16BE) ||
275fd9a0a45Sdanielk1977                (enc==SQLITE_UTF16BE && p->iPrefEnc==SQLITE_UTF16LE) ){
276fd9a0a45Sdanielk1977         match += 1;
277fd9a0a45Sdanielk1977       }
278fd9a0a45Sdanielk1977 
279fd9a0a45Sdanielk1977       if( match>bestmatch ){
280fd9a0a45Sdanielk1977         pBest = p;
281fd9a0a45Sdanielk1977         bestmatch = match;
282fd9a0a45Sdanielk1977       }
283fd9a0a45Sdanielk1977     }
284fd9a0a45Sdanielk1977   }
285fd9a0a45Sdanielk1977 
286fd9a0a45Sdanielk1977   /* If the createFlag parameter is true, and the seach did not reveal an
287fd9a0a45Sdanielk1977   ** exact match for the name, number of arguments and encoding, then add a
288fd9a0a45Sdanielk1977   ** new entry to the hash table and return it.
289fd9a0a45Sdanielk1977   */
290fd9a0a45Sdanielk1977   if( createFlag && bestmatch<6 &&
291d9cb6ac0Sdrh       (pBest = sqliteMalloc(sizeof(*pBest)+nName))!=0 ){
292fd9a0a45Sdanielk1977     pBest->nArg = nArg;
293fd9a0a45Sdanielk1977     pBest->pNext = pFirst;
294fd9a0a45Sdanielk1977     pBest->iPrefEnc = enc;
295fd9a0a45Sdanielk1977     memcpy(pBest->zName, zName, nName);
296fd9a0a45Sdanielk1977     pBest->zName[nName] = 0;
297fd9a0a45Sdanielk1977     if( pBest==sqlite3HashInsert(&db->aFunc,pBest->zName,nName,(void*)pBest) ){
298fd9a0a45Sdanielk1977       sqliteFree(pBest);
299fd9a0a45Sdanielk1977       return 0;
300fd9a0a45Sdanielk1977     }
301fd9a0a45Sdanielk1977   }
302fd9a0a45Sdanielk1977 
303fd9a0a45Sdanielk1977   if( pBest && (pBest->xStep || pBest->xFunc || createFlag) ){
304fd9a0a45Sdanielk1977     return pBest;
305fd9a0a45Sdanielk1977   }
306fd9a0a45Sdanielk1977   return 0;
307fd9a0a45Sdanielk1977 }
308