彻底解决 Docker MySQL 无法写入中文的难题：深入剖析并提供实用解决方案

2024-01-31 07:25:59

问题Docker MySQL 中文写入乱码

在使用 Docker 容器运行 MySQL 数据库时，许多开发者遇到了中文写入乱码或报错的问题。例如，在前端页面输入中文内容后，提交到后端时，数据库中却出现了乱码字符。或者在执行 SQL 查询或生成日志信息时，只要涉及中文内容，就会引发与数据库编码相关的错误。

问题根源：编码不匹配

中文写入乱码的根源在于编码不匹配。MySQL 数据库默认使用 UTF-8 字符集，而 Docker 容器中的某些组件可能使用不同的编码，如 ASCII 或 GBK。当中文数据从前端传递到数据库时，编码不一致会导致字符乱码。

解决方案：统一编码

为了解决 Docker MySQL 中文写入乱码的问题，需要确保所有涉及的数据处理环节都使用统一的编码，即 UTF-8。以下列出了几个关键步骤：

1. 设置 Docker 容器编码

使用 --env 参数在创建 Docker 容器时设置编码，如下所示：

docker run -d --env MYSQL_CHARACTER_SET=utf8 --env MYSQL_COLLATION=utf8_general_ci mysql

2. 修改 MySQL 配置文件

在 MySQL 配置文件 /etc/mysql/my.cnf 中，添加以下配置：

[mysqld]
character-set-server=utf8
collation-server=utf8_general_ci

3. 调整客户端连接编码

在连接 MySQL 数据库时，确保客户端也使用 UTF-8 编码。例如，对于 Python 应用程序，可以使用以下代码：

import mysql.connector

mydb = mysql.connector.connect(
    host="localhost",
    user="root",
    password="password",
    database="database_name",
    charset="utf8"
)

4. 创建数据库和表时指定编码

在创建数据库和表时，明确指定 UTF-8 编码，如下所示：

CREATE DATABASE `database_name` CHARACTER SET utf8 COLLATE utf8_general_ci;
CREATE TABLE `table_name` (
    `column_name` VARCHAR(255) CHARACTER SET utf8 COLLATE utf8_general_ci
) ENGINE=InnoDB;

5. 处理字符转换

对于某些情况下无法直接使用 UTF-8 编码的字符，可以使用字符转换函数进行处理。例如，对于需要存储 GBK 编码的中文数据，可以使用 CONVERT() 函数：

INSERT INTO `table_name` (`column_name`) VALUES (CONVERT('中文内容' USING GBK));

6. 检查字符集和排序规则

在执行 SQL 查询或生成日志信息时，检查字符集和排序规则是否正确。如果发现乱码，可以尝试调整字符集和排序规则以匹配 UTF-8 编码。

示例代码：

以下是使用 Python Flask 框架和 Docker MySQL 容器解决中文写入乱码问题的示例代码：

from flask import Flask, request, jsonify
import mysql.connector

app = Flask(__name__)

# Docker MySQL 连接配置
db_config = {
    "host": "localhost",
    "user": "root",
    "password": "password",
    "database": "database_name",
    "charset": "utf8"
}

@app.route('/api/save-data', methods=['POST'])
def save_data():
    try:
        # 获取中文数据
        data = request.json.get('data')

        # 连接 MySQL 数据库
        connection = mysql.connector.connect(**db_config)
        cursor = connection.cursor()

        # 执行 SQL 查询
        sql = "INSERT INTO `table_name` (`column_name`) VALUES (%s)"
        cursor.execute(sql, (data,))

        # 提交修改
        connection.commit()

        # 关闭连接
        cursor.close()
        connection.close()

        return jsonify({"success": True, "message": "数据保存成功"})
    except Exception as e:
        return jsonify({"success": False, "message": str(e)})

if __name__ == '__main__':
    app.run(debug=True)