脚本开发 / MySQL

MySQL 连接器操作对象主要提供一些操作 MySQL 的方法。 本连接器以下数据库：

• MariaDB
• Percona Server for MySQL
• 阿里云 PolarDB MySQL
• 阿里云 OceanBase
• 阿里云分析型数据库 (ADB) MySQL 版

DFF.CONN(...)参数如下：

参数	类型	必须/默认值	说明
connector_id	str	必须	连接器 ID
database	str	None	指定数据库

.query(...)

query(...)方法用于执行 SQL 语句，参数如下：

参数	类型	必须/默认值	说明
sql	str	必须	SQL 语句，可包含参数占位符。 ?表示需要转义的参数； ??表示不需要转义的参数
sql_params	list	None	SQL 参数

示例如下：

sql = 'SELECT * FROM ?? WHERE seq > ?'
sql_params = ['demo', 1]
result = db.query(sql, sql_params=sql_params)

.non_query(...)

non_query(...)方法用于执行增、删、改等 SQL 语句，返回影响行数。参数如下：

参数	类型	必须/默认值	说明
sql	str	必须	SQL 语句，可包含参数占位符。 ?表示需要转义的参数； ??表示不需要转义的参数
sql_params	list	None	SQL 参数

示例如下：

sql = 'DELETE FROM ?? WHERE id = ?'
sql_params = ['demo', 1]
effected_rows = db.non_query(sql, sql_params=sql_params)