/*
This is a program demonstrating how to use my old mysql library.
I think I wrote the library 2 or 3 years ago. And I think it might be
still useful to somebody else. If anybody finds it useful just use it.
I'll be very pleased.
To run this program we need a table in mysql's test database
like below.
create table temp(no int, name varchar(100));
2004.01.04.
written by jinyedge.
*/
#include <stdio.h>
#include "/usr/local/mysql/include/mysql.h"
/*-------------------*/
typedef struct _RecordSet{
MYSQL_RES* res;
MYSQL_ROW row;
} RecordSet;
MYSQL mysql;
/*-------------------*/
/*success = 1, error = 0*/
int db_conn(char* host, char* user, char* pw, char* db){
mysql_init(&mysql);
if(! mysql_real_connect(&mysql, host, user, pw, db, 0, (char *)NULL, 0)){return 0;}
return 1;
}
/*-------------------*/
void db_close(){
mysql_close(&mysql);
}
/*-------------------*/
/*success = 1, error = 0*/
int db_one_str(char* q, char buf[]){
MYSQL_RES* res;
MYSQL_ROW row;
if(mysql_real_query(&mysql, q, strlen(q)) != 0){
strcpy(buf, "");
return 0;
}
res = mysql_store_result(&mysql);
row = mysql_fetch_row(res);
mysql_free_result(res);
strcpy(buf, row[0]);
return 1;
}
/*-------------------*/
/*success = 1, error = 0*/
int db_exec(char *q){
if(mysql_real_query(&mysql, q, strlen(q)) != 0){return 0;}
return 1;
}
/*-------------------*/
/*error = NULL*/
RecordSet* rs_open(char *q){
RecordSet* rs;
rs = (RecordSet *)malloc(sizeof(RecordSet));
if(mysql_real_query(&mysql, q, strlen(q)) != 0){
return NULL;
}
rs->res = mysql_store_result(&mysql);
return rs;
}
/*-------------------*/
int rs_next(RecordSet* rs){
if((rs->row = mysql_fetch_row(rs->res)) == NULL){return 0;}
return 1;
}
/*-------------------*/
void rs_get_str(RecordSet* rs, int idx, char buf[]){
strcpy(buf, rs->row[idx]);
}
/*-------------------*/
void rs_close(RecordSet* rs){
mysql_free_result(rs->res);
free(rs);
}
/*-------------------*/
int main(void){
char no[255], name[255];
char* q = "";
RecordSet* rs = NULL;
/*Connect to mysql.*/
if(! db_conn("localhost", "root", "", "test")){
puts("db_conn failed!");
exit(-1);
}
/*Insert some data.*/
q = "insert into temp values(1, '홍길동')";
db_exec(q);
q = "insert into temp values(2, '고길동')";
db_exec(q);
q = "insert into temp values(3, '최길동')";
db_exec(q);
/*Select one string.*/
q = "select name from temp where no = 2";
db_one_str(q, no);
printf("%s\n%s\n\n", q, no);
/*RecordSet.*/
q = "select * from temp";
rs = rs_open(q);
while(rs_next(rs)){
rs_get_str(rs, 0, no);
rs_get_str(rs, 1, name);
printf("no = %s, name = %s\n", no, name);
}
rs_close(rs);
/*Delete data.*/
q = "delete from temp";
db_exec(q);
/*Close connection.*/
db_close();
return 0;
} |
1318745628_mysql_fun.c.txt