asp.net中通过ALinq让Mysql操作变得如此简单

程序员文章站 2024-03-07 21:54:15

1. ADO.NET 方式连接Mysql数据库经过在网上查找资料，在.net 上连接mysql 数据库有三种方式：方法一：使用CoreLab推出的MYSQL访问组件，...

1. ADO.NET 方式连接Mysql数据库
经过在网上查找资料，在.net 上连接mysql 数据库有三种方式：
方法一：
使用CoreLab推出的MYSQL访问组件，引用命名空间CoreLab.MySql
方法二：
通过ODBC访问MYSQL数据库, 前要先下载两个组件：odbc.net和MYSQL的ODBC驱动,可以使用ODBC访问Mysql数据库
方法三：
使用MYSQL推出的MySQL Connector/Net is an ADO.NET driver for MySQL，该组件为MYSQL为ADO.NET访问MYSQL数据库设计的.NET访问组件，使用MySql.Data.MySqlClient
以上三种方式的说明可以具体参照文章：
http://blog.csdn.net/lxh0959/archive/2008/08/05/2773424.aspx
此篇文章对此做了详细说明

这里要说明的是第三种方式，这种访问方式完全遵循我们Ado.net 访问SQL Server的模式，所以使用起来也更加得心应手。
ADO.NET driver for MySQL 下载地址：
官方网站： http://www.mysql.com/downloads/

2.基础数据库操作
使用ADO.net 操作数据库，固定不变的模式，五个核心对象
Connection: Connection 对象主要是开启程序和数据库之间的连结。没有利用连结对象将数据库打开，是无法从数据库中取得数据的。
Command：Command 对象主要可以用来对数据库发出一些指令，例如可以对数据库下达查询、新增、修改、删除数据等指令，以及呼叫存在数据库中的预存程序等。
DataAdapter: DataSetCommand 对象主要是在数据源以及DataSet 之间执行数据传输的工作，它可以透过Command 对象下达命令后，并将取得的数据放入DataSet 对象中。
DataSet：DataSet 这个对象可以视为一个暂存区（Cache），可以把从数据库中所查询到的数据保留起来，甚至可以将整个数据库显示出来。DataSet 的能力不只是可以储存多个Table 而已，还可以透过DataSetCommand 对象取得一些例如主键等的数据表结构，并可以记录数据表间的关联。DataSet 对象可以说是ADO.NET 中重量级的对象，这个对象架构在DataSetCommand 对象上，本身不具备和数据源沟通的能力。
DataReader: 当我们只需要循序的读取数据而不需要其它操作时，可以使用DataReader 对象。DataReader对象只是一次一笔向下循序的读取数据源中的数据，而且这些数据是只读的，并不允许作其它的操作。因为DataReader 在读取数据的时候限制了每次只读取一笔，而且只能只读，所以使用起来不但节省资源而且效率很好.

复制代码代码如下:

 
using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using MySql.Data.MySqlClient; 
namespace CimDataImport 
{ 
public class TestCharacter 
{ 
public const string mysqlConnection = "User Id=root;Host=localhost;Database=cim;password=root"; 
/// <summary> 
/// 添加数据 
/// </summary> 
/// <returns></returns> 
public int Add(UserBase entity) 
{ 
string sql = "INSERT INTO cimuser (userid,userNickName) VALUE (@userid,@userNickName)"; 
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection)) 
{ 
mycn.Open(); 
MySqlCommand command = new MySqlCommand(sql, mycn); 
command.Parameters.AddWithValue("@userid", entity.UserId); 
command.Parameters.AddWithValue("@userNickName",entity.UserNickName); 
return command.ExecuteNonQuery(); 
} 
} 
/// <summary> 
/// 修改数据 
/// </summary> 
/// <param name="entity"></param> 
/// <returns></returns> 
public int Update(UserBase entity) 
{ 
string sql = "UPDATE cimuser SET userNickName=@userNickName WHERE userid=@userid"; 
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection)) 
{ 
mycn.Open(); 
MySqlCommand command = new MySqlCommand(sql, mycn); 
command.Parameters.AddWithValue("@userid", entity.UserId); 
command.Parameters.AddWithValue("@userNickName", entity.UserNickName); 
return command.ExecuteNonQuery(); 
} 
} 
/// <summary> 
/// 删除数据 
/// </summary> 
/// <param name="primaryKey"></param> 
/// <returns></returns> 
public int Delete(int primaryKey) 
{ 
string sql = "DELETE FROM cimuser WHERE userid=@userid"; 
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection)) 
{ 
mycn.Open(); 
MySqlCommand command = new MySqlCommand(sql, mycn); 
command.Parameters.AddWithValue("@userid", primaryKey); 
return command.ExecuteNonQuery(); 
} 
} 
/// <summary> 
/// 根据主键查询 
/// </summary> 
/// <param name="primaryKey"></param> 
/// <returns></returns> 
public UserBase Get(int primaryKey) 
{ 
string sql = "SELECT userid,userNickName FROM cimuser where userid=@userid"; 
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection)) 
{ 
mycn.Open(); 
MySqlCommand command = new MySqlCommand(sql, mycn); 
command.Parameters.AddWithValue("@userid", primaryKey); 
MySqlDataReader reader = command.ExecuteReader(); 
UserBase userBase = null; 
if (reader.Read()) 
{ 
userBase = new UserBase(); 
userBase.UserId = Convert.ToInt32(reader["userid"]); 
userBase.UserNickName = reader["userNickName"] == DBNull.Value ? null : reader["userNickName"].ToString(); 
} 
return userBase; 
} 
} 
/// <summary> 
/// 查询集合 
/// </summary> 
/// <returns></returns> 
public IList<UserBase> GetList() 
{ 
string sql = "SELECT userid,userNickName FROM cimuser limit 1,10"; 
using (MySqlConnection mycn = new MySqlConnection(mysqlConnection)) 
{ 
mycn.Open(); 
MySqlCommand command = new MySqlCommand(sql, mycn); 
MySqlDataReader reader = command.ExecuteReader(); 
IList<UserBase> list = new List<UserBase>(); 
UserBase userBase = null; 
while (reader.Read()) 
{ 
userBase = new UserBase(); 
userBase.UserId = Convert.ToInt32(reader["userid"]); 
userBase.UserNickName = reader["userNickName"] == DBNull.Value ? null : reader["userNickName"].ToString(); 
list.Add(userBase); 
} 
return list; 
} 
} 
} 
} 