Passing Unit tests

git-tfs-id: [https://martin-source.visualstudio.com/DefaultCollection]$/IntegrationServices/Main;C111

Author: keif888

TextFileSplitter/TextFileSplitter2012/TextFileSplitter.cs

@@ -2366,7 +2366,8 @@ public override void PrimeOutput(int outputs, int[] outputIDs, PipelineBuffer[]
                                                             Object currentValue = null;
                                                             foreach (SSISOutputColumn errorOutputColumn in errorOutput.OutputColumnCollection)
                                                             {
-                                                                if (ManageProperties.Contains(errorOutputColumn.CustomPropertyCollection, ManageProperties.keyOutputColumnID))
+                                                                if ((ManageProperties.Contains(errorOutputColumn.CustomPropertyCollection, ManageProperties.keyOutputColumnID))
+                                                                    && (typeOfOutput != Utilities.typeOfOutputEnum.KeyRecords))
                                                                 {
                                                                     if (keyMasterValues.TryGetValue((int)ManageProperties.GetPropertyValue(errorOutputColumn.CustomPropertyCollection, ManageProperties.keyOutputColumnID), out currentValue))
                                                                     {
@@ -2386,7 +2387,19 @@ public override void PrimeOutput(int outputs, int[] outputIDs, PipelineBuffer[]
                                             if (errorFound)
                                                 break;
                                         }
-                                        currentSplitOutput.IncrementRowCount();
+                                        if (!errorFound)
+                                            currentSplitOutput.IncrementRowCount();
+                                        else
+                                        {
+                                            if (typeOfOutput == Utilities.typeOfOutputEnum.KeyRecords)
+                                            {
+                                                keyRecordFailure = true;
+                                                foreach (int keyID in keyMasterValues.Keys.ToList())
+                                                {
+                                                    keyMasterValues[keyID] = null;
+                                                }
+                                            }
+                                        }
                                     }
                                 }
                             }

TextFileSplitter/UnitTestTextFileSplitter2012/TestPrimeOutput.cs

@@ -676,13 +676,33 @@ public void TestPrimeOutput_TestDataFileWithManyErrorsAndRowCountOutput()
                 Assert.AreEqual(2, sqlData.GetInt32(0), "Number of Delimiter Not Found incorrect");
             }
 
+            rowCount = 0;
+            sqlCommand.CommandText = "SELECT * FROM [ErrorResults] WHERE ErrorMessage LIKE '%not found after field%' AND RowData = 'IAMBAD'";
+            sqlData = sqlCommand.ExecuteReader(CommandBehavior.Default);
+            while (sqlData.Read())
+            {
+                Assert.IsTrue(sqlData.IsDBNull(5), "KeyColumn1 has a value for IAMBAD");
+                rowCount++;
+            }
+            Assert.AreEqual(1, rowCount, "2nd IAMBAD Error Missing");
+
             sqlCommand.CommandText = "SELECT COUNT(*) FROM [ErrorResults] WHERE ErrorMessage LIKE '%The value is too large to fit in the column data area of the buffer%'";
             sqlData = sqlCommand.ExecuteReader(CommandBehavior.Default);
             while (sqlData.Read())
             {
                 Assert.AreEqual(2, sqlData.GetInt32(0), "Number of To Big incorrect");
             }
 
+            rowCount = 0;
+            sqlCommand.CommandText = "SELECT * FROM [ErrorResults] WHERE ErrorMessage LIKE '%The value is too large to fit in the column data area of the buffer%' AND ColumnData = '2nd Start Invoice Record'";
+            sqlData = sqlCommand.ExecuteReader(CommandBehavior.Default);
+            while (sqlData.Read())
+            {
+                Assert.IsTrue(sqlData.IsDBNull(5), "KeyColumn1 has a value for ValueToLarge");
+                rowCount++;
+            }
+            Assert.AreEqual(1, rowCount, "2nd Start Invoice Record Error Missing");
+
             sqlCommand.CommandText = "SELECT COUNT(*) FROM [ErrorResults] WHERE ErrorMessage LIKE '%Int32%'";
             sqlData = sqlCommand.ExecuteReader(CommandBehavior.Default);
             while (sqlData.Read())
@@ -709,7 +729,7 @@ public void TestPrimeOutput_TestDataFileWithManyErrorsAndRowCountOutput()
             sqlData = sqlCommand.ExecuteReader(CommandBehavior.Default);
             while (sqlData.Read())
             {
-                Assert.AreEqual(2, sqlData.GetInt32(1), "Number of 001 incorrect");
+                Assert.AreEqual(1, sqlData.GetInt32(1), "Number of 001 incorrect");
                 Assert.AreEqual("Connected and Processed", sqlData.GetString(2), "KeyValue Status on 001 incorrect");
             }
 
@@ -726,7 +746,7 @@ public void TestPrimeOutput_TestDataFileWithManyErrorsAndRowCountOutput()
             while (sqlData.Read())
             {
                 Assert.AreEqual(5, sqlData.GetInt32(1), "Number of 003 incorrect");
-                Assert.AreEqual("Connected and Processed", sqlData.GetString(2), "KeyValue Status on 003 incorrect");
+                Assert.AreEqual("Not configured", sqlData.GetString(2), "KeyValue Status on 003 incorrect");
             }