解决pymysqlcursor.fetchall()获取不到数据的问题_cursor.fetchall()

pymysql

获取数据

93 浏览量更新于2023-03-16 评论收藏 68KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

解决解决pymysql cursor.fetchall() 获取不到数据的问题获取不到数据的问题

主要介绍了解决pymysql cursor.fetchall() 获取不到数据的问题，具有很好的参考价值，希望对大家有所帮助。

一起跟随小编过来看看吧

1.之前的写法（不报错）：

data = cursor.fetchall()

data_name = data[0]['task_type']

2.简洁的写法（报错）：

data = cursor.fetchall()[0]['task_type']

用 2 的写法报错之后，一度怀疑是数据库出了问题。不服气用pycharm 的watch功能进行调试，更是错上加错。

错误原因：错误原因：

cursor.fetchall() 相当于从数据库取数据，但是取完就没有了，再下一行继续 cursor.fetchall()，取到的就只是空列表。他和变

量不一样，不能重复查询，推荐第一种写法，将数据取出来之后，放到一个变量里，再进行处理。

用watch 功能更是添乱。

补充知识：补充知识：VScode pymysql模块模块fetchall方法取不到值方法取不到值bug

这个问题是个很神奇的东西，简单来说就是用fetchall()取cusor中的_rows的值，明明_rows里面存在值，但依然取出来为空，

看了一会pymysql里cursor里的源码，大概地了解到这个bug的表面原因：

原因：原因：

cursor，在其内部有个rownumber的变量，作用大概就是“游标”的意思吧，如果你是用fetchone()方法，取出来的就是第一个

数，然后将游标移到下一位，下次去取就是从游标的位置开始还不是从_rows里的起始位置开始，fetchmany()同理，另

外，cursor中还提供了直接移动游标的方法，也就是scroll方法，接下来，我们具体分析下fetchall的代码：

def fetchall(self):

"""Fetch all the rows"""

self._check_executed()

if self._rows is None:

return ()

if self.rownumber:

result = self._rows[self.rownumber:]

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余1页未读，立即下载

def show_query1_result(self): # 查询数据 db = pymysql.connect(host='39.99.214.172', user='root', password='Solotion.123', db='jj_tset') cursor = db.cursor() db_sql = """ """ cursor.execute(db_sql) result = cursor.fetchall() db.close() # 清空表格 self.query1_window.table_widget.setRowCount(0) self.query1_window.table_widget.setColumnCount(len(result[0])) # 添加数据到表格 for row_num, row_data in enumerate(result): self.query1_window.table_widget.insertRow(row_num) for col_num, col_data in enumerate(row_data): self.query1_window.table_widget.setItem(row_num, col_num, QTableWidgetItem(str(col_data))) # 显示窗口 self.query1_window.show()怎么设置为查询为空，返回空值

result = cursor.fetchall() db.close() # 如果查询结果为空，则显示提示信息 if len(result) == 0: QMessageBox.information(self, "提示", "查询结果为空") return # 清空表格 self.query1_window.table_...

解释代码 class dbUtil(): def init(self): conn, cursor = self.get_conn() self.conn = conn self.cursor = cursor def get_time(self): time_str = time.strftime("%Y{}%m{}%d{} %X") return time_str.format("年", "月", "日") def get_conn(self): # 建立连接 conn = pymysql.connect(host="127.0.0.1", user="root", password="123456", db="shopping_analysis", charset="utf8") # c创建游标A cursor = conn.cursor() return conn, cursor def close_commit(self): self.conn.commit() if self.cursor: self.cursor.close() if self.conn: self.conn.close() def close(self): self.conn.commit() if self.cursor: self.cursor.close() if self.conn: self.conn.close() def query(self, sql, *args): self.cursor.execute(sql, args) res = self.cursor.fetchall() return res def query_noargs(self, sql): self.cursor.execute(sql) res = self.cursor.fetchall() return res

- `__init__(self)`：类的初始化方法，用于获取连接和游标对象，并将其保存到 `self.conn` 和 `self.cursor` 属性中。 - `get_time(self)`：获取当前时间的方法，返回格式化后的时间字符串。 - `get_conn(self)`：...

“ def insert(self, event): conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='root', db='wm', charset='utf8') cursor = conn.cursor() shop_name = self.t1.GetValue().encode('utf8') # 注意GetValue()获取的是unicode编码， salenum = self.t2.GetValue().encode('utf8') # 你使用的#coding=utf8，那就对获取的数据.encode('utf8')重新编码 data = (shop_name, salenum) try: sql = "insert into foodshop values (%s,%s)" cursor.execute(sql, data) conn.commit() # 提交给后台数据库 dial = wx.MessageDialog(None, '成功上架!', '结果', wx.YES_NO) # 创建一个带按钮的消息框, 语法是(self, 框中内容, 框标题, ID) dial.ShowModal() # 显示对话框 except: conn.rollback() finally: cursor.close() conn.close()”游标的作用

游标对象不仅可以执行SQL语句，还可以处理查询结果，例如使用cursor.fetchall()获取所有查询结果，或使用cursor.fetchone()获取单个查询结果。在实际开发中，游标对象还可以用于执行事务操作、批量插入数据、使用...

pymysql.err.OperationalError: (1055, "Expression #2 of SELECT list is not in GROUP BY clause and contains nonaggregated column

解决这个问题的方法是将SELECT语句中的所有列都添加到GROUP BY语句中，或者使用聚合函数对这些列进行聚合操作。例如，可以使用SUM、COUNT、AVG等聚合函数对这些列进行聚合操作，或者将这些列添加到GROUP BY语句中。 ...

pymysql.err.OperationalError: (1130, "??????99??????' is not allowed to connect to this MySQL server")

result = cursor.fetchall() # 打印查询结果 for row in result: print(row) # 关闭游标和连接 cursor.close() conn.close() ``` 请注意，上述示例中的`your_username`、`your_password`和`your_database`需要...

def find_row(self): # 打开数据库连接 db = pymysql.connect(host='localhost', port=3306, db='crime', user='qingying', password='123456') cursor = db.cursor() # 使用cursor()方法获取操作游标 sql = "SELECT * FROM criminal WHERE id = '%s'" % (id) # SQL 查询语句 try: cursor.execute(sql) # 执行SQL语句 results = cursor.fetchall() # 获取所有记录列表 if len(results) == 0: messagebox.showinfo('提示', '未找到相关数据') else: # 清空表格 for record in self.tree.get_children(): self.tree.delete(record) # 显示查询结果 for row in results: self.tree.insert('', 0, values=row) except: messagebox.showinfo('警告！', '查询失败，数据库连接失败！') db.close() # 关闭数据库连接

4. 如果查询结果不为空，则首先清空GUI界面上的表格，然后将查询结果按行插入到表格中； 5. 如果数据库连接失败，则在GUI界面上弹出警告窗口； 6. 最后关闭数据库连接。需要注意的是，这段代码中的变量id未被定义...

解释每一句import pymysql class MyMysql: def init(self): self.connect = pymysql.connect( host=Mysql服务IP地址, port=Mysql数据库端口, user=数据库用户名, password=数据库密码, database=数据库名, charset='utf8' ) self.cursor = self.connect.cursor()import random from tools.config import MyMysql class UaPool: def init(self): database = MyMysql() db = database.connect cur = database.cursor sql = 'select useragent from ua_pool where types = %s and popularity != %s' cur.execute(sql, ('Windows', 'Uncommon')) data_d = cur.fetchall() desktop_list = [] for data_d_per in data_d: desktop_list.append(data_d_per[0]) self.desktop = desktop_list cur.execute(sql, ('Android', 'Uncommon')) data_m = cur.fetchall() mobile_list = [] for data_m_per in data_m: mobile_list.append(data_m_per[0]) self.mobile = mobile_list cur.close() db.close() def choose_ua(self, platform='desktop'): if platform == 'desktop': return random.choice(self.desktop) elif platform == 'mobile': return random.choice(self.mobile) else: return random.choice(self.desktop) if name == 'main': up = UaPool() print(up.choose_ua())

14. `data_d = cur.fetchall()`：获取查询结果集，即 Windows 桌面平台上不常见的用户代理列表。 15. `desktop_list = []`：创建一个空列表，用于存储 Windows 桌面平台上不常见的用户代理。 16. `for data_d_per ...

用pymysql函数库写查询

然后使用 cursor.execute() 方法执行 SQL 查询，并使用 cursor.fetchall() 方法获取所有数据。最后，使用 connection.close() 方法关闭数据库连接。 ### 回答2：使用pymysql函数库来编写查询是一种在Python中与...

请提供采用PYMYSQL库在MYSQL数据库A的B表中依次按条件1条件2条件3条件4进行数据寻找的python代码，条件1为温度在20到25之间、条件2为水分在14到17之间、条件3为流量在480到520之间、条件4为标偏在0.2-0.3之间，返回的数据在写入表C之前需先查询表C是否存在，存在就直接将数据写入表C，不存在则先新建表C再将数据写入表C中

以下是使用PYMYSQL库在MYSQL数据库A的B表中依次按条件1条件2条件3条件4进行数据寻找的python代码： ```python import pymysql # 连接数据库 conn = pymysql.connect(host='localhost', port=3306, user='root', ...

conn.query(q) File "/Users/ljy/anaconda3/lib/python3.10/site-packages/pymysql/connections.py", line 548, in query self._execute_command(COMMAND.COM_QUERY, sql) File "/Users/ljy/anaconda3/lib/python3.10/site-packages/pymysql/connections.py", li

这个错误是因为`pymysql`连接库在执行`query`方法时发生了异常，可能是由于SQL语句格式不正确或者连接池中没有可用的连接等问题导致的。可以尝试打印出具体的`q`语句，检查是否存在语法错误或者拼写错误。另外，...

能不能用pymysql库达到上面的操作？

是的，你也可以使用 `pymysql` 库来创建 MySQL 存储过程，下面是示例代码： ```python import pymysql # 连接数据库 db = pymysql.connect(host='localhost', user='root', password='password', db='test') # ...

python 使用pymysql连接daily，读取每一张表，并且给每一张表格增加两列，表名需要使用反引号，列名是a和b，格式是小数，如果a和b列存在，则跳过

这段代码会连接到daily数据库，获取所有表名，并遍历每张表格。对于每张表格，首先查询其中所有列名，判断a和b列是否存在。如果a和b列都存在，则跳过；如果其中有一个或两个不存在，则使用ALTER TABLE语句给表格增加...

但是这样查到的数据是不含有表头信息的

在上面的代码中，`cursor.description` 返回查询结果的元数据信息，包括字段名等信息。通过列表推导式 `[desc[0] for desc in cursor.description]`，可以获取所有字段名，作为表头信息。希望这次回答能够满足你的...

python， pymysql ，判断每一行是否完全重复，如果重复，则进行去重，举个示例

4. 使用`cursor.fetchall()`获取查询结果。 5. 遍历每一行数据时，使用`if row not in unique_results:`判断该行数据是否已经存在于unique_results中。如果不存在，则将该行数据添加到unique_results中。最终得到的...

import pandas as pd import pymysql # 连接到数据库 conn = pymysql.connect(host='localhost', user='user', password='password', database='database') # 获取所有表格的名称 cursor = conn.cursor() cursor.execute("SHOW TABLES") tables = cursor.fetchall() # 遍历所有表格 for table in tables: table_name = table[0] table_name_quoted = '' + table_name + '' # 检查是否存在名为'a'的列，如果不存在则添加'a'和'b'列 cursor.execute("SHOW COLUMNS FROM " + table_name_quoted + " LIKE 'a'") a_column = cursor.fetchone() if a_column is None: cursor.execute("ALTER TABLE " + table_name_quoted + " ADD COLUMN a DECIMAL(10,2)") cursor.execute("ALTER TABLE " + table_name_quoted + " ADD COLUMN b DECIMAL(10,2)") conn.commit() # 查询net_mf_amount列的数据 query = "SELECT trade_date, net_mf_amount FROM " + table_name_quoted + " ORDER BY trade_date DESC" df = pd.read_sql_query(query, conn) # 计算a和b列 a_column = [] b_column = [] for i in range(len(df)): if i == 0: a_column.append(None) b_column.append(None) else: if pd.notnull(df.iloc[i]['net_mf_amount']) and pd.notnull(df.iloc[i-1]['net_mf_amount']): if i-2 >= 0: if pd.notnull(df.iloc[i-2]['net_mf_amount']): a = df.iloc[i]['net_mf_amount'] - df.iloc[i-1]['net_mf_amount'] b = df.iloc[i]['net_mf_amount'] - df.iloc[i-2]['net_mf_amount'] a_column.append(a) b_column.append(b) else: j = i-3 while j >= 0: if pd.notnull(df.iloc[j]['net_mf_amount']): a = df.iloc[i]['net_mf_amount'] - df.iloc[i-1]['net_mf_amount'] b = df.iloc[i]['net_mf_amount'] - df.iloc[j]['net_mf_amount'] a_column.append(a) b_column.append(b) break j -= 1 else: a = df.iloc[i]['net_mf_amount'] - df.iloc[i-1]['net_mf_amount'] b = None a_column.append(a) b_column.append(b) else: a_column.append(None) b_column.append(None) # 将结果保存到数据库 for i in range(len(df)): cursor.execute("UPDATE " + table_name_quoted + " SET a=%s, b=%s WHERE trade_date=%s", (a_column[i], b_column[i], df.iloc[i]['trade_date'])) conn.commit() # 关闭连接 cursor.close() conn.close() 报错/Users/ljy/stock/daily_analyse.py:65: UserWarning: pandas only supports SQLAlchemy connectable (engine/connection) or database string URI or sqlite3 DBAPI2 connection. Other DBAPI2 objects are not tested. Please consider using SQLAlchemy. df = pd.read_sql_query(query, conn)

engine = create_engine('mysql+pymysql://user:password@localhost/database') # 获取所有表格的名称 with engine.connect() as conn, conn.begin(): tables = conn.execute("SHOW TABLES").fetchall() # 遍历...

python 使用pymysql连接daily，读取每一张表，并且给每一张表格增加两列，列名是a和b，如果a和b列存在，则跳过

好的，我来回答你的问题。首先，你需要安装 `pymysql` 库。可以通过以下命令进行安装： ``` pip install pymysql ``` 接着，你可以使用以下代码连接到你的 MySQL 数据库： ```python import pymysql # 连接...

weixin_38591011

粉丝: 4
资源: 919

会员权益专享

解决pymysql cursor.fetchall() 获取不到数据的问题

评论0

会员权益专享

最新资源

解决pymysql cursor.fetchall() 获取不到数据的问题

评论0

Python 操作mysql数据库查询之fetchone(), fetchmany(), fetchall()用法示例

03-pymysql回顾.py

pymysql之cur.fetchall() 和cur.fetchone()用法详解

pymysql.cursor.DictCursor

pymysql.err.OperationalError: (1055, "Expression #2 of SELECT list is not in GROUP BY clause and contains nonaggregated column

pymysql.err.OperationalError: (1130, "??????99??????' is not allowed to connect to this MySQL server")

用pymysql函数库写查询

conn.query(q) File "/Users/ljy/anaconda3/lib/python3.10/site-packages/pymysql/connections.py", line 548, in query self._execute_command(COMMAND.COM_QUERY, sql) File "/Users/ljy/anaconda3/lib/python3.10/site-packages/pymysql/connections.py", li

能不能用pymysql库达到上面的操作？

python 使用pymysql连接daily，读取每一张表，并且给每一张表格增加两列，表名需要使用反引号，列名是a和b，格式是小数，如果a和b列存在，则跳过

但是这样查到的数据是不含有表头信息的

python， pymysql ，判断每一行是否完全重复，如果重复，则进行去重，举个示例

python 使用pymysql连接daily，读取每一张表，并且给每一张表格增加两列，列名是a和b，如果a和b列存在，则跳过

会员权益专享

最新资源