比如配置文件:
-- 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()