v1.31.0

- Multirun script-ek végrehajtása

v1.31.0
- Multirun script-ek végrehajtása
Schwirg László
1 parent 32c3a934
Showing 7 changed files with 398 additions and 109 deletions Show diff stats
Vrh.Log4Pro.MaintenanceConsole/ConsoleFunction - ColorConsole.cs
Vrh.Log4Pro.MaintenanceConsole/Manager - MaintenanceToolManager.cs
Vrh.Log4Pro.MaintenanceConsole/Manager - SQLDataBaseManager.cs
Vrh.Log4Pro.MaintenanceConsole/Properties/AssemblyInfo.cs
Vrh.Log4Pro.MaintenanceConsole/Tools.cs
Vrh.Log4Pro.MaintenanceConsole/Vrh.Log4Pro.MaintenanceConsole.csproj
Vrh.Log4Pro.MaintenanceConsole/packages.config
@@ -10,6 +10,12 @@ using System.Diagnostics;
 using Vrh.XmlProcessing;
 using System.Xml.Linq;
+using Microsoft.SqlServer.Management.Smo;
+using static Vrh.Log4Pro.MaintenanceConsole.CommandLineParserNS.CLP.Module.ScheduledTaskManager.Function;
+using static Vrh.Log4Pro.MaintenanceConsole.FileCleanerManagerNS.FolderToClean.XmlStructure.FolderToClean.Conditions.Condition.Attributes;
+using System.Reflection;
+using System.Threading;
+using System.Windows.Forms;
 namespace Vrh.Log4Pro.MaintenanceConsole.ColorConsoleNS
 {
@@ -68,17 +74,35 @@ namespace Vrh.Log4Pro.MaintenanceConsole.ColorConsoleNS
 		/// Visszaadja a lenyomott billentyűt, ha van, commandmode-ban pedig az enter-t
 		/// </summary>
 		/// <returns></returns>
-		public static ConsoleKeyInfo ReadKey() 
-		{
-			if (SilentMode) { return GetConsoleKey(ConsoleKey.Enter); }
-			else { return Console.ReadKey(); }
-		}
+        public static ConsoleKeyInfo? ReadKey(TimeSpan? maxwaittime)
+        {
+            if (SilentMode) { return GetConsoleKey(ConsoleKey.Enter); }
+            if (maxwaittime ==null || maxwaittime == TimeSpan.Zero) { return Console.ReadKey(); }
+			else 
+			{
+				var strtime = DateTime.Now;
+                var endtime = strtime.Add(maxwaittime.Value);
+				var nexttime = strtime;
+				while (nexttime <= endtime) 
+				{
+					if (Console.KeyAvailable) return Console.ReadKey(true);
+					Thread.Sleep(50);
+					nexttime = DateTime.Now;
+                }
+				return null;
+            }
+        }
+        public static ConsoleKeyInfo ReadKey()
+        {
+            if (SilentMode) { return GetConsoleKey(ConsoleKey.Enter); }
+            else { return Console.ReadKey(); }
+        }
-		/// <summary>
-		/// Visszaadja a lenyomott billentyűt, ha van, commandmode-ban pedig az enter-t
-		/// </summary>
-		/// <returns></returns>
-		public static ConsoleKeyInfo GetConsoleKey(ConsoleKey ck, bool shift = false, bool alt=false,bool control=false)
+        /// <summary>
+        /// Visszaadja a lenyomott billentyűt, ha van, commandmode-ban pedig az enter-t
+        /// </summary>
+        /// <returns></returns>
+        public static ConsoleKeyInfo GetConsoleKey(ConsoleKey ck, bool shift = false, bool alt=false,bool control=false)
 		{
 			switch (ck)
 			{
@@ -65,7 +65,7 @@ namespace Vrh.Log4Pro.MaintenanceConsole.MaintenanceToolManagerNS
 				ExternalProcess.StartInfo.FileName = config.Exe;
 				ExternalProcess.StartInfo.WindowStyle = config.ProcessWindowsStyle;
-				if (!Tools.ResolveArguments(config.ArgumentParameters, config.Arguments, out string resolvedtext)) { return o; };
+				if (!Tools.KvpString.Resolve(config.ArgumentParameters, config.Arguments, out string resolvedtext)) { return o; };
 				ExternalProcess.StartInfo.Arguments = resolvedtext;
 				ExternalProcess.Start();
 				int waitingtime = config.WaitForExit ? -1 : 0;
@@ -633,8 +633,8 @@ namespace Vrh.Log4Pro.MaintenanceConsole.MaintenanceToolManagerNS
 				Exe = GetValue(nameof(XmlStructure.ExternalUtility.Attributes.Exe), x, "");
 				this.Key = GetValue(nameof(XmlStructure.ExternalUtility.Attributes.Key), x, "");
 				this.Description = GetValue(nameof(XmlStructure.ExternalUtility.Attributes.Description), x, Exe);
-				Tools.ResolveArguments(ArgumentParameters, this.Key,out this.Key,interactive:false);
-				Tools.ResolveArguments(ArgumentParameters, this.Description, out this.Description, interactive: false);
+				Tools.KvpString.Resolve(ArgumentParameters, this.Key,out this.Key,disableinteractive:true);
+				Tools.KvpString.Resolve(ArgumentParameters, this.Description, out this.Description, disableinteractive: true);
 				Arguments = GetValue(nameof(XmlStructure.ExternalUtility.Attributes.Arguments), x, XmlStructure.ExternalUtility.Attributes.Arguments.Values.DEFAULT);
 				ProcessWindowsStyle = GetValue<ProcessWindowStyle>(nameof(XmlStructure.ExternalUtility.Attributes.WindowStyle), x, XmlStructure.ExternalUtility.Attributes.WindowStyle.Values.DEFAULT);
@@ -26,6 +26,12 @@ using System.Text.RegularExpressions;
 using Microsoft.SqlServer.Management.Common;
 using Microsoft.SqlServer.Management.Smo;
 using Microsoft.Data.SqlClient;
+using Microsoft.Identity.Client;
+using VRH.Common.Log4ProIS;
+using System.Security.Cryptography;
+using System.Data.Entity.Core.Common.CommandTrees.ExpressionBuilder;
+using System.Windows.Controls;
+using Menu = Vrh.Log4Pro.MaintenanceConsole.MenuNS.Menu;
 namespace Vrh.Log4Pro.MaintenanceConsole.SQLDataBaseManagerNS
 {
@@ -926,27 +932,30 @@ GO
 					else { return null; }
 				}
-				string ssScriptText = null;
-				string LastUpdatedTrigger_parameters = $"DBNAME={triggertoexecute.Db};SCHEMA={triggertoexecute.Schema};TABLE={triggertoexecute.Table};COLUMN={triggertoexecute.Column};TRIGGER={LastUpdatedTrigger_triggername};";
-				if (!Tools.ResolveArguments(LastUpdatedTrigger_parameters, RemoveLastUpdatedTrigger_Script, out ssScriptText)) { throw new ApplicationException(); }
-				try { SQLDataBaseManagerCore.ExecuteSQLScript(sqlcs, ssScriptText, 5000, null); }
-				catch (Exception e) { ColorConsole.WriteLine(e.MessageNested(), ConsoleColor.Yellow); }
-				if (!Tools.ResolveArguments(LastUpdatedTrigger_parameters, RemoveLastUpdatedColumn_Script, out ssScriptText)) { throw new ApplicationException(); }
-				try { SQLDataBaseManagerCore.ExecuteSQLScript(sqlcs, ssScriptText, 5000, null); }
-				catch (Exception e) { ColorConsole.WriteLine(e.MessageNested(), ConsoleColor.Yellow); }
-
-				if (!triggertoexecute.Remove)
+				using (var sqlc = ServerConnectionPool.GetSqlConnection(sqlcs, open: true))
 				{
-					if (!Tools.ResolveArguments(LastUpdatedTrigger_parameters, CreateLastUpdatedColumn_Script, out ssScriptText)) { throw new ApplicationException(); }
-					SQLDataBaseManagerCore.ExecuteSQLScript(sqlcs, ssScriptText, 5000, null);
+                    string ssScriptText = null;
+                    string LastUpdatedTrigger_parameters = $"DBNAME={triggertoexecute.Db};SCHEMA={triggertoexecute.Schema};TABLE={triggertoexecute.Table};COLUMN={triggertoexecute.Column};TRIGGER={LastUpdatedTrigger_triggername};";
+                    if (!Tools.KvpString.Resolve(LastUpdatedTrigger_parameters, RemoveLastUpdatedTrigger_Script, out ssScriptText)) { throw new ApplicationException(); }
+                    try { SQLDataBaseManagerCore.ExecuteSQLScript(sqlc, ssScriptText, 5000, null); }
+                    catch (Exception e) { ColorConsole.WriteLine(e.MessageNested(), ConsoleColor.Yellow); }
+                    if (!Tools.KvpString.Resolve(LastUpdatedTrigger_parameters, RemoveLastUpdatedColumn_Script, out ssScriptText)) { throw new ApplicationException(); }
+                    try { SQLDataBaseManagerCore.ExecuteSQLScript(sqlc, ssScriptText, 5000, null); }
+                    catch (Exception e) { ColorConsole.WriteLine(e.MessageNested(), ConsoleColor.Yellow); }
+                    
+					if (!triggertoexecute.Remove)
+					{
+						if (!Tools.KvpString.Resolve(LastUpdatedTrigger_parameters, CreateLastUpdatedColumn_Script, out ssScriptText)) { throw new ApplicationException(); }
+						SQLDataBaseManagerCore.ExecuteSQLScript(sqlc, ssScriptText, 5000, null);
-					if (!Tools.ResolveArguments(LastUpdatedTrigger_parameters, CreateLastUpdatedTrigger_Script, out ssScriptText)) { throw new ApplicationException(); }
-					SQLDataBaseManagerCore.ExecuteSQLScript(sqlcs, ssScriptText, 5000, null);
+						if (!Tools.KvpString.Resolve(LastUpdatedTrigger_parameters, CreateLastUpdatedTrigger_Script, out ssScriptText)) { throw new ApplicationException(); }
+                        SQLDataBaseManagerCore.ExecuteSQLScript(sqlc, ssScriptText, 5000, null);
-					if (!Tools.ResolveArguments(LastUpdatedTrigger_parameters, EnableLastUpdatedTrigger_Script, out ssScriptText)) { throw new ApplicationException(); }
-					SQLDataBaseManagerCore.ExecuteSQLScript(sqlcs, ssScriptText, 5000, null);
+                        if (!Tools.KvpString.Resolve(LastUpdatedTrigger_parameters, EnableLastUpdatedTrigger_Script, out ssScriptText)) { throw new ApplicationException(); }
+                        SQLDataBaseManagerCore.ExecuteSQLScript(sqlc, ssScriptText, 5000, null);
+                    }
 				}
-				ColorConsole.WriteLine($"SUCCESS! {removeactionText} trigger to store LastUpdate TimeStamp: {LastUpdatedTrigger_fulldesignation}", ConsoleColor.Green);
+                ColorConsole.WriteLine($"SUCCESS! {removeactionText} trigger to store LastUpdate TimeStamp: {LastUpdatedTrigger_fulldesignation}", ConsoleColor.Green);
 			}
 			catch (ApplicationException e) { ColorConsole.WriteLine("FATAL ERROR! in script parameter substitution!", ConsoleColor.Red); returntext = null; }
 			catch (Exception e) { ColorConsole.WriteLine("FATAL ERROR! " + e.MessageNested(), ConsoleColor.Red); returntext = null; }
@@ -985,29 +994,49 @@ GO
 						foreach (var s in sqld.Xml_SQLScriptList)
                         {
 							ColorConsole.Write(s.Key, ConsoleColor.Yellow, bracket: "[]",suffix:" ",prefix: "   ");
-							var fromfile = string.IsNullOrWhiteSpace(s.FilePath) ? "": $",from:{s.FilePath}";
-							ColorConsole.Write($"{s.Description} ({s.Name}{fromfile})", ConsoleColor.Yellow, prefix: "Script:"); 
-							ColorConsole.WriteLine();
+                            ColorConsole.Write(s.Name, ConsoleColor.Yellow, bracket: "[]", prefix: "Script:");
+                            if (s.Multirun) ColorConsole.Write("MULTIRUN", ConsoleColor.Red, bracket: "[]",prefix: " ");
+							ColorConsole.Write(s.Description, ConsoleColor.Yellow, prefix: " ");
+                            if (!string.IsNullOrWhiteSpace(s.FilePath)) { ColorConsole.Write(s.FilePath, ConsoleColor.Yellow, prefix: ", from file:");
+							}
+                            ColorConsole.WriteLine();
 							vlist.Add(s.Key);
 						}
 						var scriptkey = ColorConsole.ReadLine("Select the script! [empty]=next DB, [*]=all, [EX]=exit.", ConsoleColor.Yellow, prefix:"   ", suffix: " --> ", validitylist: vlist);
 						if (string.IsNullOrWhiteSpace(scriptkey)) { continue; }
 						if (scriptkey.ToUpper() == "EX") { return o; }
 						SQLDataBase.SQLScript ss = sqld.Xml_SQLScriptList.FirstOrDefault(s=>s.Key==scriptkey);
-						if (!Tools.ResolveArguments(ss.ArgumentParameters, ss.ScriptText,out string ssScriptText)) { return o; }
-						if (ss.ScriptText == null) 
-						{
-							ColorConsole.WriteLine($"Nothing to execute!. Check script definition entry!", ConsoleColor.Red);
-						}
+                        if (string.IsNullOrWhiteSpace(ss.ScriptText)) { ColorConsole.WriteLine($"Nothing to execute!. Check script definition entry!", ConsoleColor.Red); }
 						else
 						{
-							ColorConsole.WriteLine(ssScriptText);
 							var confirm = ColorConsole.ReadLine("Enter CONFIRM to start! [EX]=exit.", ConsoleColor.Yellow, prefix:"   ", suffix: " --> ", validitylist: new List<string>() {"CONFIRM"});
 							if (confirm == "CONFIRM")
 							{
-								SQLDataBaseManagerCore.ExecuteSQLScript(sqld.SQLCS, ssScriptText, ss.CommandTimeout, null);
-								ColorConsole.WriteLine($"Script executed. Name:{sqld.DBName}, script name: {ss.Name}", ConsoleColor.Green);
-							}
+								bool multirunmode = ss.Multirun;
+								int commandtimeout = ss.CommandTimeout;
+								ReturnInfoJSON result = null;
+								using (var sqlc = ServerConnectionPool.GetSqlConnection(sqld.SQLCS, open: true))
+								{
+									if (multirunmode) { result = SQLDataBaseManagerCore.ExecuteMultirunSQLScript(sqlc, ss, ExitAfterOneRun); }
+									else
+									{
+										if (!Tools.KvpString.Resolve(ss.ArgumentParameters, ss.ScriptText, out string ssScriptText)) { return o; }
+										ColorConsole.WriteLine(ssScriptText);
+										result = SQLDataBaseManagerCore.ExecuteSQLScript(sqlc, ssScriptText, commandtimeout, null);
+									}
+								}
+								if (result.ReturnValue == 0) 
+								{
+                                    ColorConsole.WriteLine(result.ReturnMessage, ConsoleColor.White);
+                                    ColorConsole.WriteLine($"Script execution SUCCESS. Name:{sqld.DBName}, script name: {ss.Name}", ConsoleColor.Green); 
+								}
+								else 
+								{
+                                    ColorConsole.WriteLine(result.ReturnMessage, ConsoleColor.White);
+                                    ColorConsole.WriteLine($"Script execution FAILURE. Name:{sqld.DBName}, script name: {ss.Name}", ConsoleColor.Red);
+                                }
+
+                            }
 							else {ColorConsole.WriteLine($"Script was NOT executed!", ConsoleColor.Red);}
 						}
 					}
@@ -1016,6 +1045,16 @@ GO
 			}
 			return o;
 		}
+        static bool ExitAfterOneRun(ReturnInfoJSON runresult) 
+		{
+			if (runresult != null) 
+			{
+				ColorConsole.Write(runresult.ReturnValue==0?"OK":"NOK", runresult.ReturnValue == 0 ? ConsoleColor.Green : ConsoleColor.Red);
+				ColorConsole.WriteLine(runresult.ReturnMessage, ConsoleColor.White,prefix:" ");
+			}
+			var returnkey = ColorConsole.ReadKey(new TimeSpan(0, 0, 5));
+			return returnkey != null; 
+		}
         private static object DropDB(object parameter, object o)
 		{
 			var config = (parameter as Menu.ExecutorParameter).GetConfig<SQLDataBaseManagerXmlProcessor>();
@@ -1893,32 +1932,218 @@ GO
 		{
 			DBKEY,DATABASE,DATASOURCE,DBOTYPE,DBONAME,DBDATAGROUP,BACKUPTS,SHRINKOPTION,SHRINKFREESPACEPERCENT,
 		}
-		#endregion DBSubstitution
+        #endregion DBSubstitution
+
+        #region ExecuteSQLScriptWithMultipleRuns
+        /// <summary>
+        /// Executes a multirun script. Its parameters are in the <Script Parameters=> attribute, as list of KEY=VALUE; pairs.
+        /// Keys:
+        ///		DAYSBACK (C# int value) or LIMITDATE (C# DateTime value): how many days from now, or from when the older rows should be deleted
+        ///		NUMOFDAYSINONERUN (C# int value): how many days are deleted in one run 
+        ///		DELAYBETWEENRUNS (C# TimeSpan value): how much delay will be between runs 
+        ///		TESTMODE (C# bool value): if testmode, no delete takes place
+        /// </summary>
+        /// <param name="sqlc">connectionstring az sql server-hez</param>
+        /// <param name="sqlscript">az sql script (multirun interfész szerint!!!)
+        ///		this should be used in the script in the following way:
+        ///		DECLARE @RUNNINGMODE AS varchar(20) = '{RUNNINGMODE}'
+        ///		IF @RUNNINGMODE = 'GETTOTALRECORDS'
+        ///		THEN
+        ///			-- this part of the script should count the number of the rows of the dab, that will decrease after each run
+        ///			SELECT @RV, @RM -- @RV:0, @RM:the number of rows
+        ///		END
+        ///		ELSE IF @RUNNINGMODE = 'GETMINDATE'
+        ///		THEN
+        ///			-- this part of the script should return a DateTime value, that is the oldest date in the database
+        ///			SELECT @RV, @RM -- @RV:0, @RM:the Date, that is considered the oldest; no rows will be deleted before this
+        ///		END
+        ///		ELSE IF @RUNNINGMODE = 'ONERUN'
+        ///		THEN
+        ///			-- this part of the script deletes some rows from the database, older then a limitdate(parameter)
+        ///			-- parameter usage: DECLARE @RUNDELETEBEFOREDATE AS DATE = '{RUNDELETEBEFOREDATE}'
+        ///			SELECT @RV, @RM -- @RV:(0=OK, otherwise NOK), @RM:message with the result description
+        ///		END
+        /// </param>
+        /// <param name="ExitAfterOneRun">az a függvény, ami minde run után végrehajtásra kerül; 
+        ///		bemenő paramétere az előző run eredménye, 
+        ///		kimenő paramétere pedig igaz, ha ki kell lépni a végrehajtásból.
+        /// </param>
+        /// <returns></returns>
+        public static ReturnInfoJSON ExecuteMultirunSQLScript(SqlConnection sqlc, SQLDataBase.SQLScript sqlscript, Func<ReturnInfoJSON, bool> ExitAfterOneRun=null)
+        {
+            var multirunresult = new List<KeyValuePair<string, string>>();
+
+            var argkvplist = (new Tools.KvpString(sqlscript.ArgumentParameters)).ResolveInteractive();
+			if(argkvplist==null) { return Finalize(0, Add(multirunresult, ERRMSG_NOTHINGTOEXECUTE)); } //user exit with selecting EX
+
+            bool par_testmode;
+            int par_limitdays;
+            DateTime par_limitdate;
+            TimeSpan par_lengthofonerun;
+            TimeSpan par_delaybetweenruns;
+
+            #region parameterek feldolgozása
+            var testmodestring = argkvplist.GetValue(XMLPAR_TESTMODE, "false"); 
+			if ( !bool.TryParse(testmodestring, out par_testmode)) { return Finalize(1, Add(multirunresult, "Result", $"Parameter error:{XMLPAR_TESTMODE}")); }
+
+            var daysbackstring = argkvplist.GetValue(XMLPAR_DAYSBACK, null);
+			var limitdatestring = argkvplist.GetValue(XMLPAR_LIMITDATE, null);
+			if (daysbackstring == null && limitdatestring == null) { par_limitdays = 90; par_limitdate = DateTime.Now.Subtract(new TimeSpan(par_limitdays, 0, 0, 0)); }
+			else if (!string.IsNullOrEmpty(daysbackstring) && !string.IsNullOrEmpty(limitdatestring)) { return Finalize(1, Add(multirunresult, "Result", $"Parameter error:{XMLPAR_DAYSBACK} and {XMLPAR_LIMITDATE} are both defined.")); }
+			else if (!string.IsNullOrEmpty(limitdatestring)) 
+			{ 
+				if (!DateTime.TryParse(limitdatestring, out par_limitdate)) return Finalize(1, Add(multirunresult, "Result", $"Parameter error:" + XMLPAR_LIMITDATE));
+				par_limitdays = (int)DateTime.Now.Subtract(par_limitdate).TotalDays;
+			}
+            else /*if (!string.IsNullOrEmpty(daysbackstring)) */
+            { 
+				if(!int.TryParse(daysbackstring, out par_limitdays)) return Finalize(1, Add(multirunresult, "Result", $"Parameter error:" + XMLPAR_DAYSBACK));
+                par_limitdate = DateTime.Now.Subtract(new TimeSpan(par_limitdays, 0, 0, 0));
+            }
-		#region ExecuteSQLScript
-		/// <summary>
-		/// Egy SQL script végrehajtása (GO-val lezárt batch-eket tartalmazhat)
-		/// </summary>
-		/// <param name="sqlconnectionstring">sql connection string</param>
-		/// <param name="sqltxt">a script</param>
-		/// <param name="commandtimeout">az egyes batch-ek végrehajtási időzítése</param>
-		/// <param name="vars">
-		/// behelyettesítendő változók (a scriptben ezek nevei {} között kell legyenek)
-		/// a következő neveket felismeri akkor is, ha nincsenek benne a sztótárban:
-		///		DATASOURCE: a sql server neve domain/név formában
-		///		DATABASE: az aadatbázis neve
-		/// </param>
-		/// <returns>
-		/// egy ReturnInfoJSON struktúrát, amiben a ReturnValue és ReturnMessage a script által előállított két 
-		/// (egy int és egy string) értéket tartalmazza pl. egy ilyen eredményt: SELECT @returncode, @returnmessage;
-		/// Ha a végrehajtás nem ad vissza eredményt, akkor az első érték 0, a második pedig null;
-		/// 
-		/// </returns>
-		public static ReturnInfoJSON ExecuteSQLScript(string sqlconnectionstring, string sqltxt, int commandtimeout, Dictionary<string, string> vars)
-		{
-			using (var sqlc = ServerConnectionPool.GetSqlConnection(sqlconnectionstring,open:true)) { return ExecuteSQLScript(sqlc,sqltxt, commandtimeout, vars); }
-		}
-		public static ReturnInfoJSON ExecuteSQLScript(SqlConnection sqlconnection, string sqltxt, int commandtimeout, Dictionary<string, string> vars)
+            if (!TimeSpan.TryParse(argkvplist.GetValue(XMLPAR_NUMOFDAYSINONERUN, "#$NONE#$"), out par_lengthofonerun)) { par_lengthofonerun = new TimeSpan(0, 12, 0); }
+            if (!TimeSpan.TryParse(argkvplist.GetValue(XMLPAR_DELAYBETWEENRUNS, "#$NONE#$"), out par_delaybetweenruns)) { par_delaybetweenruns = new TimeSpan(0, 0, 10); }
+            #endregion parameterek feldolgozása
+			if (par_limitdays<=0) { return Finalize(0, Add(multirunresult, "Result", $"SKIPPED (function disabled).")); }
+
+            Add(multirunresult, $"LIMIT", $"{par_limitdays}days (before:{par_limitdate})");
+            Add(multirunresult, $"STAT", $"run length:{par_lengthofonerun.TotalHours}hours, delay between runs:{par_delaybetweenruns.TotalSeconds}sec");
+            Add(multirunresult, $"TESTMODE", $"{par_testmode}");
+
+            try
+            {
+				DateTime starttime = DateTime.Now;
+				string sqltxtalmostresolved = argkvplist.Substitute(sqlscript.ScriptText); //parameters of the run are still unresolved
+				if (sqltxtalmostresolved == null) {return Finalize(1, Add(multirunresult, ERRMSG_NOTHINGTOEXECUTE));} //won't really get, but we never know...
+
+                ReturnInfoJSON ret1=null;
+				string sqltxt = null;
+				int? getdbnumofrowsresult=null;
+				DateTime? getdbmindateresult=null;
+
+				//get number of total records in the database
+				getdbnumofrowsresult = GetDBNumofRows(sqltxtalmostresolved, multirunresult, sqlscript.CommandTimeout, sqlc);
+                if (getdbnumofrowsresult == null) return Finalize(1, multirunresult);
+                int numoftotaldbrecords_before = getdbnumofrowsresult.Value;
+
+				//get minimum date in the database
+                getdbmindateresult = GetDBMindate(sqltxtalmostresolved, multirunresult, sqlscript.CommandTimeout, sqlc);
+                if (getdbmindateresult == null) return Finalize(1, multirunresult);
+                DateTime mindateTS_before = getdbmindateresult.Value;
+
+                var limitdatefornextrun = mindateTS_before;
+                int exceptioncounter = 0;
+				const int MAXEXCEPTIONS = 3; //after this number of subsequent exceptions we exit
+				int deleteruncounter = 0;
+				int runresult;
+                while (true)
+                {
+                    if (limitdatefornextrun >= par_limitdate) break;
+                    limitdatefornextrun = limitdatefornextrun + par_lengthofonerun;
+                    var loople = new List<KeyValuePair<string, string>>();
+                    if (limitdatefornextrun > par_limitdate) limitdatefornextrun = par_limitdate;
+                    Add(loople, $"RUN#{deleteruncounter}");
+					try
+					{
+						sqltxt = Tools.KvpString.Substitute($"{RUNNINGMODE}={RUNNINGMODE_ONERUN};{RUNNINGMODE_ONERUN_PARAMETER_DELETEBEFOREDATE}={limitdatefornextrun:s};", sqltxtalmostresolved);
+						if (sqltxt == null) { return Finalize(1, Add(multirunresult, ERRMSG_NOTHINGTOEXECUTE)); } //won't really get, but we never know...
+						ret1 = ExecuteSQLScript(sqlc, sqltxt, sqlscript.CommandTimeout, null);
+						Add(loople, $"LIMITDATE", limitdatefornextrun.ToString());
+						Add(loople, $"RETCODE", ret1.ReturnValue.ToString());
+						Add(loople, $"RETMSG", ret1.ReturnMessage);
+
+						deleteruncounter++;
+						exceptioncounter = 0;
+						runresult = 0;
+                    }
+					catch (Exception ex)
+					{
+						exceptioncounter++;
+						string errmsg = ""; while (ex != null) { errmsg += ex.Message; ex = ex.InnerException; }
+						Add(loople, $"EXCEPTION RESULT DeleteRun", errmsg);
+                        runresult = 1;
+                        if (exceptioncounter > MAXEXCEPTIONS) { return Finalize(1, multirunresult); }
+                    }
+                    var exitfromloop = (ExitAfterOneRun?.Invoke(Finalize(runresult, loople))) ?? false;
+                    if (exitfromloop) { Add(multirunresult, $"Exit requested by user"); break; }
+                    Thread.Sleep((int)(par_delaybetweenruns.TotalMilliseconds));
+                }
+
+                //get minimum date in the database
+				getdbmindateresult = GetDBMindate(sqltxtalmostresolved,multirunresult, sqlscript.CommandTimeout,sqlc);
+				if (getdbmindateresult==null) return Finalize(1, multirunresult);
+				DateTime mindateTS_after = getdbmindateresult.Value;
+
+                //get number of total records in the database
+                getdbnumofrowsresult = GetDBNumofRows(sqltxtalmostresolved, multirunresult, sqlscript.CommandTimeout, sqlc);
+                if (getdbnumofrowsresult == null) return Finalize(1, multirunresult);
+                int numoftotaldbrecords_after = getdbnumofrowsresult.Value;
+
+                Add(multirunresult, $"NUMOFRUNS", deleteruncounter.ToString());
+                Add(multirunresult, $"DBRECORDS", $"{numoftotaldbrecords_before}-->{numoftotaldbrecords_after}");
+                Add(multirunresult, $"MINDATE", $"{mindateTS_before}-->{mindateTS_after}");
+                Add(multirunresult, $"PROCESSINGTIME", $"{DateTime.Now.Subtract(starttime)}");
+                return Finalize(0, multirunresult);
+            }
+            catch (Exception ex) { return Finalize(1, Add(multirunresult, ex)); }
+        }
+		private static DateTime? GetDBMindate(string sqltxtalmostresolved, List<KeyValuePair<string, string>> multirunresult,int commandtimeout, SqlConnection sqlc) 
+		{
+            //get minimum date in the database
+            string sqltxt = Tools.KvpString.Substitute($"{RUNNINGMODE}={RUNNINGMODE_GETMINDATE};{RUNNINGMODE_ONERUN_PARAMETER_DELETEBEFOREDATE}=;", sqltxtalmostresolved);
+            if (sqltxt == null) { Add(multirunresult, ERRMSG_NOTHINGTOEXECUTE); return null; } //won't really get, but we never know...
+            var ret1 = ExecuteSQLScript(sqlc, sqltxt, commandtimeout, null);
+            if (ret1.ReturnValue != 0) { Add(multirunresult, RUNNINGMODE_GETMINDATE + " FAILURE", ret1.ReturnMessage); return null; }
+            return DateTime.Parse(ret1.ReturnMessage);//GetOldestDate.Invoke(sqlconnectionstring);
+        }
+		private static int? GetDBNumofRows(string sqltxtalmostresolved, List<KeyValuePair<string, string>> multirunresult, int commandtimeout, SqlConnection sqlc) 
+		{
+            string sqltxt = Tools.KvpString.Substitute($"{RUNNINGMODE}={RUNNINGMODE_GETTOTALRECORDS};{RUNNINGMODE_ONERUN_PARAMETER_DELETEBEFOREDATE}=;", sqltxtalmostresolved);
+            if (sqltxt == null) { Add(multirunresult, ERRMSG_NOTHINGTOEXECUTE); return null; } //won't really get, but we never know...
+            var ret1 = ExecuteSQLScript(sqlc, sqltxt, commandtimeout, null);
+            if (ret1.ReturnValue != 0) { Add(multirunresult, RUNNINGMODE_GETTOTALRECORDS + " FAILURE", ret1.ReturnMessage); return null; }
+            return int.Parse(ret1.ReturnMessage);
+        }
+
+        const string RUNNINGMODE = "RUNNINGMODE";
+        const string RUNNINGMODE_GETTOTALRECORDS = "GETTOTALRECORDS";
+        const string RUNNINGMODE_GETMINDATE = "GETMINDATE";
+        const string RUNNINGMODE_ONERUN = "ONERUN";
+        const string RUNNINGMODE_ONERUN_PARAMETER_DELETEBEFOREDATE = "RUNDELETEBEFOREDATE";
+
+        const string XMLPAR_NUMOFDAYSINONERUN = "NUMOFDAYSINONERUN";
+        const string XMLPAR_DELAYBETWEENRUNS = "DELAYBETWEENRUNS";
+        const string XMLPAR_TESTMODE = "TESTMODE";
+        const string XMLPAR_DAYSBACK = "DAYSBACK";
+        const string XMLPAR_LIMITDATE = "LIMITDATE";
+
+        const string ERRMSG_NOTHINGTOEXECUTE = "FAILURE! Nothing to execute! Check script definition entry!";
+
+        private static List<KeyValuePair<string, string>> Add(List<KeyValuePair<string, string>> kvp, string a, string b=null) { kvp.Add(new KeyValuePair<string, string>(a, b)); return kvp; }
+        private static List<KeyValuePair<string, string>> Add(List<KeyValuePair<string, string>> kvp,Exception ex) { string errmsg = ""; while (ex != null) { errmsg += ex.Message; ex = ex.InnerException; } return Add(kvp, "EXCEPTION RESULT",errmsg); }
+        private static ReturnInfoJSON Finalize(int returnvalue,List<KeyValuePair<string, string>> kvplist) { var rmsg = "";foreach (var kvp in kvplist) rmsg += string.IsNullOrWhiteSpace(kvp.Value)? $"{kvp.Key};" : $"{kvp.Key}={kvp.Value};"; return new ReturnInfoJSON() { ReturnValue = returnvalue, ReturnMessage = rmsg, }; }
+        #endregion ExecuteSQLScriptWithMultipleRuns
+
+        #region ExecuteSQLScript
+        /// <summary>
+        /// Egy SQL script végrehajtása (GO-val lezárt batch-eket tartalmazhat)
+        /// </summary>
+        /// <param name="sqlconnectionstring">sql connection string</param>
+        /// <param name="sqltxt">a script</param>
+        /// <param name="commandtimeout">az egyes batch-ek végrehajtási időzítése</param>
+        /// <param name="vars">
+        /// behelyettesítendő változók (a scriptben ezek nevei {} között kell legyenek)
+        /// a következő neveket felismeri akkor is, ha nincsenek benne a sztótárban:
+        ///		DATASOURCE: a sql server neve domain/név formában
+        ///		DATABASE: az aadatbázis neve
+        /// </param>
+        /// <returns>
+        /// egy ReturnInfoJSON struktúrát, amiben a ReturnValue és ReturnMessage a script által előállított két 
+        /// (egy int és egy string) értéket tartalmazza pl. egy ilyen eredményt: SELECT @returncode, @returnmessage;
+        /// Ha a végrehajtás nem ad vissza eredményt, akkor az első érték 0, a második pedig null;
+        /// 
+        /// </returns>
+        public static ReturnInfoJSON ExecuteSQLScript(SqlConnection sqlconnection, string sqltxt, int commandtimeout, Dictionary<string, string> vars)
 		{
 			sqltxt = VRH.Common.StringConstructor.ResolveConstructorR(vars, sqltxt, "{}@@");
@@ -2607,6 +2832,7 @@ GO
 							public static class Description { public static class Values { public const string DEFAULT = ""; } }
 							public static class ScriptCommandTimeout { public static class Values { public const int DEFAULT = 10000; } }
 							public static class Parameters { public static class Values { public const string DEFAULT = ""; } }
+							public static class Multirun { public static class Values { public const bool DEFAULT = false; } }
 						}
 					}
 				}
@@ -2623,6 +2849,7 @@ GO
 			public string ScriptText = "";
 			public int CommandTimeout = 10000;
 			public string ArgumentParameters;
+			public bool Multirun = false;
 			public SQLScript() { }
 			public SQLScript(SQLScript sqls) { Name = sqls.Name; Description = sqls.Description; ScriptText= sqls.ScriptText; }
@@ -2634,8 +2861,10 @@ GO
 				Name = GetValue(nameof(XmlStructure.SQLDataBase.Scripts.Script.Attributes.Name), sqlscriptXml, XmlStructure.SQLDataBase.Scripts.Script.Attributes.Name.Values.DEFAULT);
 				FilePath = GetValue(nameof(XmlStructure.SQLDataBase.Scripts.Script.Attributes.File), sqlscriptXml, XmlStructure.SQLDataBase.Scripts.Script.Attributes.File.Values.DEFAULT);
 				Description= GetValue(nameof(XmlStructure.SQLDataBase.Scripts.Script.Attributes.Description), sqlscriptXml, XmlStructure.SQLDataBase.Scripts.Script.Attributes.Description.Values.DEFAULT);
-				Tools.ResolveArguments(ArgumentParameters, this.Name, out this.Name, interactive: false);
-				Tools.ResolveArguments(ArgumentParameters, this.Description, out this.Description, interactive: false);
+				Multirun= GetValue(nameof(XmlStructure.SQLDataBase.Scripts.Script.Attributes.Multirun), sqlscriptXml, XmlStructure.SQLDataBase.Scripts.Script.Attributes.Multirun.Values.DEFAULT);
+
+                Tools.KvpString.Resolve(ArgumentParameters, this.Name, out this.Name, disableinteractive: true);
+                Tools.KvpString.Resolve(ArgumentParameters, this.Description, out this.Description, disableinteractive: true);
 				if (string.IsNullOrWhiteSpace(this.FilePath))
 				{
 					ScriptText = GetValue(sqlscriptXml, XmlStructure.SQLDataBase.Scripts.Script.Values.DEFAULT);
@@ -32,5 +32,5 @@ using System.Runtime.InteropServices;
 // You can specify all the values or you can default the Build and Revision Numbers
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.30.1.0")]
-[assembly: AssemblyFileVersion("1.30.1.0")]
+[assembly: AssemblyVersion("1.31.0.0")]
+[assembly: AssemblyFileVersion("1.31.0.0")]
@@ -20,6 +20,8 @@ using VRH.Common;
 using Microsoft.Win32;
 using System.Reflection;
 using Vrh.Log4Pro.MaintenanceConsole.CommandLineParserNS;
+using System.Runtime.CompilerServices;
+using static Vrh.Log4Pro.MaintenanceConsole.MaintenanceToolManagerNS.MaintenanceToolsXmlProcessor.XmlStructure.ExternalUtility.Attributes;
 namespace Vrh.Log4Pro.MaintenanceConsole.ToolsNS
 {
@@ -325,39 +327,70 @@ namespace Vrh.Log4Pro.MaintenanceConsole.ToolsNS
 			if (list32.Count() > 0) { if (list64.Count() > 0) { os = "64bit"; } else { os = "32bit"; } }
 			return os;
 		}
-		public static bool ResolveArguments(string parameterkvpstring, string stringwithparameters, out string resolvedtext, bool interactive = true)
+		public class KvpString 
 		{
-			var argumentparametersdictionary = parameterkvpstring.Split(new char[] { ';', ',' }, StringSplitOptions.RemoveEmptyEntries)
-				.Select(kvp => CreateKVP(kvp))
-				.Where(kvp => kvp.Key != null)
-				.ToDictionary(kvp => kvp.Key, kvp => kvp.Value);
-			Dictionary<string, string> resolveddictionary = new Dictionary<string, string>();
-			resolvedtext = stringwithparameters;
-			foreach (var kvp in argumentparametersdictionary)
+			public KvpString(string parameterkvpstring) { this.kvpstring = parameterkvpstring; BuildDict(force:true);}
+			private string kvpstring;
+			private Dictionary<string, string> kvpdict = null;
+			private Dictionary<string, string> kvpdictresolved = null;
+            public string GetValue(string argumentname, string notexistvalue = null)
+            {
+                BuildDict();
+                return this.kvpdictresolved.ContainsKey(argumentname) ? this.kvpdictresolved[argumentname] : notexistvalue;
+            }
+            private void BuildDict(bool force=false)
+            {
+				if (this.kvpdict != null && !force) return;
+                this.kvpdict = (this.kvpstring).Split(new char[] { ';', ',' }, StringSplitOptions.RemoveEmptyEntries)
+                    .Select(kvp => CreateKVP(kvp))
+                    .Where(kvp => kvp.Key != null)
+                    .ToDictionary(kvp => kvp.Key, kvp => kvp.Value);
+				this.kvpdictresolved = this.kvpdict.ToDictionary(d => d.Key, d => d.Value);
+            }
+            public KvpString ResolveInteractive(bool disable = false)
+            {
+                this.kvpdictresolved = new Dictionary<string, string>();
+                foreach (var kvp in this.kvpdict)
+                {
+                    if (kvp.Value == null) { this.kvpdictresolved.Add(kvp.Key, ""); }
+                    else if (kvp.Value.StartsWith("?") && !disable)
+                    {
+                        // "?default?prompt"
+                        string prompt = $"Enter value for {kvp.Key}:";
+                        string kvpdefaultvalue = null;
+                        if (kvp.Value.Length > 1)
+                        {
+                            var ppp = kvp.Value.Substring(1).Split(new char[] { '?' }, StringSplitOptions.RemoveEmptyEntries);
+                            if (!string.IsNullOrWhiteSpace(ppp[0])) { kvpdefaultvalue = ppp[0]; };
+                            if (kvp.Value.Substring(1).IndexOf('?') != -1) { prompt = ppp[1]; }
+                        }
+                        string value = ColorConsole.ReadLine(prompt, ConsoleColor.Yellow, defaultvalue: kvpdefaultvalue);
+                        if (value.ToUpper() == "EX") { return null; }
+                        this.kvpdictresolved.Add(kvp.Key, value);
+                    }
+                    else if (kvp.Value.StartsWith("?") && disable) this.kvpdictresolved.Add(kvp.Key, $"{{{kvp.Key}}}");
+                    else { this.kvpdictresolved.Add(kvp.Key, kvp.Value); }
+                }
+                return this;
+            }
+			public string Substitute(string stringwithparameters) 
 			{
-				if (kvp.Value == null) { resolveddictionary.Add(kvp.Key, "");}
-				else if (kvp.Value.StartsWith("?") && interactive)
-				{
-					// "?default?prompt"
-					string prompt = $"Enter value for {kvp.Key}:";
-					string kvpdefaultvalue = null;
-					if (kvp.Value.Length > 1)
-					{
-						var ppp = kvp.Value.Substring(1).Split(new char[] { '?' }, StringSplitOptions.RemoveEmptyEntries);
-						if (!string.IsNullOrWhiteSpace(ppp[0])) { kvpdefaultvalue = ppp[0]; };
-						if (kvp.Value.Substring(1).IndexOf('?') != -1) { prompt = ppp[1]; }
-					}
-					string value = ColorConsole.ReadLine(prompt, ConsoleColor.Yellow, defaultvalue: kvpdefaultvalue);
-					if (value.ToUpper() == "EX") { return false; }
-					resolveddictionary.Add(kvp.Key, value);
-				}
-				else if (kvp.Value.StartsWith("?") && !interactive) resolveddictionary.Add(kvp.Key, $"{{{kvp.Key}}}");
-				else { resolveddictionary.Add(kvp.Key, kvp.Value); }
+                return VRH.Common.StringConstructor.ResolveConstructorR(this.kvpdictresolved, stringwithparameters, "{}@@");
+            }
+            public static string Substitute(string kvpstring, string stringwithparameters)
+            {
+                return VRH.Common.StringConstructor.ResolveConstructorR(new KvpString(kvpstring).kvpdictresolved, stringwithparameters, "{}@@");
+            }
+            public static bool Resolve(string kvpstring,string stringwithparameters, out string resolvedtext, bool disableinteractive = false) 
+			{
+				resolvedtext = null;
+                var resolvedkvpstring = (new Tools.KvpString(kvpstring)).ResolveInteractive(disableinteractive);
+				if (resolvedkvpstring == null) return false;//exit with EX
+                resolvedtext = resolvedkvpstring.Substitute(stringwithparameters);
+                return true;
 			}
-			resolvedtext = VRH.Common.StringConstructor.ResolveConstructorR(resolveddictionary, stringwithparameters, "{}@@");
-			return true;
-		}
-		private static KeyValuePair<string, string> CreateKVP(string kvpstring)
+        }
+        private static KeyValuePair<string, string> CreateKVP(string kvpstring)
 		{
 			string kvpk = null;
 			string kvpv = null;
@@ -368,7 +401,7 @@ namespace Vrh.Log4Pro.MaintenanceConsole.ToolsNS
 				KeyValuePair<string, string> r = new KeyValuePair<string, string>(kvpk, kvpv);
 				return r;
 			}
-			catch { return new KeyValuePair<string, string>(kvpk, null); }
+			catch { return new KeyValuePair<string, string>(kvpk, ""); }
 		}
 	}
@@ -347,14 +347,17 @@
     <Reference Include="Microsoft.CSharp" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
-    <Reference Include="VRH.Common, Version=3.0.1.0, Culture=neutral, processorArchitecture=MSIL">
-      <HintPath>..\packages\VRH.Common.3.0.1\lib\net45\VRH.Common.dll</HintPath>
+    <Reference Include="VRH.Common, Version=4.1.1.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\VRH.Common.4.1.1\lib\net462\VRH.Common.dll</HintPath>
     </Reference>
-    <Reference Include="VRH.Common.COM, Version=3.0.0.0, Culture=neutral, processorArchitecture=MSIL">
-      <HintPath>..\packages\VRH.Common.3.0.1\lib\net45\VRH.Common.COM.dll</HintPath>
+    <Reference Include="VRH.Common.COM, Version=4.1.0.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\VRH.Common.4.1.1\lib\net462\VRH.Common.COM.dll</HintPath>
     </Reference>
-    <Reference Include="VRH.Common.EF, Version=3.0.0.0, Culture=neutral, processorArchitecture=MSIL">
-      <HintPath>..\packages\VRH.Common.3.0.1\lib\net45\VRH.Common.EF.dll</HintPath>
+    <Reference Include="VRH.Common.EF, Version=4.1.0.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\VRH.Common.4.1.1\lib\net462\VRH.Common.EF.dll</HintPath>
+    </Reference>
+    <Reference Include="VRH.Common.Log4ProIS, Version=4.1.1.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\VRH.Common.4.1.1\lib\net462\VRH.Common.Log4ProIS.dll</HintPath>
     </Reference>
     <Reference Include="Vrh.Web.Providers, Version=2.0.2.0, Culture=neutral, processorArchitecture=MSIL">
       <HintPath>..\packages\VRH.Web.Providers.2.0.2\lib\net452\Vrh.Web.Providers.dll</HintPath>
@@ -73,7 +73,7 @@
   <package id="System.Threading.Timer" version="4.0.1" targetFramework="net472" />
   <package id="System.Xml.ReaderWriter" version="4.0.11" targetFramework="net472" />
   <package id="System.Xml.XDocument" version="4.0.11" targetFramework="net472" />
-  <package id="VRH.Common" version="3.0.1" targetFramework="net472" />
+  <package id="VRH.Common" version="4.1.1" targetFramework="net472" />
   <package id="VRH.Web.Providers" version="2.0.2" targetFramework="net472" />
   <package id="Vrh.XmlProcessing" version="2.8.0" targetFramework="net472" />
 </packages>
 \ No newline at end of file