建立连接(DBConnection)
DBConnection(自 Python API 3.0.4.0
起支持)表示客户端与服务端之间的单个底层连接,用于执行脚本、调用函数和上传变量。
单连接推荐使用 DBConnection,多线程连接推荐使用
SimpleDBConnectionPool;原 Session 作为兼容层保留(详见“从
Session 迁移到 DBConnection”)。
注意:实例化 DBConnection 时不会自动连接服务器,执行操作前需先调用
connect()。
import dolphindb as ddb
conn = ddb.DBConnection(protocol="ddb")
try:
connected = conn.connect(
host="localhost",
port=8848,
userid="admin",
password="your_password",
)
if not connected:
raise RuntimeError("Failed to connect to DolphinDB")
print(conn.exec("1 + 1"))
# 输出:2
finally:
conn.close()
使用时需根据场景选择合适的连接接口:
| 使用场景 | 推荐接口 |
|---|---|
| 在单个连接上执行脚本、调用函数或上传变量 | DBConnection |
需要通过 Python 对象直接操作 DolphinDB 库表(如调用
s.table()、s.loadTable()、s.database())或使用内置流订阅
s.subscribe() |
Session |
| 在多线程中复用并自行获取、归还连接 | SimpleDBConnectionPool |
说明:后续示例为突出核心操作,均默认 conn 已成功连接。在生产环境中,建议使用
try...finally 块显式调用
conn.close(),以确保网络连接和系统资源能够正确释放。
