C\C++访问MySQL

// 111.cpp : 定义控制台应用程序的入口点。
//
#include "stdafx.h"
#include <windows.h>
#include <iostream>
#include <D:\TDdownload\MySQL\111\include\mysql\mysql.h>
int main(int argc,char* argv[])
{
    char *user ="root", *pwd ="123456", *dbname = "chardb";
    MYSQL  mysql;
    MYSQL_RES  *mysql_ret;
    MYSQL_ROW  mysql_row;
    unsigned  long  num_rows;
    int  ret;
    mysql_init(&mysql);
    if(mysql_real_connect(&mysql,NULL,user,pwd,dbname,0,NULL,0))
    {
        printf("连接成功!\n");
        ret  =  mysql_query(&mysql,"select  *  from  accounts");
        if(!ret)
        {
            printf("查询成功!\n");
            mysql_ret  =  mysql_store_result(&mysql);
            if(mysql_ret  !=  NULL)
            {
                printf("存储结果成功!\n");
                num_rows  =  mysql_num_rows(mysql_ret);
                if(num_rows  !=  0)
                {
                    printf("%d\n",num_rows);
                    while(mysql_row  =  mysql_fetch_row(mysql_ret))
                    {
                        printf("%s\t%s\t%s\t%s\t%s\t%s\n",mysql_row[0],mysql_row[1],mysql_row[2],mysql_row[3],mysql_row[4],mysql_row[5]);
                    }
                }
                else
                {
                    exit(-1);
                }
                mysql_free_result(mysql_ret);
                exit(0);
            }
            else
            {
                exit(-1);
            }
        }
        else
        {
            exit(-1);
        }
    }
    else
    {
        printf("连接失败\n");
        exit(-1);
    }
}

修改后的代码

// 111.cpp : 定义控制台应用程序的入口点。
//
#include "stdafx.h"
#include <windows.h>
#include <iostream>
#include ".\include\mysql\mysql.h"
int main(int argc,char* argv[])
{
    char *user ="root", *pwd ="123456", *dbname = "chardb";
    MYSQL  mysql;
    MYSQL_RES  *mysql_ret;
    MYSQL_ROW  mysql_row;
    unsigned  long  num_rows;
    int  ret;
    mysql_init(&mysql);
    if(mysql_real_connect(&mysql,NULL,user,pwd,dbname,0,NULL,0))
    {
        printf("连接成功!\n");
        ret  =  mysql_query(&mysql,"select  *  from  accounts");
        if(!ret)
        {
            printf("查询成功!\n");
            mysql_ret  =  mysql_store_result(&mysql);
            if(mysql_ret  !=  NULL)
            {
                printf("存储结果成功!\n");
                num_rows  =  mysql_num_rows(mysql_ret);
                if(num_rows  !=  0)
                {
                    printf("%d\n",num_rows);
                    while(mysql_row  =  mysql_fetch_row(mysql_ret))
                    {
                        printf("%s\t%s\t%s\t%s\t%s\t%s\n",mysql_row[0],mysql_row[1],mysql_row[2],mysql_row[3],mysql_row[4],mysql_row[5]);
                    }
                }
                else
                {
                    mysql_close(&mysql);
                    exit(-1);
                }
                mysql_free_result(mysql_ret);
                mysql_close(&mysql);
                exit(0);
            }
            else
            {
                mysql_close(&mysql);
                exit(-1);
            }
        }
        else
        {
            mysql_close(&mysql);
            exit(-1);
        }
    }
    else
    {
        printf("连接失败\n");
        mysql_close(&mysql);
        exit(-1);
    }
    mysql_close(&mysql);
}

• 没有相关文章