在使用 Python 连接多个 MySQL 数据库时，可以通过以下几种方式进行区分和管理，以确保在操作过程中不会混淆不同数据库的连接： ### 1. 使用不同的连接对象和变量名 为每个数据库连接创建独立的连接对象，并使用具有描述性的变量名，例如 `prod_conn` 和 `dev_conn`，这样可以直观地区分不同数据库的连接。每个连接对象独立管理，互不影响。 ```python import pymysql # 生产环境数据库连接 prod_conn = pymysql.connect( host='prod_host', port=3306, user='prod_user', password='prod_password', database='prod_db' ) # 开发环境数据库连接 dev_conn = pymysql.connect( host='dev_host', port=3306, user='dev_user', password='dev_password', database='dev_db' ) ``` 通过这种方式，可以确保每个数据库连接的操作都在其对应的连接对象上执行，避免了操作错误。 ### 2. 使用不同的游标对象 每个连接对象都可以创建独立的游标对象，用于执行 SQL 查询。通过为每个连接创建独立的游标对象，例如 `prod_cursor` 和 `dev_cursor`，可以进一步区分不同数据库的操作。 ```python # 为生产环境数据库创建游标 prod_cursor = prod_conn.cursor() # 为开发环境数据库创建游标 dev_cursor = dev_conn.cursor() ``` 通过使用不同的游标对象，可以确保在执行 SQL 查询时，操作的是正确的数据库连接。 ### 3. 使用连接池管理多个连接 在处理多个数据库连接时，可以使用连接池技术来管理这些连接。连接池可以提供更高效的连接管理和复用，避免频繁地创建和销毁连接。通过连接池，可以为每个数据库连接配置独立的连接池，从而实现更高效的连接管理。 ```python from DBUtils.PooledDB import PooledDB import pymysql # 创建生产环境数据库连接池 prod_pool = PooledDB( creator=pymysql, host='prod_host', port=3306, user='prod_user', password='prod_password', database='prod_db' ) # 创建开发环境数据库连接池 dev_pool = PooledDB( creator=pymysql, host='dev_host', port=3306, user='dev_user', password='dev_password', database='dev_db' ) # 从连接池中获取连接 prod_conn = prod_pool.connection() dev_conn = dev_pool.connection() ``` 通过连接池，可以有效管理多个数据库连接，提高系统的性能和稳定性。 ### 4. 使用配置文件管理连接参数 为了简化代码的维护和管理，可以将不同数据库的连接参数存储在配置文件中。通过读取配置文件，可以动态加载不同数据库的连接信息，从而实现更灵活的连接管理。 ```python import configparser import pymysql # 读取配置文件 config = configparser.ConfigParser() config.read('database_config.ini') # 获取生产环境数据库配置 prod_config = config['Production'] prod_conn = pymysql.connect(**prod_config) # 获取开发环境数据库配置 dev_config = config['Development'] dev_conn = pymysql.connect(**dev_config) ``` 通过配置文件管理连接参数，可以提高代码的可维护性和灵活性，同时减少硬编码带来的问题。 ### 5. 使用上下文管理器确保连接正确关闭 为了避免连接泄漏，可以使用上下文管理器（`with` 语句）来确保连接在使用完毕后自动关闭。通过这种方式，可以确保每个数据库连接在操作完成后正确释放资源。 ```python with pymysql.connect(**prod_config) as prod_conn: with prod_conn.cursor() as prod_cursor: # 执行生产环境数据库操作 prod_cursor.execute("SELECT * FROM prod_table") with pymysql.connect(**dev_config) as dev_conn: with dev_conn.cursor() as dev_cursor: # 执行开发环境数据库操作 dev_cursor.execute("SELECT * FROM dev_table") ``` 通过上下文管理器，可以简化连接和游标的管理，并确保资源的正确释放。 ###