本文介绍如何从工作流-代码块中通过 Python 代码访问 Oracle 数据库
参考资料:
- 如何扩展代码块执行环境版本
https://docs.pd.mingdao.com/faq/codeextensionversion
- 安装对应的扩展库
https://docs.pd.mingdao.com/faq/codeextension
- 论坛神贴-明道云集成篇----《数据库集成》读数据
https://bbs.mingdao.net/topic/1470
一、安装 Python-OracleDB
参照参考资料 2 即可
说明:Oracledb 的包是新推出来的,替换了以前的 cx-oracle,具体可见
https://pypi.org/project/oracledb/
二、配置工作流
import oracledb
import JSON
con = oracledb.connect(dsn="user/password@ip:port/sid")
cur = con.cursor()
cur.execute("select * from table")
cols=cur.description
alldata=[]
res = cur.fetchall()
for data in res:
i = 0
op= {}
for col in cols:
op[cols[cols.index(col)][i]] =str(data[cols.index(col)])
i=i+1
alldata.append(op)
output = {'ret1':alldata}
cur.close()
con.close()
具体语法可自行百度 Python,我用的是 Python3
教程 | 菜鸟教程 (runoob.com)
三、配置 JSON 解析
四、获取数组对象
五、批量新增记录