使用python在dolphinDB上运行SQL

需要先部署好dolphindb并启动数据库

步骤1：链接dolphinDB数据库

安装依赖库：pip install dolphindb

然后运行：

import dolphindb as ddbdef get_dolphin_session():"""获取dolphinDB的session"""dolphin_config = {"host": "127.0.0.1","port": 13900,"username": "admin","password": "123456",}s = ddb.session()_result = s.connect(dolphin_config['host'], dolphin_config['port'], dolphin_config['username'],dolphin_config['password'])if not _result:logger.error("DolphinDB 数据库无法连接！！")return Nonereturn s

步骤2. 写SQL

对于需要执行这样的一个SQL：

SELECT DISTINCT my_date FROM base_info
WHERE trade_date >= "2010-01-01"
ORDER BY trade_date DESC

使用python编写的函数如下：

def get_latest_trading_date():"""选择my_db数据库的base_info表最新交易记录"""dolphin_s = get_dolphin_session()dolphin_dt = dolphin_s.loadTable(tableName="base_info", dbPath="dfs://my_db")trade_list = dolphin_dt.select("DISTINCT my_date").where(f"""my_date >= timestamp(2010.01.01)ORDER BY my_date DESC""").toList()return trade_list

这里有几个重点：

最好提前写好SQL并且运行通过，再移植到python上，因为如果报错，dolphindb只会报错不会给错误信息
在其他数据库中，日期可以用"2010-01-01"这样表示，而在dolphindb中，会认为这是一个减法操作，需要改写为："timestamp(2010.01.01)"，这样才认为是日期（当然可以做其他转换）
最后toList()才会执行sql，也可以toDF()为dataframe格式，showSQL()直接返回执行的SQL语句而不执行

日期格式如果作为参数，传入时可以改写为如下程序：

dt_from = pd.to_datetime("2010-01-01")
dt_to = pd.to_datetime("2020-01-01")
trade_list = dolphin_dt.select("DISTINCT my_date").where(f"""my_date >= timestamp({dt_from.strftime('%Y.%m.%d')})AND my_date <= timestamp({dt_to.strftime('%Y.%m.%d')})""").toList()