zoukankan      html  css  js  c++  java
  • C语言访问mysql数据库

    mysql中新建的数据库为hyx,hyx中的表为my_schema,表中的数据为下图:

    编写代码,访问表中的数据,测试代码如下:

    #include "stdafx.h"
    #include <WinSock2.h> /*socket通信,系统头文件*/
    #include <windows.h>
    #include <stdio.h>
    #include <stdlib.h>
    #include <time.h>
    #include "mysql.h"
    #pragma comment(lib, "libmysql.lib")
    
    
    /*数据库连接用宏*/
    #define HOST "localhost"
    #define USERNAME "root"
    #define PASSWORD "root"
    #define DATABASE "hyx"
    void query_sql(char* sql);
    int main()
    {
        char *query;
        query="select * from my_schema";
        query_sql(query);
        return 0;
    }
    void query_sql(char* sql)
    {
        MYSQL *conn; /*这是一个数据库连接*/
        int res; /*执行sql語句后的返回标志*/
        MYSQL_RES *res_ptr; /*指向查询结果的指针*/
        MYSQL_FIELD *field; /*字段结构指针*/
        MYSQL_ROW result_row; /*按行返回的查询信息*/
        int row, column; /*查询返回的行数和列数*/
        int i, j;
        /*初始化mysql连接my_connection*/
        conn=mysql_init(NULL);
        /*建立mysql连接*/
        if (NULL != mysql_real_connect(conn, HOST, USERNAME, PASSWORD,
                                       DATABASE, 0, NULL, CLIENT_FOUND_ROWS))  /*连接成功*/
        {
            printf("数据库查询query_sql连接成功!
    ");
            /*设置查询编码为gbk,以支持中文*/
            mysql_query(conn, "set names gbk");
            res = mysql_query(conn, sql);
            if (res)   /*执行失败*/
            {
                printf("Error: mysql_query !
    ");
                /*关闭连接*/
                mysql_close(conn);
            }
            else     /*现在就代表执行成功了*/
            {
                /*将查询的結果给res_ptr*/
                res_ptr = mysql_store_result(conn);
                /*如果结果不为空,就把结果print*/
                if (res_ptr)
                {
                    /*取得結果的行数和*/
                    column = mysql_num_fields(res_ptr);
                    row = mysql_num_rows(res_ptr);
                    printf("查询到 %d 行 
    ", row);
                    /*输出結果的字段名*/
                    for (i = 0; field = mysql_fetch_field(res_ptr); i++)
                        printf("%10s ", field->name);
                    printf("
    ");
                    /*按行输出結果*/
                    for (i = 1; i < row+1; i++)
                    {
                        result_row = mysql_fetch_row(res_ptr);
                        for (j = 0; j < column; j++)
                            printf("%10s ", result_row[j]);
                        printf("
    ");
                    }
                }
                /*不要忘了关闭连接*/
                mysql_close(conn);
            }
        }
        else
        {
            printf("数据库连接失败");
        }
    }

    运行结果:

  • 相关阅读:
    sql 读取txt 文件内容,并写入sql的方法
    Thread.Mutex 互斥体
    SQL语句创建登录名,数据库用户,数据库角色及分配权限:
    倾国倾城 歌词
    LINUX下c/c++的学习(4)linux file and direction(stat fstat lstat access umask chmod ...)
    飞蛾扑火
    生成验证码点击可刷新
    C#项目调用非托管代码函数的方法
    【学习】数据库事务
    如何判断数据库是否存在
  • 原文地址:https://www.cnblogs.com/myidea/p/5263208.html
Copyright © 2011-2022 走看看