mysql数据库open函数_C#访问Mysql数据库方法，以及库函数
先說說在C#當中需要準備的工作吧。在這里我分為了四個步驟：
1.網上下載MySql.Data.dll
2.在項目當中添加引用MySql.Data.dll
3.在操作類當中添加：
using MySql.Data;
using MySql.Data.MySqlClient;
4．接下來就是具體的函數了
同時，在這里我提供一個C#操作Mysql數據庫的庫函數，供大家學習~~
public class MySQL
{
//public static string ConnStr = @"server=localhost;uid=root;pwd=;database=my_soft;charset=utf8";
public static string ConnStr = MyData.Properties.Settings.Default.my_soft_mysqlConn;
//打開數據庫鏈接
public static MySqlConnection Open_Conn(string ConnStr)
{
try
{
MySqlConnection Conn = new MySqlConnection(ConnStr + "Connect Timeout=5;");
Conn.Open();
return Conn;
}
catch (Exception Ex)
{
throw Ex;
}
}
//關閉數據庫鏈接
public static void Close_Conn(MySqlConnection Conn)
{
if(Conn != null)
{
Conn.Close();
Conn.Dispose();
}
GC.Collect();
}
//運行MySql語句
public static int Run_SQL(string SQL, string ConnStr)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlCommand Cmd = Create_Cmd(SQL, Conn);
try
{
int result_count = Cmd.ExecuteNonQuery();
Close_Conn(Conn);
return result_count;
}
catch
{
Close_Conn(Conn);
return 0;
}
}
// 生成Command對象
public static MySqlCommand Create_Cmd(string SQL, MySqlConnection Conn)
{
MySqlCommand Cmd = new MySqlCommand(SQL, Conn);
return Cmd;
}
// 運行MySql語句返回 DataTable
public static DataTable Get_DataTable(string SQL, string ConnStr, string Table_name)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlDataAdapter Da = new MySqlDataAdapter(SQL, Conn);
DataTable dt = new DataTable(Table_name);
Da.Fill(dt);
Close_Conn(Conn);
return dt;
}
// 運行MySql語句返回 MySqlDataReader對象
public static MySqlDataReader Get_Reader(string SQL, string ConnStr)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlCommand Cmd = Create_Cmd(SQL, Conn);
MySqlDataReader Dr;
try
{
Dr = Cmd.ExecuteReader(CommandBehavior.Default);
}
catch
{
throw new Exception(SQL);
}
Close_Conn(Conn);
return Dr;
}
// 運行MySql語句返回 MySqlDataAdapter對象
public static MySqlDataAdapter Get_Adapter(string SQL, string ConnStr)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlDataAdapter Da = new MySqlDataAdapter(SQL, Conn);
return Da;
}
// 運行MySql語句,返回DataSet對象
public static DataSet Get_DataSet(string SQL, string ConnStr, DataSet Ds)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlDataAdapter Da = new MySqlDataAdapter(SQL, Conn);
try
{
Da.Fill(Ds);
}
catch(Exception Err)
{
throw Err;
}
Close_Conn(Conn);
return Ds;
}
// 運行MySql語句,返回DataSet對象
public static DataSet Get_DataSet(string SQL, string ConnStr, DataSet Ds, string tablename)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlDataAdapter Da = new MySqlDataAdapter(SQL, Conn);
try
{
Da.Fill(Ds,tablename);
}
catch(Exception Ex)
{
throw Ex;
}
Close_Conn(Conn);
return Ds;
}
// 運行MySql語句,返回DataSet對象，將數據進行了分頁
public static DataSet Get_DataSet(string SQL, string ConnStr, DataSet Ds, int StartIndex, int PageSize, string tablename)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlDataAdapter Da = new MySqlDataAdapter(SQL, Conn);
try
{
Da.Fill(Ds, StartIndex, PageSize, tablename);
}
catch(Exception Ex)
{
throw Ex;
}
Close_Conn(Conn);
return Ds;
}
// 返回MySql語句執行結果的第一行第一列
public static string Get_Row1_Col1_Value(string SQL, string ConnStr)
{
MySqlConnection Conn = Open_Conn(ConnStr);
string result;
MySqlDataReader Dr ;
try
{
Dr = Create_Cmd(SQL,Conn).ExecuteReader();
if (Dr.Read())
{
result = Dr[0].ToString();
Dr.Close();
}
else
{
result = "";
Dr.Close();
}
}
catch
{
throw new Exception(SQL);
}
Close_Conn(Conn);
return result;
}
///
// 存儲過程 相關操作
///
// 生成一個存儲過程使用的MySqlcommand.
// procName 存儲過程名, prams 存儲過程入參數組, 返回 MySqlCommand對象
public static MySqlCommand Proc_Create_Cmd(string procName, MySqlParameter[] prams, string ConnStr)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlCommand Cmd = new MySqlCommand(procName, Conn);
Cmd.CommandType = CommandType.StoredProcedure;
if (prams != null)
{
foreach (MySqlParameter parameter in prams)
{
if(parameter != null)
{
Cmd.Parameters.Add(parameter);
}
}
}
return Cmd;
}
// 生成一個存儲過程使用的MySqlCommand.
// procName 存儲過程名, prams 存儲過程入參數組, 返回 MySqlCommand對象
private static MySqlCommand Proc_Create_Cmd(string procName, MySqlParameter[] prams, string ConnStr, MySqlDataReader Dr)
{
MySqlCommand Cmd = Proc_Create_Cmd(procName, prams, ConnStr);
if (prams != null)
{
foreach (MySqlParameter parameter in prams)
Cmd.Parameters.Add(parameter);
}
Cmd.Parameters.Add(
new MySqlParameter("ReturnValue", MySqlDbType.Int32, 4,
ParameterDirection.ReturnValue, false, 0, 0,
string.Empty, DataRowVersion.Default, null));
return Cmd;
}
// 運行存儲過程,返回 MySqlDataReader對象
public static void Proc_Get_Reader(string procName, MySqlParameter[] prams, string ConnStr, MySqlDataReader Dr)
{
MySqlCommand Cmd = Proc_Create_Cmd(procName, prams, ConnStr, Dr);
Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
return;
}
// 運行存儲過程,返回執行結果的第一行第一列
public static string Proc_Get_Value(string procName, MySqlParameter[] prams, string ConnStr)
{
MySqlDataReader Dr;
MySqlCommand Cmd = Proc_Create_Cmd(procName, prams, ConnStr);
Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
if(Dr.Read())
{
return Dr.GetValue(0).ToString();
}
else
{
return "";
}
}
// 運行存儲過程,返回 DataSet對象
public static DataSet Proc_Get_DataSet(string procName, MySqlParameter[] prams, string ConnStr, DataSet Ds)
{
MySqlCommand Cmd = Proc_Create_Cmd(procName, prams, ConnStr);
MySqlDataAdapter Da = new MySqlDataAdapter(Cmd);
try
{
Da.Fill(Ds);
}
catch(Exception Ex)
{
throw Ex;
}
return Ds;
}
}
總結
以上是生活随笔為你收集整理的mysql数据库open函数_C#访问Mysql数据库方法，以及库函数的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 事物日志恢复 mysql_浅谈SQL S
- 下一篇： http通道连接mysql_通过http