我来帮你排查并解决这个常见的MySQL连接错误。这个报错的核心原因是：你的Python代码在执行表创建、数据插入操作时，当前的MySQL连接没有选中任何数据库——哪怕你调用了create_and_switch_database函数，大概率是这个函数没有正确完成数据库切换的操作，或者后续操作没有继承这个上下文。

下面是具体的排查和解决步骤：

1. 检查create_and_switch_database函数的实现 #

首先你需要确认自己封装的db.create_and_switch_database函数是否正确执行了数据库切换命令。这个函数必须包含USE {DB_NAME};的SQL语句，否则连接不会切换到目标库。一个正确的实现应该类似这样：

# 示例：正确的create_and_switch_database函数实现
import mysql.connector

def create_and_switch_database(connection, db_name, switch_db_name):
    try:
        cursor = connection.cursor()
        # 创建数据库（如果不存在）
        cursor.execute(f"CREATE DATABASE IF NOT EXISTS {db_name};")
        # 关键：切换到目标数据库
        cursor.execute(f"USE {switch_db_name};")
        cursor.close()
        print(f"数据库 {db_name} 已创建（若不存在），并切换到 {switch_db_name}")
    except mysql.connector.Error as err:
        print(f"操作出错: {err}")
        connection.rollback()

如果你的函数里缺少了USE语句，或者执行USE时抛出了异常没被捕获，就会导致后续操作找不到数据库。

2. 快速修复：在SQL语句中显式指定数据库 #

如果你不想修改db模块的函数，可以直接在所有表操作的SQL语句里加上数据库前缀，让MySQL明确知道要操作哪个库的表。

比如修改创建表的SQL：

create table if not exists ecommerce_record.users(
user_id varchar(10) primary key,
user_name varchar(45) not null,
user_email varchar(45) not null,
user_password varchar(45) not null,
user_address varchar(45) null,
is_vendor tinyint(1) default 0
)

再修改插入数据的SQL：

insert into ecommerce_record.users(user_id,user_name,user_email,user_password,user_address, is_vendor)
values(%s,%s,%s,%s,%s,%s)

这样即使连接没有切换数据库，MySQL也能通过数据库名.表名的方式定位到目标表。

3. 更优雅的方案：创建连接时直接指定数据库 #

如果你的db.create_server_connection函数支持，可以在创建连接时直接传入数据库名，这样连接建立后就自动选中了目标库，不需要后续手动切换。

修改连接创建的代码：

# 假设create_server_connection函数接受第四个参数指定数据库
connection = db.create_server_connection(LOCALHOST, ROOT, PW, DB)

对应的create_server_connection函数需要调整为：

def create_server_connection(host_name, user_name, user_password, db_name=None):
    connection = None
    try:
        if db_name:
            # 连接时直接指定数据库
            connection = mysql.connector.connect(
                host=host_name,
                user=user_name,
                passwd=user_password,
                database=db_name
            )
        else:
            # 不指定数据库的连接
            connection = mysql.connector.connect(
                host=host_name,
                user=user_name,
                passwd=user_password
            )
        print("MySQL数据库连接成功")
    except mysql.connector.Error as err:
        print(f"连接出错: {err}")
    return connection

4. 验证数据库是否正确选中 #

在执行表操作前，你可以加一段代码验证当前连接选中的数据库，方便排查问题：

cursor = connection.cursor()
cursor.execute("SELECT DATABASE();")
current_selected_db = cursor.fetchone()[0]
print(f"当前选中的数据库: {current_selected_db}")
cursor.close()

如果输出不是ecommerce_record，说明切换数据库的操作没有生效，需要回到第一步检查函数实现。

按照上面的方法调整后，你的代码应该就能正常执行表创建和数据插入操作了。

内容的提问来源于stack exchange，提问作者sagar patel