[Test] [Category(TestType.NeedsDeployment)] public void PopulateRangeInStores() { ExecutePopulateRangeInStoreProcedure("csg_sp_populate_RangeInStore"); using (var connection = IKBDatabaseConnection.GetConnectionForIKBTFS()) { string query1 = SELECT count (distinct DESC7) FROM ix_spc_planogram (NOLOCK) WHERE dbstatus= 1"; string query2 = SELECT count (distinct EquipmentType) FROM Csg_Range_In_Store (NOLOCK) WHERE DisplayGroup = '" + ?????+ "'"; var command1 = new SqlCommand(query1, connection); var command2 = new SqlCommand(query2, connection); //string output = " "; //var = " "; //var actualDG = " "; var actualDG = " "; var expectedDG = " "; var dataReader1 = command1.ExecuteReader(); var dataReader2 = command2.ExecuteReader(); if (dataReader1.Read()) { DataTable dt = new DataTable(); dt.Load(dataReader1); expectedDG = dt.Rows.Count.ToString(); } if (dataReader2.Read()) { DataTable dt = new DataTable(); dt.Load(dataReader2); actualDG = dt.Rows.Count.ToString(); } actualDG.Should().Be(expectedDG); } } private void ExecutePopulateRangeInStoreProcedure(string storedProcedure) { using (var connection = IKBDatabaseConnection.GetConnectionForIKBTFS()) { using (SqlCommand cmd = new SqlCommand(storedProcedure, connection)) { cmd.CommandType = CommandType.StoredProcedure; cmd.Parameters.Add("@ix_sys_error", SqlDbType.Int).Value = 0; cmd.CommandTimeout = 0; cmd.ExecuteNonQuery(); } } }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)