MySQL教程 2023-04-27

C语言玩转MySQL构建你的代码块（c 使用mysql代码块）

C语言玩转MySQL：构建你的代码块

MySQL是一种广泛使用的数据库管理系统，而C语言是一种应用广泛的编程语言。如果将这两者结合起来，将会有很多有意义的事情发生。在本文中，我们将介绍如何通过C语言与MySQL进行交互，并构建自己的MySQL代码块，以便在编写程序时能更加高效地操作数据库。

1. 连接MySQL

要与MySQL进行交互，首先需要建立一个MySQL连接。下面是连接MySQL的C语言代码块：

“`c

#include

int mn(void)

{

MYSQL *conn;

conn = mysql_init(NULL);

if (!conn)

{

fprintf(stderr, “mysql_init() fled.\n”);

return 1;

}

conn = mysql_real_connect(conn, “localhost”, “root”, “password”, NULL, 0, NULL, 0);

if (conn == NULL)

{

fprintf(stderr, “mysql_real_connect() fled: %s.\n”, mysql_error(conn));

mysql_close(conn);

return 1;

}

mysql_close(conn);

return 0;

}


这段代码首先使用mysql_init()函数初始化一个MYSQL结构体对象，并检查它是否初始化成功。然后，使用mysql_real_connect()函数连接到MySQL数据库，并传入所需的参数，例如服务器名、用户名、密码等等。如果连接成功，该函数将返回一个非空的MYSQL结构体指针，否则返回NULL。

使用mysql_close()函数关闭连接，释放内存。

2. 查询数据库

一旦建立了MySQL连接，就可以执行查询语句并访问数据库了。下面是一个执行查询语句的C语言代码块：

```c
#include 
int mn(void)
{
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;

    conn = mysql_init(NULL);
    
    ...

    if (mysql_query(conn, "SELECT * FROM `books`"))
    {
        fprintf(stderr, "mysql_query() fled: %s.\n", mysql_error(conn));
        mysql_close(conn);
        return 1;
    }
    res = mysql_use_result(conn);

    while ((row = mysql_fetch_row(res)) != NULL)
    {
        printf("%s\t%s\t%s\n", row[0], row[1], row[2]);
    }
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}

这段代码首先使用mysql_query()函数执行一个SQL查询，并检查它是否执行成功。然后，使用mysql_use_result()函数获取查询结果的结果集，并从结果集中逐行提取每一行的数据。

在本例中，我们查询一个名为“books”的表，并将结果集中每一行的第1列、第2列和第3列打印出来。

使用mysql_free_result()函数释放结果集的内存，并使用mysql_close()函数关闭连接，释放内存。

3. 执行SQL语句

除了查询语句外，还可以执行其他类型的SQL语句，例如插入、更新和删除。下面是一个执行插入语句的C语言代码块：

“`c

#include

int mn(void)

{

MYSQL *conn;

conn = mysql_init(NULL);

…

if (mysql_query(conn, “INSERT INTO `books` (`title`, `author`, `year`) VALUES (‘C语言玩转MySQL’, ‘张三’, ‘2021’)”))

{

fprintf(stderr, “mysql_query() fled: %s.\n”, mysql_error(conn));

mysql_close(conn);

return 1;

}

mysql_close(conn);

return 0;

}


这段代码首先使用mysql_query()函数执行一个插入语句，并检查它是否执行成功。

在本例中，我们插入一条记录到“books”表中，该记录包含三个字段：标题、作者和出版年份。注意，在SQL语句中，文本字段需要用单引号括起来。

使用mysql_close()函数关闭连接，释放内存。

4. 错误处理

在与MySQL进行交互时，可能会发生错误，例如连接失败、查询失败等等。为了捕获和处理这些错误，我们需要使用错误处理机制。

下面是一个处理错误的C语言代码块：

```c
#include 
int mn(void)
{
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;

    conn = mysql_init(NULL);

    if (!conn)
    {
        fprintf(stderr, "mysql_init() fled.\n");
        return 1;
    }

    conn = mysql_real_connect(conn, "localhost", "root", "password", NULL, 0, NULL, 0);
    
    if (conn == NULL)
    {
        fprintf(stderr, "mysql_real_connect() fled: %s.\n", mysql_error(conn));
        mysql_close(conn);
        return 1;
    }
    if (mysql_query(conn, "SELECT * FROM `books`"))
    {
        fprintf(stderr, "mysql_query() fled: %s.\n", mysql_error(conn));
        mysql_close(conn);
        return 1;
    }
    res = mysql_use_result(conn);

    if (res == NULL)
    {
        fprintf(stderr, "mysql_use_result() fled: %s.\n", mysql_error(conn));
        mysql_close(conn);
        return 1;
    }
    while ((row = mysql_fetch_row(res)) != NULL)
    {
        printf("%s\t%s\t%s\n", row[0], row[1], row[2]);
    }
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}