mirror of
https://github.com/php/php-src.git
synced 2024-10-22 00:39:31 +00:00
353 lines
9.7 KiB
C
353 lines
9.7 KiB
C
/*
|
|
** 2003 April 6
|
|
**
|
|
** The author disclaims copyright to this source code. In place of
|
|
** a legal notice, here is a blessing:
|
|
**
|
|
** May you do good and not evil.
|
|
** May you find forgiveness for yourself and forgive others.
|
|
** May you share freely, never taking more than you give.
|
|
**
|
|
*************************************************************************
|
|
** This file contains code used to implement the ATTACH and DETACH commands.
|
|
**
|
|
** $Id$
|
|
*/
|
|
#include "sqliteInt.h"
|
|
|
|
/*
|
|
** This routine is called by the parser to process an ATTACH statement:
|
|
**
|
|
** ATTACH DATABASE filename AS dbname
|
|
**
|
|
** The pFilename and pDbname arguments are the tokens that define the
|
|
** filename and dbname in the ATTACH statement.
|
|
*/
|
|
void sqlite3Attach(
|
|
Parse *pParse, /* The parser context */
|
|
Token *pFilename, /* Name of database file */
|
|
Token *pDbname, /* Name of the database to use internally */
|
|
int keyType, /* 0: no key. 1: TEXT, 2: BLOB */
|
|
Token *pKey /* Text of the key for keytype 1 and 2 */
|
|
){
|
|
Db *aNew;
|
|
int rc, i;
|
|
char *zFile = 0;
|
|
char *zName = 0;
|
|
sqlite3 *db;
|
|
Vdbe *v;
|
|
|
|
v = sqlite3GetVdbe(pParse);
|
|
if( !v ) return;
|
|
sqlite3VdbeAddOp(v, OP_Expire, 1, 0);
|
|
sqlite3VdbeAddOp(v, OP_Halt, 0, 0);
|
|
if( pParse->explain ) return;
|
|
db = pParse->db;
|
|
if( db->nDb>=MAX_ATTACHED+2 ){
|
|
sqlite3ErrorMsg(pParse, "too many attached databases - max %d",
|
|
MAX_ATTACHED);
|
|
pParse->rc = SQLITE_ERROR;
|
|
return;
|
|
}
|
|
|
|
if( !db->autoCommit ){
|
|
sqlite3ErrorMsg(pParse, "cannot ATTACH database within transaction");
|
|
pParse->rc = SQLITE_ERROR;
|
|
return;
|
|
}
|
|
|
|
zFile = sqlite3NameFromToken(pFilename);
|
|
if( zFile==0 ){
|
|
goto attach_end;
|
|
}
|
|
#ifndef SQLITE_OMIT_AUTHORIZATION
|
|
if( sqlite3AuthCheck(pParse, SQLITE_ATTACH, zFile, 0, 0)!=SQLITE_OK ){
|
|
goto attach_end;
|
|
}
|
|
#endif /* SQLITE_OMIT_AUTHORIZATION */
|
|
|
|
zName = sqlite3NameFromToken(pDbname);
|
|
if( zName==0 ){
|
|
goto attach_end;
|
|
}
|
|
for(i=0; i<db->nDb; i++){
|
|
char *z = db->aDb[i].zName;
|
|
if( z && sqlite3StrICmp(z, zName)==0 ){
|
|
sqlite3ErrorMsg(pParse, "database %s is already in use", zName);
|
|
pParse->rc = SQLITE_ERROR;
|
|
goto attach_end;
|
|
}
|
|
}
|
|
|
|
if( db->aDb==db->aDbStatic ){
|
|
aNew = sqliteMalloc( sizeof(db->aDb[0])*3 );
|
|
if( aNew==0 ){
|
|
goto attach_end;
|
|
}
|
|
memcpy(aNew, db->aDb, sizeof(db->aDb[0])*2);
|
|
}else{
|
|
aNew = sqliteRealloc(db->aDb, sizeof(db->aDb[0])*(db->nDb+1) );
|
|
if( aNew==0 ){
|
|
goto attach_end;
|
|
}
|
|
}
|
|
db->aDb = aNew;
|
|
aNew = &db->aDb[db->nDb++];
|
|
memset(aNew, 0, sizeof(*aNew));
|
|
sqlite3HashInit(&aNew->tblHash, SQLITE_HASH_STRING, 0);
|
|
sqlite3HashInit(&aNew->idxHash, SQLITE_HASH_STRING, 0);
|
|
sqlite3HashInit(&aNew->trigHash, SQLITE_HASH_STRING, 0);
|
|
sqlite3HashInit(&aNew->aFKey, SQLITE_HASH_STRING, 1);
|
|
aNew->zName = zName;
|
|
zName = 0;
|
|
aNew->safety_level = 3;
|
|
rc = sqlite3BtreeFactory(db, zFile, 0, MAX_PAGES, &aNew->pBt);
|
|
if( rc ){
|
|
sqlite3ErrorMsg(pParse, "unable to open database: %s", zFile);
|
|
}
|
|
#if SQLITE_HAS_CODEC
|
|
{
|
|
extern int sqlite3CodecAttach(sqlite3*, int, void*, int);
|
|
char *zKey;
|
|
int nKey;
|
|
if( keyType==0 ){
|
|
/* No key specified. Use the key from the main database */
|
|
extern void sqlite3CodecGetKey(sqlite3*, int, void**, int*);
|
|
sqlite3CodecGetKey(db, 0, (void**)&zKey, &nKey);
|
|
}else if( keyType==1 ){
|
|
/* Key specified as text */
|
|
zKey = sqlite3NameFromToken(pKey);
|
|
nKey = strlen(zKey);
|
|
}else{
|
|
/* Key specified as a BLOB */
|
|
char *zTemp;
|
|
assert( keyType==2 );
|
|
pKey->z++;
|
|
pKey->n--;
|
|
zTemp = sqlite3NameFromToken(pKey);
|
|
zKey = sqlite3HexToBlob(zTemp);
|
|
sqliteFree(zTemp);
|
|
}
|
|
sqlite3CodecAttach(db, db->nDb-1, zKey, nKey);
|
|
if( keyType ){
|
|
sqliteFree(zKey);
|
|
}
|
|
}
|
|
#endif
|
|
db->flags &= ~SQLITE_Initialized;
|
|
if( pParse->nErr==0 && rc==SQLITE_OK ){
|
|
rc = sqlite3ReadSchema(pParse);
|
|
}
|
|
if( rc ){
|
|
int i = db->nDb - 1;
|
|
assert( i>=2 );
|
|
if( db->aDb[i].pBt ){
|
|
sqlite3BtreeClose(db->aDb[i].pBt);
|
|
db->aDb[i].pBt = 0;
|
|
}
|
|
sqlite3ResetInternalSchema(db, 0);
|
|
assert( pParse->nErr>0 ); /* Always set by sqlite3ReadSchema() */
|
|
if( pParse->rc==SQLITE_OK ){
|
|
pParse->rc = SQLITE_ERROR;
|
|
}
|
|
}
|
|
|
|
attach_end:
|
|
sqliteFree(zFile);
|
|
sqliteFree(zName);
|
|
}
|
|
|
|
/*
|
|
** This routine is called by the parser to process a DETACH statement:
|
|
**
|
|
** DETACH DATABASE dbname
|
|
**
|
|
** The pDbname argument is the name of the database in the DETACH statement.
|
|
*/
|
|
void sqlite3Detach(Parse *pParse, Token *pDbname){
|
|
int i;
|
|
sqlite3 *db;
|
|
Vdbe *v;
|
|
Db *pDb = 0;
|
|
char *zName;
|
|
|
|
v = sqlite3GetVdbe(pParse);
|
|
if( !v ) return;
|
|
sqlite3VdbeAddOp(v, OP_Expire, 0, 0);
|
|
sqlite3VdbeAddOp(v, OP_Halt, 0, 0);
|
|
if( pParse->explain ) return;
|
|
db = pParse->db;
|
|
zName = sqlite3NameFromToken(pDbname);
|
|
if( zName==0 ) return;
|
|
for(i=0; i<db->nDb; i++){
|
|
pDb = &db->aDb[i];
|
|
if( pDb->pBt==0 ) continue;
|
|
if( sqlite3StrICmp(pDb->zName, zName)==0 ) break;
|
|
}
|
|
if( i>=db->nDb ){
|
|
sqlite3ErrorMsg(pParse, "no such database: %z", zName);
|
|
return;
|
|
}
|
|
if( i<2 ){
|
|
sqlite3ErrorMsg(pParse, "cannot detach database %z", zName);
|
|
return;
|
|
}
|
|
sqliteFree(zName);
|
|
if( !db->autoCommit ){
|
|
sqlite3ErrorMsg(pParse, "cannot DETACH database within transaction");
|
|
pParse->rc = SQLITE_ERROR;
|
|
return;
|
|
}
|
|
#ifndef SQLITE_OMIT_AUTHORIZATION
|
|
if( sqlite3AuthCheck(pParse,SQLITE_DETACH,db->aDb[i].zName,0,0)!=SQLITE_OK ){
|
|
return;
|
|
}
|
|
#endif /* SQLITE_OMIT_AUTHORIZATION */
|
|
sqlite3BtreeClose(pDb->pBt);
|
|
pDb->pBt = 0;
|
|
sqlite3ResetInternalSchema(db, 0);
|
|
}
|
|
|
|
/*
|
|
** Initialize a DbFixer structure. This routine must be called prior
|
|
** to passing the structure to one of the sqliteFixAAAA() routines below.
|
|
**
|
|
** The return value indicates whether or not fixation is required. TRUE
|
|
** means we do need to fix the database references, FALSE means we do not.
|
|
*/
|
|
int sqlite3FixInit(
|
|
DbFixer *pFix, /* The fixer to be initialized */
|
|
Parse *pParse, /* Error messages will be written here */
|
|
int iDb, /* This is the database that must be used */
|
|
const char *zType, /* "view", "trigger", or "index" */
|
|
const Token *pName /* Name of the view, trigger, or index */
|
|
){
|
|
sqlite3 *db;
|
|
|
|
if( iDb<0 || iDb==1 ) return 0;
|
|
db = pParse->db;
|
|
assert( db->nDb>iDb );
|
|
pFix->pParse = pParse;
|
|
pFix->zDb = db->aDb[iDb].zName;
|
|
pFix->zType = zType;
|
|
pFix->pName = pName;
|
|
return 1;
|
|
}
|
|
|
|
/*
|
|
** The following set of routines walk through the parse tree and assign
|
|
** a specific database to all table references where the database name
|
|
** was left unspecified in the original SQL statement. The pFix structure
|
|
** must have been initialized by a prior call to sqlite3FixInit().
|
|
**
|
|
** These routines are used to make sure that an index, trigger, or
|
|
** view in one database does not refer to objects in a different database.
|
|
** (Exception: indices, triggers, and views in the TEMP database are
|
|
** allowed to refer to anything.) If a reference is explicitly made
|
|
** to an object in a different database, an error message is added to
|
|
** pParse->zErrMsg and these routines return non-zero. If everything
|
|
** checks out, these routines return 0.
|
|
*/
|
|
int sqlite3FixSrcList(
|
|
DbFixer *pFix, /* Context of the fixation */
|
|
SrcList *pList /* The Source list to check and modify */
|
|
){
|
|
int i;
|
|
const char *zDb;
|
|
struct SrcList_item *pItem;
|
|
|
|
if( pList==0 ) return 0;
|
|
zDb = pFix->zDb;
|
|
for(i=0, pItem=pList->a; i<pList->nSrc; i++, pItem++){
|
|
if( pItem->zDatabase==0 ){
|
|
pItem->zDatabase = sqliteStrDup(zDb);
|
|
}else if( sqlite3StrICmp(pItem->zDatabase,zDb)!=0 ){
|
|
sqlite3ErrorMsg(pFix->pParse,
|
|
"%s %T cannot reference objects in database %s",
|
|
pFix->zType, pFix->pName, pItem->zDatabase);
|
|
return 1;
|
|
}
|
|
#if !defined(SQLITE_OMIT_VIEW) || !defined(SQLITE_OMIT_TRIGGER)
|
|
if( sqlite3FixSelect(pFix, pItem->pSelect) ) return 1;
|
|
if( sqlite3FixExpr(pFix, pItem->pOn) ) return 1;
|
|
#endif
|
|
}
|
|
return 0;
|
|
}
|
|
#if !defined(SQLITE_OMIT_VIEW) || !defined(SQLITE_OMIT_TRIGGER)
|
|
int sqlite3FixSelect(
|
|
DbFixer *pFix, /* Context of the fixation */
|
|
Select *pSelect /* The SELECT statement to be fixed to one database */
|
|
){
|
|
while( pSelect ){
|
|
if( sqlite3FixExprList(pFix, pSelect->pEList) ){
|
|
return 1;
|
|
}
|
|
if( sqlite3FixSrcList(pFix, pSelect->pSrc) ){
|
|
return 1;
|
|
}
|
|
if( sqlite3FixExpr(pFix, pSelect->pWhere) ){
|
|
return 1;
|
|
}
|
|
if( sqlite3FixExpr(pFix, pSelect->pHaving) ){
|
|
return 1;
|
|
}
|
|
pSelect = pSelect->pPrior;
|
|
}
|
|
return 0;
|
|
}
|
|
int sqlite3FixExpr(
|
|
DbFixer *pFix, /* Context of the fixation */
|
|
Expr *pExpr /* The expression to be fixed to one database */
|
|
){
|
|
while( pExpr ){
|
|
if( sqlite3FixSelect(pFix, pExpr->pSelect) ){
|
|
return 1;
|
|
}
|
|
if( sqlite3FixExprList(pFix, pExpr->pList) ){
|
|
return 1;
|
|
}
|
|
if( sqlite3FixExpr(pFix, pExpr->pRight) ){
|
|
return 1;
|
|
}
|
|
pExpr = pExpr->pLeft;
|
|
}
|
|
return 0;
|
|
}
|
|
int sqlite3FixExprList(
|
|
DbFixer *pFix, /* Context of the fixation */
|
|
ExprList *pList /* The expression to be fixed to one database */
|
|
){
|
|
int i;
|
|
struct ExprList_item *pItem;
|
|
if( pList==0 ) return 0;
|
|
for(i=0, pItem=pList->a; i<pList->nExpr; i++, pItem++){
|
|
if( sqlite3FixExpr(pFix, pItem->pExpr) ){
|
|
return 1;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
#endif
|
|
|
|
#ifndef SQLITE_OMIT_TRIGGER
|
|
int sqlite3FixTriggerStep(
|
|
DbFixer *pFix, /* Context of the fixation */
|
|
TriggerStep *pStep /* The trigger step be fixed to one database */
|
|
){
|
|
while( pStep ){
|
|
if( sqlite3FixSelect(pFix, pStep->pSelect) ){
|
|
return 1;
|
|
}
|
|
if( sqlite3FixExpr(pFix, pStep->pWhere) ){
|
|
return 1;
|
|
}
|
|
if( sqlite3FixExprList(pFix, pStep->pExprList) ){
|
|
return 1;
|
|
}
|
|
pStep = pStep->pNext;
|
|
}
|
|
return 0;
|
|
}
|
|
#endif
|