Index: Ringtoets/Piping/src/Ringtoets.Piping.IO/SoilProfile/PipingSoilProfileReader.cs =================================================================== diff -u -rd82fa09fe9ae053ce7702ba89ef23ae029640d1b -r0c4e4faf0839d9ad90af4ff556357fc27c1f333a --- Ringtoets/Piping/src/Ringtoets.Piping.IO/SoilProfile/PipingSoilProfileReader.cs (.../PipingSoilProfileReader.cs) (revision d82fa09fe9ae053ce7702ba89ef23ae029640d1b) +++ Ringtoets/Piping/src/Ringtoets.Piping.IO/SoilProfile/PipingSoilProfileReader.cs (.../PipingSoilProfileReader.cs) (revision 0c4e4faf0839d9ad90af4ff556357fc27c1f333a) @@ -25,6 +25,7 @@ using Core.Common.IO.Exceptions; using Core.Common.IO.Readers; using Core.Common.Utils.Builders; +using Ringtoets.Piping.IO.Builders; using Ringtoets.Piping.IO.Exceptions; using Ringtoets.Piping.IO.Properties; using Ringtoets.Piping.Primitives; @@ -222,17 +223,7 @@ /// A query could not be executed on the database schema. private void PrepareReader() { - string countQuery = string.Format(string.Join( - " ", - "SELECT", - "(SELECT COUNT(*)", - "FROM Mechanism as m", - "JOIN MechanismPointLocation as mpl ON mpl.ME_ID = m.ME_ID", - "JOIN SoilProfile2D as p2 ON p2.SP2D_ID = mpl.SP2D_ID", - "WHERE m.ME_Name = @{0})", - " + ", - "(SELECT COUNT(*)", - "FROM SoilProfile1D) as {1};"), mechanismParameterName, SoilProfileDatabaseColumns.ProfileCount); + string countQuery = SoilDatabaseQueryBuilder.GetPipingSoilProfileCountQuery(); string materialPropertiesQuery = string.Format( string.Join(" ", @@ -355,7 +346,13 @@ DbType = DbType.String, Value = pipingMechanismName, ParameterName = mechanismParameterName - }); + }, new SQLiteParameter + { + DbType = DbType.String, + ParameterName = String.Format("@{0}", MechanismDatabaseColumns.MechanismName), + Value = pipingMechanismName + } + ); } private void GetCount()