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

c 存储过程返回值返回参数结果集

admin
行业动态
2025-02-24
1

存储过程可返回值、返回参数及结果集，用于处理复杂业务逻辑并返回数据。

在数据库编程中，存储过程是一种非常有用的工具，它允许你将一系列SQL语句封装成一个单元，这样可以重复使用并提高性能，C语言通过各种数据库API（如ODBC, MySQL Connector/C等）可以调用这些存储过程，下面我们来详细探讨如何在C语言中处理存储过程的返回值、返回参数和结果集。

存储过程的返回值

存储过程可以有一个整型返回值，这个返回值通常用来表示存储过程的执行状态，0可能表示成功，非0值表示不同类型的错误，在C语言中，你可以这样处理返回值：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    int qstate;
    conn = mysql_init(NULL);
    if (!mysql_real_connect(conn, "host", "user", "password", "database", 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    qstate = mysql_query(conn, "CALL my_stored_procedure()");
    if (qstate != 0) {
        fprintf(stderr, "ERROR: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    // 获取存储过程的返回值
    qstate = mysql_store_result(conn);
    if (qstate == NULL) {
        fprintf(stderr, "ERROR: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    row = mysql_fetch_row(res);
    if (row) {
        printf("Return Value: %s
", row[0]); // 假设返回值是第一列
    }
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}

存储过程的返回参数

除了返回值之外，存储过程还可以有输出参数，这些参数可以在存储过程内部被赋值，并在调用后检索，在C语言中处理返回参数通常涉及以下步骤：

1、声明一个变量来接收输出参数。

c 存储过程返回值返回参数结果集

2、在调用存储过程时，绑定这个变量作为输出参数。

3、执行存储过程后，读取这个变量的值。

示例代码如下：

c 存储过程返回值返回参数结果集

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    MYSQL_STMT *stmt;
    MYSQL_BIND bind[1];
    int out_param;
    my_bool is_null[1];
    conn = mysql_init(NULL);
    if (!mysql_real_connect(conn, "host", "user", "password", "database", 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    stmt = mysql_stmt_init(conn);
    if (!stmt) {
        fprintf(stderr, "Prepare failed
");
        exit(1);
    }
    if (mysql_stmt_prepare(stmt, "CALL my_stored_procedure(?)", -1)) {
        fprintf(stderr, "Prepare failed: %s
", mysql_error(conn));
        exit(1);
    }
    memset(bind, 0, sizeof(bind));
    bind[0].buffer_type = MYSQL_TYPE_INT;
    bind[0].buffer = &out_param;
    bind[0].is_null = &is_null[0];
    bind[0].length = 0;
    if (mysql_stmt_bind_param(stmt, bind)) {
        fprintf(stderr, "Bind failed: %s
", mysql_error(conn));
        exit(1);
    }
    if (mysql_stmt_execute(stmt)) {
        fprintf(stderr, "Execute failed: %s
", mysql_error(conn));
        exit(1);
    }
    printf("Output Parameter: %d
", out_param);
    mysql_stmt_close(stmt);
    mysql_close(conn);
    return 0;
}

结果集的处理

如果存储过程返回一个结果集，你需要遍历这个结果集并处理每一行数据，这可以通过mysql_store_result和mysql_fetch_row函数来实现，以下是一个简单的例子：

#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;
    int qstate;
    conn = mysql_init(NULL);
    if (!mysql_real_connect(conn, "host", "user", "password", "database", 0, NULL, 0)) {
        fprintf(stderr, "%s
", mysql_error(conn));
        exit(1);
    }
    qstate = mysql_query(conn, "CALL my_stored_procedure()");
    if (qstate != 0) {
        fprintf(stderr, "ERROR: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    res = mysql_store_result(conn);
    if (res == NULL) {
        fprintf(stderr, "Store result error: %s
", mysql_error(conn));
        mysql_close(conn);
        exit(1);
    }
    while ((row = mysql_fetch_row(res)) != NULL) {
        printf("%st%s
", row[0], row[1]); // 假设结果集有两列
    }
    mysql_free_result(res);
    mysql_close(conn);
    return 0;
}