我试图对包含python中的pymysql的特定表的所有数据库运行一个查询。我正在创建一个游标,并且能够获得我想要运行查询的所有数据库的结果集。我在试图将这些数据库名称传递到我的查询时遇到了问题。
我尝试过使用pymysql.cursors.DictCursor和pymysql.cursors.Cursor来存储结果,但是当我试图循环遍历结果行并将它们传递给USE语句中的占位符或进行类似于SELECT * from dbname.tablename的查询时,就会出现语法错误,在数据库名称周围放置单引号。
import pymysql
import pymysql.cursors
conn = pymysql.connect(host, username, password)
cur = conn.cursor(pymysql.cursors.DictCursor)
sql_find_db = "SELECT distinct TABLE_SCHEMA FROM `information_schema`.`TABLES` WHERE TABLE_NAME = 'tbl_special_table'"
cur.execute(sql_find_db)
cur2 = conn.cursor(pymysql.cursors.Cursor)
for row in cur:
db = row['TABLE_SCHEMA']
cur2.execute("USE %s", db)
sql_query = "SELECT * FROM some_table"
result = cur2.execute(sql_query)
print(result)我希望这样可以打印SELECT * FROM db.some_table的结果,但是我得到了以下结果:
您的SQL语法有错误;请检查与您的MySQL服务器版本对应的手册,以获得在第1行“数据库_0”附近使用的正确语法)
发布于 2019-08-05 21:54:11
不能为数据库、表或列名使用占位符,必须使用正常的字符串格式。例如,您可以使用f-字符串来完成该操作:
cur2.execute(f"USE `{db}`")https://stackoverflow.com/questions/57366453
复制相似问题