using MySql.Data.MySqlClient;
using System.Data;
using System;
using System.Data.Common;
class DbHelper
{
public MySqlConnection con = new MySqlConnection("server=localhost;userid=root;password=root;database=dothrmproxy");
public MySqlCommand cmd;
public MySqlDataAdapter Mdr;
public int Execute(string query)
{
int i = 0;
try
{
con.Open();
cmd = new MySqlCommand(query, con);
i = cmd.ExecuteNonQuery();
}
catch
{
i = -1;
}
finally
{
con.Close();
}
return i;
}
public int Execute(string commandtext,object [,]parameter,CommandType ct)
{
int i = 0;
try
{
con.Open();
cmd = new MySqlCommand(commandtext, con);
cmd.CommandType = ct;
MySqlParameter oParameter;
for (int j = 0; j < parameter.Length / 2; j++)
{
oParameter = cmd.CreateParameter();
oParameter.ParameterName = parameter[j, 0].ToString();
oParameter.Value = parameter[j, 1];
cmd.Parameters.Add(oParameter);
}
i = cmd.ExecuteNonQuery();
}
catch
{
i = -1;
}
finally
{
con.Close();
}
return i;
}
public DataTable GetTable(string query)
{
DataTable result = new DataTable();
try
{
Mdr = new MySqlDataAdapter(query, con);
if (con.State == ConnectionState.Closed)
con.Open();
Mdr.Fill(result);
return result;
}
catch (Exception err)
{ return result; }
finally
{
con.Close();
}
}
public DataSet GetSet(string query)
{
DataSet result = new DataSet();
try
{
Mdr = new MySqlDataAdapter(query, con);
if (con.State == ConnectionState.Closed)
con.Open();
Mdr.Fill(result);
return result;
}
catch (Exception err)
{ return result; }
finally
{
con.Close();
}
}
}