DB adapter refactoring

Author: abhinavminhas

QueryDB/MSSQL/Adapter.cs

@@ -13,13 +13,14 @@ internal class Adapter
         /// <summary>
         /// Gets the 'SQL Server' data reader.
         /// </summary>
-        /// <param name="selectSql">'Select' sql value.</param>
+        /// <param name="cmdText">The text of the query.</param>
         /// <param name="connection">'SQL Server' connection.</param>
-        /// <returns>'SQL Server' data reader for the select sql.</returns>
-        internal SqlDataReader GetSqlReader(string selectSql, SqlConnection connection)
+        /// <param name="commandType">Sql command type.</param>
+        /// <returns>'SQL Server' data reader.</returns>
+        internal SqlDataReader GetSqlReader(string cmdText, SqlConnection connection, CommandType commandType)
         {
             connection.Open();
-            using (var sqlCommand = new SqlCommand(selectSql, connection) { CommandType = CommandType.Text })
+            using (var sqlCommand = new SqlCommand(cmdText, connection) { CommandType = commandType })
             {
                 return sqlCommand.ExecuteReader();
             }
@@ -36,7 +37,7 @@ internal SqlDataReader GetSqlReader(string selectSql, SqlConnection connection)
         internal List<DataDictionary> FetchData(string selectSql, SqlConnection connection, bool upperCaseKeys)
         {
             var dataList = new List<DataDictionary>();
-            using (var reader = GetSqlReader(selectSql, connection))
+            using (var reader = GetSqlReader(selectSql, connection, CommandType.Text))
             {
                 while (reader.Read())
                 {

QueryDB/MySQL/Adapter.cs

@@ -13,13 +13,14 @@ internal class Adapter
         /// <summary>
         /// Gets the 'MySQL' data reader.
         /// </summary>
-        /// <param name="selectSql">'Select' sql value.</param>
+        /// <param name="cmdText">The text of the query.</param>
         /// <param name="connection">'MySQL' connection.</param>
-        /// <returns>'MySQL' data reader for the select sql.</returns>
-        internal MySqlDataReader GetMySqlReader(string selectSql, MySqlConnection connection)
+        /// <param name="commandType">Sql command type.</param>
+        /// <returns>'MySQL' data reader.</returns>
+        internal MySqlDataReader GetMySqlReader(string cmdText, MySqlConnection connection, CommandType commandType)
         {
             connection.Open();
-            using (var sqlCommand = new MySqlCommand(selectSql, connection) { CommandType = CommandType.Text })
+            using (var sqlCommand = new MySqlCommand(cmdText, connection) { CommandType = commandType })
             {
                 return sqlCommand.ExecuteReader();
             }
@@ -36,7 +37,7 @@ internal MySqlDataReader GetMySqlReader(string selectSql, MySqlConnection connec
         internal List<DataDictionary> FetchData(string selectSql, MySqlConnection connection, bool upperCaseKeys)
         {
             var dataList = new List<DataDictionary>();
-            using (var reader = GetMySqlReader(selectSql, connection))
+            using (var reader = GetMySqlReader(selectSql, connection, CommandType.Text))
             {
                 while (reader.Read())
                 {

QueryDB/Oracle/Adapter.cs

@@ -13,13 +13,14 @@ internal class Adapter
         /// <summary>
         /// Gets the 'Oracle' data reader.
         /// </summary>
-        /// <param name="selectSql">'Select' sql value.</param>
+        /// <param name="cmdText">The text of the query.</param>
         /// <param name="connection">'Oracle' connection.</param>
-        /// <returns>'Oracle' data reader for the select sql.</returns>
-        internal OracleDataReader GetOracleReader(string selectSql, OracleConnection connection)
+        /// <param name="commandType">Sql command type.</param>
+        /// <returns>'Oracle' data reader.</returns>
+        internal OracleDataReader GetOracleReader(string cmdText, OracleConnection connection, CommandType commandType)
         {
             connection.Open();
-            using (var sqlCommand = new OracleCommand(selectSql, connection) { CommandType = CommandType.Text })
+            using (var sqlCommand = new OracleCommand(cmdText, connection) { CommandType = commandType })
             {
                 return sqlCommand.ExecuteReader();
             }
@@ -36,7 +37,7 @@ internal OracleDataReader GetOracleReader(string selectSql, OracleConnection con
         internal List<DataDictionary> FetchData(string selectSql, OracleConnection connection, bool upperCaseKeys)
         {
             var dataList = new List<DataDictionary>();
-            using (var reader = GetOracleReader(selectSql, connection))
+            using (var reader = GetOracleReader(selectSql, connection, CommandType.Text))
             {
                 while (reader.Read())
                 {