zoukankan      html  css  js  c++  java
  • Entity Framework执行Sql语句返回DataTable

    Entity Framework中对外开放了数据库连接字符串,使用的时候可以直接得到这个连接字符串,然后进行相关的操作。如果在使用的过程中,发现Entity Framework中有一些满足不了的需求的话,那么就可以用这个连接字符串,自己写ADO的代码,去数据库进行相关的操作。特别是对于一些复杂的查询,这时候,一般是想直接执行一个Sql语句,返回一个结果集。下面是一个方法,直接返回DataTable。


    /// <summary>
    /// EF SQL 语句返回 dataTable
    /// </summary>
    /// <param name="db"></param>
    /// <param name="sql"></param>
    /// <param name="parameters"></param>
    /// <returns></returns>
    public static DataTable SqlQueryForDataTatable(this Database db,
    string sql,
    SqlParameter[] parameters)
    {
    SqlConnection conn = new System.Data.SqlClient.SqlConnection();
    conn.ConnectionString = db.Connection.ConnectionString;
    if (conn.State != ConnectionState.Open)
    {
    conn.Open();
    }
    SqlCommand cmd = new SqlCommand();
    cmd.Connection = conn;
    cmd.CommandText = sql;
    if (parameters.Length > 0)
    {
    foreach (var item in parameters)
    {
    cmd.Parameters.Add(item);
    }
    }
    SqlDataAdapter adapter = new SqlDataAdapter(cmd);
    DataTable table = new DataTable();
    adapter.Fill(table);
    return table;
    }

    然后调用的时候,直接传入Context的Database进去,就可以了。

    方法二、写成类的扩展方法


    public static class DbExtend
    {
    public static DataTable Select_Table_Info(this DbEntities model, string sql, SqlParameter[] parameters)
    {
    SqlConnection conn = new System.Data.SqlClient.SqlConnection();
    conn.ConnectionString = model.Database.Connection.ConnectionString;
    if (conn.State != ConnectionState.Open)
    {
    conn.Open();
    }
    SqlCommand cmd = new SqlCommand();
    cmd.Connection = conn;
    cmd.CommandText = sql;
    if(parameters !=null && parameters.Length >0)
    foreach (var item in parameters)
    {
    cmd.Parameters.Add(item);
    }
    SqlDataAdapter adapter = new SqlDataAdapter(cmd);
    DataTable table = new DataTable();
    adapter.Fill(table);
    return table;
    }
    }
    ————————————————
    版权声明:本文为CSDN博主「chengmodelong」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
    原文链接:https://blog.csdn.net/chengmodelong/article/details/44497587

  • 相关阅读:
    Eclipse创建Python工程
    MySQL python安装
    pip安装-python2.7.15
    接口测试-HTTP重点知识及 测试工具
    接口测试-基础
    关闭win10的自动更新功能
    高版本MySQL(5.7,5.8)的JDBC连接新问题
    错误:java.sql.SQLException: Access denied for user ''@'localhost' (using password: NO)
    Idea SpringBoot工程提示 "Error running 'xxxx'": Command line is too long... 问题解决
    错误:23:36:21.161 [main] ERROR org.springframework.boot.SpringApplication
  • 原文地址:https://www.cnblogs.com/cxxtreasure/p/13040453.html
Copyright © 2011-2022 走看看