private static MySqlConnection mySqlConn; //선언
public static void DBConn()
{
//연결
try
{
string strconn = "Server=127.0.0.1;Database=test;Uid=root;Pwd=apmsetup;";
mySqlConn = new MySqlConnection(strconn);
mySqlConn.Open();
}
catch (Exception ex)
{
Console.WriteLine("연결 실패\n인터넷 연결을 확인해주세요\n" + ex.Message);
}
finally
{
}
}
public static MySqlConnection getInsent()
{
if (mySqlConn == null || mySqlConn.State != System.Data.ConnectionState.Open || mySqlConn.Ping() == false)
{
DBConn();
Console.WriteLine("DB재연결");
}
return mySqlConn;
}
public void sendMSG()
{
try
{
// MYSQL 내보내기
string msg = "SELECT * FROM member WHERE Idx = 1;";
// MYSQL 내보내기
// 날릴 쿼리가 있으면
string str = "";
if (!(msg == ""))
{
using (MySqlCommand count = new MySqlCommand(msg, mySqlConn))
{
//count.ExecuteNonQuery();
MySqlDataReader myCount = count.ExecuteReader();
while (myCount.Read())
{
str = myCount["Name"].ToString();
}
myCount.Close();
}
}
}
catch (Exception ex)
{
Console.WriteLine("READ Error!\n" + ex.Message);
}
finally
{
}
}