TypeError: expected string or bytes-like object, got 'decimal.Decimal'

### 问题分析与解决方法 在使用 `pymysql` 执行数据库操作时，如果出现 `cursor.execute` 报错并伴随 `traceback connections.py _read_packet raise_mysql_exception` 的异常信息，通常表明底层的 MySQL 协议通信过程中发生了错误。这类问题可能由多种原因引起，包括 SQL 语句语法错误、数据类型不匹配、连接状态异常或服务器响应包格式异常等。 #### 1. **SQL 语法错误导致 InternalError** 当执行的 SQL 语句中包含不存在的列名或表名时，会引发 `InternalError: (1054, "Unknown column 'xxx' in 'where clause'")` 错误。例如，在删除操作中若指定的列 `id` 实际上并不存在于目标表中，则会触发该异常。为避免此类问题，应通过 `DESCRIBE table_name` 命令验证表结构，并确保 SQL 语句中的列名与数据库实际定义一致[^3]。 ```python def delete_email(email_id): try: conn = pymysql.connect(host='localhost', user='root', password='password', database='test_db') with conn.cursor() as cursor: sql = "DELETE FROM email WHERE email_id = %s" cursor.execute(sql, (email_id,)) conn.commit() print(f"成功删除 {cursor.rowcount} 条记录") except pymysql.Error as e: print(f"数据库错误: {e}") ``` #### 2. **连接中断或协议错误** 在某些情况下，可能会遇到 `Packet sequence number wrong - got 5 expected 1` 这类错误，这通常是由于网络不稳定、MySQL 服务器重启或长时间未进行数据库交互导致连接失效。此时，建议重新建立数据库连接，并检查网络环境是否正常。对于长期运行的应用程序，可以考虑实现连接保活机制（如定期发送 `PING` 请求）以维持连接活跃状态[^1]。 ```python def execute_query(query, params=None): retry_count = 3 for attempt in range(retry_count): try: conn = pymysql.connect(host='localhost', user='root', password='password', database='test_db') with conn.cursor() as cursor: cursor.execute(query, params) result = cursor.fetchall() conn.commit() return result except pymysql.err.InternalError as e: if "Packet sequence number wrong" in str(e): print("检测到连接异常，正在尝试重连...") continue else: raise raise Exception("多次尝试失败，请检查数据库连接状态") ``` #### 3. **数据类型转换错误** 当插入或更新的数据类型与数据库字段定义不兼容时，例如将 `None` 插入非空字段或将字节流直接赋值给 `DECIMAL` 类型字段，也可能导致 `TypeError` 或 `DataError`。为了防止此类问题，应在执行 SQL 操作前对输入数据进行校验和类型转换。同时，使用参数化查询可以有效避免手动拼接字符串带来的风险[^2]。 ```python def insert_data(value): try: conn = pymysql.connect(host='localhost', user='root', password='password', database='test_db') with conn.cursor() as cursor: sql = "INSERT INTO data_table (decimal_column) VALUES (%s)" # 确保 value 是数字类型而非 bytes cursor.execute(sql, (float(value),)) conn.commit() except (TypeError, ValueError) as e: print(f"数据类型错误: {e}") except pymysql.Error as e: print(f"数据库错误: {e}") ``` --- ###