將文本文件保存到mysql數據庫中c＃

Question

我通過c＃讀取文件，文件格式是這樣的。
輸入文件

00001740,  0.125,  0,  able 
00001740,  0.125,  0,  unable 
00002098,  0,   0.75, country 
00002312,  0,   0,  love  

我想在MySQL數據庫文件。我編寫的代碼將每行存儲在數據庫的每個行中。但下面的代碼只寫文本文件的第一行

private void button1_Click(object sender, EventArgs e) 
     { 
      string MyConString = "server=localhost;" + 
       "database=zahid;" + "password=zia;" + 
       "User Id=root;"; 
      MySqlConnection connection = new MySqlConnection(MyConString); 
      MySqlCommand command = connection.CreateCommand(); 
      MySqlDataReader Reader; 
      connection.Open(); 
      StreamReader reader = new StreamReader("D:\\out.txt"); 

      string line; 
      while ((line = reader.ReadLine()) != null) 
      { 
       string[] parts = line.Split(','); 
       command.CommandText = "insert into score(POS_ID,Pos,Neg,Word) values('" + parts[1] + "','" + parts[2] + "','" + parts[3] + "','" + parts[4] + "')"; 



       Reader = command.ExecuteReader();  
      } 
     } 

這個代碼僅返回第一線，但我想，在數據庫中的文本文件存儲的所有行。在此先感謝

Answer 1

嘗試清潔爛攤子：

private void button1_Click(object sender, EventArgs e) 
{ 
    string[] lines = File.ReadAllLines("D:\\out.txt"); 
    foreach (var line in lines) 
    { 
     var data = line.Split(new[] { ',' }, 4); 
     int posId = int.Parse(data[0].Trim()); 
     double pos = double.Parse(data[1].Trim()); 
     double neg = double.Parse(data[2].Trim()); 
     string word = data[3].Trim(); 
     StoreRecord(posId, pos, neg, word); 
    } 
} 

private void StoreRecord(int posId, double pos, double neg, string word) 
{ 
    var conStr = "server=localhost; database=zahid; password=zia; User Id=root;"; 
    using (var connection = new MySqlConnection(conStr)) 
    using (var command = connection.CreateCommand()) 
    { 
     connection.Open(); 
     command.CommandText = 
     @"INSERT INTO score 
      (POS_ID, Pos, Neg, Word) 
      VALUES 
      (@posId, @pos, @neg, @word)"; 
     command.Parameters.AddWithValue("@posId", posId); 
     command.Parameters.AddWithValue("@pos", pos); 
     command.Parameters.AddWithValue("@neg", neg); 
     command.Parameters.AddWithValue("@word", word); 
     command.ExecuteNonQuery(); 
    } 
} 

事情需要注意：

• 分離數據庫插入邏輯放到一個專門的方法，以避免在同一個地方
做分析和數據庫插入
• 使用using statemenets正確配置IDisposable資源，如連接和命令
• 使用參數化查詢，以避免SQL注入

而且你可能不希望使用rolling your own CSV parser但String.Split使用一個真正的CSV解析器來代替。

如果CSV文件是很大的，你可以在同一時間閱讀一行，以避免在內存中加載它立刻：

private void button1_Click(object sender, EventArgs e) 
{ 
    using (var stream = File.OpenRead("D:\\out.txt")) 
    using (var reader = new StreamReader(stream)) 
    { 
     string line; 
     while ((line = reader.ReadLine()) != null) 
     { 
      var data = line.Split(new[] { ',' }, 4); 
      int posId = int.Parse(data[0].Trim()); 
      double pos = double.Parse(data[1].Trim()); 
      double neg = double.Parse(data[2].Trim()); 
      string word = data[3].Trim(); 
      StoreRecord(posId, pos, neg, word); 
     } 
    } 
}