SQlite3 C++ 基本应用sqlite3_stmt搞定二进制

SQlite3轻巧,效率高,是小型软件数据库的首选。近来在网上参考了些资料,自己动手编程,有些收获,整理了下代码,记下来...

源码中包括数据库数据的插入,查询等基本操作。

源码:

#include <stdio.h>
#include <windows.h>
#include <iostream>
using namespace std;

extern "C"
{
	#include "./sqlite3.h"
};

void sqlite3_exec_report(sqlite3* db,const char* sql,sqlite3_callback func_callback,void *para);
void select_v2(sqlite3 *db,const char*sql);
void outputItem(sqlite3_stmt* stat,int nColumn,char* out_pic_path);
string GetType(int t);
//回调函数
int select_items(void *para,int n_column,char **column_val,char **column_name);//查询

int main(int args,char*argv[])
{
	int result,ret;
	sqlite3* db = NULL;
	char* errmsg = NULL;
	
	char module_path[100];

	//获取当前exe路径
	DWORD dwPathLen = GetModuleFileNameA(NULL,module_path,100);
	char *p = module_path + dwPathLen;
	while (1)
	{
		char c = *p;
		if (c == '\\')
		{
			*(p+1) = '\0';
			break;
		}
		p--;
	}
	//合成数据库文件路径
	strcat_s(module_path,100,"db\\mydb.db");
	string db_path(module_path);
	//打开(创建)数据库
	result = sqlite3_open(db_path.c_str(),&db);

	//----------------------------第一张表------------------------------
	//--不包含blob数据,通过普通的方法插入
	//-- --------------------------------------------------------------
	if (result == SQLITE_OK)
	{
		//创建第一张表
		sqlite3_exec_report(db,"create table MyTable_1(ID integer autoincrement primary key,name nvarchar(30))",NULL,NULL);
		//先清除数据
		sqlite3_exec_report(db,"delete from MyTable_1",NULL);
		//插入数据	
		const char * sqls[] = {
			"insert into MyTable_1(ID,name) values(0,'钱学森')","insert into MyTable_1(ID,name) values(1,'邓稼先')",name) values(2,'钱三强')",name) values(3,'李四光')",name) values(4,'贺才良')"
		};
		for (int i = 0; i < sizeof(sqls)/sizeof(char*); i++)
		{
			sqlite3_exec_report(db,sqls[i],NULL);
		}

		//查询插入的数据  用的是回调的方法
		sqlite3_exec_report(db,"select * from MyTable_1",select_items,NULL);
		sqlite3_close(db);
	}
	else
	{
		//打开数据库失败
		cout << sqlite3_errmsg(db) << endl;
		ret = -1;
	}

	//-----------------------------第二张表------------------------------
	//--包含blob数据,通过sqlite3_prepare,sqlite3_bind_blob,sqlite3_step
	//-- 的方法实现数据的插入
	//-- --------------------------------------------------------------
	result = sqlite3_open(module_path,&db);
	if (result==SQLITE_OK)
	{
		sqlite3_exec_report(db,"create table stu_msg(ID integer primary key autoincrement,name nvarchar(32),picture blob)",NULL);
		sqlite3_exec_report(db,"delete from stu_msg",NULL);

		sqlite3_stmt *stat;
		const char *pzTail = NULL;

		const char *sqls[] = {
			"insert into stu_msg(ID,name,picture) values(0,'华罗庚',?);","insert into stu_msg(ID,picture) values(1,'钱学森',?);"
		};
		const char *names[] = {
			"pic\\hualuogen.jpg","pic\\qianxuesen.jpg"
		};

		for (int j=0; j<sizeof(sqls)/sizeof(char*); j++)
		{
			//准备
			result = sqlite3_prepare(db,sqls[j],-1,&stat,&pzTail);

			if (!result && stat)
			{
				// 读取头像数据
				*(p+1) = '\0';//重复利用ModuleFileName
				strcat_s(module_path,names[j]);
				FILE *file = NULL;
				fopen_s(&file,"rb+");
				char* data = NULL;
				long l_file_size = 0;
				if (file)
				{
					fseek(file,SEEK_END);
					l_file_size = ftell(file);
					fseek(file,SEEK_SET);
					data = new char[l_file_size];
					fread(data,1,l_file_size,file);

					//和sql的第一个?绑定(如果有多个问号,那就要分开绑定)
					result = sqlite3_bind_blob(stat,data,NULL);

					//将数据输入数据库
					result = sqlite3_step(stat);
					cout << "Insert result:" << sqlite3_errmsg(db) << endl;
					fclose(file);
					delete [] data;
				}			
				ret = 0;
			}
			else
			{
				//准备失败
				cout << "sqlite3_prepare failed!  " << sqlite3_errmsg(db) << endl; 
				ret = -1;
			}
			//释放stat
			sqlite3_finalize(stat);
		}
		
		//查看插入数据
		select_v2(db,"select ID,picture from stu_msg");

		//关闭数据库
		sqlite3_close(db);
	} 
	else
	{
		cout << "打开数据库" << module_path << sqlite3_errmsg(db);
		ret = -1;
	}

	//---------------------读出各记录的头像-----------------
	result = sqlite3_open(db_path.c_str(),&db);
	if (!result)
	{
		sqlite3_stmt *stat;
		const char *pzTail = NULL;
		sqlite3_prepare(db,"select * from stu_msg;",&pzTail);
		int nColumn = sqlite3_column_count(stat);
		cout << "总的列数:" << nColumn << endl;

		result = sqlite3_step(stat);//读取某一条记录
		while (result == SQLITE_ROW) /* sqlite3_step() has another row ready */
		{
			*(p+1) = '\0';
			outputItem(stat,nColumn,module_path);
			cout << endl;
			result = sqlite3_step(stat);
		}
		cout << "end..." << endl;
	}

	return ret;
}

//输出一条记录
void outputItem(sqlite3_stmt* stat,char* out_pic_path)
{
	int m = -1;
	for (int k=0; k< nColumn; k++)
	{
		string s;
		int colType = sqlite3_column_type(stat,k);
		if (colType == 3)//text
		{
			m = k; //得到名字
		}
		s = GetType(colType);
		cout << "column " << k << ":" << s.c_str() << endl;

		switch(colType){
		case 1: cout << "Value: " << sqlite3_column_int(stat,k) << endl;break;
		case 2: cout << "Value: " << sqlite3_column_int(stat,k) << endl; break;
		case 3: cout << "Value: " << sqlite3_column_text(stat,k) << endl; break;		
		case 5: cout << "Value: " << "内容为空" << endl; break;
		case 4: cout << "Value: " << "二进制数据" << endl; 		
			const void* bi = sqlite3_column_blob(stat,k);
			int size = sqlite3_column_bytes(stat,k);
			char *name = NULL;
			if (m == -1)
			{
				name = "xxx";
			} 
			else
			{
				name = (char*)sqlite3_column_text(stat,m);
			}
			strcat_s(out_pic_path,"out_pic\\");
			strcat_s(out_pic_path,(char*)name);
			strcat_s(out_pic_path,".jpg");
			FILE *f = NULL;

			fopen_s(&f,out_pic_path,"wb+");
			if (f)
			{
				fwrite(bi,size,f);
				fclose(f);
			}
			break;
		}
	}
	
}

//获取类型
string GetType(int t)
{
	string s;
	switch (t)
	{
	case 1: s = "SQLITE_INTEGER";break;
	case 2: s = "SQLITE_FLOATE"; break;
	case 3: s = "SQLITE_TEXT"; break;
	case 4: s = "SQLITE_BLOB"; break;
	case 5: s = "SQLITE_NULL"; break;
	}
	return s;
}

//执行sql语句并报告执行结果
void sqlite3_exec_report(sqlite3* db,void *para)
{
	char* errmsg;
	int result = sqlite3_exec(db,sql,func_callback,para,&errmsg);
	cout << endl << endl;
	if(result != SQLITE_OK)
	{
		cout << "error code: " << result << endl
			<< "error: " << errmsg << endl;
	}
	else 
		cout << "SQL execute succeed: " << sql << endl;
}

//一条记录调用一次回调函数
int select_items(void *para,char **column_name)
{
	int i;
	cout << "contain " << n_column << " columns" << endl;
	for (i = 0; i<n_column; i++)
	{
		cout << "column" << i << ": " << column_name[i] << endl
		     << "values: " << column_val[i] << endl;
	}
	return 0;
}

//另一种查询方式
void select_v2(sqlite3 *db,const char*sql)
{
#if 1
	
	char *errmsg = NULL;
	char** dbResult = NULL;
	int nRow,nColumn;
	int result = sqlite3_get_table( db,&dbResult,&nRow,&nColumn,&errmsg );

	//查询成功
	int index = nColumn; //dbResult 前面第一行数据是字段名称,从 nColumn 索引开始才是真正的数据

	for( int i = 0; i < nRow ; i++ )
	{
		cout << "第" << i+1 << "条记录" << endl; 
		for(int j = 0 ; j < nColumn; j++ )
		{
			cout << "字段名:" << dbResult[j] << "  "
				<< "字段值:" << dbResult[index] << endl;
			++index; // dbResult 的字段值是连续的,从第0索引到第 nColumn - 1索引都是字段名称,从第 nColumn 索引开始,后面都是字段值,它把一个二维的表(传统的行列表示法)用一个扁平的形式来表示
		}
		cout << "------------" << endl;
	}

	sqlite3_free_table(dbResult);//释放查询空间
#endif
}

另外推荐一款查看sqlites数据库的软件:sqlite expert 私人版,功能很强大伊~

>_<

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

相关推荐


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