mysql数据库open函数_C#访问Mysql数据库方法，以及库函数
先說(shuō)說(shuō)在C#當(dāng)中需要準(zhǔn)備的工作吧。在這里我分為了四個(gè)步驟：
1.網(wǎng)上下載MySql.Data.dll
2.在項(xiàng)目當(dāng)中添加引用MySql.Data.dll
3.在操作類當(dāng)中添加：
using MySql.Data;
using MySql.Data.MySqlClient;
4．接下來(lái)就是具體的函數(shù)了
同時(shí)，在這里我提供一個(gè)C#操作Mysql數(shù)據(jù)庫(kù)的庫(kù)函數(shù)，供大家學(xué)習(xí)~~
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;
//打開(kāi)數(shù)據(jù)庫(kù)鏈接
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;
}
}
//關(guān)閉數(shù)據(jù)庫(kù)鏈接
public static void Close_Conn(MySqlConnection Conn)
{
if(Conn != null)
{
Conn.Close();
Conn.Dispose();
}
GC.Collect();
}
//運(yùn)行MySql語(yǔ)句
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對(duì)象
public static MySqlCommand Create_Cmd(string SQL, MySqlConnection Conn)
{
MySqlCommand Cmd = new MySqlCommand(SQL, Conn);
return Cmd;
}
// 運(yùn)行MySql語(yǔ)句返回 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;
}
// 運(yùn)行MySql語(yǔ)句返回 MySqlDataReader對(duì)象
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;
}
// 運(yùn)行MySql語(yǔ)句返回 MySqlDataAdapter對(duì)象
public static MySqlDataAdapter Get_Adapter(string SQL, string ConnStr)
{
MySqlConnection Conn = Open_Conn(ConnStr);
MySqlDataAdapter Da = new MySqlDataAdapter(SQL, Conn);
return Da;
}
// 運(yùn)行MySql語(yǔ)句,返回DataSet對(duì)象
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;
}
// 運(yùn)行MySql語(yǔ)句,返回DataSet對(duì)象
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;
}
// 運(yùn)行MySql語(yǔ)句,返回DataSet對(duì)象，將數(shù)據(jù)進(jìn)行了分頁(yè)
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語(yǔ)句執(zhí)行結(jié)果的第一行第一列
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;
}
///
// 存儲(chǔ)過(guò)程 相關(guān)操作
///
// 生成一個(gè)存儲(chǔ)過(guò)程使用的MySqlcommand.
// procName 存儲(chǔ)過(guò)程名, prams 存儲(chǔ)過(guò)程入?yún)?shù)組, 返回 MySqlCommand對(duì)象
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;
}
// 生成一個(gè)存儲(chǔ)過(guò)程使用的MySqlCommand.
// procName 存儲(chǔ)過(guò)程名, prams 存儲(chǔ)過(guò)程入?yún)?shù)組, 返回 MySqlCommand對(duì)象
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;
}
// 運(yùn)行存儲(chǔ)過(guò)程,返回 MySqlDataReader對(duì)象
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;
}
// 運(yùn)行存儲(chǔ)過(guò)程,返回執(zhí)行結(jié)果的第一行第一列
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 "";
}
}
// 運(yùn)行存儲(chǔ)過(guò)程,返回 DataSet對(duì)象
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;
}
}
總結(jié)
以上是生活随笔為你收集整理的mysql数据库open函数_C#访问Mysql数据库方法，以及库函数的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 事物日志恢复 mysql_浅谈SQL S
- 下一篇： http通道连接mysql_通过http