数据结构作业:传输数据的增删改
#include <stdio.h>
#include <sqlite3.h>
#include <stdlib.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
int do_insert(sqlite3 *db,char *excl);//向表格中增加,传参为句柄指针和excl表格名
int do_updata(sqlite3 * db,char *excl);//改。参数为句柄指针和表格名,通过Id来修改
int do_delete(sqlite3 *db,char *excl);//删除,传参为创建的表格
int main(int argc, const char *argv[])
{
if(argc<2)
{
printf("没有输入要创建打开的数据库\n");
return -1;
}
//打开创建一个数据库
sqlite3 *db =NULL;//打开创建出来的句柄指针
if(sqlite3_open(argv[1],&db)!=SQLITE_OK<0)
{
fprintf(stderr,"line = __%d__,sqlite3_open = %s\n",__LINE__,sqlite3_errmsg(db));
fprintf(stderr,"line = __%d__,sqlite3_open = %d\n",__LINE__,sqlite3_errcode(db));
return 0;
}
printf("database open success\n");
//创建表格,sqlite3_exec作用让c执行创建,同时将主键设置为id
char sql[128]="";//c中要执行的语句
char excl[23]="";//创建出来的表格名
printf("请输入要创建的表格名->>");
fgets(excl,sizeof(excl),stdin);
excl[strlen(excl)-1]=0;
sprintf(sql,"create table if not exists %s (id int PRIMARY key ,name char ,score float);",excl);
char * errmsg=NULL;
if(sqlite3_exec(db,sql,NULL,NULL,&errmsg)<0)
{
fprintf(stderr,"line = __%d__,sqlite3_open = %s\n",__LINE__,errmsg);
fprintf(stderr,"line = __%d__,sqlite3_open = %s\n",__LINE__,errmsg);
return -1;
}
printf("create table success");
printf("%s\n",sql);
//面板
char c= 0;
while(1)
{
system("clear");
printf("---------------------------\n");
printf("------------1.增-----------\n");
printf("------------2.删-----------\n");
printf("------------3.改-----------\n");
printf("------------4.查-----------\n");
printf("------------5.退出---------\n");
printf("---------------------------\n");
printf("请输入");
//清屏
c= getchar();
printf("%c\n",c);
while(getchar()!=10);
switch(c)
{
case '1'://增
if(do_insert(db,excl)<0)
{
sleep(3);
printf("输入错误\n");
}
//do_insert();
break;
case '2'://删
do_delete(db,excl);
//do_delete();
break;
case '3'://改
if(do_updata(db,excl)<0)
{
printf("修改错误\n");
sleep(3);
}
//do_updata();
break;
case '4'://查
//do_
break;
case '5':
goto END;
default:
printf("输入错误\n");
}
printf("输入任意字符清屏\n");
while(getchar()!= 10);
}
END:
//关闭文件库
if(sqlite3_close(db)!= SQLITE_OK)
{
fprintf(stderr,"line = __%d__,sqlite3_open = %d\n",__LINE__,sqlite3_errcode(db));
fprintf(stderr,"line = __%d__,sqlite3_open = %s\n",__LINE__,sqlite3_errmsg(db));
return -1;
}
printf("database close success\n");
return 0;
}
int do_insert(sqlite3 *db,char *excl)//向表格中增加,传参为句柄指针和excl表格名
{
printf("向表格中插入\n");
int id= 0 ;
char name[20]= "";
float score = 0;
char *errmg =NULL;//错误信息
//sqlite3_exec调用是所用的参数
char sql1[64]="";//全字段插入,用于最后的拼接
printf("请输入序号->>");
scanf("%d",&id);
while(getchar()!=10);
printf("请输入姓名->>");
fgets(name,sizeof(name),stdin);
name[strlen(name)-1]=0;
printf("请输入成绩->>");
scanf("%f",&score);
sprintf(sql1,"insert into %s values (%d,'%s' ,%.2f);",excl,id,name,score);//拼接后写到sql1中
printf("%s\n",sql1);
if(sqlite3_exec(db,sql1,NULL,NULL,&errmg)!= SQLITE_OK)
{
fprintf(stderr,"__%d__,%s\n",__LINE__,errmg);
return -1;
}
printf("add success\n");
return 0;
}
int do_delete(sqlite3 *db,char *excl)//删除,传参为创建的表格
{
printf("删除表格中的内容\n");
char *errmg =NULL;//错误信息
int id= 0;//id 是主键
char sql1[64]="";//全字段删除,用于最后的拼接
printf("请输入序号->>");
scanf("%d",&id);
sprintf(sql1,"delete from %s where id = %d",excl,id);//全字段删除,以主键id来判断
//删除
if(sqlite3_exec(db,sql1,NULL,NULL,&errmg)!= SQLITE_OK)
{
printf("__%d__,%s\n",__LINE__,errmg);
return -1;
}
printf("remove success\n");
return 0;
}
int do_updata(sqlite3 * db,char *excl)//改。参数为句柄指针和表格名,通过Id来修改
{
printf("修改表格中的数据\n");
//改
char *errmg =NULL;//错误信息
char temp[20] ="";// 中间值
char change[20]="";//要改变的值
char name[21]="";//要改变成为姓名
float score =0;//要改变的成绩
int newid =0;//要改变成为的id
int id= 0;//id 是主键,id所在的那一行是进行改变的行
char sql1[64]="";//全字段删除,用于最后的拼接
printf("请输入序号->>");
scanf("%d",&id);
while(getchar()!=10);
NEX:
printf("输入要修改的字段 id or name or score->>");
fgets(temp,sizeof(temp),stdin);
temp[strlen(temp)-1]=0;
if(strcmp(temp,"name")==0)
{
strcpy(change,temp);
printf("请输入要改变成为的姓名->>");
fgets(name,sizeof(name),stdin);
name[strlen(name)-1]=0;
sprintf(sql1,"update %s set %s ='%s' where id = %d ;",excl,change,name,id);
printf("%s\n",sql1);
}
else if(strcmp(temp,"score") ==0 )
{
strcpy(change,temp);
printf("请输入要改变成为的成绩->>");
scanf("%f",&score);
sprintf(sql1,"update %s set %s =%.2f where id =%d ; ",excl,change,score,id);
printf("%s\n",sql1);
}
else if(strcmp(temp,"id") ==0 )
{
strcpy(change,temp);
printf("请输入要改变成为的id->>");
scanf("%d",&newid);
while(getchar()!=10);
sprintf(sql1,"update %s set %s =%d where id =%d ; ",excl,change,newid,id);
printf("%s\n",sql1);
}
else {
printf("要改变的值输入错误\n");
bzero(temp,sizeof(temp));
goto NEX;
}
if(sqlite3_exec(db,sql1,NULL,NULL,&errmg)!= SQLITE_OK)
{
printf("__%d__,%s\n",__LINE__,errmg);
return -1;
}
printf("updata success\n");
return 0;
}