SQLite3使用详解之三

前端之家收集整理的这篇文章主要介绍了SQLite3使用详解之三前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

/***

@H_403_2@ @H_403_2@

下面是上面的函数的辅助处理函数

@H_403_2@ @H_403_2@

***/

@H_403_2@ @H_403_2@

// 从用户提供的缓冲区中得到一个加密密钥

@H_403_2@ @H_403_2@

// 用户提供的密钥可能位数上满足不了要求,使用这个函数来完成密钥扩展

@H_403_2@ @H_403_2@

static unsigned char * DeriveKey(const void *pKey,int nKeyLen);

@H_403_2@ @H_403_2@

//创建或更新一个页的加密算法索引.此函数会申请缓冲区.

@H_403_2@ @H_403_2@

static LPCryptBlock CreateCryptBlock(unsigned char* hKey,Pager *pager,LPCryp

@H_403_2@

tBlock pExisting);

@H_403_2@ @H_403_2@

//加密/解密函数,被pager调用

@H_403_2@ @H_403_2@

void * sqlite3Codec(void *pArg,unsigned char *data,Pgno nPageNum,int nMode)

@H_403_2@

;

@H_403_2@ @H_403_2@

//设置密码函数

@H_403_2@ @H_403_2@

int __stdcall sqlite3_key_interop(sqlite3 *db,const void *pKey,int nKeySize)

@H_403_2@

;

@H_403_2@ @H_403_2@

// 修改密码函数

@H_403_2@ @H_403_2@

int __stdcall sqlite3_rekey_interop(sqlite3 *db,int nKeySiz

@H_403_2@

e);

@H_403_2@ @H_403_2@

//销毁一个加密块及相关的缓冲区,密钥.

@H_403_2@ @H_403_2@

static void DestroyCryptBlock(LPCryptBlock pBlock);

@H_403_2@ @H_403_2@

static void * sqlite3pager_get_codecarg(Pager *pPager);

@H_403_2@ @H_403_2@

void sqlite3pager_set_codec(Pager *pPager,void *(*xCodec)(void*,void*,Pgno,int

@H_403_2@

),void *pCodecArg );

@H_403_2@ @H_403_2@

//加密/解密函数,int nMode)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

LPCryptBlock pBlock = (LPCryptBlock)pArg;

@H_403_2@ @H_403_2@

unsigned int dwPageSize = 0;

@H_403_2@ @H_403_2@

if (!pBlock) return data;

@H_403_2@ @H_403_2@

// 确保pager的页长度和加密块的页长度相等.如果改变,就需要调整.

@H_403_2@ @H_403_2@

if (nMode != 2)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

PgHdr *pageHeader;

@H_403_2@ @H_403_2@

pageHeader = DATA_TO_PGHDR(data);

@H_403_2@ @H_403_2@

if (pageHeader->pPager->pageSize != pBlock->PageSize)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

CreateCryptBlock(0,pageHeader->pPager,pBlock);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

switch(nMode)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

case 0: // Undo a "case 7" journal file encryption

@H_403_2@ @H_403_2@

case 2: //重载一个页

@H_403_2@ @H_403_2@

case 3: //载入一个页

@H_403_2@ @H_403_2@

if (!pBlock->ReadKey) break;

@H_403_2@ @H_403_2@

dwPageSize = pBlock->PageSize;

@H_403_2@ @H_403_2@

My_DeEncrypt_Func(data,dwPageSize,pBlock->ReadKey,DB_KEY_LENGTH_BYTE )

@H_403_2@

; /*调用我的解密函数*/

@H_403_2@ @H_403_2@

break;

@H_403_2@ @H_403_2@

case 6: //加密一个主数据库文件的页

@H_403_2@ @H_403_2@

if (!pBlock->WriteKey) break;

@H_403_2@ @H_403_2@

memcpy(pBlock->Data + CRYPT_OFFSET,data,pBlock->PageSize);

@H_403_2@ @H_403_2@

data = pBlock->Data + CRYPT_OFFSET;

@H_403_2@ @H_403_2@

dwPageSize = pBlock->PageSize;

@H_403_2@ @H_403_2@

My_Encrypt_Func(data,pBlock->WriteKey,DB_KEY_LENGTH_BYTE )

@H_403_2@

; /*调用我的加密函数*/

@H_403_2@ @H_403_2@

break;

@H_403_2@ @H_403_2@

case 7: //加密事务文件的页

@H_403_2@ @H_403_2@

/*在正常环境下,读密钥和写密钥相同. 当数据库是被重新加密的,读密钥和写密钥

@H_403_2@

未必相同.

@H_403_2@ @H_403_2@

回滚事务必要用数据库文件的原始密钥写入.因此,当一次回滚被写入,总是用数据库

@H_403_2@

的读密钥,

@H_403_2@ @H_403_2@

这是为了保证与读取原始数据的密钥相同.

@H_403_2@ @H_403_2@

*/

@H_403_2@ @H_403_2@

if (!pBlock->ReadKey) break;

@H_403_2@ @H_403_2@

memcpy(pBlock->Data + CRYPT_OFFSET,pBlock->PageSize);

@H_403_2@ @H_403_2@

data = pBlock->Data + CRYPT_OFFSET;

@H_403_2@ @H_403_2@

dwPageSize = pBlock->PageSize;

@H_403_2@ @H_403_2@

My_Encrypt_Func( data,DB_KEY_LENGTH_BYTE );

@H_403_2@

/*调用我的加密函数*/

@H_403_2@ @H_403_2@

break;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

return data;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

//销毁一个加密块及相关的缓冲区,密钥.

@H_403_2@ @H_403_2@

static void DestroyCryptBlock(LPCryptBlock pBlock)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

//销毁读密钥.

@H_403_2@ @H_403_2@

if (pBlock->ReadKey){

@H_403_2@ @H_403_2@

sqliteFree(pBlock->ReadKey);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

//如果写密钥存在并且不等于读密钥,也销毁.

@H_403_2@ @H_403_2@

if (pBlock->WriteKey && pBlock->WriteKey != pBlock->ReadKey){

@H_403_2@ @H_403_2@

sqliteFree(pBlock->WriteKey);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

if(pBlock->Data){

@H_403_2@ @H_403_2@

sqliteFree(pBlock->Data);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

//释放加密块.

@H_403_2@ @H_403_2@

sqliteFree(pBlock);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

static void * sqlite3pager_get_codecarg(Pager *pPager)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

return (pPager->xCodec) ? pPager->pCodecArg: NULL;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// 从用户提供的缓冲区中得到一个加密密钥

@H_403_2@ @H_403_2@

static unsigned char * DeriveKey(const void *pKey,int nKeyLen)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

unsigned char * hKey = NULL;

@H_403_2@ @H_403_2@

int j;

@H_403_2@ @H_403_2@

if( pKey == NULL || nKeyLen == 0 )

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

return NULL;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

hKey = sqliteMalloc( DB_KEY_LENGTH_BYTE + 1 );

@H_403_2@ @H_403_2@

if( hKey == NULL )

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

return NULL;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

hKey[ DB_KEY_LENGTH_BYTE ] = 0;

@H_403_2@ @H_403_2@

if( nKeyLen < DB_KEY_LENGTH_BYTE )

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

memcpy( hKey,pKey,nKeyLen ); //先拷贝得到密钥前面的部分

@H_403_2@ @H_403_2@

j = DB_KEY_LENGTH_BYTE - nKeyLen;

@H_403_2@ @H_403_2@

//补充密钥后面的部分

@H_403_2@ @H_403_2@

memset( hKey + nKeyLen,DB_KEY_PADDING,j );

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

else

@H_403_2@ @H_403_2@

{ //密钥位数已经足够,直接把密钥取过来

@H_403_2@ @H_403_2@

memcpy( hKey,DB_KEY_LENGTH_BYTE );

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

return hKey;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

//创建或更新一个页的加密算法索引.此函数会申请缓冲区.

@H_403_2@ @H_403_2@

static LPCryptBlock CreateCryptBlock(unsigned char* hKey,LPCryp

@H_403_2@

tBlock pExisting)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

LPCryptBlock pBlock;

@H_403_2@ @H_403_2@

if (!pExisting) //创建新加密块

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

pBlock = sqliteMalloc(sizeof(CryptBlock));

@H_403_2@ @H_403_2@

memset(pBlock,sizeof(CryptBlock));

@H_403_2@ @H_403_2@

pBlock->ReadKey = hKey;

@H_403_2@ @H_403_2@

pBlock->WriteKey = hKey;

@H_403_2@ @H_403_2@

pBlock->PageSize = pager->pageSize;

@H_403_2@ @H_403_2@

pBlock->Data = (unsigned char*)sqliteMalloc(pBlock->PageSize + CRYPT_OFFS

@H_403_2@

ET);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

else //更新存在的加密块

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

pBlock = pExisting;

@H_403_2@ @H_403_2@

if ( pBlock->PageSize != pager->pageSize && !pBlock->Data){

@H_403_2@ @H_403_2@

sqliteFree(pBlock->Data);

@H_403_2@ @H_403_2@

pBlock->PageSize = pager->pageSize;

@H_403_2@ @H_403_2@

pBlock->Data = (unsigned char*)sqliteMalloc(pBlock->PageSize + CRYPT

@H_403_2@

_OFFSET);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

memset(pBlock->Data,pBlock->PageSize + CRYPT_OFFSET);

@H_403_2@ @H_403_2@

return pBlock;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

/*

@H_403_2@ @H_403_2@

** Set the codec for this pager

@H_403_2@ @H_403_2@

*/

@H_403_2@ @H_403_2@

void sqlite3pager_set_codec(

@H_403_2@ @H_403_2@

Pager *pPager,

@H_403_2@ @H_403_2@

void *(*xCodec)(void*,int),

@H_403_2@ @H_403_2@

void *pCodecArg

@H_403_2@ @H_403_2@

)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

pPager->xCodec = xCodec;

@H_403_2@ @H_403_2@

pPager->pCodecArg = pCodecArg;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

int sqlite3_key(sqlite3 *db,int nKey)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

return sqlite3_key_interop(db,nKey);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

int sqlite3_rekey(sqlite3 *db,int nKey)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

return sqlite3_rekey_interop(db,nKey);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

/*被sqlite 和 sqlite3_key_interop 调用,附加密钥到数据库.*/

@H_403_2@ @H_403_2@

int sqlite3CodecAttach(sqlite3 *db,int nDb,int nKeyLen)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

int rc = sqlITE_ERROR;

@H_403_2@ @H_403_2@

unsigned char* hKey = 0;

@H_403_2@ @H_403_2@

//如果没有指定密匙,可能标识用了主数据库的加密或没加密.

@H_403_2@ @H_403_2@

if (!pKey || !nKeyLen)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

if (!nDb)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

return sqlITE_OK; //主数据库,没有指定密钥所以没有加密.

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

else //附加数据库,使用主数据库的密钥.

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

//获取数据库的加密块并复制密钥给附加数据库使用

@H_403_2@ @H_403_2@

LPCryptBlock pBlock = (LPCryptBlock)sqlite3pager_get_codecarg(sqli

@H_403_2@

te3BtreePager(db->aDb[0].pBt));

@H_403_2@ @H_403_2@

if (!pBlock) return sqlITE_OK; //主数据库没有加密

@H_403_2@ @H_403_2@

if (!pBlock->ReadKey) return sqlITE_OK; //没有加密

@H_403_2@ @H_403_2@

memcpy(pBlock->ReadKey,&hKey,16);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

else //用户提供了密码,从中创建密钥.

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

hKey = DeriveKey(pKey,nKeyLen);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

//创建一个新的加密块,并将解码器指向新的附加数据库.

@H_403_2@ @H_403_2@

if (hKey)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

LPCryptBlock pBlock = CreateCryptBlock(hKey,sqlite3BtreePager(db->aDb

@H_403_2@

[nDb].pBt),NULL);

@H_403_2@ @H_403_2@

sqlite3pager_set_codec(sqlite3BtreePager(db->aDb[nDb].pBt),sqlite3Cod

@H_403_2@

ec,pBlock);

@H_403_2@ @H_403_2@

rc = sqlITE_OK;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

return rc;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// Changes the encryption key for an existing database.

@H_403_2@ @H_403_2@

int __stdcall sqlite3_rekey_interop(sqlite3 *db,int nKeySiz

@H_403_2@

e)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

Btree *pbt = db->aDb[0].pBt;

@H_403_2@ @H_403_2@

Pager *p = sqlite3BtreePager(pbt);

@H_403_2@ @H_403_2@

LPCryptBlock pBlock = (LPCryptBlock)sqlite3pager_get_codecarg(p);

@H_403_2@ @H_403_2@

unsigned char * hKey = DeriveKey(pKey,nKeySize);

@H_403_2@ @H_403_2@

int rc = sqlITE_ERROR;

@H_403_2@ @H_403_2@

if (!pBlock && !hKey) return sqlITE_OK;

@H_403_2@ @H_403_2@

//重新加密一个数据库,改变pager的写密钥,读密钥依旧保留.

@H_403_2@ @H_403_2@

if (!pBlock) //加密一个未加密的数据库

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

pBlock = CreateCryptBlock(hKey,p,NULL);

@H_403_2@ @H_403_2@

pBlock->ReadKey = 0; // 原始数据库未加密

@H_403_2@ @H_403_2@

sqlite3pager_set_codec(sqlite3BtreePager(pbt),sqlite3Codec,pBlock);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

else // 改变已加密数据库的写密钥

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

pBlock->WriteKey = hKey;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// 开始一个事务

@H_403_2@ @H_403_2@

rc = sqlite3BtreeBeginTrans(pbt,1);

@H_403_2@ @H_403_2@

if (!rc)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

// 用新密钥重写所有的页到数据库

@H_403_2@ @H_403_2@

Pgno nPage = sqlite3PagerPagecount(p);

@H_403_2@ @H_403_2@

Pgno nSkip = PAGER_MJ_PGNO(p);

@H_403_2@ @H_403_2@

void *pPage;

@H_403_2@ @H_403_2@

Pgno n;

@H_403_2@ @H_403_2@

for(n = 1; rc == sqlITE_OK && n <= nPage; n ++)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

if (n == nSkip) continue;

@H_403_2@ @H_403_2@

rc = sqlite3PagerGet(p,n,&pPage);

@H_403_2@ @H_403_2@

if(!rc)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

rc = sqlite3PagerWrite(pPage);

@H_403_2@ @H_403_2@

sqlite3PagerUnref(pPage);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// 如果成功,提交事务。

@H_403_2@ @H_403_2@

if (!rc)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

rc = sqlite3BtreeCommit(pbt);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// 如果失败,回滚。

@H_403_2@ @H_403_2@

if (rc)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

sqlite3BtreeRollback(pbt);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// 如果成功,销毁先前的读密钥。并使读密钥等于当前的写密钥。

@H_403_2@ @H_403_2@

if (!rc)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

if (pBlock->ReadKey)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

sqliteFree(pBlock->ReadKey);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

pBlock->ReadKey = pBlock->WriteKey;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

else// 如果失败,销毁当前的写密钥,并恢复为当前的读密钥。

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

if (pBlock->WriteKey)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

sqliteFree(pBlock->WriteKey);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

pBlock->WriteKey = pBlock->ReadKey;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// 如果读密钥和写密钥皆为空,就不需要再对页进行编解码。

@H_403_2@ @H_403_2@

// 销毁加密块并移除页的编解码器

@H_403_2@ @H_403_2@

if (!pBlock->ReadKey && !pBlock->WriteKey)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

sqlite3pager_set_codec(p,NULL,NULL);

@H_403_2@ @H_403_2@

DestroyCryptBlock(pBlock);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

return rc;

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

/***

@H_403_2@ @H_403_2@

下面是加密函数的主体

@H_403_2@ @H_403_2@

***/

@H_403_2@ @H_403_2@

int __stdcall sqlite3_key_interop(sqlite3 *db,int nKeySize)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

return sqlite3CodecAttach(db,nKeySize);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

// 释放与一个页相关的加密块

@H_403_2@ @H_403_2@

void sqlite3pager_free_codecarg(void *pArg)

@H_403_2@ @H_403_2@

{

@H_403_2@ @H_403_2@

if (pArg)

@H_403_2@ @H_403_2@

DestroyCryptBlock((LPCryptBlock)pArg);

@H_403_2@ @H_403_2@

}

@H_403_2@ @H_403_2@

#endif //#ifdef sqlITE_HAS_CODEC

@H_403_2@ @H_403_2@

五、 后记

@H_403_2@

写此教程,可不是一个累字能解释。

@H_403_2@ @H_403_2@

但是我还是觉得欣慰的,因为我很久以前就想写 sqlite 的教程,一来自己备忘,二而已

@H_403_2@

造福大众,大家不用再走弯路。

@H_403_2@ @H_403_2@

本人第一次写教程,不足的地方请大家指出。

@H_403_2@ @H_403_2@

本文可随意转载、修改、引用。但无论是转载、修改、引用,都请附带我的名字:董淳光

@H_403_2@

。以示对我劳动的肯定

@H_403_2@ @H_403_2@

(源码网整理:www.codepub.com)

猜你在找的Sqlite相关文章