py执行数据库存储过程

比如配置文件:

-- config.ini:
[mysql_133]
db_port = 33601
db_user = xxxx
db_host = 172.18.1.x
db_pass = xxx
db_name=xxx

py读取数据库信息执行存储过程:

#!/usr/bin/env python
# -*- coding:UTF-8 -*-
import pymysql,configparser,os
#定义数据库连接信息
def login_mysql():
#    cur_path=os.path.dirname(os.path.realpath("__file__"))
#   configpath=os.path.join(cur_path,"config.ini")
    conf=configparser.ConfigParser()
    conf.read("/database/sync/applogs/executor/jobhandler/gluesource/config.ini",encoding='utf-8')
    host = str(conf.get('mysql_133', 'db_host'))
   # host = conf['mysql_133']['db_host']
    port = int(conf.get('mysql_133', 'db_port'))
    database = conf.get('mysql_133', 'db_name')
    user = conf.get('mysql_133', 'db_user')
    password = conf.get('mysql_133', 'db_pass')
    conn = pymysql.connect(host=host,port=port,db=database,user=user,password=password,charset='utf8mb4')
    cusor = conn.cursor()
    sql='''call  proc_sales_reorg_data()'''
    try:
        cusor.execute(sql)
        conn.commit()
    except Exception as e:
        print(e)
        conn.rollback()
    return conn,cusor

if __name__ == '__main__':
   login_mysql()
原文地址:https://www.cnblogs.com/5sdba-notes/p/12960569.html