在 C 应用程序中调用 MySQL 存储过程给出错误

Question

我想在一个用 C 编写的应用程序中使用 MySQL 的CURSOR。

我创建了一个存储过程

CREATE PROCEDURE curdemo(IN id INT)
BEGIN
    DECLARE a INT;
    DECLARE flag BOOL DEFAULT FALSE;
    DECLARE done INT DEFAULT FALSE;
    DECLARE cur1 CURSOR FOR SELECT test.Cars.Id FROM test.Cars;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

    OPEN cur1;

    read_loop: LOOP
            FETCH cur1 INTO a;
            IF done THEN
                    LEAVE read_loop;
            END IF;

            IF flag THEN
                    SELECT test.Cars.Price FROM test.Cars WHERE test.Cars.id = a;
                    LEAVE read_loop;
            END IF;

            IF a = id THEN
                    SET flag = TRUE;
            END IF;
    END LOOP;

    CLOSE cur1;
    END//

这是我在数据库测试中名为 Cars 的表

+------+------------+--------+

| Id   | Name       | Price  |

+------+------------+--------+

|    1 | Audi       |  52642 |

|    2 | Mercedes   |  57127 |

|    3 | Skoda      |   9000 |

|    4 | Volvo      |  29000 |

|    5 | Bentley    | 350000 |

|    6 | Citroen    |  21000 |

|    7 | Hummer     |  41400 |

|    8 | Volkswagen |  21600 |

+------+------------+--------+

当我使用来自 C 应用程序的以下查询时，我得到结果 = NULL，因此只有在 id = 8 时才会出现分段错误，否则它可以正常工作

 snprintf(statement, 100, "CALL curdemo('%d')", id);
    // Call stored procedure query
    if ( mysql_query(device_table_conn, statement) )
    {
            error_function(device_table_conn);
            //return 1;
    }

    result = mysql_use_result(device_table_conn);

如果发生错误，mysql_use_result() 将返回 NULL。

但如果 CALL 返回 NULL 或空结果，则不应返回 NULL。

Answer 1

终于明白了。

按照处理多个语句的步骤： https://dev.mysql.com/doc/refman/5.0/en/c-api-multiple-queries.html

这里是代码

    snprintf(statement, 100, "CALL curdemo('%d')", id);
    if ( mysql_query(device_table_conn, statement) )
    {
            error_function(device_table_conn);
            //return 1;
    }

    do{
            // did current statement return data?
            result = mysql_store_result(device_table_conn);
            if (result)
            {
                    // yes; process rows and free the result set
                    num_fields = mysql_num_fields(result);

                    while ((row = mysql_fetch_row(result)))
                    {
                            for ( i = 0; i < num_fields; i++ )
                            {
                                    printf("%s\n", row[i]);
                            }
                    }

                    mysql_free_result(result);
            }
            else
            {
                    mysql_free_result(result);
            }
            // more results? -1 = no, >0 = error, 0 = yes (keep looping)
            if ((status = mysql_next_result(device_table_conn)) > 0)
            {
                    ;
            }
    } while (status == 0);

    mysql_close(device_table_conn);

对于任何错误的 id（表中不存在）以及 id = 8 时，它不会返回任何内容。

Answer 2

你的read_loop 逻辑很有趣。

让我们来看看吧：

1. 你从光标中获取到a；
2. 你测试你的done标志；
3. 你测试你的flag标志；
4. 您针对id 测试a 的值并设置flag
5. 你再次从光标获取，覆盖a的值；
6. 您测试您的done 标志；
7. 您测试了您的flag 标志，现在是true，此时您执行选择，但针对a 的错误值。

当您的输入 id 是 8 时，您最终会超过表中的最后一行，这就是我认为您得到空结果的原因。

你需要测试a 和id 的值在做其他事情之前：

read_loop: LOOP
        FETCH cur1 INTO a;
        IF done THEN
                LEAVE read_loop;
        END IF;

        IF a = id THEN
                SET flag = TRUE;
        END IF;

        IF flag THEN
                SELECT test.Cars.Price FROM test.Cars WHERE test.Cars.id = a;
                LEAVE read_loop;
        END IF;

END LOOP;

编辑

我不得不问，为什么不直接获取指定 ID 的价格，调用mysql_store_result()，然后调用mysql_num_rows() 来查看查询是否真的返回了什么？如果您要获取特定的行键，那么您的结果集将永远只有 0 或 1 行，因此立即存储它不应该有问题。

要么，要么先执行select count(*) from cars where id = :id;，并且仅在结果> 0时继续。