直接上代碼.
/// <summary>
/// 建立mysql數據庫鏈接
/// </summary>
/// <returns></returns>
public static MySqlConnection getMySqlCon()
{
String mysqlStr = "Database=數據庫名稱;Data Source=數據庫遠程ip;User Id=數據庫里面的用戶名;Password=數據庫用戶名的密碼;pooling=false;CharSet=utf8;port=3306";
// String mySqlCon = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;
MySqlConnection mysql = new MySqlConnection(mysqlStr);
return mysql;
}
/// <summary>
/// 建立執行命令語句對象
/// </summary>
/// <param name="sql"></param>
/// <param name="mysql"></param>
/// <returns></returns>
public static MySqlCommand getSqlCommand(String sql, MySqlConnection mysql)
{
MySqlCommand mySqlCommand = new MySqlCommand(sql, mysql);
// MySqlCommand mySqlCommand = new MySqlCommand(sql);
// mySqlCommand.Connection = mysql;
return mySqlCommand;
}
/// <summary>
/// 查詢並獲得結果集並遍歷
/// </summary>
/// <param name="mySqlCommand"></param>
public static void getResultset(MySqlCommand mySqlCommand)
{
MySqlDataReader reader = mySqlCommand.ExecuteReader();
try
{
while (reader.Read())
{
if (reader.HasRows)
{
Console.WriteLine("name:" + reader.GetString(0));
}
}
}
catch (Exception)
{
Console.WriteLine("查詢失敗了!");
}
finally
{
reader.Close();
}
}
/// <summary>
/// 添加數據
/// </summary>
/// <param name="mySqlCommand"></param>
public static void getInsert(MySqlCommand mySqlCommand)
{
try
{
mySqlCommand.ExecuteNonQuery();
}
catch (Exception ex)
{
String message = ex.Message;
Console.WriteLine("插入數據失敗了!" + message);
}
}
/// <summary>
/// 修改數據
/// </summary>
/// <param name="mySqlCommand"></param>
public static void getUpdate(MySqlCommand mySqlCommand)
{
try
{
mySqlCommand.ExecuteNonQuery();
}
catch (Exception ex)
{
String message = ex.Message;
Console.WriteLine("修改數據失敗了!" + message);
}
}
/// <summary>
/// 刪除數據
/// </summary>
/// <param name="mySqlCommand"></param>
public static void getDel(MySqlCommand mySqlCommand)
{
try
{
mySqlCommand.ExecuteNonQuery();
}
catch (Exception ex)
{
String message = ex.Message;
Console.WriteLine("刪除數據失敗了!" + message);
}
}
下面是操作.
MySqlConnection mysql = getMySqlCon();
//查詢sql
String sqlSearch = "select * from 你數據庫的表名";
////插入sql
//String sqlInsert = "insert into test values ('中方')";
////修改sql
//String sqlUpdate = "update test set name='李四' where id= 3";
////刪除sql
//String sqlDel = "delete from test where id = 12";
////打印SQL語句
//Console.WriteLine(sqlDel);
////四種語句對象
//MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);
//MySqlCommand mySqlCommand = getSqlCommand(sqlInsert, mysql);
//MySqlCommand mySqlCommand = getSqlCommand(sqlUpdate, mysql);
MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);
mysql.Open();
getResultset(mySqlCommand);
// getInsert(mySqlCommand);
//getUpdate(mySqlCommand);
//getDel(mySqlCommand);
//記得關閉
mysql.Close();
Console.WriteLine("完成");
Console.ReadLine();
記錄清是多久前在網上copy的.今天發到這里做個記錄.
上面的代碼需要引用 MySql.Data.dll 這個dll文件.我在我的機器上,vs2010 + net 2.0 測試我的服務器上遠程連接成功.如果你和我一樣是用的cPanel X,在cPanel X里面需要設置一個遠程MySql,使用通配符%就可以了.