我的MySql 数据访问层

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
// Myself using
using MySql.Data.MySqlClient;
using System.Web.Configuration;
/**/ /// <summary>
/// myDataTable 的摘要说明
/// </summary>
public class myDataTable
{
public string Client_Str;

public myDataTable( string My_str)
{
//
// TODO: 在此处添加构造函数逻辑
//
Client_Str = My_str; // 通过构造函数传递strng给class类的全局变量strng;
}
public void mysql_EXE() // 执行SQL但不返回数据
{
string myConn_str = WebConfigurationManager.ConnectionStrings[ " MySqlConnectionString " ].ConnectionString;
MySqlConnection myConn = new MySqlConnection(myConn_str);
MySqlCommand myComm = new MySqlCommand(Client_Str);
// myConn.Open();
myComm.Connection = myConn;
try
{
if (myComm.Connection.State.ToString() == " Closed " ) myComm.Connection.Open();
myComm.ExecuteNonQuery();
}
catch (Exception ex)
{
Session[ " Error " ] = ex.ToString();
Response.Redirect( " error.aspx " );
}
finally
{
myComm.Dispose();
myComm.Connection.Close();
myConn.Dispose();
myConn.Close();
}
// myConn.Close();
}
public DataTable myTable() // 执行SQL并返回DataTable数据
{
string myConn_str = WebConfigurationManager.ConnectionStrings[ " MySqlConnectionString " ].ConnectionString;
MySqlConnection myConn = new MySqlConnection(myConn_str);
MySqlCommand myComm = new MySqlCommand(Client_Str);
// myConn.Open();
myComm.Connection = myConn;
try
{
if (myComm.Connection.State.ToString() == " Closed " ) myComm.Connection.Open();
myComm.ExecuteNonQuery();
}
catch (Exception ex)
{
Session[ " Error " ] = ex.ToString();
Response.Redirect( " error.aspx " );
}
finally
{
myComm.Dispose();
myComm.Connection.Close();
myConn.Dispose();
myConn.Close();
}
// myConn.Close();
MySqlDataAdapter myAdapter = new MySqlDataAdapter(myComm);
DataTable table = new DataTable();
myAdapter.Fill(table);
return table;
}
public void Delete_procedure() // “删除”的存储过程
{
string str_orgid = Client_Str; // 获得orgid
string myConn_str = WebConfigurationManager.ConnectionStrings[ " MySqlConnectionString " ].ConnectionString;
MySqlConnection myConn = new MySqlConnection(myConn_str);
MySqlCommand myComm = new MySqlCommand( " DELETEDB " , myConn); // (Client_Str);
// myComm.Connection = myConn;
try
{
if (myComm.Connection.State.ToString() == " Closed " ) myComm.Connection.Open();
myComm.CommandType = CommandType.StoredProcedure;
MySqlParameter myParameter;
myParameter = new MySqlParameter( " ?m_orgid " , MySqlDbType.String);
myParameter.Value = str_orgid;
myParameter.Direction = ParameterDirection.Input;
myComm.Parameters.Add(myParameter);

// myComm.CommandText = "DELETEDB"; // 存储过程名
// myComm.Parameters.Add("m_orgid", str_orgid);
myComm.ExecuteNonQuery();
}
catch (Exception ex)
{
Session[ " Error " ] = ex.ToString();
Response.Redirect( " error.aspx " );
}
finally
{
myComm.Dispose();
myComm.Connection.Close();
myConn.Dispose();
myConn.Close();
}
}
public int My_ExecuteScalar() // 执行SQL并返回int记录数
{
string str_orgid = Client_Str; // 获得orgid
int Re_result = 0 ;
string myConn_str = WebConfigurationManager.ConnectionStrings[ " MySqlConnectionString " ].ConnectionString;
MySqlConnection myConn = new MySqlConnection(myConn_str);
MySqlCommand myComm = new MySqlCommand(Client_Str,myConn);
try
{
if (myComm.Connection.State.ToString() == " Closed " ) myComm.Connection.Open();
// cmd.CommandText = "select count(*) from region";
// Int32 count = (int32)cmd.ExecuteScalar();
Re_result = Convert.ToInt32(myComm.ExecuteScalar());
}
catch (Exception ex)
{
Session[ " Error " ] = ex.ToString();
Response.Redirect( " error.aspx " );
}
finally
{
myComm.Dispose();
myComm.Connection.Close();
myConn.Dispose();
myConn.Close();
}
return Re_result;
}
}