flink sql 查询sql 返回String

在 Flink SQL 中，可以使用 SELECT 语句来查询数据，并将结果返回为字符串。下面是一个简单的示例代码：

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableResult;
import org.apache.flink.types.Row;

public class FlinkSQLExample {
    public static void main(String[] args) throws Exception {
        // 创建执行环境
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();

        // 创建TableEnvironment
        BatchTableEnvironment tEnv = BatchTableEnvironment.create(env, settings);

        // 创建输入表
        String createTableSql = "CREATE TABLE myTable (name STRING, age INT) WITH ('connector.type' = 'filesystem', 'format.type' = 'csv', 'connector.path' = 'path/to/csv/file')";
        tEnv.executeSql(createTableSql);

        // 执行查询
        String querySql = "SELECT * FROM myTable";
        TableResult tableResult = tEnv.executeSql(querySql);

        // 将查询结果转换为字符串
        String resultStr = tableResult.collect().stream()
                .map(Row::toString)
                .collect(Collectors.joining("\n"));

        // 打印查询结果
        System.out.println(resultStr);
    }
}

在示例代码中，首先创建了一个 Flink 的执行环境和 TableEnvironment，然后使用 `CREATE TABLE` 语句创建了一个输入表。接下来，使用 `SELECT` 语句执行了查询，并将查询结果转换为字符串。最后，打印了查询结果。

请注意，这只是一个简单的示例，实际使用时需要根据具体的数据源和表结构进行相应的配置和调整。