Dataphin如何使用计算任务Python脚本链接MySQL数据库

问题描述

Dataphin如何使用计算任务Python脚本链接MySQL数据库？

解决方案

Python脚本如下：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
#===============================================
import mysql.connector

def select_sql(sql):
    try:
        conn=mysql.connector.connect(
                host='xxx',
                user = 'xxx',
                passwd = 'xxx',
                port = 'xxx',
                db='xxx'
            )
        cur = conn.cursor()
        cur.execute(sql)
        for ccc in cur:
            print(ccc)
    finally:
        cur.close()
        cur.close()

if __name__ == '__main__':
    select_sql('select 123 as ccc')

执行效果如下：

适用于

• Dataphin