import pymysql db = pymysql.connect(host='***.***.***.160', user='root', passwd='Ca8th**#Python', db='fusion_media', charset='utf8mb4', port=3306) cur = db.cursor() # 查询 sql1 = "SELECT data_box FROM t_ai_images WHERE identifying = %s" cur = db.cursor() cur.execute(sql1, (identifying)) img_data = cur.fetchone() # cur.fetchall() if img_data[0]: data_box = img_data[0] # 插入 sql = "INSERT INTO t_ai_images(input_img_url, identifying, status, type) VALUES(%s, %s, 0, 2)" cur.execute(sql, (img_url, identifying)) db.commit() # 更新 sql_update='''update t_spread_theme_stastic set keyword_num='{}', update_time=now() WHERE theme_id='{}' and keyword='{}' '''.format(keyword_num,theme_id ,keyword) cursor.execute(sql_update) conn.commit() # 删除 sql = """DELETE FROM student WHERE ID = %s"""%(3) cursor.execute(sql) db.commit() # 回滚 try: pass except: conn.rollback() finally: db.close()
以上是伪代码,仅作示例使用