使用GridDB Python API查询无结果但数据存在的问题排查

问题原因及修复方案 #

1. 参数占位符索引错误 #

GridDB Python API中，查询参数的索引从0开始，而非1。你代码中使用query.set_int(1, 1)，实际是给不存在的第2个占位符赋值，导致查询条件不匹配，无结果返回。

修复：将索引改为0：

query.set_int(0, 1)

2. 获取容器的方式错误 #

你通过store.get_container(conInfo)并设置create_if_not_exist=True获取已存在的容器，可能触发不必要的schema校验，导致无法正确关联目标容器。正确做法是直接通过容器名获取已存在的容器。

修复：替换容器获取逻辑：

# 直接获取已存在的容器
con = store.get_container("mycontainer")

如果需要兼容容器不存在的场景，可先判断再创建：

container_name = "mycontainer"
if not store.has_container(container_name):
    conInfo = griddb.ContainerInfo(container_name,
                                   [["id", griddb.Type.INTEGER],
                                    ["name", griddb.Type.STRING]],
                                   griddb.ContainerType.COLLECTION, True)
    con = store.put_container(conInfo)
else:
    con = store.get_container(container_name)

3. 查询结果获取逻辑问题 #

query.fetch(False)中all=False表示仅获取一行结果，若需遍历所有匹配数据，应设置all=True（或省略参数，默认值为True）。

修复：修改fetch调用：

rs = query.fetch()
# 或者显式指定all=True
rs = query.fetch(True)

完整修复代码 #

import griddb_python as griddb

factory = griddb.StoreFactory.get_instance()
store = factory.get_store(
    host='localhost',
    port=2406,
    cluster_name='mycluster',
    username='admin',
    password='admin'
)

container_name = "mycontainer"
if not store.has_container(container_name):
    conInfo = griddb.ContainerInfo(container_name,
                                   [["id", griddb.Type.INTEGER],
                                    ["name", griddb.Type.STRING]],
                                   griddb.ContainerType.COLLECTION, True)
    con = store.put_container(conInfo)
else:
    con = store.get_container(container_name)

query = con.query("select * where id = ?", griddb.Type.INTEGER)
query.set_int(0, 1)
rs = query.fetch()
for row in rs:
    print(row)

可选：添加异常捕获排查问题

try:
    # 上述完整代码逻辑
except griddb.GSException as e:
    print(f"GridDB错误信息: {e.get_message()}")

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