added function to get stopsyncversion from the relaydb instead of cti…

…ds and pass that into the mysqldatautils
wayfair-archive · Feb 3, 2014 · d514a08 · d514a08
1 parent 0525f04
commit d514a08
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 2 deletions.
diff --git a/TeslaSQL/Agents/MasterMaintenance.cs b/TeslaSQL/Agents/MasterMaintenance.cs
@@ -38,7 +38,16 @@ public MasterMaintenance(IDataUtils dataUtils, IDataUtils destDataUtils, Logger
 
         public override void Run() {
             var chopDate = DateTime.Now - new TimeSpan(Config.ChangeRetentionHours, 0, 0);
-            var CTIDs = destDataUtils.GetOldCTIDsMaster(Config.RelayDB, chopDate);
+            IEnumerable<long> CTIDs;
+            if (Config.MasterType == SqlFlavor.MySQL)
+            {
+                var temp = (MSSQLDataUtils)destDataUtils;
+                CTIDs = temp.GetOldStopSyncMaster(Config.RelayDB, chopDate);
+            }
+            else
+            {
+                CTIDs = destDataUtils.GetOldCTIDsMaster(Config.RelayDB, chopDate);
+            }
             var tables = sourceDataUtils.GetTables(Config.MasterCTDB);
             if (tables.Count() > 0) {
                 logger.Log("Deleting {" + string.Join(",", CTIDs) + "} from { " + string.Join(",", tables.Select(t => t.name)) + "}", LogLevel.Debug);

diff --git a/TeslaSQL/DataUtils/MSSQLDataUtils.cs b/TeslaSQL/DataUtils/MSSQLDataUtils.cs
@@ -1241,6 +1241,20 @@ THEN DELETE
             var cmd = new SqlCommand(sql);
             SqlNonQuery(consolidatedDB, cmd);
         }
+
+        public IEnumerable<long> GetOldStopSyncMaster(string dbName, DateTime chopDate)
+        {
+            string sql = "SELECT syncStopVersion AS ctid FROM [dbo].[tblCTVersion] WHERE syncStartTime < @chopDate";
+            var cmd = new SqlCommand(sql);
+            cmd.Parameters.Add("@chopDate", SqlDbType.DateTime).Value = chopDate;
+            var res = SqlQuery(dbName, cmd);
+            var CTIDs = new List<long>();
+            foreach (DataRow row in res.Rows)
+            {
+                CTIDs.Add(row.Field<long>("ctid"));
+            }
+            return CTIDs;
+        }
 
     }
 }
diff --git a/TeslaSQL/DataUtils/MySQLDataUtils.cs b/TeslaSQL/DataUtils/MySQLDataUtils.cs
@@ -938,7 +938,7 @@ public IEnumerable<TTable> GetTables(string dbName)
 
         public IEnumerable<long> GetOldCTIDsMaster(string dbName, DateTime chopDate)
         {
-            string sql = "SELECT syncStopVersion AS ctid FROM tblCTVersion WHERE syncStartTime < @chopDate";
+            string sql = "SELECT ctid FROM tblCTVersion WHERE syncStartTime < @chopDate";
             var cmd = new MySqlCommand(sql);
             cmd.Parameters.Add("@chopDate", MySqlDbType.Timestamp).Value = chopDate.ToUniversalTime();
             DataTable res = MySqlQuery(dbName, cmd);
@@ -1330,5 +1330,6 @@ public bool CleanupTriggerTable(string dbName, string tableName, DateTime chopDa
             return true;
 
         }
+
     }
 }