数据库操作的增、删、改完成
 

#include <myhead.h>

//查询的回调函数
int callback(void* data,int count,char** argv, char** columnName)
{
	//count是字段数
	//argv是字段内容
	//columnName是字段名称
    for(int i=0;i<count;i++) 
    {
        printf("%s=%s\n", columnName[i], argv[i] ? argv[i] : "NULL");
    }
    puts("");
    return 0;
}
int main(int argc, const char *argv[])
{
	//定义数据库句柄指针
	sqlite3 *ppfd=NULL;
	//打开一个数据库，如果不存在则创建并打开
	if(sqlite3_open("./my.db",&ppfd)!=SQLITE_OK)
	{
		printf("sqlite3_open error,errcode\n");
		return -1;
	}
	puts("数据库打开成功");
	//创建数据表
	//1、准备sql1语句
	char sql1[128]="create table if not exists worker(id int,name char,salary double)";
	char *errmsg=NULL;    //存放执行SQL语句中的错误信息
	if(sqlite3_exec(ppfd,sql1,NULL,NULL,&errmsg)!=SQLITE_OK)
	{
		printf("exec error:%s\n",errmsg);
		sqlite3_free(errmsg);
		errmsg=NULL;
		return -1;
	}
	puts("员工信息表创建成功");
	int number;           //操作码
	while(1)
	{
		system("clear");    //清空之前的终端信息
		printf("\t\t=======XXX公司员工管理系统=======\n");
		printf("\t\t======1、添加员工信息=========\n");
		printf("\t\t======2、删除员工信息=========\n");
		printf("\t\t======3、修改员工信息=========\n");
		printf("\t\t======4、查询员工信息=========\n");
		printf("\t\t======0、退出=========\n");

		printf("请输入操作码:");          
		scanf("%d", &number);
		getchar();                          
		switch(number)
		{
		case 1:    //添加员工信息
			{
				//定义修改数据表中的数据容器
				char id[128]; //id	
				char name[128];      //name
				char salary[128];   //salary
				printf("请输入数据:");
				scanf("%s %s %s",id,name,salary);
				//准备sql2语句
				char sql2[128];
				sprintf(sql2,"insert into worker values (%s,'%s',%s)",id,name,salary);
				char *errmsg=NULL;    //存放执行SQL语句中的错误信息
				if(sqlite3_exec(ppfd,sql2,NULL,NULL,&errmsg)!=SQLITE_OK)
				{
					printf("exec error:%s\n",errmsg);
					sqlite3_free(errmsg);
					errmsg=NULL;
					return -1;
				}
			}
			break;
		case 2:      //删除员工信息
			{
				char rbuf[128];   //字段名
				char sbuf[128];   //数据
				printf("请输入字段名和数据:");
				scanf("%s %s",rbuf,sbuf);
				//准备sql3语句
				char sql3[128];
				sprintf(sql3,"delete from worker where %s='%s'",rbuf,sbuf);
				 printf("%s\n",sql3);
				char *errmsg=NULL;    //存放执行SQL语句中的错误信息
				if(sqlite3_exec(ppfd,sql3,NULL,NULL,&errmsg)!=SQLITE_OK)
				{
					printf("exec error:%s\n",errmsg);
					sqlite3_free(errmsg);
					errmsg=NULL;
					return -1;
				}
			}
			break;
		case 3:    //修改员工信息
			{
				char rbuf[128];   //字段名
				char sbuf[128];   //数据
				char buf1[128];   //限制条件字段名
				char buf2[128];   //限制条件数据
				printf("请输入限制条件字段名和数据:");
				scanf(" %s %s",buf1,buf2);
				printf("修改的字段名和数据:");
				scanf(" %s %s",rbuf,sbuf);
				//准备sql4语句
				char sql4[128];
				sprintf(sql4,"update worker set %s='%s' where %s='%s'",rbuf,sbuf,buf1,buf2);
				char *errmsg=NULL;    //存放执行SQL语句中的错误信息
				if(sqlite3_exec(ppfd,sql4,NULL,NULL,&errmsg)!=SQLITE_OK)
				{
					printf("exec error:%s\n",errmsg);
					sqlite3_free(errmsg);
					errmsg=NULL;
					return -1;
				}
			}
			break;
		case 4:     //查询员工信息
			{ 
				char rbuf[128];   //字段名
				char sbuf[128];   //数据
				printf("查询的字段名和数据:");
				scanf(" %s %s",rbuf,sbuf);
				//准备sql5语句
				char sql5[128];
				sprintf(sql5,"select * from worker where %s='%s'",rbuf,sbuf);
				char *errmsg=NULL;    //存放执行SQL语句中的错误信息
				if(sqlite3_exec(ppfd,sql5,callback,NULL,&errmsg)!=SQLITE_OK)
				{
					printf("exec error:%s\n",errmsg);
					sqlite3_free(errmsg);
					errmsg=NULL;
					return -1;
				}
			}
			break;
		case 0:
			goto END;
		default:printf("您输入的功能有误，请重新输入！！！\n");
		}
		printf("请输入任意键，按回车清屏\n");
		while(getchar()!= '\n');
	}
END:
	//关闭数据库
	sqlite3_close(ppfd);
	return 0;
}

 

思维导图