|
#include <stdio.h>
#include <mysql.h>
#include <string.h>
#include <stdlib.h>
MYSQL mysql; //mysql連接
MYSQL_RES *res; //這個結(jié)構(gòu)代表返回行的一個查詢結(jié)果集
MYSQL_ROW row; //一個行數(shù)據(jù)的類型安全(type-safe)的表示
char query[100]; //查詢語句
char order[100];
void STRINSERT(int count)
{
char *delim="_";
char *p;
char *q;
char temp[20];
scanf("%s",temp);
strcpy(order,strtok(query,delim));
strcat(order,temp);
int i=1;
while((p=strtok(NULL,delim)))
{
strcat(order,p);
if(i<count)
{
scanf("%s",temp);
i++;
}
else
{
break;
}
strcat(order,temp);
}
strcpy(query,order);
}
void show()
{
int t,r;
strcpy(query," select * from qq");
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));//執(zhí)行指定為計(jì)數(shù)字符串的SQL查詢。
if(t)
{
printf("執(zhí)行顯示時出現(xiàn)異常: %s",mysql_error(&mysql));
}
res=mysql_store_result(&mysql);//檢索完整的結(jié)果集至客戶端。
printf("姓名\t學(xué)號\t年齡\t\n");
while(row=mysql_fetch_row(res))
{
for(t=0;t<mysql_num_fields(res);t++)
{
printf("%s\t" ,row[t]);
}
printf("\n");
}
mysql_free_result(res);//釋放結(jié)果集使用的內(nèi)存。
}
void insert()
{
int t,r;
printf("請輸入姓名、學(xué)號、年齡\n");//安一次回車為輸入一項(xiàng)
strcpy(query,"insert into qq(sname,sno,sage) values('_','_',_)");
STRINSERT(3);//轉(zhuǎn)化為命令函數(shù)
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("執(zhí)行插入時出現(xiàn)異常: %s",mysql_error(&mysql));
}
else
{
printf("添加成功\n");
}
}
void delete()
{
int t,r;
printf("請輸入你要刪除學(xué)生的學(xué)號:\n");
strcpy(query,"delete from qq where sno='_'");
STRINSERT(1);
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("執(zhí)行刪除時出現(xiàn)異常: %s",mysql_error(&mysql));
}
}
void search()
{
int t,r;
printf("請輸入你要查找學(xué)生的信息:\n");
strcpy(query,"select * from qq where sno='_'");
STRINSERT(1);
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));//執(zhí)行指定為計(jì)數(shù)字符串的SQL查詢。
if(t)
{
printf("執(zhí)行查詢時出現(xiàn)異常: %s",mysql_error(&mysql));
}
res=mysql_store_result(&mysql);//檢索完整的結(jié)果集至客戶端。
printf("姓名\t學(xué)號\t年齡\t\n");
while(row=mysql_fetch_row(res))
{
for(t=0;t<mysql_num_fields(res);t++)
{
printf("%s\t" ,row[t]);
}
printf("\n");
}
mysql_free_result(res);//釋放結(jié)果集使用的內(nèi)存。
}
void updata()
{
int t,r;
printf("請輸入新的學(xué)號和你要修改學(xué)生的學(xué)號:\n");
strcpy(query,"update qq set sno='_' where sno='_'");
STRINSERT(2);
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("執(zhí)行更新時出現(xiàn)異常: %s",mysql_error(&mysql));
}
else
{
printf("修改成功\n");
}
}
void menu()
{
printf("\t\t1、顯示學(xué)生信息\n");
printf("\t\t2、添加學(xué)生信息\n");
printf("\t\t3、刪除學(xué)生信息\n");
printf("\t\t4、查找學(xué)生信息\n");
printf("\t\t5、修改學(xué)生信息\n");
printf("\t\t0、退出系統(tǒng) \n");
}
void quit()
{
mysql_close(&mysql);
printf("數(shù)據(jù)庫已關(guān)閉 \n");
exit(1);
}
int main()
{
mysql_init(&mysql);
if (!mysql_real_connect(&mysql,"localhost", "root", NULL, "test",0,NULL,0))
{
printf( "Error connecting to database: %s",mysql_error(&mysql));
}
else
{
printf("Connected...\n");
}
int choice;
while(1)
{
menu();
printf("\n\t請選擇:");
scanf("%d",&choice);
switch(choice)
{
case 1:show();break;
case 2:insert();break;
case 3:delete();break;
case 4:search();break;
case 5:updata();break;
case 0:quit();
}
}
return 0;
} |
|