今天寫的例子,只貼代碼,不使用文字說明.
mysqltool.h
#include <stdio.h>
#include <stdlib.h>
#include <winsock.h>
#include <mysql.h>
int xinsert(MYSQL *mysql,char *strsql)
{
int t;
MYSQL_RES *res;
t=mysql_real_query(mysql,strsql,(unsigned int)strlen(strsql));
if(t){
printf( "Error id=%d Error: %s\n",mysql_errno(mysql),mysql_error(mysql));
return mysql_errno(mysql);
}else{
res=mysql_store_result(mysql);
printf("插入行數=%d\n",mysql_affected_rows(mysql));
mysql_free_result(res);
}
return 0;
}
int xupate(MYSQL *mysql,char *strsql)
{
int t;
MYSQL_RES *res;
t=mysql_real_query(mysql,strsql,(unsigned int)strlen(strsql));
if(t){
printf( "Error id=%d Error: %s\n",mysql_errno(mysql),mysql_error(mysql));
return mysql_errno(mysql);
}else{
res=mysql_store_result(mysql);
printf("更新行數=%d\n",mysql_affected_rows(mysql));
mysql_free_result(res);
}
return 0;
}
int xdelete(MYSQL *mysql,char *strsql)
{
int t;
MYSQL_RES *res;
t=mysql_real_query(mysql,strsql,(unsigned int)strlen(strsql));
if(t){
printf( "Error id=%d Error: %s\n",mysql_errno(mysql),mysql_error(mysql));
return mysql_errno(mysql);
}else{
res=mysql_store_result(mysql);
printf("刪行數=%d\n",mysql_affected_rows(mysql));
mysql_free_result(res);
}
return 0;
}
one.c 代碼如下:
#include <stdlib.h>
#include <winsock.h>
#include <mysql.h>
#include <stdio.h>
#include <mysqltool.h>
int main()
{
MYSQL mysql; //mysql連接
MYSQL_RES *res; //這個結構代表返回行的一個查詢結果集
MYSQL_ROW row; //一個行數據的類型安全(type-safe)的表示
char *query; //查詢語句
int t,r;
mysql_init(&mysql);
if (!mysql_real_connect(&mysql,"localhost", "lottobar", "123456", "lottobar",3306,NULL,0))
{
printf( "Error connecting to database: %s\n",mysql_error(&mysql));
} else
printf("Connected
\n");
query="SET CHARACTER SET GBK"; //設置編碼
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("編碼設置失敗\n");
}
query=" select * from demo ";
t=mysql_real_query(&mysql,query,(unsigned int)strlen(query));
if(t)
{
printf("執行查詢時出現異常: %s",mysql_error(&mysql));
}else
printf("[%s] 構建成功 \n",query);
res=mysql_store_result(&mysql);
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);
t=mysql_real_query(&mysql,"SET AUTOCOMMIT =0",(unsigned int)strlen("SET AUTOCOMMIT =0"));
if(t){
printf("啟用手工事務失敗\n");
}else{
printf("啟用手工事務成功\n");
}
t=mysql_real_query(&mysql,"Begin ;",(unsigned int)strlen("Begin ;"));
query="insert into demo(name,age)values('老裴','89')";
int inset_result=xinsert(&mysql,query);
query="delete from demo where name='老裴'";
int delete_result=xdelete(&mysql,query);
query="update demo set name='裴屋村' where name='ccd' and inc_id=13";
int update_result=xupate(&mysql,query);
query="insert into demo(inc_id,name,age)values(16,'老裴','89')";//執行會出現異常的語句
int fail_result=xinsert(&mysql,query);
if(inset_result==0 && delete_result==0 && update_result==0 && fail_result==0){
printf("事務提交\n");
t=mysql_real_query(&mysql,"COMMIT;",(unsigned int)strlen("COMMIT;"));
}else{
printf("事務回滾\n");
t=mysql_real_query(&mysql,"ROLLBACK;",(unsigned int)strlen("ROLLBACK;"));
}
return 0;
}
posted on 2008-03-15 17:33
有貓相伴的日子 閱讀(2034)
評論(0) 編輯 收藏 所屬分類:
unix/windows C 程序設計