一、场景
目前Dataphin已经支持了MySQL、AnalyticDB for PostgreSQL、Oracle、Presto、starrocks、clickhouse这些数据库SQL,可以进行数据库操作,当我们想要跟其他数据库进行交互,但是Dataphin暂时不支持数据库SQL时,我们可以怎么处理呢?
二、解决方案及功能
可以利用Python 中的各种数据库连接库(如 pymssql、pyodbc、mysql-connector-python
等)直接编写Python脚本来连接和操作这些数据库,接下来以sql server数据库为例,演示如何通过pymssql
连接数据库并建表
①【管理中心-三方库管理-Python三方包】可以通过在线安装或是上传安装的方式安装所需的Python三方包
②创建一个 Python 脚本,用于建立数据库连接并创建表
import pymssql # 连接到 SQL Server connection = pymssql.connect(server='xxx', user='xxx', password=${dp_glb_sql_server_pwd}, database='xxx') cursor = connection.cursor() # 创建表 cursor.execute(''' CREATE TABLE customers ( id INT PRIMARY KEY IDENTITY(1,1), -- Customer ID, auto-incrementing primary key first_name NVARCHAR(50) NOT NULL, -- First name, cannot be null last_name NVARCHAR(50) NOT NULL, -- Last name, cannot be null email NVARCHAR(100) NOT NULL UNIQUE,-- Email, cannot be null and must be unique phone NVARCHAR(15), -- Phone number, can be null created_at DATETIME DEFAULT GETDATE() -- Registration timestamp, defaults to current time ) ''') # 提交更改并关闭连接 connection.commit() cursor.close() connection.close()
③在【属性】配置项选择需要用到的Python三方包