使用Ballerina MySQL库报错：action invocation as an expression not allowed here

你的代码存在两个核心问题，直接导致了该错误：

1. 错误选择了SQL操作方法 #

execute方法仅适用于无返回结果的SQL操作（比如INSERT、UPDATE、DELETE、CREATE TABLE这类DDL/DML语句），而你执行的是SELECT查询，需要用专门的查询方法来获取结果集。

2. Action调用语法不符合规范 #

在Ballerina中，通过->调用的action不能直接作为表达式赋值给变量，必须在支持action执行的上下文（如函数体语句、查询表达式中）使用。

修正后的代码示例 #

import ballerina/sql;
import ballerinax/mysql;
import ballerina/io;

// 定义与patient表结构匹配的记录类型，字段需和表字段一一对应
type Patient record {
    int id;
    string name;
    // 按需添加其他字段，比如 age, phone 等
};

public function main() returns error? {
    // 初始化数据库客户端，用check处理初始化阶段的错误
    mysql:Client dbClient = check new ("localhost", "root", "password", "db", 3306);

    // 使用query action获取查询结果流，用模板字符串定义参数化查询
    stream<Patient, sql:Error?> patientStream = dbClient->query(`SELECT * FROM patient`);

    // 遍历结果流，处理每条查询数据
    check from Patient p in patientStream
        do {
            io:println("患者信息: ", p);
        };

    // 显式关闭客户端连接，避免资源泄漏
    check dbClient.close();
}

关键修正说明 #

• 定义Patient记录：让Ballerina自动将数据库查询结果映射为强类型数据，方便后续处理
• 用query替代execute：query是专门处理SELECT查询的action，会返回包含结果的stream
• 规范action调用：在函数体中直接执行dbClient->query(...)获取结果流，再通过查询表达式遍历处理
• 显式关闭客户端：主动释放数据库连接资源

内容的提问来源于stack exchange，提问作者Dulmina