Dataphin功能Tips系列(35)-通过Python脚本连接数据库

本文涉及的产品
智能数据建设与治理Dataphin,200数据处理单元
简介: 通过Python脚本连接数据库

一、场景

目前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三方包

相关文章
|
10天前
|
前端开发 数据库
会议室管理系统源码(含数据库脚本)
会议室管理系统源码(含数据库脚本)
30 0
|
2天前
|
Java 数据库
jsp CRM客户管理系统(含数据库脚本以及文档)
jsp CRM客户管理系统(含数据库脚本以及文档)
29 10
|
9天前
|
Java 关系型数据库 MySQL
Java汽车租赁系统源码(含数据库脚本)
Java汽车租赁系统源码(含数据库脚本)
30 4
|
2月前
|
SQL 数据采集 分布式计算
深度探索 Dataphin 数据中台的功能与表现
深度探索 Dataphin 数据中台的功能与表现
119 7
|
2月前
|
存储 SQL Oracle
|
2月前
|
关系型数据库 MySQL 数据库
|
2月前
|
SQL 分布式计算 资源调度
Dataphin功能Tips系列(48)-如何根据Hive SQL/Spark SQL的任务优先级指定YARN资源队列
如何根据Hive SQL/Spark SQL的任务优先级指定YARN资源队列
|
2月前
|
分布式计算 监控 Java
|
2月前
|
资源调度 Kubernetes 调度
Dataphin功能Tips系列(46)-实时研发任务在session调试和运行 时资源分配上的区别
实时研发任务在session调试和运行 时资源分配上的区别
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等