SQLite3使用详解之三

分类：Sqlite作者：佚名

/***



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



***/



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



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



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



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



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


tBlock pExisting);



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



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


;



//设置密码函数



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


;



// 修改密码函数



int __stdcall sqlite3_rekey_interop(sqlite3 *db,int nKeySiz


e);



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



static void DestroyCryptBlock(LPCryptBlock pBlock);



static void * sqlite3pager_get_codecarg(Pager *pPager);



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


),void *pCodecArg );



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



{



LPCryptBlock pBlock = (LPCryptBlock)pArg;



unsigned int dwPageSize = 0;



if (!pBlock) return data;



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



if (nMode != 2)



{



PgHdr *pageHeader;



pageHeader = DATA_TO_PGHDR(data);



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



{



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



}



}



switch(nMode)



{



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



case 2: //重载一个页



case 3: //载入一个页



if (!pBlock->ReadKey) break;



dwPageSize = pBlock->PageSize;



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


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



break;



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



if (!pBlock->WriteKey) break;



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



data = pBlock->Data + CRYPT_OFFSET;



dwPageSize = pBlock->PageSize;



My_Encrypt_Func(data,pBlock->WriteKey,DB_KEY_LENGTH_BYTE )


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



break;



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



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


未必相同.



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


的读密钥,



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



*/



if (!pBlock->ReadKey) break;



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



data = pBlock->Data + CRYPT_OFFSET;



dwPageSize = pBlock->PageSize;



My_Encrypt_Func( data,DB_KEY_LENGTH_BYTE );


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



break;



}



return data;



}



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



static void DestroyCryptBlock(LPCryptBlock pBlock)



{



//销毁读密钥.



if (pBlock->ReadKey){



sqliteFree(pBlock->ReadKey);



}



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



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



sqliteFree(pBlock->WriteKey);



}



if(pBlock->Data){



sqliteFree(pBlock->Data);



}



//释放加密块.



sqliteFree(pBlock);



}



static void * sqlite3pager_get_codecarg(Pager *pPager)



{



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



}



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



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



{



unsigned char * hKey = NULL;



int j;



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



{



return NULL;



}



hKey = sqliteMalloc( DB_KEY_LENGTH_BYTE + 1 );



if( hKey == NULL )



{



return NULL;



}



hKey[ DB_KEY_LENGTH_BYTE ] = 0;



if( nKeyLen < DB_KEY_LENGTH_BYTE )



{



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



j = DB_KEY_LENGTH_BYTE - nKeyLen;



//补充密钥后面的部分



memset( hKey + nKeyLen,DB_KEY_PADDING,j );



}



else



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



memcpy( hKey,DB_KEY_LENGTH_BYTE );



}



return hKey;



}



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



static LPCryptBlock CreateCryptBlock(unsigned char* hKey,LPCryp


tBlock pExisting)



{



LPCryptBlock pBlock;



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



{



pBlock = sqliteMalloc(sizeof(CryptBlock));



memset(pBlock,sizeof(CryptBlock));



pBlock->ReadKey = hKey;



pBlock->WriteKey = hKey;



pBlock->PageSize = pager->pageSize;



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


ET);



}



else //更新存在的加密块



{



pBlock = pExisting;



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



sqliteFree(pBlock->Data);



pBlock->PageSize = pager->pageSize;



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


_OFFSET);



}



}



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



return pBlock;



}



/*



** Set the codec for this pager



*/



void sqlite3pager_set_codec(



Pager *pPager,



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



void *pCodecArg



)



{



pPager->xCodec = xCodec;



pPager->pCodecArg = pCodecArg;



}



int sqlite3_key(sqlite3 *db,int nKey)



{



return sqlite3_key_interop(db,nKey);



}



int sqlite3_rekey(sqlite3 *db,int nKey)



{



return sqlite3_rekey_interop(db,nKey);



}



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



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



{



int rc = sqlITE_ERROR;



unsigned char* hKey = 0;



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



if (!pKey || !nKeyLen)



{



if (!nDb)



{



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



}



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



{



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



LPCryptBlock pBlock = (LPCryptBlock)sqlite3pager_get_codecarg(sqli


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



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



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



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



}



}



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



{



hKey = DeriveKey(pKey,nKeyLen);



}



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



if (hKey)



{



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


[nDb].pBt),NULL);



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


ec,pBlock);



rc = sqlITE_OK;



}



return rc;



}



// Changes the encryption key for an existing database.



int __stdcall sqlite3_rekey_interop(sqlite3 *db,int nKeySiz


e)



{



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



Pager *p = sqlite3BtreePager(pbt);



LPCryptBlock pBlock = (LPCryptBlock)sqlite3pager_get_codecarg(p);



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



int rc = sqlITE_ERROR;



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



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



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



{



pBlock = CreateCryptBlock(hKey,p,NULL);



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



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



}



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



{



pBlock->WriteKey = hKey;



}



// 开始一个事务



rc = sqlite3BtreeBeginTrans(pbt,1);



if (!rc)



{



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



Pgno nPage = sqlite3PagerPagecount(p);



Pgno nSkip = PAGER_MJ_PGNO(p);



void *pPage;



Pgno n;



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



{



if (n == nSkip) continue;



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



if(!rc)



{



rc = sqlite3PagerWrite(pPage);



sqlite3PagerUnref(pPage);



}



}



}



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



if (!rc)



{



rc = sqlite3BtreeCommit(pbt);



}



// 如果失败，回滚。



if (rc)



{



sqlite3BtreeRollback(pbt);



}



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



if (!rc)



{



if (pBlock->ReadKey)



{



sqliteFree(pBlock->ReadKey);



}



pBlock->ReadKey = pBlock->WriteKey;



}



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



{



if (pBlock->WriteKey)



{



sqliteFree(pBlock->WriteKey);



}



pBlock->WriteKey = pBlock->ReadKey;



}



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



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



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



{



sqlite3pager_set_codec(p,NULL,NULL);



DestroyCryptBlock(pBlock);



}



return rc;



}



/***



下面是加密函数的主体



***/



int __stdcall sqlite3_key_interop(sqlite3 *db,int nKeySize)



{



return sqlite3CodecAttach(db,nKeySize);



}



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



void sqlite3pager_free_codecarg(void *pArg)



{



if (pArg)



DestroyCryptBlock((LPCryptBlock)pArg);



}



#endif //#ifdef sqlITE_HAS_CODEC



五、 后记


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



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


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



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



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


。以示对我劳动的肯定



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

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

Java 嵌入数据处理引擎：SQLite 的挑战者 esProc SPL
SQLite架构简单，又有Json计算能力，有时会承担Json文件/RESTful的计算功能，但SQLite不能直接解析Json文件/RESTful，需要用Java代码硬写，或借助第三方类库，最后再拼成insert语句插入数据表，代码非常繁琐，这里就不展示了。参考前面的代码可知，入库的过程比较麻烦，不能只用SQL，还要借助Java或命令行。SPL是现代的数据计算语言，属于简化的面向对象的语言风格，有对象的概念，可以用点号访问属性并进行多步骤计算，但没有继承重载这些内容，不算彻底的面向对象语言。...
五、使用Python操作数据库
使用Python操作内置数据库SQLite以及MySQL数据库。
AndroidStudio-实现登录界面数据存储在SQLite
登陆界面
一文教会你导出微信聊天记录
破解微信数据库密码，用python导出微信聊天记录
UnitySqlite持久化数据
（Unity）SQLite 是一个软件库，实现了自给自足的、无服务器的、零配置的、事务性的 SQL 数据库引擎。SQLite 是在世界上最广泛部署的 SQL 数据库引擎。SQLite 源代码不受版权限制。本教程将告诉您如何使用 SQLite 编程，并让你迅速上手。.................................
Android用户登陆与注册功能的简单实现SQLite
安卓开发，利用SQLite实现登陆注册功能
SQLite——Java使用SQLite初体验
相比大多数数据库而言，具有等优势，广泛应用于、等领域。
使用SqlSugar连接多个数据库sqlserver，sqlite，mysql
有时候，一个项目只有一个数据库，比如只有SQLite，或者MySQL数据库，那么我们只需要使用一个固定的数据库即可。但是一个项目如果写好了，有多个用户使用，但是多个用户使用不同的数据库，这个时候，我们就需要把软件设计成可以连接多个数据库的模式，用什么数据库，就配置什么数据库即可。4.Users实体类，这个实体类要和数据库一样的，形成一一对应的关系。11.Sqlite数据库，需要在代码里面创建数据库，建立表，再建立数据。8.我们开启MySQL数据库，然后进行调试，看程序的结果。2.安装SqlSugar。
基于Android的背单词软件【源码+文档+答辩PPT】
基于Android的背单词软件，功能强大完整。
python ——操作sqlite 数据库
SQLite，是一款轻型的数据库，是遵守ACID的关系型数据库管理系统。说白了就是使用起来轻便简单，
Android -- 购物车
Android的简单购物车案例
SQLite3-轻量级数据库
SQLite，是一款轻型的数据库，是遵守ACID的关系型数据库管理系统，它包含在一个相对小的C库中。它是D.RichardHipp建立的公有领域项目。它的设计目标是嵌入式的，而且已经在很多嵌入式产品中使用了它，它占用资源非常的低，在嵌入式设备中，可能只需要几百K的内存就够了。它能够支持Windows/Linux/Unix等等主流的操作系统，同时能够跟很多程序语言相结合，比如 Tcl、C#、PHP、Java等，还有ODBC接口，同样比起Mysql、PostgreSQL这两款开源的世界著名数据库...
Qt设计精美的登录注册界面包含SQLite数据库应用
Qt设计较为美观好看的登录注册界面（包含SQLite数据库以及TCP通信的应用）
Java 嵌入数据处理引擎：SQLite 的挑战者
SQLite是用C语言开发的跨平台小型数据库，可嵌入其他开发语言，也可在单机执行。SPL是用Java开发的跨平台的数据计算语言，可嵌入Java，可在单机执行，可以数据计算服务的形式被远程调用。两者的代码都是解释执行的。...
Sqlite_入门命令
新建库.openDATA_BASE;新建表createtableLIST_NAME(DATA);语法:NAME关键字...<用逗号分割>删除表droptableNAME;查看表.schema查看表信息新建数据insertintoLIST_NAMEvalues();语法:CLASS,PARAMETER...,CLASS是类别,PARAMETER是参数<用逗号分割新建的
sqlite占位符的事例
importsqlite3classDemo01:def__init__(self):self.conn=sqlite3.connect("sql_demo_001.db")self.cursor1=self.conn.cursor()self.cursor1.execute("select*fromtable_001wherename=?andid=?",('ssss&#0
C# SQLite数据库
 在客户端配置文件<configuration>节点下，添加：<connectionStrings>      <add name="localdb" connectionString="Data Source=config/local.db;Version=3;UseUTF16Encoding=True;" providerName="System.Data.SQLite.SQLiteFactory"/&g
SQLite也可能出现死锁
提到锁就不得不说到死锁的问题，而SQLite也可能出现死锁。下面举个例子：连接1：BEGIN（UNLOCKED）连接1：SELECT...（SHARED）连接1：INSERT...（RESERVED）连接2：BEGIN（UNLOCKED）连接2：SELECT...（SHARED）连接1：COMMIT（PENDING，尝试获取EXCLUSIVE锁，但还有SHARED锁未释放，返回SQLITE_BUSY）连接2：INSERT...
PYTHON 对SQLITE3的简单使用
SQLite是一种嵌入式数据库，它的数据库就是一个文件。由于SQLite本身是C写的，而且体积很小，所以，经常被集成到各种应用程序中，甚至在iOS和Android的App中都可以集成。Python就内置了SQLite3，所以，在Python中使用SQLite，不需要安装任何东西，直接使用。在使用SQLite前，我们先要搞清楚几个概念：表
安卓入门——————简单记账本的开发用sqlite存储数据一
设计思想————首先要确定有几个页面、和每个页面的大致布局由于是入门，我也是学习了不是很长的时间，所以项目比较low。。。。第一个页面，也就是打开APP的首页面：今天这个博客，先实现添加功能！：首先对主界面进行布局：其中activity_main.xml的代码为<?xmlversion="1.0"encoding="
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot