C# asp.net 连接MYSQL帮助类

以前使用过MYSQL ，但是早已经忘的一干二净。这次项目中由于要去远程连接别人的数据库，而且是MYSQL的

当时去网上搜索了一下基本上都是千篇一律。。说什么3种连接方法。。

没有看到一个具体点的MYSQLHelper

所以与大家分享一下：

我使用连接MQSQL的方法是引用MySql.Data.dll

这个DLL 可以去官方网站下载 http://www.mysql.com/

其实引用了MySql.Data.dll后我们就可以像使用ADO.NET连接SQLSERVER一样的简单明了了。

1：数据访问层添加引用MySql.Data.dll

2：config里配置连接，你也可以直接写在类里

config配置：

<connectionStrings>

<add name="MySqlCon" connectionString="Database=deal;Data Source=118.123.242.22;User Id=root;Password=****;pooling=false;CharSet=utf8;port=2011" />
</connectionStrings>

3：建立库类MYSQLHelper

代码如下：

public class MySqlHelper
{
private static string connectionString = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;

/// <summary>
/// 执行一条计算查询结果语句，返回查询结果（object）。
/// </summary>
/// <param name="sqlString">计算查询结果语句</param>
/// <returns>查询结果（object）</returns>
public static object GetSingle(string sqlString)
{
using (MySqlConnection connection = new MySqlConnection(connectionString))
{
using (MySqlCommand cmd = new MySqlCommand(sqlString, connection))
{
try
{
connection.Open();
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw new Exception(e.Message);
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
}

/// <summary>
/// 执行SQL语句，返回影响的记录数
/// </summary>
/// <param name="sqlString">SQL语句</param>
/// <returns>影响的记录数</returns>
public static int ExecuteSql(string sqlString)
{
using (MySqlConnection connection = new MySqlConnection(connectionString))
{
using (MySqlCommand cmd = new MySqlCommand(sqlString, connection))
{
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException E)
{
connection.Close();
throw new Exception(E.Message);
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
}
/// <summary>
/// 执行查询语句，返回MySqlDataReader
/// </summary>
/// <param name="sqlString">查询语句</param>
/// <returns>MySqlDataReader</returns>
public static MySqlDataReader ExecuteReader(string sqlString)
{
MySqlConnection connection = new MySqlConnection(connectionString);
MySqlCommand cmd = new MySqlCommand(sqlString, connection);
MySqlDataReader myReader = null;
try
{
connection.Open();
myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
return myReader;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw new Exception(e.Message);
}
finally
{
if (myReader == null)
{
cmd.Dispose();
connection.Close();
}
}
}
}

感觉很简单吧。

其实区别就在于把你以前SqlConnection变成MySqlConnection多了一个My而已，其他也是这样

希望对大家使用MYSQL有所帮助