1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:
43:
44:
45:
46:
47:
48:
49:
50:
51:
52:
53:

private System.Timers.Timer timer;
public ServerListerstellen SL = new ServerListerstellen();
public Connection c = new Connection();

protected override void OnStart(string[] args)
        {
            try
            {
               
                this.timer = new System.Timers.Timer(120000D); 
                this.timer.AutoReset = true;
                this.timer.Elapsed += new System.Timers.ElapsedEventHandler(this.timer_Elapsed);
                this.timer.Start();
            }
            catch (Exception ex)
            {
                WriteLogFile.WriteInLog(ex.ToString());
            }
        }

        protected override void OnStop()
        {
            this.timer.Stop();
            this.timer = null;
        }

        private void timer_Elapsed(object sender, ElapsedEventArgs e)
        {
            try
            {
               
                SL.datenHolen();
            }
            catch (Exception ex)
            {
                WriteLogFile.WriteInLog(ex.ToString());
            }

            try
            {
                string sqlQuery = "INSERT INTO [DB] (CPU_cores, Customer, Average_CPU_usage, Free_HDD_space, ServerIP, "
                                   + "Max_HDD_space, Max_RAM_space, Available_RAM_space, ServerNames, Collect_time, ServerUUID )"
                                   + "VALUES ('" + SL._ccpu + "', '" + SL._customer + "', '" + SL._cpu + "', '" + (((SL._fhdd / 1024) / 1024) / 1024) + "', '"
                                   + "" + SL._ip + "', '" + (((SL._mhdd / 1024) / 1024) / 1024) + "', '" + (SL._mram / 1024) + "', '" + (SL._ram / 1024) + "', '"
                                   + "" + SL._sname + "', '" + DateTime.Now + "', '" + SL._uuid + "' )";

                c.OpenSqlConnection();
                c.ExecuteQuery(sqlQuery);
           }
           catch (Exception ex)
            {
                WriteLogFile.WriteInLog(""+ex.ToString());
            }					

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:
43:
44:
45:
46:
47:
48:
49:
50:
51:
52:
53:
54:
55:
56:
57:
58:
59:
60:
61:
62:
63:
64:
65:
66:
67:
68:
69:
70:
71:
72:

public class Connection
    {
        private static readonly string SQL_CON = "Data Source = x.x.x.x,1434; Provider=SQLOLEDB; Initial Catalog = DB; Persist Security Info=True;User ID = XX; Password=XXXXXX";

public void ExecuteQuery(string sqlQuery)
        {
            CloseSqlConnection();
            OpenSqlConnection();
            try
            {
                Command = new OleDbCommand(sqlQuery, SqlConnection);
                Command.ExecuteNonQuery();
               
            }
            catch (Exception ex)
            {
                WriteLogFile.WriteInLog("ExecuteQuery " + ex.ToString() + "- Query => " + sqlQuery);
            }
        }

        private static OleDbCommand command;
        public static OleDbCommand Command
        {
            get { return command; }
            set { command = value; }
        }

        public void OpenSqlConnection()
        {
            try
            {
                if (SqlConnection.State.ToString() == "Closed")
                {
                    SqlConnection.Open();
                }
            }
            catch (Exception ex)
            {
               WriteLogFile.WriteInLog("OpenSql " + ex.ToString());
            }
        }

        public void CloseSqlConnection()
        {
            try
            {
                if (SqlConnection.State.ToString() != null && SqlConnection.State.ToString() == "Open")
                {
                    SqlConnection.Close();
                }
            }
            catch (Exception ex)
            {
                WriteLogFile.WriteInLog("CloseSql " + ex.ToString());
            }
        }


        private static string connectionString = SQL_CON;
        public static string ConnectionString
        {
            get { return connectionString; }
            set { connectionString = value; }
        }
        private static OleDbConnection sqlConnection = new OleDbConnection(ConnectionString);
        public static OleDbConnection SqlConnection
        {
            get { return sqlConnection; }
            set { sqlConnection = value; }
        }
    }
}