当前位置： 移动技术网 > IT编程>开发语言>.net > MySqlBulkLoader 中文乱码

MySqlBulkLoader 中文乱码

2019年06月13日  | 移动技术网IT编程  | 我要评论

海南儋州政务网,智动,cicistudy

mysql驱动：mysqlconnector
github地址：https://github.com/mysql-net/mysqlconnector.git
文档地址：https://mysql-net.github.io/mysqlconnector/

代码插入之后发现出现中文乱码现象。

原来的代码逻辑简略版

实现逻辑梳理，将数组写入csv，通过mysqlbulkloader批量插入

        public async task bulkloadlocalcsvfile()
        {
            using (var connection = new mysqlconnection(getlocalconnectionstring()))
            {
                await connection.openasync();
                var path = path.gettempfilename();
                mysqlbulkloader bl = new mysqlbulkloader(connection);
                bl.filename = path;
                bl.tablename = "test";
                bl.fieldterminator = ",";
                bl.fieldquotationcharacter = '"';
                bl.fieldquotationoptional = true;
                bl.local = true;
                using (var writer = new streamwriter(path))
                {
                    var configuration = new configuration
                    {
                        hasheaderrecord = false,
                    };
                    using (var csv = new csvwriter(writer, configuration))
                    {
                        csv.writerecords(datasource);
                        var writerconfiguration = csv.context.writerconfiguration;
                        var map = writerconfiguration.maps.find<t>();
                        foreach (var membermap in map.membermaps)
                        {
                            var membername = membermap.data.member.name;
                            loader.columns.add(membername);
                        }
                    }
                }
                int rowcount = await bl.loadasync();
                file.delete(path);
            }
        }

分析乱码原因

  • 需要指定csv文件的字符集
  • 需要指定streamwriter字符集
  • 需要指定mysqlbulkloader字符集

指定csv文件的字符集

写csv文件借助的是开源包csvhelper。
csvhelper

指定 csvhelper.configuration.configuration字符集

var configuration = new configuration
{
     encoding = encoding.utf8
 };

没能解决。

指定streamwriter字符集

var writer = new streamwriter(path, true, encoding.utf8)

不行。

指定mysqlbulkloader字符集

bl.characterset = "utf8";

乱码解决。

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网