.NET中使用MySQL数据库基本命令操作

步骤一:下载MySql驱动包
官方下载地址是http://dev.mysql.com/downloads/connector/net

步骤二:引入组件

下载的文件是一个压缩文件,将其解压缩到本地磁盘。找到bin文件夹中的MySql.Data.dll文件,这个就是我们要引用的组件。通过Visual Studio将其引用到你的项目中
部署dll流程:
首先把dll文件放到应用程序...\bin\Debug\下;
然后在解决方案中添加引用:右键鼠标-->添加引用-->浏览-->选择dll放置路径后点击“确定”。
注意:要在应用文件头处使用using MySql.Data.MySqlClient;命令。


 ExecuteReader()返回一个类型化的DataReader对象,返回的对象可对用于遍历返回的记录

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using MySql.Data;
  6. using MySql.Data.MySqlClient;

  7. namespace MySqlConnectionTest
  8. {
  9.     class Program
  10.     {
  11.         static void Main(String[] args)
  12.         {
  13.             Console.WriteLine("--------");

  14.             string myconn = "Database='test';Data Source=localhost;User ID=root;Password=123456;CharSet=utf8;";
  15.             //需要执行的SQL语句
  16.             string mysql = "SELECT * from users";
  17.             //创建数据库连接
  18.             MySqlConnection myconnection = new MySqlConnection(myconn);

  19.             myconnection.Open();
  20.             //创建MySqlCommand对象
  21.             MySqlCommand mycommand = new MySqlCommand(mysql, myconnection);
  22.             //通过MySqlCommand的ExecuteReader()方法构造DataReader对象
  23.             MySqlDataReader myreader = mycommand.ExecuteReader();

  24.             while (myreader.Read())
  25.             {
  26.                 Console.WriteLine(myreader.GetInt32(0) + "," + myreader.GetString(1) + "," + myreader.GetString(2));
  27.             }
  28.             myreader.Close();

  29.             myconnection.Close();
  30.         }
  31.     }
  32. }
ExecuteNonQuery()一般用于UPDATE、INSERT或DELETE语句,其中唯一的返回值是受影响的记录个数。

  1. static void Main(String[] args)
  2.         {
  3.             string myconn = "Database='test';Data Source=localhost;User ID=root;Password=123456;CharSet=utf8;";
  4.             // 建立数据库连接
  5.             MySqlConnection DBConn = new MySqlConnection(myconn);
  6.             DBConn.Open();

  7.             // 执行查询语句
  8.             MySqlCommand DBComm = new MySqlCommand("UPDATE users SET user_passwd = '123456' WHERE user_name = 'aaa' ", DBConn);

  9.             int rowsReturned = DBComm.ExecuteNonQuery();

  10.             // 显示数据
  11.             Console.WriteLine("{0} rows returned.",rowsReturned);
  12.             DBConn.Close();
  13.         }

  1. static void Main(String[] args)
  2.         {
  3.             string myconn = "Database='test';Data Source=localhost;User ID=root;Password=123456;CharSet=utf8;";
  4.             // 建立数据库连接
  5.             MySqlConnection DBConn = new MySqlConnection(myconn);
  6.             DBConn.Open();

  7.             // 执行查询语句
  8.             MySqlCommand DBComm = new MySqlCommand("SELECT COUNT(*) FROM users", DBConn);

  9.             //ExecuteScalar()用于从SQL语句返回一个结果,如给定表中的记录个数,或者服务器上的当前日期、时间。
  10.             Object o = DBComm.ExecuteScalar();

  11.             Console.WriteLine(o);
  12.         }


上一篇:泛函编程(6)-数据结构-List基础


下一篇:二、数据库的基本操作