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语句