搜索
设为首页收藏本站
 找回密码
 立即注册

QQ登录

只需一步,快速开始

本文来自

Visual Studio

Visual Studio

订阅|关注

请添加对本版块的简短描述

精选帖子

C#连接mysql数据库完整实例

[复制链接]

51

主题

74

帖子

79

积分

管理员

Rank: 9Rank: 9Rank: 9

积分
79
790 mengydz 发表于 2017-7-7 00:11:00
  1. using System;
  2. using System.Configuration;
  3. using MySql.Data.MySqlClient;
  4. /// <summary>
  5. /// TestDatebase 的摘要说明
  6. /// </summary>
  7. public class TestDatebase
  8. {
  9.   public TestDatebase()
  10.   {
  11.     //
  12.     // TODO: 在此处添加构造函数逻辑
  13.     //
  14.   }
  15.   public static void Main(String[] args)
  16.   {
  17.     MySqlConnection mysql = getMySqlCon();
  18.     //查询sql
  19.     String sqlSearch = "select * from student";
  20.     //插入sql
  21.     String sqlInsert = "insert into student values (12,'张三',25,'大专')";
  22.     //修改sql
  23.     String sqlUpdate = "update student set name='李四' where id= 3";
  24.     //删除sql
  25.     String sqlDel = "delete from student where id = 12";
  26.     //打印SQL语句
  27.     Console.WriteLine(sqlDel);
  28.     //四种语句对象
  29.     //MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);
  30.     //MySqlCommand mySqlCommand = getSqlCommand(sqlInsert, mysql);
  31.     //MySqlCommand mySqlCommand = getSqlCommand(sqlUpdate, mysql);
  32.     MySqlCommand mySqlCommand = getSqlCommand(sqlDel, mysql);
  33.     mysql.Open();
  34.     //getResultset(mySqlCommand);
  35.     //getInsert(mySqlCommand);
  36.     //getUpdate(mySqlCommand);
  37.     getDel(mySqlCommand);
  38.     //记得关闭
  39.     mysql.Close();
  40.     String readLine = Console.ReadLine();
  41.   }
  42.   /// <summary>
  43.   /// 建立mysql数据库链接
  44.   /// </summary>
  45.   /// <returns></returns>
  46.   public static MySqlConnection getMySqlCon()
  47.   {
  48.     String mysqlStr = "Database=test;Data Source=127.0.0.1;User Id=root\"\"assword=root;pooling=false;CharSet=utf8;port=3306";
  49.     // String mySqlCon = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;
  50.     MySqlConnection mysql = new MySqlConnection(mysqlStr);
  51.     return mysql;
  52.   }
  53.   /// <summary>
  54.   /// 建立执行命令语句对象
  55.   /// </summary>
  56.   /// <param name="sql"></param>
  57.   /// <param name="mysql"></param>
  58.   /// <returns></returns>
  59.   public static MySqlCommand getSqlCommand(String sql,MySqlConnection mysql)
  60.   {
  61.     MySqlCommand mySqlCommand = new MySqlCommand(sql, mysql);
  62.     // MySqlCommand mySqlCommand = new MySqlCommand(sql);
  63.     // mySqlCommand.Connection = mysql;
  64.     return mySqlCommand;
  65.   }
  66.   /// <summary>
  67.   /// 查询并获得结果集并遍历
  68.   /// </summary>
  69.   /// <param name="mySqlCommand"></param>
  70.   public static void getResultset(MySqlCommand mySqlCommand)
  71.   {
  72.     MySqlDataReader reader = mySqlCommand.ExecuteReader();
  73.     try
  74.     {
  75.       while (reader.Read())
  76.       {
  77.         if (reader.HasRows)
  78.         {
  79.           Console.WriteLine("编号:" + reader.GetInt32(0) + "|姓名:" + reader.GetString(1) + "|年龄:" + reader.GetInt32(2) + "|学历:" + reader.GetString(3));
  80.         }
  81.       }
  82.     }
  83.     catch (Exception)
  84.     {
  85.       Console.WriteLine("查询失败了!");
  86.     }
  87.     finally
  88.     {
  89.       reader.Close();
  90.     }
  91.   }
  92.   /// <summary>
  93.   /// 添加数据
  94.   /// </summary>
  95.   /// <param name="mySqlCommand"></param>
  96.   public static void getInsert(MySqlCommand mySqlCommand)
  97.   {
  98.     try
  99.     {
  100.       mySqlCommand.ExecuteNonQuery();
  101.     }
  102.     catch (Exception ex)
  103.     {
  104.       String message = ex.Message;
  105.       Console.WriteLine("插入数据失败了!" + message);
  106.     }
  107.    
  108.   }
  109.   /// <summary>
  110.   /// 修改数据
  111.   /// </summary>
  112.   /// <param name="mySqlCommand"></param>
  113.   public static void getUpdate(MySqlCommand mySqlCommand)
  114.   {
  115.     try
  116.     {
  117.       mySqlCommand.ExecuteNonQuery();
  118.     }
  119.     catch (Exception ex)
  120.     {
  121.       String message = ex.Message;
  122.       Console.WriteLine("修改数据失败了!" + message);
  123.     }
  124.   }
  125.   /// <summary>
  126.   /// 删除数据
  127.   /// </summary>
  128.   /// <param name="mySqlCommand"></param>
  129.   public static void getDel(MySqlCommand mySqlCommand)
  130.   {
  131.     try
  132.     {
  133.       mySqlCommand.ExecuteNonQuery();
  134.     }
  135.     catch (Exception ex)
  136.     {
  137.       String message = ex.Message;
  138.       Console.WriteLine("删除数据失败了!" + message);
  139.     }
  140.   }
  141. }

回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

快速回复 返回顶部 返回列表