在单个sql命令中执行多个插入时捕获错误命令行

本文关键字：插入 命令行 错误 sql 单个 命令 执行 | 更新日期: 2023-09-27 18:11:44

我必须在我的应用程序的单个sqlcommand中自动执行多个sql插入命令，并且我必须保留在执行的c#的sqlcommand 中不执行的插入命令(因为错误)。顺便说一下，我不希望错误导致查询无法继续执行。

有什么建议吗?

谢谢

在单个sql命令中执行多个插入时捕获错误命令行

在SQL语句中使用try catch

请参阅此MSDN链接和CodeProject链接

你可以对所有可用的命令执行一个for或for循环:在这个循环中，你放一个try catch，在catch块中你记录/报告异常，但不抛出，所以循环将继续进行下一次迭代。

请注意，您还可以使用SqlBulk对象以类似于您所描述的方式执行许多插入。

编辑:

如果这是慢，你肯定可以使用SqlBulkCopy:检查这里一步一步的例子:从c#应用程序批量插入到SQL

这行得通

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);
}
相关文章：