Поймать командные строки ошибки при выполнении нескольких вставок в одной команде sql - PullRequest
Новая
       7

Поймать командные строки ошибки при выполнении нескольких вставок в одной команде sql

0 голосов
/ 19 октября 2011

Мне нужно автоматизировать выполнение нескольких sql команд вставки в одном sqlcommand моего приложения, и я должен сохранять команды вставки, которые не выполняются облаком (из-за ошибок) в выполняемых c # s sqlcommand. Кстати, я не хочу, чтобы ошибки подавляли продолжение выполнения запроса.

есть предложения?

спасибо

Ответы [ 3 ]

2 голосов
/ 19 октября 2011

Использование try catch в операторе SQL

см. эта ссылка MSDN и ссылка CodeProject

1 голос
/ 19 октября 2011

Вы можете выполнить цикл «за» или «каждый» для всех доступных команд для выполнения: внутри этого цикла вы помещаете try catch, а в блок catch вы регистрируете / сообщаете об исключении, но не выбрасываете, чтобы цикл продолжился со следующей итерации..

Обратите внимание, что вы также можете использовать объекты SqlBulk для выполнения многих вставок способом, аналогичным описанному вами.

Редактировать:

, если этодля замедления, вы определенно можете использовать SqlBulkCopy: отметьте здесь шаг за шагом пример: Массовая вставка в SQL из приложения C #

0 голосов
/ 20 октября 2011

это сработало 

void ConvertCsv(string sourcePath, string ResultPath)
{


    #region
    using (StreamReader sr = new StreamReader(sourcePath))
    {
        using (StreamWriter sw = new StreamWriter(ResultPath))
        {
            sw.WriteLine(@"DECLARE @er NVARCHAR(MAX)='',@i INT=0 BEGIN  TRY");
            if (sr.Peek() >= 0)
            {
                string currentLine = sr.ReadLine();

                while (currentLine.Trim() == "" && sr.Peek() >= 0)
                    currentLine = sr.ReadLine();
                if (currentLine.Trim() == "")
                {
                    //error :the file is empty
                }
                sw.WriteLine(currentLine);

            }

            while (sr.Peek() >= 0)
            {
                string currentLine = sr.ReadLine();

                if (currentLine.Trim() == "")
                    continue;
                if (currentLine.Trim().StartsWith("INSERT"))
                {
                    while (!currentLine.Trim().StartsWith("INSERT"))
                        currentLine += sr.ReadLine();
                    currentLine = @"END TRY
                                                    BEGIN CATCH
                                                    SELECT @er+=','+LTRIM(RTRIM(STR(ERROR_LINE()))),@i+=1
                                                END CATCH BEGIN  TRY" + Environment.NewLine + currentLine.Trim();

                }
                sw.WriteLine(currentLine.Trim());
            }
            sw.WriteLine(@"END TRY
                                        BEGIN CATCH
                                        SELECT @er+=','+LTRIM(RTRIM(STR(ERROR_LINE())))
                                    END CATCH SELECT @er AS errorLines,@i AS errorCount");
            sw.Close();
            sr.Close();

        }
    }
    #endregion
    ExecuteConvertedFile(ResultPath,Server.MapPath(@"~/Data/Uploads/csv/ErrorLogs/ErrorLog.sql"));
}

void ExecuteConvertedFile(string ResultPath, string errorResultPath)
{
    string wholeQuery = System.IO.File.ReadAllText(ResultPath);
    using (SqlCommand cmd = new SqlCommand { CommandType = CommandType.Text, CommandText = wholeQuery, Connection = new SqlConnection(((SqlConnection)((EntityConnection)new NezaratEntities().Connection).StoreConnection).ConnectionString) })
    {
        cmd.Connection.Open();
        var dr = cmd.ExecuteReader();
        dr.Read();

        WriteErrorLogs(ResultPath,errorResultPath,dr["errorLines"].ToString().Trim());
        Label1.Text = dr["errorCount"].ToString()+"unsuccessful transactions";

    }
}

для сохранения неудачных команд sql: 

void WriteErrorLogs(string sourcePath, string ResultPath,string errorLinesTolog)
{
    string[] lines = File.ReadAllLines(sourcePath);
    string ErrorLog="";
    errorLinesTolog=errorLinesTolog.Remove(0, 1);

    foreach (var line in errorLinesTolog.Split(','))
    {
        ErrorLog += lines[int.Parse(line)-1] + Environment.NewLine;
    }
    System.IO.File.WriteAllText(ResultPath, ErrorLog);
}
...