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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
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");
// ConnectionString
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();
}
}
} |
