using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using MySql.Data.MySqlClient; namespace MySQLHelp { public class sqlHelper { // 服务器地址;端口号;数据库;用户名;密码 public static string connectStr = ""; // 设置MySQL连接字符串 public static string setMySQLStr(string ip,string port,string database,string user,string password) { try { connectStr = "server=" + ip + ";port=" + port + ";database=" + database + ";user=" + user + ";password=" + password + ""; return "set connStr ok"; } catch(Exception e) { return e.ToString(); } } //using MySql.Data.MySqlClient; //声明conn对象创建,方便建立连接 public static MySqlConnection conn = null; //建立Mysql连接 public static string connMysql() { try { conn = new MySqlConnection(connectStr); conn.Open(); return "conn MySQL ok"; } catch (Exception e) { return e.ToString(); } } //关闭Mysql连接 public static string closedMysql() { try { conn.Close(); return "close MySQL ok"; } catch (Exception e) { return e.ToString(); } } //执行SQL语句 public static String excuteSQL(string str) { try { connMysql(); //建立MySQL连接 MySqlCommand cmd = new MySqlCommand(str, conn); //执行 MySqlDataReader reader = cmd.ExecuteReader(); //读取数组 while (reader.Read()) // true表示能读取该行数据 { return reader[0].ToString(); //访问数组 } closedMysql(); //关闭MySQL连接 return "qure ok"; } catch (Exception e) { return e.ToString(); } } } }