Einfügen von Daten von SQL Server zu SQLite

Question

Ich möchte Daten von SQL Server zu SQLite verschieben. Was ich tue, ist zuerst die Daten von SQL Server auf dataset zu verschieben und dann von dort in die SQLite-Tabelle zu verschieben.

Folgendes ist der Code, der das tut. Ich glaube, es kann effizienter

try 
{ 
    using (SqlConnection sqlConnection = new SqlConnection(DataSources.RemoteConnectionString())) 
    { 
     sqlConnection.Open(); 

     using (SqlCommand sqlCommand = new SqlCommand("[DB7934_businessmind].[DownloadAreaOfLaw]", sqlConnection)) 
     { 
      sqlCommand.CommandType = CommandType.StoredProcedure; 
      sqlCommand.Parameters.AddWithValue("@AoLId", aolid); 

      SqlDataAdapter sqlDataAdapter = new SqlDataAdapter(); 
      sqlDataAdapter.SelectCommand = sqlCommand; 
      sqlDataAdapter.Fill(aolDataSet.TempAoL); 

      if (aolDataSet.TempAoL.Rows.Count > 0) 
      { 
       using (SQLiteConnection sqliteConnection = new SQLiteConnection(DataSources.LocalConnectionString())) 
       { 
        sqliteConnection.Open(); 

        using (SQLiteCommand sqliteCommand = new SQLiteCommand(sqliteConnection)) 
        { 
         foreach (Models.AoLDataSet.TempAoLRow r in aolDataSet.TempAoL.Rows) 
         { 
          sqliteCommand.CommandText = "INSERT INTO AreaOfLaw(AoLId, AreaOfLawTitle) VALUES(@AoLId, @AreaOfLawText)"; 
          sqliteCommand.Parameters.AddWithValue("@AoLId", r.AoLId); 
          sqliteCommand.Parameters.AddWithValue("AreaOfLawText", r.AreaOfLawTitle); 
          sqliteCommand.ExecuteNonQuery(); 
         } 

         sqliteCommand.Dispose(); 
        } 

        sqliteConnection.Close(); 
       } 
      } 
     } 

     sqlConnection.Close(); 
    } 
} 
catch (Exception ex) 
{ 
    MessageBox.Show("An error has occurred while downloading Areas Of Law from the cloud, the original error is: " + ex.Message, "Area Of Law", MessageBoxButtons.OK, MessageBoxIcon.Error); 
} 

Danke im Voraus

Answer 1

Versuchen Sie, alle Einsätze in einer Transaktion Einwickeln:

try 
{ 
    using (SqlConnection sqlConnection = new SqlConnection(DataSources.RemoteConnectionString())) 
    { 
     sqlConnection.Open(); 
     using (SqlCommand sqlCommand = new SqlCommand("[DB7934_businessmind].[DownloadAreaOfLaw]", sqlConnection)) 
     { 
      sqlCommand.CommandType = CommandType.StoredProcedure; 
      sqlCommand.Parameters.AddWithValue("@AoLId", aolid); 
      SqlDataAdapter sqlDataAdapter = new SqlDataAdapter(); 
      sqlDataAdapter.SelectCommand = sqlCommand; 
      sqlDataAdapter.Fill(aolDataSet.TempAoL); 
      if (aolDataSet.TempAoL.Rows.Count > 0) 
      { 
       using (SQLiteConnection sqliteConnection = new SQLiteConnection(DataSources.LocalConnectionString())) 
       { 
        sqliteConnection.Open(); 

        using(SqliteTransaction tr = sqliteConnection.BeginTransaction()) 
        { 
         using (SQLiteCommand sqliteCommand = new SQLiteCommand(sqliteConnection)) 
         { 
          foreach (Models.AoLDataSet.TempAoLRow r in aolDataSet.TempAoL.Rows) 
          { 
           sqliteCommand.CommandText = "INSERT INTO AreaOfLaw(AoLId, AreaOfLawTitle) VALUES(@AoLId, @AreaOfLawText)"; 
           sqliteCommand.Parameters.AddWithValue("@AoLId", r.AoLId); 
           sqliteCommand.Parameters.AddWithValue("AreaOfLawText", r.AreaOfLawTitle); 
           sqliteCommand.ExecuteNonQuery(); 
          } 
          sqliteCommand.Dispose(); 
         } 

         tr.Commit(); 
        } 
        sqliteConnection.Close(); 
       } 
      } 
     } 
     sqlConnection.Close(); 
    } 
} 
catch (Exception ex) 
{ 
    MessageBox.Show("An error has occurred while downloading Areas Of Law from the cloud, the original error is: " + ex.Message, "Area Of Law", MessageBoxButtons.OK, MessageBoxIcon.Error); 
} 

Ich habe mit Einführungsgeschwindigkeit über die gleiche Frage kam mit sqlite und diese Technik löste das Problem - Einführungsgeschwindigkeit enorm erhöht. Ich weiß nicht, ob es noch andere Optionen gibt, um das Problem zu lösen, wenn dieses nicht passt.