using System;
using MySql.Data.MySqlClient;
using System.Data;
namespace Macro_Correlation_Divergence_Arbitrage {
class DataBaseHandler {
static string myConnectionString = "server=localhost;database=Correlations;uid=Sam;pwd=230999;";
public static MySqlConnection sqlCon = new MySqlConnection(myConnectionString);
public static void StartServer() {
OpenConnection();
}
public static MySqlDataReader GetData(string command) {
ReadyConnection();
MySqlCommand com = new MySqlCommand(command, sqlCon);
MySqlDataReader reader;
//for (int i = 0; i < 10; i++) {
//try {
reader = com.ExecuteReader();
return reader;
//}
//catch {
// if (i == 9) {
// try {
// sqlCon.Close();
// } catch { }
// OpenConnection();
// i = 0;
// }
//}
//}
}
public static void SetData(string command) {
ReadyConnection();
MySqlCommand com = new MySqlCommand(command, sqlCon);
//for (int i = 0; i < 10; i++) {
//try {
com.ExecuteNonQuery();
// } catch {
// if (i == 9) {
// try {
// sqlCon.Close();
// } catch { }
// OpenConnection();
// i = 0;
// }
// }
//}
}
public static int GetCount(string command) {
ReadyConnection();
MySqlCommand com = new MySqlCommand(command, sqlCon);
//for (int i = 0; i < 10; i++) {
//try {
string t = com.ExecuteScalar().ToString();
if (t.Length == 0) {
return 0;
} else {
return int.Parse(t);
}
// } catch {
// if (i == 9) {
// try {
// sqlCon.Close();
// } catch { }
// OpenConnection();
// i = 0;
// }
// }
//}
}
public static double GetCountDouble(string command) {
ReadyConnection();
MySqlCommand com = new MySqlCommand(command, sqlCon);
//for (int i = 0; i < 10; i++) {
//try {
string t = com.ExecuteScalar().ToString();
if (t.Length == 0) {
return 0;
} else {
return double.Parse(t);
}
// } catch {
// if (i == 9) {
// try {
// sqlCon.Close();
// } catch { }
// OpenConnection();
// i = 0;
// }
// }
//}
}
static void ReadyConnection() {
try {
sqlCon.Close();
} catch { }
StartServer();
}
private static void OpenConnection() {
for (int i = 0; i < 10; i++) {
try {
sqlCon.Open();
break;
} catch {
if (i == 9) {
throw new Exception("Failed to connect to database");
}
}
}
}
}
}
Anonymous - 1 year ago