源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

C#操作mysql数据库的代码实例

  • 时间:2021-09-03 07:30 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:C#操作mysql数据库的代码实例
直接看代码
[u]复制代码[/u] 代码如下:
using System; using System.Configuration; using MySql.Data.MySqlClient; /// <summary> /// TestDatebase 的摘要说明 /// </summary> public class TestDatebase {     public TestDatebase()     {         //         // TODO: 在此处添加构造函数逻辑         //     }     public static void Main(String[] args)     {         MySqlConnection mysql = getMySqlCon();         //查询sql         String sqlSearch = "select * from student";         //插入sql         String sqlInsert = "insert into student values (12,'张三',25,'大专')";         //修改sql         String sqlUpdate = "update student set name='李四' where id= 3";         //删除sql         String sqlDel = "delete from student 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(sqlDel, mysql);         mysql.Open();         //getResultset(mySqlCommand);         //getInsert(mySqlCommand);         //getUpdate(mySqlCommand);         getDel(mySqlCommand);         //记得关闭         mysql.Close();        String readLine = Console.ReadLine();     }     /// <summary>     /// 建立mysql数据库链接     /// </summary>     /// <returns></returns>     public static MySqlConnection getMySqlCon()     {         String mysqlStr = "Database=test;Data Source=127.0.0.1;User Id=root;Password=root;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("编号:" + reader.GetInt32(0) + "|姓名:" + reader.GetString(1) + "|年龄:" + reader.GetInt32(2) + "|学历:" + reader.GetString(3));                 }             }         }         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);         }     } }
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部