mysql crud操作_c#操作mysql数据库CRUD操作

【实例简介】

c#操作mysql数据库 CRUD

【实例截图】

【核心代码】

class SqlHelper {

//返回链接数据库的字符串

public static string ConnString {

get {

return "Data Source='localhost';Database='dbdemo';User Id='root';Password='wdf123';charset='utf8'";

}

}

///

/// sqlserver 执行通用的添加，修改，删除操作

///

/// insert/update/delete语句

/// 参数类型的数组

/// int 受影响的条数

public static int mssql_exec(string sql,SqlParameter[] pars) {

SqlConnection conn = new SqlConnection(ConnString);

try {

if (conn.State == ConnectionState.Closed) {

conn.Open();

}

SqlCommand cmd = new SqlCommand(sql, conn);

if (pars != null && pars.Length > 0) {

foreach (SqlParameter p in pars) {

cmd.Parameters.Add(p);

}

}

int count = cmd.ExecuteNonQuery();

return count;

}catch(Exception ex){

throw ex;

//return 0;

} finally {

conn.Close();

}

}

///

/// sqlserver 执行通用的添加，修改，删除操作

///

/// insert/update/delete语句

/// 参数类型的数组

/// int 受影响的条数

public static int mysql_exec(string sql, MySqlParameter[] pars) {

MySqlConnection conn = new MySqlConnection(ConnString);

try {

if (conn.State == ConnectionState.Closed) {

conn.Open();

}

MySqlCommand cmd = new MySqlCommand(sql, conn);

if (pars != null && pars.Length > 0) {

foreach (MySqlParameter p in pars) {

cmd.Parameters.Add(p);

}

}

int count = cmd.ExecuteNonQuery();

return count;

} catch (Exception ex) {

throw ex;

//return 0;

} finally {

conn.Close();

}

}