当前位置：首页 > 行业动态 > 正文

c执行mysql脚本

admin
行业动态
2025-02-04
3

c执行mysql脚本可通过命令行工具、图形化管理工具、编程语言接口及自动化工具实现。命令行工具灵活，适用于各操作系统；图形化工具直观便捷；编程语言接口便于自动化任务；自动化工具如Ansible可配置管理和部署。

在C语言中执行MySQL脚本涉及几个关键步骤，包括连接到MySQL数据库、执行SQL脚本以及处理结果，以下是详细步骤和示例代码：

安装必要的库

确保你的系统上安装了MySQL开发库，对于大多数Linux发行版，你可以使用包管理器来安装这些库，在Ubuntu上，你可以运行以下命令：

sudo apt-get install libmysqlclient-dev

包含头文件

在你的C程序中，你需要包含MySQL的头文件：

#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>

初始化MySQL连接

创建一个函数来初始化与MySQL服务器的连接：

MYSQL *init_mysql() {
    MYSQL *conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_real_connect(conn, "localhost", "your_username", "your_password", "your_database", 0, NULL, 0) == NULL) {
        fprintf(stderr, "%s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    return conn;
}

执行SQL脚本

创建一个函数来执行SQL脚本文件：

c执行mysql脚本

void execute_sql_script(MYSQL *conn, const char *script_path) {
    FILE *file = fopen(script_path, "r");
    if (file == NULL) {
        perror("Error opening file");
        exit(1);
    }
    char query[1024];
    while (fgets(query, sizeof(query), file)) {
        if (mysql_query(conn, query)) {
            fprintf(stderr, "%s
", mysql_error(conn));
            break;
        }
    }
    fclose(file);
}

关闭连接

创建一个函数来关闭与MySQL服务器的连接：

void close_mysql(MYSQL *conn) {
    mysql_close(conn);
}

主函数

将所有部分组合在一起，创建主函数：

int main() {
    MYSQL *conn = init_mysql();
    execute_sql_script(conn, "path/to/your/script.sql");
    close_mysql(conn);
    return 0;
}

编译和运行

编译你的C程序时，需要链接MySQL客户端库：

gcc -o myprogram myprogram.c $(mysql_config --cflags --libs)
./myprogram

8. 示例SQL脚本（script.sql）

c执行mysql脚本

这是一个简单的SQL脚本示例，用于创建表并插入数据：

CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    email VARCHAR(100) NOT NULL
);
INSERT INTO users (username, email) VALUES ('user1', 'user1@example.com');
INSERT INTO users (username, email) VALUES ('user2', 'user2@example.com');