hdfs到mysql中文乱码

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class HdfsToMySQL {
    public static void main(String[] args) throws Exception {
        // HDFS配置
        Configuration conf = new Configuration();
        FileSystem fs = FileSystem.get(conf);
        Path hdfsPath = new Path("hdfs://yourhdfs/path/to/yourfile.txt");

        // 读取HDFS文件
        BufferedReader reader = new BufferedReader(new InputStreamReader(fs.open(hdfsPath), "UTF-8"));
        String line;
        while ((line = reader.readLine()) != null) {
            // 插入到MySQL数据库
            insertIntoMySQL(line);
        }
        reader.close();
    }

    private static void insertIntoMySQL(String data) throws Exception {
        // MySQL连接配置
        String url = "jdbc:mysql://localhost:3306/yourdatabase?useUnicode=yes&characterEncoding=UTF-8";
        Connection conn = DriverManager.getConnection(url, "username", "password");

        // 插入数据
        String sql = "INSERT INTO yourtable (yourcolumn) VALUES (?)";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        pstmt.setString(1, data);
        pstmt.executeUpdate();

        pstmt.close();
        conn.close();
    }
}