时间戳

首页 > 解决方案 > 获取特定表的所有数据库名称并对每个结果运行查询

python - 获取特定表的所有数据库名称并对每个结果运行查询

问题描述

我正在尝试对包含特定表的所有数据库运行查询，并在 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”附近使用的正确语法”）

标签： pythonpymysql

解决方案

您不能为数据库、表或列名使用占位符，您必须使用正常的字符串格式。例如，您可以使用 f 字符串：

cur2.execute(f"USE `{db}`")

推荐阅读