GridDB Python客户端无法为已有容器添加列的问题咨询

问题描述 #

通过GridDB Python客户端创建了Users容器：

from griddb_python import griddb

factory = griddb.StoreFactory.get_instance()
gridstore = factory.get_store(
    host="127.0.0.1", port=31999, 
    cluster_name="defaultCluster", 
    username="admin", password="admin"
)

con_info = griddb.ContainerInfo(
    "Users",
    [["id", griddb.Type.INTEGER], ["name", griddb.Type.STRING]],
    griddb.ContainerType.COLLECTION, True  
)
container = gridstore.put_container(con_info)
container.put([1, "Abdullah"])

后续需要为Users容器添加age列，尝试更新ContainerInfo并再次调用put_container：

new_con_info = griddb.ContainerInfo(
    "Users",
    [["id", griddb.Type.INTEGER], ["name", griddb.Type.STRING], ["age", griddb.Type.INTEGER]],
    griddb.ContainerType.COLLECTION, True
)
new_container = gridstore.put_container(new_con_info) 

执行后报错：

GSException: (code: -8, message: Container already exists)

疑问：能否通过GridDB Python客户端在容器创建后修改其Schema（如添加或删除列）？如果不能，GridDB中推荐的数据Schema演进方式是什么？

解决方案 #

1. 关于容器Schema修改的结论 #

当前GridDB Python客户端不支持在容器创建后直接修改Schema（包括添加、删除列）。你调用put_container时的报错是因为该方法仅用于创建新容器，无法覆盖或修改已存在的容器结构。

2. 推荐的Schema演进方式 #

方式一：创建新容器迁移数据

这是最直接的结构化扩展方式，步骤如下：

• 新建包含目标Schema的容器
• 从原容器读取所有数据，补充新列的默认值后写入新容器
• 验证数据无误后，可删除原容器并将新容器重命名为原名称（如果需要）

示例代码：

from griddb_python import griddb

# 初始化连接
factory = griddb.StoreFactory.get_instance()
gridstore = factory.get_store(
    host="127.0.0.1", port=31999, 
    cluster_name="defaultCluster", 
    username="admin", password="admin"
)

# 获取原容器
old_container = gridstore.get_container("Users")

# 创建带age列的新容器
new_con_info = griddb.ContainerInfo(
    "Users_new",
    [["id", griddb.Type.INTEGER], ["name", griddb.Type.STRING], ["age", griddb.Type.INTEGER]],
    griddb.ContainerType.COLLECTION, True
)
new_container = gridstore.put_container(new_con_info)

# 迁移数据，为age设置默认值0
query = old_container.query("select *")
rs = query.fetch()
while rs.has_next():
    row = rs.next()
    new_container.put([row[0], row[1], 0])

# 可选：删除原容器并将新容器重命名为原名称
gridstore.drop_container("Users")
gridstore.rename_container("Users_new", "Users")

方式二：使用JSON字符串存储动态字段

如果Schema需要频繁变动，可以将非核心字段打包为JSON字符串，存储在一个STRING类型的列中，无需修改容器结构即可扩展字段。

示例代码：

from griddb_python import griddb
import json

factory = griddb.StoreFactory.get_instance()
gridstore = factory.get_store(
    host="127.0.0.1", port=31999, 
    cluster_name="defaultCluster", 
    username="admin", password="admin"
)

# 创建包含extra字段的容器
con_info = griddb.ContainerInfo(
    "Users",
    [["id", griddb.Type.INTEGER], ["name", griddb.Type.STRING], ["extra", griddb.Type.STRING]],
    griddb.ContainerType.COLLECTION, True
)
container = gridstore.put_container(con_info)

# 存入包含age的JSON数据
extra_data = json.dumps({"age": 25, "city": "Dubai"})
container.put([1, "Abdullah", extra_data])

# 查询时解析JSON获取动态字段
query = container.query("select * where id=1")
rs = query.fetch()
if rs.has_next():
    row = rs.next()
    extra_fields = json.loads(row[2])
    print(f"Age: {extra_fields['age']}")  # 输出 Age: 25

方式三：提前预留备用字段

在初始创建容器时，预先定义几个通用备用列（如reserve1、reserve2），后续需要扩展字段时直接复用这些预留列，避免修改Schema的操作。

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