2

私は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();      
            }
        }

このコードは最初の行のみを返しますが、テキストファイルのすべての行をデータベースに保存したいと考えています。前もって感謝します

4

1 に答える 1

4

混乱をきれいにしてみてください：

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して、接続やコマンドなどの IDisposable リソースを適切に破棄する
  • SQL インジェクションを回避するためのパラメーター化されたクエリの使用

rolling your own CSV parserまた、おそらく使用したくないかもしれませんString.Splitが、代わりに実際の CSV パーサーを使用してください。

CSV ファイルが大きい場合は、一度に 1 行ずつ読み取って、一度にメモリに読み込まないようにすることができます。

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);
        }
    }
}
于 2013-03-03T09:40:56.427 に答える