/***
@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@ @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@ @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@ @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)