c调用mysql存储过程

DELIMITER //

CREATE PROCEDURE InsertUser(
    IN p_name VARCHAR(255),
    IN p_email VARCHAR(255)
)
BEGIN
    INSERT INTO users (name, email) VALUES (p_name, p_email);
END //

DELIMITER ;

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

int main() {
    MYSQL *conn;
    MYSQL_STMT *stmt;
    MYSQL_BIND bind[2];
    char name[255], email[255];

    // 初始化MySQL连接
    conn = mysql_init(NULL);
    if (!mysql_real_connect(conn, "localhost", "user", "password", "database", 0, NULL, 0)) {
        fprintf(stderr, "%s\n", mysql_error(conn));
        exit(1);
    }

    // 准备调用存储过程
    stmt = mysql_stmt_init(conn);
    if (!mysql_stmt_prepare(stmt, "CALL InsertUser(?, ?)", -1)) {
        fprintf(stderr, "%s\n", mysql_stmt_error(stmt));
        exit(1);
    }

    // 绑定参数
    memset(bind, 0, sizeof(bind));
    bind[0].buffer_type = MYSQL_TYPE_STRING;
    bind[0].buffer = (char *)name;
    bind[0].buffer_length = sizeof(name);
    bind[1].buffer_type = MYSQL_TYPE_STRING;
    bind[1].buffer = (char *)email;
    bind[1].buffer_length = sizeof(email);

    if (mysql_stmt_bind_param(stmt, bind) != 0) {
        fprintf(stderr, "%s\n", mysql_stmt_error(stmt));
        exit(1);
    }

    // 设置参数值
    strcpy(name, "John Doe");
    strcpy(email, "john.doe@example.com");

    // 执行存储过程
    if (mysql_stmt_execute(stmt) != 0) {
        fprintf(stderr, "%s\n", mysql_stmt_error(stmt));
        exit(1);
    }

    // 清理资源
    mysql_stmt_close(stmt);
    mysql_close(conn);

    return 0;
}