第五章 Python SDK
5.1 安装与引入
Python SDK为单文件模块，将 sxdb_client.py 复制到项目目录即可使用。无需安装任何第三方依赖，仅使用Python标准库socket和json模块。
from sxdb_client import SxdbClient, SxdbResultSet
5.2 客户端核心API
| 方法 | 参数 | 说明 |
| connect() | - | 连接服务器 |
| login(user, pass) | 用户名、密码 | 认证登录 |
| open_db(db) | 数据库名 | 打开数据库 |
| execute(db, sql, params) | 库名、SQL、参数 | 执行DDL/DML |
| query(db, sql, params) | 库名、SQL、参数 | 查询数据 |
| batch(db, statements) | 库名、SQL列表 | 批量执行 |
| insert(db, table, data) | 库名、表名、字段字典 | 插入一行 |
| select(db, table, ...) | 多个查询参数 | 简化查询 |
| close() | - | 关闭连接 |
5.3 基本使用示例
from sxdb_client import SxdbClient
使用 context manager 自动管理连接
with SxdbClient("127.0.0.1", 31111) as client:
登录
client.login("admin", "admin123")
client.open_db("myapp")
创建表
client.execute("myapp",
"CREATE TABLE IF NOT EXISTS orders("
"id INTEGER PRIMARY KEY AUTOINCREMENT, "
"product TEXT, quantity INTEGER, total REAL)")
插入数据 (便捷方法)
client.insert("myapp", "orders", {
"product": "电子书",
"quantity": 3,
"total": 89.7
})
查询数据 (便捷方法)
result = client.select("myapp", "orders",
columns="*", where="quantity > 1",
order_by="total DESC", limit=10)
解析结果
rs = result["data"]
print(rs["columns"]) # ["id","product","quantity","total"]
| for row in rs["rows"]: | print(row) |
| client.close_db("myapp") | 代码5-1 Python 基本使用示例 |
5.4 高级用法：批量操作
from sxdb_client import SxdbClient, SxdbResultSet
client = SxdbClient("127.0.0.1", 31111)
client.connect()
client.login("admin", "admin123")
批量执行多条SQL
result = client.batch("myapp", [
{"sql": "INSERT INTO orders(product,quantity,total) VALUES(?,?,?)",
"params": ["手机", 1, 4999]},
{"sql": "INSERT INTO orders(product,quantity,total) VALUES(?,?,?)",
"params": ["耳机", 2, 198]},
{"sql": "INSERT INTO orders(product,quantity,total) VALUES(?,?,?)",
"params": ["充电器", 1, 129]},
])
print("Batch result:", result)
使用 SxdbResultSet 封装结果
raw = client.query("myapp", "SELECT * FROM orders WHERE total > 100")
rs = SxdbResultSet(raw)
for row in rs:
print(f" {row['product']}: {row['total']:.2f}")
client.close()
代码5-2 Python 批量操作与结果封装