如何使用Sourcestream将CSV文件加载到mySQL？

发布于 01-21 09:55 字数 948 浏览 4 评论 0原文

我正在尝试使用流将CSV文件加载到MySQL数据库表。但是mysqlbulkloader并未识别属性源源。对于在MySqlBulkLoader中使用Sourcestream，我并不感到困惑。

    List<string> data= File.ReadAllLines(@"C:\mycsv.txt").ToList();

    string myConn = "Server=localhost;Database=AAAA;Uid=BBB;Pwd=CCCC";
    MySqlConnection testConn= new MySqlConnection(myConn );
    var stream = new MemoryStream()
    MySqlBulkLoader bulk = new MySqlBulkLoader(testConn)
    {
      CharacterSet = "UTF8",
      FieldQuotationCharacter = '\t',
      LineTerminator = "\r\n",
      NumberOfLinesToSkip = 1,
      TableName = "mytable",
      Local = false,
      SourceStream = stream 
      var writer = new StreamWriter(stream);   

     foreach (var d in data)
        writer.WriteLine(string.Join("\t", d));     

     writer.Flush();
     stream.Position = 0;

   }

    bulk.Load();

错误是：

mysqlbulkloader'不包含'sourcestream''
的定义

感谢您的帮助解决此问题。

原文

I am trying to load a csv file to mysql database table using a stream. But MySqlBulkLoader is not identifying the property SourceStream. I am little confused about using SourceStream in MySqlBulkLoader.

    List<string> data= File.ReadAllLines(@"C:\mycsv.txt").ToList();

    string myConn = "Server=localhost;Database=AAAA;Uid=BBB;Pwd=CCCC";
    MySqlConnection testConn= new MySqlConnection(myConn );
    var stream = new MemoryStream()
    MySqlBulkLoader bulk = new MySqlBulkLoader(testConn)
    {
      CharacterSet = "UTF8",
      FieldQuotationCharacter = '\t',
      LineTerminator = "\r\n",
      NumberOfLinesToSkip = 1,
      TableName = "mytable",
      Local = false,
      SourceStream = stream 
      var writer = new StreamWriter(stream);   

     foreach (var d in data)
        writer.WriteLine(string.Join("\t", d));     

     writer.Flush();
     stream.Position = 0;

   }

    bulk.Load();

The error is:

MySqlBulkLoader' does not contain a definition for 'SourceStream'

Thanks for your help to fix this issue.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

蓝眸2025-01-28 09:55:46

You should set Local=true, it will fix the issue.

Related Doc:

回复收藏 0 原文

_畞蕅2025-01-28 09:55:46

使用以下代码将数据从S3存储桶加载到我的SQL中

LOAD DATA FROM S3 's3://db-bucket-name/folder-name/test.csv' INTO TABLE table-name FIELDS TERMINATED BY ',' ENCLOSED BY '"+'"'+"' LINES TERMINATED BY '\r\n';

Use below code to load data from S3 bucket to My SQL in just line of code

LOAD DATA FROM S3 's3://db-bucket-name/folder-name/test.csv' INTO TABLE table-name FIELDS TERMINATED BY ',' ENCLOSED BY '"+'"'+"' LINES TERMINATED BY '\r\n';

回复收藏 0 原文

~没有更多了~