Cyher.NET

**********************************************************
 *                                                                                     
 *       Filename:  mysqltest.c 
 *    Description:  mysql 
 *                                                                                     
 *        Version:  1.0 
 *        Created:  2009年02月16日 15时19分39秒 
 *       Revision: 
 *       Compiler:  gcc 
 * 
 *         Author:  cyher (), cyher.net@gmail.com 
 *        Company:  cyher.NET 
 *                                                                                     
 ***********************************************************/ 
 
#include                              /* mysql库 */ 
#include
#include
#include
#include "mysqltest.h"
 
MYSQL my_sql;
 
int init_datebase(void)
{
        my_bool on = 1; 
 
        mysql_init(&my_sql); 
 
     /* MYSQL_OPT_RECONNECT如果发现连接丢失，启动或禁止与服务器的自动再连接。从MySQL 5.0.3 
          * 开始，默认情况下禁止再连接，这是5.0.13中的新选项， 
          * 提供了一种以显式方式设置再连接行为的方法。 */ 
 
        if ( 0 != mysql_options(&my_sql, MYSQL_OPT_RECONNECT, &on)) { 
                printf( "Error set mysql_options for MYSOL_OPT_RECONNECT:%s\n", mysql_error(&my_sql) ); 
                return (OK); 
        } 
 
        if (!mysql_real_connect(&my_sql,"localhost", "root", "123456789", "Grandi_Power",0,NULL,0)) { 
                printf( "Error connecting to database: %s\n",mysql_error(&my_sql)); 
                return(ERROR); 
        } 
 
        return(OK); 
 
}
 
int my_insert(struct user_info * user)
{
 
        MYSQL_STMT *stmt; 
        MYSQL_BIND  bind[5]; 
        int user_name_len, user_pswd_len; 
 
        my_ulonglong  affected_rows; 
 
        char *sql="insert into user (USERNAME,PASSWORD,ARK_GROUP_ID,PURVIWE_GROUP_ID,LEVEL) values(?,?,?,?,?)"; 
 
        if (!(stmt = mysql_stmt_init(&my_sql))) 
                return; 
 
        memset(bind,0,sizeof(bind)); 
 
        if(mysql_stmt_prepare(stmt, sql, strlen(sql))) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        user_name_len = strlen(user->name); 
        user_pswd_len = strlen(user->pswd); 
 
        bind[0].buffer_type = MYSQL_TYPE_VAR_STRING; 
        bind[0].buffer = &(user->name); 
        bind[0].buffer_length = 25;                 /* 最大长度 */ 
        bind[0].is_null = 0; 
        bind[0].length= (unsigned long *)&user_name_len;                   /* 实际长度的地址 */ 
 
        bind[1].buffer_type = MYSQL_TYPE_VAR_STRING; 
        bind[1].buffer = &(user->pswd); 
        bind[1].buffer_length = 25;                 /* 最大长度 */ 
        bind[1].is_null = 0; 
        bind[1].length= (unsigned long *)&user_pswd_len;                   /* 实际长度的地址 */ 
 
        bind[2].buffer_type = MYSQL_TYPE_LONG; 
        bind[2].buffer = (char*)&(user->ark_grp); 
        bind[2].is_null = 0; 
        bind[2].length = 0; 
 
        bind[3].buffer_type = MYSQL_TYPE_LONG; 
        bind[3].buffer = (char*)&(user->puv_grp); 
        bind[3].is_null = 0; 
        bind[3].length = 0; 
 
        bind[4].buffer_type = MYSQL_TYPE_LONG; 
        bind[4].buffer = (char*)&(user->level); 
        bind[4].is_null= 0; 
        bind[4].length= 0; 
 
        if (mysql_stmt_bind_param(stmt, bind)) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        if (mysql_stmt_execute(stmt)) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        affected_rows = mysql_stmt_affected_rows(stmt); 
 
        if(1!=affected_rows) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        printf("INSERT SUCCEESFUL\n"); 
 
        mysql_stmt_close(stmt); 
}
 
int main(int argc, char **argv)
{
        struct user_info user; 
        strcpy(user.name,"haha"); 
        strcpy(user.pswd,"ninini"); 
        user.level = 4; 
        user.ark_grp = 88822; 
        user.puv_grp = 333; 
 
        init_datebase(); 
        my_insert(&user); 
 
        return OK; 
}

mytest: mysqltest.c  mysqltest.h
        gcc -o mytest mysqltest.c -I/usr/include/mysql -L/usr/lib/mysql  -lmysqlclient