连接mysql数据库2013_使用VS2013 + EF6 + .NET4.5 连接Mysql数据库

1、安装插件

在使用Visual Studio 2013添加ADO.NET实体数据模型新建连接时，默认是没有Mysql选项的。此时我们需要安装两个东西：

1、mysql-for-visualstudio：Mysql的Visual Studio插件，推荐1.2.3版本

2、mysql-connector-net：.net连接Mysql的程序，推荐6.8.3,版本。如果安装高版本可能导致一系列问题。详见：http://blog.csdn.net/niewq/article/details/41877301。

2、新建ADO.NET实体数据模型

2、1、按图操作，添加实体数据模型：

2.2、一切进展貌似都很顺利。接下来你可能会看到Visual Studio给出了如下的提示：

2.3、解决方法：在NuGet的控制台输入以下命令：

Install-Package EntityFramework -Version 6.0.0

Install-Package EntityFramework.zh-Hans -Version 6.0.0

Install-Package MySql.Data.Entity.EF6

每个命令输入之后按回车执行，你会发现前两个都很顺利，但是第三个却报错了：

此时我们不通过NuGet添加这个引用，具体步骤为将MySQL Connector Net 6.8.3\Assemblies\v4.5(视你的项目使用的.net版本而定，我的是.net 4.5)下的所有dll文件引用进来。我的机器上安装目录如下：

全部引用

然后在应用程序配置文件中添加：

然后，一定要重新生成项目！！！

2.4、继续下面的步骤，成功。

3、Mysql数据库改动

接下来，就是从数据库选择表以生成EDMX文件，但是在此过程中，你可能会遇到下列问题：

VS给出了一堆的提示，但是重点就是红框内的：表“TableDetails”中列“IsPrimaryKey”的值为 DBNull。这个问题的解决方案在这。我们按照文中所说，设置数据库testbak(我用的数据库)：

1、重启数据库服务器。

2、use testbak;

3、set global optimizer_switch='derived_merge=OFF';

再去尝试一次，成功！！！

解决方案窗口多了很多文件：

每个实体数据模型生成一个context类，数据库每个表生成一个entity类。在Model1.edmx中包含的两个重要的文件Model1.Context.tt和Model1.tt。第一个是用于生成Context类的T4模板，第二是用于生成表映射实体类(POCO类，POCO：Plain Old CLR Object)的T4模板。

Model1.Context.cs是从System.Data.Entity.DbContext类继承。EF4.1中则是从ObjectContext类继承。DbContext类与ObjectContext类似，它对ObjcetContext类进行包装更利于开发的三种模式：CodeFirst、Model First、Database First。

4、DbContext

DbContext是EntityFramework很重要的部分，连接域模型与数据库的桥梁，是与数据库通信的主要类。

DbContext主要负责以下活动：

EntitySet:：DbContext包含了所有映射到表的entities

Querying：将Linq-To-Entities转译为Sql并发送到数据库

Change Tracking：从数据库获取entities后保留并跟踪实体数据变化

Persisting Data：根据entity状态执行Insert、update、delete命令

Caching：DbContext的默认第一级缓存，在上下文中的生命周期中存储entity

Manage Relationship：DbContext在DbFirst模式中使用CSDL、MSL、SSDL管理对象关系，Code first中使用fluent api 管理关系

Object Materialization：DbContext将物理表转成entity实例对象

//DbContext实例化：

using (var ctx =newSchoolDBEntities())

{//Can perform CRUD operation using ctx here..

}//将DbContext转为ObjectContext

using (var ctx =newSchoolDBEntities())

{var objectContext = (ctx asSystem.Data.Entity.Infrastructure.IObjectContextAdapter).ObjectContext;//use objectContext here..

}

5、增删改查操作

5.1 IDAL

usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Linq.Expressions;usingSystem.Text;usingSystem.Threading.Tasks;namespaceADO.NETEFDemo

{public interface IDAL where T : class,new()

{///

///增///

///

intAdd(T model);///

///删///

///

int Delete(Expression>whereLambda);///

///改///

///

int Update(Expression> whereLambda, string[] propertyNames, object[] perpertyValues);///

///查///

///

List GetModelList(Expression>whereLambda);

}

5.2 DAL

usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Linq.Expressions;usingSystem.Reflection;usingSystem.Text;usingSystem.Threading.Tasks;namespaceADO.NETEFDemo

{public class DAL : IDAL where T : class,new()

{///

///增///

///

public intAdd(T model)

{using (testbakEntities db = newtestbakEntities())

{

db.Set().Add(model);returndb.SaveChanges();

}

}///

///删///

///

public int Delete(Expression>whereLambda)

{using (testbakEntities db = newtestbakEntities())

{var dbQuery = db.Set();//先查询对应表的集合

var list =dbQuery.Where(whereLambda).ToList();//遍历集合里要删除的元素

foreach (var item inlist)

{//标记为删除状态

dbQuery.Remove(item);

}returndb.SaveChanges();

}

}///

///改///

///

public int Update(Expression> whereLambda, string[] propertyNames, object[] perpertyValues)

{using (testbakEntities db = newtestbakEntities())

{//1、查询要修改的对象集合

var list = db.Set().Where(whereLambda).ToList();//2、获取要修改的对象的类型

Type t = typeof(T);//3、循环要修改的实体对象，并根据要修改的属性名修改对象对应的属性值

foreach (var item inlist)

{//循环要修改的属性名称，并反射取出 t 中的属性对象

for (int index = 0; index < propertyNames.Length; index++)

{//获取要修改的属性名

string pName =propertyNames[index];//获取属性对象

PropertyInfo pi =t.GetProperty(pName);//调用属性对象的 SetValue方法为当前循环的 item对象对应的属性赋值

pi.SetValue(item, perpertyValues[index], null);

}

}returndb.SaveChanges();

}

}///

///查///

///

public List GetModelList(Expression>whereLambda)

{using (testbakEntities db = newtestbakEntities())

{return db.Set().Where(whereLambda).ToList();

}

5.3 BLL

usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Linq.Expressions;usingSystem.Text;usingSystem.Threading.Tasks;namespaceADO.NETEFDemo

{public static class BLL where T : class,new()

{private static IDAL dal = new DAL();///

///新增///

///

public static intAdd(T model)

{returndal.Add(model);

}///

///删除///

///

public static int Delete(Expression>whereLambda)

{returndal.Delete(whereLambda);

}///

///修改///

///

public static int Update(Expression> whereLambda, string[] propertyNames, object[] perpertyValues)

{returndal.Update(whereLambda, propertyNames, perpertyValues);

}///

///查询///

///

public static List GetModelList(Expression>whereLambda)

{returndal.GetModelList(whereLambda);

}

5.4 调用

usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Text;namespaceADO.NETEFDemo

{classProgram

{static void Main(string[] args)

{

GetArticleList();

AddArticle();

GetArticleList();

UpdateArticle();

GetArticleList();

DeleteArticel();

GetArticleList();

Console.ReadKey();

}///

///更新///

private static voidUpdateArticle()

{int result = BLL.Update(e=> e.title.Contains("EF"), new[] { "title", "update_time"},new object[] { "我是使用EF修改过标题的文章", DateTime.Now });if (result >= 0)

{

Console.WriteLine("更新成功");

}else{

Console.WriteLine("更新失败");

}

Console.WriteLine();

}///

///删除///

private static voidDeleteArticel()

{int result = BLL.Delete(e => e.title.Contains("EF"));if (result >= 0)

{

Console.WriteLine("删除成功");