#include <stdio.h>
#include <mysql.h>
#include <string.h>
#include <stdlib.h>
MYSQL mysql; //mysql連接
MYSQL_RES *res; //這個結構代表返回行的一個查詢結果集
MYSQL_ROW row; //一個行數據的類型安全(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));//執行指定為計數字符串的SQL查詢。
if(t)
{
printf("執行顯示時出現異常: %s",mysql_error(&mysql));
}
res=mysql_store_result(&mysql);//檢索完整的結果集至客戶端。
printf("姓名\t學號\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);//釋放結果集使用的內存。
}
void insert()
{
int t,r;
printf("請輸入姓名、學號、年齡\n");//安一次回車為輸入一項
strcpy(query,"insert into qq(sname,sno,sage) values('_','_',_)");
STRINSERT(3);//轉化為命令函數
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("執行插入時出現異常: %s",mysql_error(&mysql));
}
else
{
printf("添加成功\n");
}
}
void delete()
{
int t,r;
printf("請輸入你要刪除學生的學號：\n");
strcpy(query,"delete from qq where sno='_'");
STRINSERT(1);
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("執行刪除時出現異常: %s",mysql_error(&mysql));
}
}
void search()
{
int t,r;
printf("請輸入你要查找學生的信息：\n");
strcpy(query,"select * from qq where sno='_'");
STRINSERT(1);
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));//執行指定為計數字符串的SQL查詢。
if(t)
{
printf("執行查詢時出現異常: %s",mysql_error(&mysql));
}
res=mysql_store_result(&mysql);//檢索完整的結果集至客戶端。
printf("姓名\t學號\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);//釋放結果集使用的內存。
}
void updata()
{
int t,r;
printf("請輸入新的學號和你要修改學生的學號：\n");
strcpy(query,"update qq set sno='_' where sno='_'");
STRINSERT(2);
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("執行更新時出現異常: %s",mysql_error(&mysql));
}
else
{
printf("修改成功\n");
}
}
void menu()
{
printf("\t\t1、顯示學生信息\n");
printf("\t\t2、添加學生信息\n");
printf("\t\t3、刪除學生信息\n");
printf("\t\t4、查找學生信息\n");
printf("\t\t5、修改學生信息\n");
printf("\t\t0、退出系統 \n");
}
void quit()
{
mysql_close(&mysql);
printf("數據庫已關閉 \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;
} |
