建立连接(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(),以确保网络连接和系统资源能够正确释放。