Skip to content

Commit b54e2a6

Browse files
StephenCWillsclackner-gpa
authored andcommitted
GSF.TimeSeries: Query the database using AdoDataConnection in StatisticsEngine.DBUpdateHelper
1 parent 72ddc2c commit b54e2a6

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

Source/Libraries/GSF.TimeSeries/Statistics/StatisticsEngine.cs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -303,20 +303,17 @@ private Dictionary<int, string> GetCompanyLookup()
303303

304304
public T ExecuteScalar<T>(string queryFormat, params object[] parameters)
305305
{
306-
string query = m_database.ParameterizedQueryString(queryFormat, parameters.Select((_, index) => $"p{index}").ToArray());
307-
return (T)Convert.ChangeType(m_database.Connection.ExecuteScalar(query, DataExtensions.DefaultTimeoutDuration, parameters), typeof(T));
306+
return m_database.ExecuteScalar<T>(DataExtensions.DefaultTimeoutDuration, queryFormat, parameters);
308307
}
309308

310309
public void ExecuteNonQuery(string queryFormat, params object[] parameters)
311310
{
312-
string query = m_database.ParameterizedQueryString(queryFormat, parameters.Select((_, index) => $"p{index}").ToArray());
313-
m_database.Connection.ExecuteNonQuery(query, DataExtensions.DefaultTimeoutDuration, parameters);
311+
m_database.ExecuteNonQuery(DataExtensions.DefaultTimeoutDuration, queryFormat, parameters);
314312
}
315313

316314
public DataTable RetrieveData(string queryFormat, params object[] parameters)
317315
{
318-
string query = m_database.ParameterizedQueryString(queryFormat, parameters.Select((_, index) => $"p{index}").ToArray());
319-
return m_database.Connection.RetrieveData(m_database.AdapterType, query, DataExtensions.DefaultTimeoutDuration, parameters);
316+
return m_database.RetrieveData(DataExtensions.DefaultTimeoutDuration, queryFormat, parameters);
320317
}
321318

322319
#endregion

0 commit comments

Comments
 (0)