MySQL データ挿入効率の比較

パブリッククラス MySqlInstance
  {
    //接続文字列 private static string mySqlConnectionStr = "Server = localhost; Database = test; Uid = root; Pwd = password.1;";
    プライベート静的 MySqlConnection _mysqlConnect;
    プライベート静的MySqlConnection mysqlConnect
    {
      得る
      {
        (null == _mysqlConnect)の場合
        {
          _mysqlConnect = 新しい MySqlConnection(mySqlConnectionStr);
        }
        _mysqlConnect を返します。
      }
    }
    プライベート静的 MySqlCommand _mysqlCommand;
    プライベート静的 MySqlCommand mysqlCommand
    {
      得る
      {
        if (null == _mysqlCommand)
        {
          _mysqlCommand = mysqlConnect.CreateCommand();
        }
        _mysqlCommand を返します。
      }
    }
    //接続を開く public static void OpenConnect()
    {
      mysqlConnect() を開きます。
    }
    //接続を閉じる public static void CloseConnect()
    {
      mysqlConnect.Close();
    }
    パブリック スタティック MySqlConnection 接続
    {
      得る
      {
        mysqlConnect を返します。
      }
    }
    // アンチインジェクション方式でデータを挿入します // トランザクション 10000 を使用して挿入し、最後にトランザクションを 1 回コミットします public static int InsertData(string Command, List<MySqlParameter> Params)
    {
      // プログラム時間監視 Stopwatch sw = new Stopwatch();
      //プログラムタイミング開始sw.Start();
      オープンコネクト();
      //トランザクションの開始 MySqlTransaction trans = mysqlConnect.BeginTransaction();
      mysqlCommand.CommandText = コマンド;
      mysqlCommand.Parameters.AddRange(Params.ToArray());
      整数カウント = 0;
      (int i = 0; i < 10000; i++) の場合
      {
        (mysqlCommand.ExecuteNonQuery() > 0) の場合
          カウント++;
      }
      //トランザクションのコミット trans.Commit();
      CloseConnect();
      mysqlコマンドのパラメータをクリアします。
      //タイマーが停止します sw.Stop();
      TimeSpan ts2 = sw.Elapsed;
      Console.WriteLine(ts2.TotalMilliseconds);
      カウントを返します。
    }
    //クエリの結果は MySqlDataReader に返されます。接続を使用する場合は、接続を閉じることはできません。public static MySqlDataReader SelectData(string sql)
    {
      ストップウォッチ sw = new Stopwatch();
      sw.Start();
      // OpenConnect();
      MySqlCommand newcommond = 新しい MySqlCommand(sql, mysqlConnect);
      MySqlDataReader データ = newcommond.ExecuteReader();
      // CloseConnect();
      sw.停止();
      TimeSpan ts2 = sw.Elapsed;
      Console.WriteLine(ts2.TotalMilliseconds);
      データを返します。
    }
    /// <要約>
    /// クエリの結果はデー​​タセットになります/// </summary>
    /// <パラメータ名="sql"></パラメータ>
    /// <戻り値></戻り値>
    パブリック静的データセットSelectDataSet(文字列sql)
    {
      MySqlCommand newcommond = 新しい MySqlCommand(sql, mysqlConnect);
      MySqlDataAdapter アダプタ = 新しい MySqlDataAdapter();
      アダプタ.SelectCommand = newcommond;
      データセット ds = 新しいデータセット();
      アダプタ.Fill(ds);
      ds を返します。
    }
    // インジェクションによる安全でない挿入 public static int InsertDataSql(string sql)
    {
      // OpenConnect();
      mysqlCommand.CommandText = sql;
      int count = mysqlCommand.ExecuteNonQuery();
      // CloseConnect();
      カウントを返します。
    }
    //@を使用してパラメータを安全に挿入します
    //トランザクションを使用せずに 10,000 回挿入する public static int InsertDataNoTran(string Command, List<MySqlParameter> Params)
    {
      ストップウォッチ sw = new Stopwatch();
      sw.Start();
      オープンコネクト();
      mysqlCommand.CommandText = コマンド;
      mysqlCommand.Parameters.AddRange(Params.ToArray());
      整数カウント = 0;
      (int i = 0; i < 10000; i++) の場合
      {
        (mysqlCommand.ExecuteNonQuery() > 0) の場合
          カウント++;
      }
      CloseConnect();
      mysqlコマンドのパラメータをクリアします。
      sw.停止();
      TimeSpan ts2 = sw.Elapsed;
      Console.WriteLine(ts2.TotalMilliseconds);
      カウントを返します。
    }
    // 10,000 個の挿入ステートメントを一度に入力し、一度に送信する public static void test4()
    {
      ストップウォッチ sw = new Stopwatch();
      sw.Start();
      MySqlInstance.OpenConnect();
      MySqlTransaction tran = MySqlInstance.Connection.BeginTransaction();
      文字列コマンド = 文字列.Empty;
      (int i = 0; i < 10000; i++) の場合
      {
        string temp = string.Format("test.testtable(pname,pwd) に挿入します。値 ('{0}','{1}'); \r\n", "name" + i, "password." + i);
        コマンド += temp;
      }
      MySqlInstance.InsertDataSql(コマンド);
      tran.Commit();
      MySqlInstance.CloseConnect();
      sw.停止();
      TimeSpan ts2 = sw.Elapsed;
      Console.WriteLine(ts2.TotalMilliseconds);
    }
 }

システムの使用;
System.Collections.Generic を使用します。
System.Linq を使用します。
System.Text を使用します。
System.Threading.Tasks を使用します。
MySql.Data を使用します。
MySql.Web を使用します。
MySql.Data.MySqlClient を使用します。
System.Diagnostics を使用します。
System.Data を使用します。
名前空間 mysqlDEMO01
{
  クラスプログラム
  {
    静的void Main(文字列[] 引数)
    {      
      テスト挿入();
      コンソールの行を読み取ります。
    }
    //@ を使用して、アンチインジェクション パラメータを安全に挿入します。
    パブリック静的 void testInsert()
    {
      リスト<MySqlParameter> lmp = 新しいリスト<MySqlParameter>();
      lmp.Add(新しいMySqlParameter("@pname", "hello2"));
      lmp.Add(新しいMySqlParameter("@pwd", "1232"));
      文字列コマンド = "test.testtable(pname,pwd) に挿入します。値(@pname,@pwd); ";
      MySqlInstance.InsertData(コマンド、lmp);
      リスト<MySqlParameter> lmp2 = 新しいリスト<MySqlParameter>();
      lmp2.Add(新しいMySqlParameter("@pname", "hello2"));
      lmp2.Add(新しいMySqlParameter("@pwd", "1232"));
      MySqlInstance.InsertDataNoTran(コマンド、lmp2);
      テスト4();
    }
   }
}