1

我正在尝试连接到 mysql 数据库以检索某些用户的一些 id，并使用这些 id 从另一个表中检索另一组数据。这应该很容易，但我收到 mysql 错误。这是我正在尝试做的一个片段。

import MySQLdb
from langdetect import detect

my_db = MySQLdb.connect(
                    host="localhost", 
                    port = 3306,
                    user="user", 
                    passwd="password",
                    db="mydb",
                    charset = 'utf8'
                    )

sql1 = """SELECT id, comment FROM users WHERE usertype = 5 LIMIT 100"""

users = []
db_cursor = my_db.cursor()
db_cursor.execute(sql1)
users = db_cursor.fetchall()

sql2 = """SELECT first_name, last_name, email FROM user_contact WHERE id = %s"""

user_contact =[]
for user in users:
    comment = user[1]
    if detect(comment) == 'en': 
        id = user[0]
        db_cursor = my_db.cursor()
        db_cursor.execute(sql2, (id))
        temp = db_cursor.fetchall()
        user_contact . append (temp)

print (user_contact)

这是我尝试运行此查询时收到的错误消息。

_mysql_exceptions.OperationalError: (2013, 'Lost connection to MySQL server during query')

查询的第一部分通常会通过，但在第二部分尝试再次连接到 mysql 时通常会失败。我只测试了 100 条记录，只是为了检查是否是查询运行时间过长的问题，但即使有 10 条记录，它仍然是一样的。

4

1 回答 1

0

对于您的第二部分，您可能不会执行 sql；）

尝试改变

for user in users:
    comment = user[1]
    if detect(comment) == 'en': 
        id = user[0]
        db_cursor = my_db.cursor()
        temp = db_cursor.fetchall()
        user_contact . append (temp)

至

for user in users:
    comment = user[1]
    if detect(comment) == 'en': 
        id = user[0]
        db_cursor = my_db.cursor()
        db_cursor.execute(sql1, (id))
        temp = db_cursor.fetchall()
        user_contact . append (temp)
于 2016-05-13T03:50:38.830 回答