egtbeamwall/EgtBEAMWALL.DataLayer/DbConfig.cs

using System.Diagnostics;
using System;
using System.IO;
using System.Reflection;

namespace EgtBEAMWALL.DataLayer
{
    public static class DbConfig
    {
        #region Public Fields

        public static string DATABASE_NAME = "EgtBwDb";

        public static int DATABASE_PROCESS_TIMEOUT = 5;
        public static string DATABASE_PWD = "viacremasca";

        // Database config
        public static string DATABASE_SERV = "127.0.0.1";

        public static string DATABASE_USER = "EgtUser";

        #endregion Public Fields

        #region Public Properties

        /// <summary>
        /// DB Connection string per azioni amministrative
        /// </summary>
        public static string ADMIN_CONNECTION_STRING { get; set; } = "";

        /// <summary>
        /// DB Connection string
        /// </summary>
        public static string CONNECTION_STRING { get; set; } = "";

        #endregion Public Properties

        #region Public Methods

        /// <summary>
        /// Effettua migrazione esplicita del DB
        /// </summary>
        /// <returns></returns>
        public static bool CheckMigrateDb()
        {
            // esecuzione script di migrations del DB
            return Controllers.DbController.man.checkMigrateDb();
        }

        /// <summary>
        /// Effettua verifica presenza utente
        /// </summary>
        /// <param name="nKey"></param>
        /// <param name="sKey"></param>
        /// <param name="isNetwork"></param>
        /// <returns></returns>
        public static bool CheckUser(string nKey, string sKey, bool isNetwork)
        {
            // esecuzione script di install locale
            return Controllers.DbController.man.checkCreateUser(DATABASE_USER, DATABASE_PWD, isNetwork);
        }

        /// <summary>
        /// Effettua verifica presenza view prod + relativo utente
        /// </summary>
        /// <param name="nKey"></param>
        /// <param name="sKey"></param>
        /// <param name="isNetwork"></param>
        /// <returns></returns>
        public static bool CheckViews(string nKey, string sKey)
        {
            // esecuzione script di install locale
            return Controllers.DbController.man.refreshViews(DATABASE_NAME);
        }
        /// <summary>
        /// Effettua DUMP del DB dato utente admin + percorso salvataggio
        /// </summary>
        /// <param name="outFilePath">Percorso di salvataggio del dump (*.sql)</param>
        /// <returns></returns>
        public static bool DumpDB(string mysqlDumpPath, string outFilePath)
        {
            bool fatto = false;
            // aggiungo sql finale
            if (!outFilePath.EndsWith(".sql"))
            {
                outFilePath = $"{outFilePath}.sql";
            }
            // esecuzione script x dump del DB
            string dirPath = Path.GetDirectoryName(outFilePath);
            if (!Directory.Exists(dirPath))
            {
                Directory.CreateDirectory(dirPath);
            }
            // se ci fosse già file elimino...
            if (File.Exists(outFilePath))
            {
                File.Delete(outFilePath);
            }
            // chiamo script esterno...
            string callScript = $"\"{mysqlDumpPath}\" -u{DATABASE_USER}  -p{DATABASE_PWD} {DATABASE_NAME} > {outFilePath}";
            ExecuteCommand(callScript);
            return fatto;
        }
        /// <summary>
        /// Esecuzione di un comando esterno
        /// </summary>
        /// <param name="command"></param>
        public static void ExecuteCommand(string command)
        {
            int exitCode;
            ProcessStartInfo processInfo;
            Process process;

            processInfo = new ProcessStartInfo("cmd.exe", "/c " + command);
            processInfo.CreateNoWindow = true;
            processInfo.UseShellExecute = false;
            // *** Redirect the output ***
            processInfo.RedirectStandardError = true;
            processInfo.RedirectStandardOutput = true;

            process = Process.Start(processInfo);
            process.WaitForExit();

            // *** Read the streams ***
            // Warning: This approach can lead to deadlocks, see Edit #2
            string output = process.StandardOutput.ReadToEnd();
            string error = process.StandardError.ReadToEnd();

            exitCode = process.ExitCode;

            Console.WriteLine("output>>" + (String.IsNullOrEmpty(output) ? "(none)" : output));
            Console.WriteLine("error>>" + (String.IsNullOrEmpty(error) ? "(none)" : error));
            Console.WriteLine("ExitCode: " + exitCode.ToString(), "ExecuteCommand");
            process.Close();
        }


        /// <summary>
        /// Metodo di init standard per DB in rete con Master_Key
        /// </summary>
        /// <param name="server">Indirizzo del server (tipicamente indirizzo di rete)</param>
        /// <param name="nKey">Numero chiave</param>
        /// <param name="sKey">Codice/pwd associato a chaive</param>
        /// <param name="masterKey">Numero di chiave master con cui è creato il DB</param>
        public static void InitDb(string server, string nKey, string sKey, string masterKey = "")
        {
            // se nulla metto amster come nKey...
            masterKey = string.IsNullOrEmpty(masterKey) ? nKey : masterKey;
            DATABASE_SERV = server;
            DATABASE_NAME = $"EgtBwDb_{masterKey}";
            DATABASE_USER = $"user_{nKey}";
            DATABASE_PWD = $"pwd_{sKey}";
            CONNECTION_STRING = $"server={DATABASE_SERV};port=3306;database={DATABASE_NAME};uid={DATABASE_USER};pwd={DATABASE_PWD};SslMode=None";
            // stringa admin con utente root egalware...
            ADMIN_CONNECTION_STRING = $"server={DATABASE_SERV};port=3306;database=mysql;uid=root;pwd=Egalware_24068!;SslMode=none;CHARSET=utf8";
        }

        /// <summary>
        /// Aggiorna conf NLog x target DIR
        /// </summary>
        /// <param name="logDir"></param>
        public static void SetupLogDir(string logDir)
        {
            string appDir = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);
            string filePath = Path.Combine(appDir, "NLog.config");
            // leggo il file NLog
            string rawData = File.ReadAllText(filePath);

            // sostituzione livello minimo da selezione
            rawData = rawData.Replace("${basedir}", logDir);

            // ri-scrivo file NLog
            File.WriteAllText(filePath, rawData);
        }

        #endregion Public Methods
    }
}