Vergleich der Effizienz der Dateneinfügung in MySQL

öffentliche Klasse MySqlInstance
  {
    //Verbindungszeichenfolge private statische Zeichenfolge mySqlConnectionStr = "Server = localhost; Datenbank = Test; Uid = root; Pwd = Passwort.1;";
    private statische MySqlConnection _mysqlConnect;
    private statische MySqlConnection mysqlConnect
    {
      erhalten
      {
        wenn (null == _mysqlConnect)
        {
          _mysqlConnect = neue MySqlConnection(mySqlConnectionStr);
        }
        gibt _mysqlConnect zurück;
      }
    }
    privater statischer MySqlCommand _mysqlCommand;
    privater statischer MySqlCommand mysqlCommand
    {
      erhalten
      {
        wenn (null == _mysqlCommand)
        {
          _mysqlCommand = mysqlConnect.CreateCommand();
        }
        gibt _mysqlCommand zurück;
      }
    }
    //Öffne die Verbindung public static void OpenConnect()
    {
      mysqlConnect.Öffnen();
    }
    //Verbindung schließen public static void CloseConnect()
    {
      mysqlConnect.Close();
    }
    öffentliche statische MySqlConnection-Verbindung
    {
      erhalten
      {
        gibt mysqlConnect zurück;
      }
    }
    //Daten mit Anti-Injection-Methode einfügen //Verwenden Sie zum Einfügen die Transaktion 10000 und bestätigen Sie die Transaktion einmal am Ende public static int InsertData(string Command, List<MySqlParameter> Params)
    {
      //Programmzeitüberwachung Stoppuhr sw = new Stopwatch();
      //Programmzeitpunkt startssw.Start();
      Öffnen SieConnect();
      //Transaktion starten MySqlTransaction trans = mysqlConnect.BeginTransaction();
      mysqlCommand.CommandText = Befehl;
      mysqlCommand.Parameters.AddRange(Params.ToArray());
      int-Anzahl = 0;
      für (int i = 0; i < 10000; i++)
      {
        wenn (mysqlCommand.ExecuteNonQuery() > 0)
          zählen++;
      }
      //Transaktions-Commit trans.Commit();
      Schließen SieConnect();
      mysqlCommand.Parameters.Clear();
      //Der Timer stoppt sw.Stop();
      Zeitspanne ts2 = sw.Verstrichen;
      Console.WriteLine(ts2.TotalMilliseconds);
      Anzahl zurückgeben;
    }
    //Die Abfrageergebnisse liegen in MySqlDataReader. Sie können die Verbindung nicht schließen, wenn Sie sie verwenden möchten. public static MySqlDataReader SelectData(string sql)
    {
      Stoppuhr sw = neue Stoppuhr();
      sw.Start();
      // Öffnen SieConnect();
      MySqlCommand newcommond = neuer MySqlCommand(sql, mysqlConnect);
      MySqlDataReader-Daten = newcommond.ExecuteReader();
      // Schließen SieConnect();
      sw.Stopp();
      Zeitspanne ts2 = sw.Verstrichen;
      Console.WriteLine(ts2.TotalMilliseconds);
      Daten zurückgeben;
    }
    /// <Zusammenfassung>
    /// Die Abfrage ergibt einen Datensatz/// </summary>
    /// <param name="sql"></param>
    /// <Rückgabe></Rückgabe>
    öffentliches statisches DataSet SelectDataSet (Zeichenfolge SQL)
    {
      MySqlCommand newcommond = neuer MySqlCommand(sql, mysqlConnect);
      MySqlDataAdapter-Adapter = neuer MySqlDataAdapter();
      adapter.SelectCommand = neuer Befehl;
      Datensatz ds = neuer Datensatz();
      Adapter.Füllen(ds);
      Rückgabe ds;
    }
    //Unsicheres Einfügen mit Injektion public static int InsertDataSql(string sql)
    {
      // Öffnen SieConnect();
      mysqlCommand.Befehlstext = sql;
      : In diesem Fall muss mysql.exe ExecuteNonQuery();
      // Schließen SieConnect();
      Anzahl zurückgeben;
    }
    //Parameter sicher einfügen mit @
    //10.000 Mal einfügen, ohne Transaktionen zu verwenden public static int InsertDataNoTran(string Command, List<MySqlParameter> Params)
    {
      Stoppuhr sw = neue Stoppuhr();
      sw.Start();
      Öffnen SieConnect();
      mysqlCommand.CommandText = Befehl;
      mysqlCommand.Parameters.AddRange(Params.ToArray());
      int-Anzahl = 0;
      für (int i = 0; i < 10000; i++)
      {
        wenn (mysqlCommand.ExecuteNonQuery() > 0)
          zählen++;
      }
      Schließen SieConnect();
      mysqlCommand.Parameters.Clear();
      sw.Stopp();
      Zeitspanne ts2 = sw.Verstrichen;
      Console.WriteLine(ts2.TotalMilliseconds);
      Anzahl zurückgeben;
    }
    //Buchstabieren Sie 10.000 Insert-Anweisungen auf einmal und senden Sie sie auf einmal ab. public static void test4()
    {
      Stoppuhr sw = neue Stoppuhr();
      sw.Start();
      MySqlInstance.OpenConnect();
      MySqlTransaction tran = MySqlInstance.Connection.BeginTransaction();
      Zeichenfolgenbefehl = Zeichenfolge.Leer;
      für (int i = 0; i < 10000; i++)
      {
        Zeichenfolge temp = Zeichenfolge.Format("einfügen in test.testtable(pname,pwd) Wert ('{0}','{1}'); \r\n", "Name" + i, "Passwort." + i);
        Befehl += Temp;
      }
      MySqlInstance.InsertDataSql(Befehl);
      tran.Commit();
      MySqlInstance.CloseConnect();
      sw.Stopp();
      Zeitspanne ts2 = sw.Verstrichen;
      Console.WriteLine(ts2.TotalMilliseconds);
    }
 }

System verwenden;
mit System.Collections.Generic;
mit System.Linq;
mit System.Text;
verwenden von System.Threading.Tasks;
mit MySql.Data;
Verwendung von MySql.Web;
mit MySql.Data.MySqlClient;
mithilfe von System.Diagnostics;
mit System.Data;
Namespace mysqlDEMO01
{
  Klassenprogramm
  {
    statischer void Main(string[] args)
    {      
      testInsert();
      Console.ReadLine();
    }
    //Verwenden Sie @, um den Anti-Injection-Parameter sicher einzufügen.
    öffentliche statische void testInsert()
    {
      Liste<MySqlParameter> lmp = neue Liste<MySqlParameter>();
      lmp.Add(neuer MySqlParameter("@pname", "hello2"));
      lmp.Add(neuer MySqlParameter("@pwd", "1232"));
      Zeichenfolgenbefehl = "in test.testtable(pname,pwd) Wert(@pname,@pwd) einfügen); ";
      MySqlInstance.InsertData(Befehl, lmp);
      Liste<MySqlParameter> lmp2 = neue Liste<MySqlParameter>();
      lmp2.Add(neuer MySqlParameter("@pname", "hello2"));
      lmp2.Add(neuer MySqlParameter("@pwd", "1232"));
      MySqlInstance.InsertDataNoTran(Befehl, lmp2);
      test4();
    }
   }
}