Addition - Execute DDLs

Author: abhinavminhas

QueryDB.Core.Tests/MSSQLTests.cs

@@ -308,6 +308,46 @@ public void Test_MSSQL_FetchData_Entity_Strict_Error_Check()
 
         #endregion
 
+        #region Execute DDL Tests - << void ExecuteDDL(string ddlStatement) >>
+
+        [TestMethod]
+        [TestCategory(DB_TESTS), TestCategory(MSSQL_TESTS)]
+        public void Test_MSSQL_ExecuteDDL_Queries()
+        {
+            var createTableSql = Queries.MSSQLQueries.TestDB.DDL.Create_Table;
+            var alterTableSql = Queries.MSSQLQueries.TestDB.DDL.Alter_Table;
+            var truncateTableSql = Queries.MSSQLQueries.TestDB.DDL.Truncate_Table;
+            var renameTableSql = Queries.MSSQLQueries.TestDB.DDL.Rename_Table;
+            var dropTableSql = Queries.MSSQLQueries.TestDB.DDL.Drop_Table;
+            var dDLExecutionCheckSql = Queries.MSSQLQueries.TestDB.DDL.DDL_Execute_check;
+
+            var dbContext = new DBContext(DB.MSSQL, MSSQLConnectionString);
+            dbContext.ExecuteDDL(createTableSql);
+            dbContext.ExecuteDDL(alterTableSql);
+            dbContext.ExecuteDDL(truncateTableSql);
+
+            var tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "dbo", "Employee"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["Table_Count"]);
+
+            dbContext.ExecuteDDL(renameTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "dbo", "Employee"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["Table_Count"]);
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "dbo", "Employees"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["Table_Count"]);
+
+            dbContext.ExecuteDDL(dropTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "dbo", "Employees"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["Table_Count"]);
+        }
+
+        #endregion
+
         #endregion
 
     }

QueryDB.Core.Tests/MySQLTests.cs

@@ -288,6 +288,46 @@ public void Test_MySQL_FetchData_Entity_Strict_Error_Check()
 
         #endregion
 
+        #region Execute DDL Tests - << void ExecuteDDL(string ddlStatement) >>
+
+        [TestMethod]
+        [TestCategory(DB_TESTS), TestCategory(MYSQL_TESTS)]
+        public void Test_MySQL_ExecuteDDL_Queries()
+        {
+            var createTableSql = Queries.MySQLQueries.TestDB.DDL.Create_Table;
+            var alterTableSql = Queries.MySQLQueries.TestDB.DDL.Alter_Table;
+            var truncateTableSql = Queries.MySQLQueries.TestDB.DDL.Truncate_Table;
+            var renameTableSql = Queries.MySQLQueries.TestDB.DDL.Rename_Table;
+            var dropTableSql = Queries.MySQLQueries.TestDB.DDL.Drop_Table;
+            var dDLExecutionCheckSql = Queries.MySQLQueries.TestDB.DDL.DDL_Execute_check;
+
+            var dbContext = new DBContext(DB.MySQL, MySQLConnectionString);
+            dbContext.ExecuteDDL(createTableSql);
+            dbContext.ExecuteDDL(alterTableSql);
+            dbContext.ExecuteDDL(truncateTableSql);
+
+            var tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "mysql", "Employee"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["Table_Count"]);
+
+            dbContext.ExecuteDDL(renameTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "mysql", "Employee"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["Table_Count"]);
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "mysql", "Employees"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["Table_Count"]);
+
+            dbContext.ExecuteDDL(dropTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "mysql", "Employees"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["Table_Count"]);
+        }
+
+        #endregion
+
         #endregion
 
     }

QueryDB.Core.Tests/OracleTests.cs

@@ -290,6 +290,46 @@ public void Test_Oracle_FetchData_Entity_Strict_Error_Check()
 
         #endregion
 
+        #region Execute DDL Tests - << void ExecuteDDL(string ddlStatement) >>
+
+        [TestMethod]
+        [TestCategory(DB_TESTS), TestCategory(ORACLE_TESTS)]
+        public void Test_PostgreSQL_ExecuteDDL_Queries()
+        {
+            var createTableSql = Queries.OracleQueries.TestDB.DDL.Create_Table;
+            var alterTableSql = Queries.OracleQueries.TestDB.DDL.Alter_Table;
+            var truncateTableSql = Queries.OracleQueries.TestDB.DDL.Truncate_Table;
+            var renameTableSql = Queries.OracleQueries.TestDB.DDL.Rename_Table;
+            var dropTableSql = Queries.OracleQueries.TestDB.DDL.Drop_Table;
+            var dDLExecutionCheckSql = Queries.OracleQueries.TestDB.DDL.DDL_Execute_check;
+
+            var dbContext = new DBContext(DB.Oracle, OracleConnectionString);
+            dbContext.ExecuteDDL(createTableSql);
+            dbContext.ExecuteDDL(alterTableSql);
+            dbContext.ExecuteDDL(truncateTableSql);
+
+            var tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "Employee"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["TABLE_COUNT"]);
+
+            dbContext.ExecuteDDL(renameTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "Employee"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["TABLE_COUNT"]);
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "Employees"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["TABLE_COUNT"]);
+
+            dbContext.ExecuteDDL(dropTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "Employees"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["TABLE_COUNT"]);
+        }
+
+        #endregion
+
         #endregion
 
     }

QueryDB.Core.Tests/PostgreSQLTests.cs

@@ -282,6 +282,46 @@ public void Test_PostgreSQL_FetchData_Entity_Strict_Error_Check()
 
         #endregion
 
+        #region Execute DDL Tests - << void ExecuteDDL(string ddlStatement) >>
+
+        [TestMethod]
+        [TestCategory(DB_TESTS), TestCategory(POSTGRESQL_TESTS)]
+        public void Test_PostgreSQL_ExecuteDDL_Queries()
+        {
+            var createTableSql = Queries.PostgreSQLQueries.TestDB.DDL.Create_Table;
+            var alterTableSql = Queries.PostgreSQLQueries.TestDB.DDL.Alter_Table;
+            var truncateTableSql = Queries.PostgreSQLQueries.TestDB.DDL.Truncate_Table;
+            var renameTableSql = Queries.PostgreSQLQueries.TestDB.DDL.Rename_Table;
+            var dropTableSql = Queries.PostgreSQLQueries.TestDB.DDL.Drop_Table;
+            var dDLExecutionCheckSql = Queries.PostgreSQLQueries.TestDB.DDL.DDL_Execute_check;
+
+            var dbContext = new DBContext(DB.PostgreSQL, PostgreSQLConnectionString);
+            dbContext.ExecuteDDL(createTableSql);
+            dbContext.ExecuteDDL(alterTableSql);
+            dbContext.ExecuteDDL(truncateTableSql);
+
+            var tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "public", "Employee"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["table_count"]);
+
+            dbContext.ExecuteDDL(renameTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "public", "Employee"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["table_count"]);
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "public", "Employees"));
+            Assert.AreEqual("1", tableCount[0].ReferenceData["table_count"]);
+
+            dbContext.ExecuteDDL(dropTableSql);
+
+            tableCount = dbContext
+                .FetchData(string.Format(dDLExecutionCheckSql, "public", "Employees"));
+            Assert.AreEqual("0", tableCount[0].ReferenceData["table_count"]);
+        }
+
+        #endregion
+
         #endregion
 
     }

QueryDB.Core.Tests/Queries.cs

@@ -21,6 +21,15 @@ internal static class TestDB
                 public static string SelectSql_Strict = @"SELECT A.Agent_Code, A.Agent_Name AS Agent, C.Cust_Code, C.Cust_Name AS Customer, O.Ord_Num, O.Ord_Amount FROM Agents A INNER JOIN 
                                                         Customer C ON C.Agent_Code = A.Agent_Code INNER JOIN 
                                                         Orders O ON O.Cust_Code = C.Cust_Code AND O.Agent_Code = A.Agent_Code";
+                internal static class DDL
+                {
+                    public static string Create_Table = @"CREATE TABLE Employee (EmployeeID INT PRIMARY KEY, FirstName NVARCHAR(50), LastName NVARCHAR(50))";
+                    public static string Alter_Table = @"ALTER TABLE Employee ADD MiddleName VARCHAR(50)";
+                    public static string Truncate_Table = @"TRUNCATE TABLE Employee";
+                    public static string Rename_Table = @"EXEC SP_RENAME Employee, Employees";
+                    public static string Drop_Table = @"DROP TABLE Employees";
+                    public static string DDL_Execute_check = @"SELECT COUNT(*) AS Table_Count FROM Information_Schema.Tables WHERE LOWER(Table_Schema) = LOWER('{0}') AND LOWER(Table_Name) = LOWER('{1}')";
+                }
             }
         }
 
@@ -43,6 +52,15 @@ internal static class TestDB
                 public static string SelectSql_Strict = @"SELECT A.Agent_Code, A.Agent_Name AS Agent, C.Cust_Code, C.Cust_Name AS Customer, O.Ord_Num, O.Ord_Amount FROM Agents A INNER JOIN 
                                                         Customer C ON C.Agent_Code = A.Agent_Code INNER JOIN 
                                                         Orders O ON O.Cust_Code = C.Cust_Code AND O.Agent_Code = A.Agent_Code";
+                internal static class DDL
+                {
+                    public static string Create_Table = @"CREATE TABLE Employee (EmployeeID INT PRIMARY KEY, FirstName NVARCHAR(50), LastName NVARCHAR(50))";
+                    public static string Alter_Table = @"ALTER TABLE Employee ADD MiddleName VARCHAR(50)";
+                    public static string Truncate_Table = @"TRUNCATE TABLE Employee";
+                    public static string Rename_Table = @"ALTER TABLE Employee RENAME TO Employees";
+                    public static string Drop_Table = @"DROP TABLE Employees";
+                    public static string DDL_Execute_check = @"SELECT COUNT(*) AS Table_Count FROM Information_Schema.Tables WHERE LOWER(Table_Schema) = LOWER('{0}') AND LOWER(Table_Name) = LOWER('{1}')";
+                }
             }
         }
 
@@ -65,6 +83,15 @@ internal static class TestDB
                 public static string SelectSql_Strict = @"SELECT A.Agent_Code, A.Agent_Name AS Agent, C.Cust_Code, C.Cust_Name AS Customer, O.Ord_Num, O.Ord_Amount FROM Agents A INNER JOIN 
                                                         Customer C ON C.Agent_Code = A.Agent_Code INNER JOIN 
                                                         Orders O ON O.Cust_Code = C.Cust_Code AND O.Agent_Code = A.Agent_Code";
+                internal static class DDL
+                {
+                    public static string Create_Table = @"CREATE TABLE Employee (EmployeeID NUMBER PRIMARY KEY, FirstName NVARCHAR2(50), LastName NVARCHAR2(50))";
+                    public static string Alter_Table = @"ALTER TABLE Employee ADD MiddleName VARCHAR(50)";
+                    public static string Truncate_Table = @"TRUNCATE TABLE Employee";
+                    public static string Rename_Table = @"RENAME Employee TO Employees";
+                    public static string Drop_Table = @"DROP TABLE Employees";
+                    public static string DDL_Execute_check = @"SELECT COUNT(*) FROM user_tables WHERE LOWER(table_Name) = LOWER('{0}');";
+                }
             }
         }
 
@@ -87,6 +114,15 @@ internal static class TestDB
                 public static string SelectSql_Strict = @"SELECT A.Agent_Code, A.Agent_Name AS Agent, C.Cust_Code, C.Cust_Name AS Customer, O.Ord_Num, O.Ord_Amount FROM Agents A INNER JOIN 
                                                         Customer C ON C.Agent_Code = A.Agent_Code INNER JOIN 
                                                         Orders O ON O.Cust_Code = C.Cust_Code AND O.Agent_Code = A.Agent_Code";
+                internal static class DDL
+                {
+                    public static string Create_Table = @"CREATE TABLE Employee (EmployeeID INT PRIMARY KEY, FirstName VARCHAR(50), LastName VARCHAR(50))";
+                    public static string Alter_Table = @"ALTER TABLE Employee ADD MiddleName VARCHAR(50)";
+                    public static string Truncate_Table = @"TRUNCATE TABLE Employee";
+                    public static string Rename_Table = @"ALTER TABLE Employee RENAME TO Employees";
+                    public static string Drop_Table = @"DROP TABLE Employees";
+                    public static string DDL_Execute_check = @"SELECT COUNT(*) AS Table_Count FROM Information_Schema.Tables WHERE LOWER(Table_Schema) = LOWER('{0}') AND LOWER(Table_Name) = LOWER('{1}')";
+                }
             }
         }
     }

QueryDB/DBContext.cs

@@ -142,6 +142,42 @@ public List<DataDictionary> FetchData(string selectSql, bool upperCaseKeys = fal
             return dataList;
         }
 
+        public void ExecuteDDL(string ddlStatement)
+        {
+            if (Database.Equals(DB.MSSQL))
+            {
+                using (var msSqlDBConnection = GetSqlServerConnection())
+                {
+                    var _systemAdapter = new MSSQL.Adapter();
+                    _systemAdapter.ExecuteDDL(ddlStatement, msSqlDBConnection.SqlConnection);
+                }
+            }
+            else if (Database.Equals(DB.MySQL))
+            {
+                using (var mySqlDBConnection = GetMySqlConnection())
+                {
+                    var _systemAdapter = new MySQL.Adapter();
+                    _systemAdapter.ExecuteDDL(ddlStatement, mySqlDBConnection.MySqlConnection);
+                }
+            }
+            else if (Database.Equals(DB.Oracle))
+            {
+                using (var oracleDBConnection = GetOracleConnection())
+                {
+                    var _systemAdapter = new Oracle.Adapter();
+                    _systemAdapter.ExecuteDDL(ddlStatement, oracleDBConnection.OracleConnection);
+                }
+            }
+            else if (Database.Equals(DB.PostgreSQL))
+            {
+                using (var postgreSqlDBConnection = GetPostgreSqlConnection())
+                {
+                    var _systemAdapter = new PostgreSQL.Adapter();
+                    _systemAdapter.ExecuteDDL(ddlStatement, postgreSqlDBConnection.PostgreSQLConnection);
+                }
+            }
+        }
+
         /// <summary>
         /// Gets 'SQL Server' connection.
         /// </summary>

QueryDB/IDBContext.cs

@@ -24,5 +24,11 @@ interface IDBContext
         /// <param name="strict">Enables fetch data only for object <T> properties existing in database query result. Default - 'false'.</param>
         /// <returns>List of data rows mapped into object entity into a list for multiple rows of data.</returns>
         List<T> FetchData<T>(string selectSql, bool strict = false) where T : new();
+
+        /// <summary>
+        /// Executes 'Data Definition Language' commands.
+        /// </summary>
+        /// <param name="ddlStatement">DDL statement as command.</param>
+        void ExecuteDDL(string ddlStatement);
     }
 }

QueryDB/MSSQL/Adapter.cs

@@ -27,6 +27,13 @@ internal SqlDataReader GetSqlReader(string cmdText, SqlConnection connection, Co
             }
         }
 
+        internal SqlCommand GetSqlCommand(string cmdText, SqlConnection connection, CommandType commandType)
+        {
+            connection.Open();
+            var sqlCommand = new SqlCommand(cmdText, connection) { CommandType = commandType };
+            return sqlCommand;
+        }
+
         /// <summary>
         /// Retrieves records for 'Select' queries from the database.
         /// Converts column names to keys holding values, with multiple database rows returned into a list.
@@ -84,6 +91,13 @@ internal List<DataDictionary> FetchData(string selectSql, SqlConnection connecti
             }
             return dataList;
         }
-        
+
+        internal void ExecuteDDL(string ddlStatement, SqlConnection connection)
+        {
+            using(var sqlCommand = GetSqlCommand(ddlStatement, connection, CommandType.Text))
+            {
+                sqlCommand.ExecuteNonQuery();
+            }
+        }
     }
 }

QueryDB/MySQL/Adapter.cs

@@ -27,6 +27,13 @@ internal MySqlDataReader GetMySqlReader(string cmdText, MySqlConnection connecti
             }
         }
 
+        internal MySqlCommand GetMySqlCommand(string cmdText, MySqlConnection connection, CommandType commandType)
+        {
+            connection.Open();
+            var sqlCommand = new MySqlCommand(cmdText, connection) { CommandType = commandType };
+            return sqlCommand;
+        }
+
         /// <summary>
         /// Retrieves records for 'Select' queries from the database.
         /// Converts column names to keys holding values, with multiple database rows returned into a list.
@@ -84,5 +91,13 @@ internal List<DataDictionary> FetchData(string selectSql, MySqlConnection connec
             }
             return dataList;
         }
+
+        internal void ExecuteDDL(string ddlStatement, MySqlConnection connection)
+        {
+            using (var sqlCommand = GetMySqlCommand(ddlStatement, connection, CommandType.Text))
+            {
+                sqlCommand.ExecuteNonQuery();
+            }
+        }
     }
 }

QueryDB/Oracle/Adapter.cs

@@ -27,6 +27,13 @@ internal OracleDataReader GetOracleReader(string cmdText, OracleConnection conne
             }
         }
 
+        internal OracleCommand GetOracleCommand(string cmdText, OracleConnection connection, CommandType commandType)
+        {
+            connection.Open();
+            var sqlCommand = new OracleCommand(cmdText, connection) { CommandType = commandType };
+            return sqlCommand;
+        }
+
         /// <summary>
         /// Retrieves records for 'Select' queries from the database.
         /// Converts column names to keys holding values, with multiple database rows returned into a list.
@@ -91,5 +98,13 @@ internal List<DataDictionary> FetchData(string selectSql, OracleConnection conne
             }
             return dataList;
         }
+
+        internal void ExecuteDDL(string ddlStatement, OracleConnection connection)
+        {
+            using (var sqlCommand = GetOracleCommand(ddlStatement, connection, CommandType.Text))
+            {
+                sqlCommand.ExecuteNonQuery();
+            }
+        }
     }
 }