通过 Python SDK 读取 SQL 查询结果中的 DATETIME、DATE 和 TIME 类型数据。
前提条件
安装Tablestore Python SDK并初始化客户端。
SQL 查询功能需要使用 5.4.2 及以上版本,建议使用最新版本。
已为待操作的数据表创建映射关系。
功能说明
调用 exe_sql_query 方法执行 SELECT 语句,并使用 SQL 日期和时间函数将数值转换为 DATETIME、TIME 或 DATE。from_unixtime 的输入为秒级 Unix 时间戳。
def exe_sql_query(self, query)
以下示例转换 example_table 中 event_time 列的值。Python SDK 将三种 SQL 类型都解析为字符串。
query = (
"SELECT from_unixtime(event_time) AS datetime_value, "
"time(from_unixtime(event_time)) AS time_value, "
"date(from_unixtime(event_time)) AS date_value "
"FROM example_table WHERE pk = 'row1' LIMIT 1"
)
row_list, _, _ = client.exe_sql_query(query)
for row in row_list:
values = dict(row.attribute_columns)
print(values["datetime_value"])
print(values["time_value"])
print(values["date_value"])
参数说明
exe_sql_query 方法包含以下参数。
|
名称 |
类型 |
说明 |
|
query(必选) |
String |
要执行的 |
返回值
exe_sql_query 方法返回一个三元组,包含以下元素。
|
元素 |
类型 |
说明 |
|
|
List[Row] |
查询结果行列表。 |
|
|
List[Tuple] |
各数据表消耗的读写 CU。每个元组包含数据表名称和 |
|
|
List[Tuple] |
各多元索引消耗的读写 CU。每个元组包含多元索引名称和 |
该文章对您有帮助吗?