GridDB多容器批量操作报错：容器'name01'未找到

核心错误原因 #

1. 容器名称混淆 #

你在JavaScript代码中定义的容器实际名称是usedcaranalysis和gdpanalysis，但Java代码里错误地使用了变量名name01、name02作为容器名称去查询，GridDB集群中不存在这两个名称的容器，因此抛出Container not found错误。

2. 未正确获取目标容器实例 #

代码中直接遍历containerList，但没有从GridStore实例中获取实际的容器对象，需要先通过GridDB API加载或创建目标容器。

3. TQL查询与容器Schema不匹配 #

目标容器的Schema中没有No_Of_Sold字段：

• usedcaranalysis容器中记录销售状态的字段是sold（字符串类型）
• gdpanalysis容器中是各年份的销量数据（Double类型）
  原查询语句完全不符合实际结构，无法执行。

4. 语法与类型错误 #

• 结果容器ContainerInfo的columnInfoList定义缺少闭合括号
• 读取Row字段时索引错误（结果容器中Country是第2列，索引为1；No_Of_Sold是第3列，索引为2）
• Java中基本类型是int而非Int
• 输出语句缺少闭合括号

修正后的完整代码 #

以下代码针对上述问题进行修复，并实现从两个容器中提取汽车品牌销量数据的逻辑：

import java.util.*;
import com.toshiba.mwcloud.gs.*;

public class BatchQueryExample {
    public static void main(String[] args) throws GSException {
        // 1. 配置连接参数
        Properties props = new Properties();
        props.setProperty("notificationAddress", args[0]);
        props.setProperty("notificationPort", args[1]);
        props.setProperty("clusterName", args[2]);
        props.setProperty("user", args[3]);
        props.setProperty("password", args[4]);

        try (GridStore store = GridStoreFactory.getInstance().getGridStore(props)) {
            // 2. 定义目标容器名称（注意是实际容器名，不是变量名）
            final List<String> containerNameList = Arrays.asList(
                "usedcaranalysis", "gdpanalysis");
            
            // 3. 获取所有目标容器实例
            List<Container<String, Row>> containerList = new ArrayList<>();
            for (String containerName : containerNameList) {
                // 加载容器（若不存在可使用putContainer创建）
                Container<String, Row> container = store.getContainer(containerName, Row.class);
                containerList.add(container);
            }

            // 4. 构建批量查询（根据不同容器的Schema编写对应TQL）
            List<Query<Row>> queryList = new ArrayList<>();
            for (Container<String, Row> container : containerList) {
                String tql;
                if (container.getName().equals("usedcaranalysis")) {
                    // 查询已售出的车辆记录
                    tql = "SELECT name, Country FROM usedcaranalysis WHERE sold = 'Yes'";
                } else {
                    // 查询2023年销量大于100000的品牌（示例）
                    tql = "SELECT name, Country, 2023 FROM gdpanalysis WHERE 2023 >= 100000";
                }
                queryList.add(container.query(tql));
            }

            // 5. 批量执行查询
            store.fetchAll(queryList);

            // 6. 处理查询结果
            for (int i = 0; i < queryList.size(); i++) {
                Query<Row> query = queryList.get(i);
                try (RowSet<Row> rs = query.getRowSet()) {
                    String containerName = containerNameList.get(i);
                    System.out.println("===== 容器 " + containerName + " 查询结果 =====");
                    while (rs.hasNext()) {
                        Row row = rs.next();
                        String carName = row.getString(0);
                        String country = row.getString(1);
                        
                        if (containerName.equals("usedcaranalysis")) {
                            // 统计usedcaranalysis中的销量（这里可根据需求累加）
                            System.out.println("品牌: " + carName + ", 地区: " + country + ", 状态: 已售出");
                        } else {
                            double sales2023 = row.getDouble(2);
                            System.out.println("品牌: " + carName + ", 国家: " + country + ", 2023年销量: " + sales2023);
                        }
                    }
                }
            }
        } catch (GSException e) {
            e.printStackTrace();
        }
    }
}

额外注意事项 #

• 确保GridDB集群中确实存在usedcaranalysis和gdpanalysis容器，可通过GridDB CLI工具gs_sh执行show containers命令验证。
• 若需要将查询结果写入新容器，需先通过store.putContainer创建结果容器，并在处理结果时插入数据。
• 批量查询时，不同容器的TQL语句需匹配各自的Schema，避免字段不存在的错误。

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