Python链接Mysql处理语句

import pymysql
import calendar


def get_info(sql):
    # 打开数据库连接
    try:
        db = pymysql.connect(host=host, user=user,passwd=passwd, port=3306, db=db, charset='utf8')
    except Exception as e:
        print("报错:%s" % (e))
        print('连接失败,请检查远程访问权限!')
        input()

    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = db.cursor()
    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print('succeed')

    except Exception as e:
        print("\n执行状态:")
        print("报错:%" % (e))
        # 如果发生错误则回滚
        db.rollback()
        print('Error,rollback!')

    # 关闭数据库连接
    db.close()

这里面涉及到的是Python对Mysql的处理,我封装好了,大家可以自己调用或者改写

参数:

host=host, user=user,passwd=passwd, port=3306, db=db,

请自己修改

关于执行的命令是这行

cursor.execute(sql)

sql为带引号的SQL语句

Katen Doe

Fiime分享

专业分享,共建知识殿堂

猜你喜欢

wave

按 ECS 键退出搜索