【发布时间】:2020-04-02 09:06:15
【问题描述】:
我创建函数 function1_db() 用于从列 j_id 获取最新的 id,而 function2_read() 用于插入新数据。每个函数都必须像这样连接到 MySQL 数据库。
mydb = mysql.connector.connect(
host="xxxxxxxxxxx",
user="xxx",
passwd="xxxxxx",
database="test_db"
)
def function1_db():
last_id = 0
mycursor = mydb.cursor()
sql = "SELECT * FROM log ORDER BY j_id DESC"
mycursor.execute(sql)
result = mycursor.fetchone()
mycursor.close()
if result != None:
last_id = result[4]
return last_id
def function2_read(last_id):
mycursor = mydb.cursor()
res = "xxx"
if not res.empty:
sql = "INSERT INTO log (id, user, number, time, j_id, alert) VALUES (%s, %s, %s, %s)"
val = [(None, res['User'], res['Pages'] , res['State'], last_id, 0 )]
mycursor.executemany(sql, val)
mydb.commit()
print(mycursor.rowcount, "was inserted.")
mycursor.close()
当我运行此代码时,它会显示这样的错误。如何解决?
raise errors.InternalError("Unread result found")
InternalError: Unread result found
【问题讨论】:
标签: python database mysql-python