故如虹,知恩;故如月,知明
排名
6
文章
6
粉丝
16
评论
8
{{item.articleTitle}}
{{item.blogName}} : {{item.content}}
ICP备案 :渝ICP备18016597号-1
网站信息:2018-2024TNBLOG.NET
技术交流:群号656732739
联系我们:contact@tnblog.net
欢迎加群交流技术

ef ,ef core 使用原生 SQL 查询

5890人阅读 2020/3/25 23:47 总访问:3841758 评论:0 收藏:0 手机
分类: EF

有时候在执行一个赋值一点的sql要动态生成用lamdba来写很不方便,新版本用动态生成表达式树的方式也不怎么行了...

需要时间去慢慢研究,我们也可以尝试选择使用原生的sql方法。可以使用FromSqlRaw 或FromSqlInterpolated

一个简单的动态拼接or条件的例子:

//动态构建sql语句        
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.Append("select * from Article where userid=@userid and IsXX!=1 and (");
List<SqlParameter> sqlParameters = new List<SqlParameter>();
sqlParameters.Add(new SqlParameter("userid", userid));

for (int i = 0; i < _keywords.Count; i++)
{
    stringBuilder.Append(" Title like @key" + i);
    if (i != _keywords.Count - 1)
    {
        stringBuilder.Append(" or ");//不是最后一个说明还有条件需要链接一个or
    }
    sqlParameters.Add(new SqlParameter("key" + i, "%" + _keywords[i] + "%"));
}
stringBuilder.Append(" ) ");

var queryable = context.Article.FromSqlRaw(stringBuilder.ToString(), sqlParameters.ToArray()).ToList();


ef core执行原生sql的查询你可能还需要加上的扩展方法:
如下:

public static class EntityFrameworkCoreExtensions
{
    private static DbCommand CreateCommand(DatabaseFacade facade, string sql, out DbConnection connection, params object[] parameters)
    {
        var conn = facade.GetDbConnection();
        connection = conn;
        conn.Open();
        var cmd = conn.CreateCommand();
        if (facade.IsSqlServer())
        {
            cmd.CommandText = sql;
            cmd.Parameters.AddRange(parameters);
        }
        return cmd;
    }

    public static DataTable SqlQuery(this DatabaseFacade facade, string sql, params object[] parameters)
    {
        var command = CreateCommand(facade, sql, out DbConnection conn, parameters);
        var reader = command.ExecuteReader();
        var dt = new DataTable();
        dt.Load(reader);
        reader.Close();
        conn.Close();
        return dt;
    }

    public static List<T> SqlQuery<T>(this DatabaseFacade facade, string sql, params object[] parameters) where T : class, new()
    {
        var dt = SqlQuery(facade, sql, parameters);
        return dt.ToList<T>();
    }

    public static List<T> ToList<T>(this DataTable dt) where T : class, new()
    {
        var propertyInfos = typeof(T).GetProperties();
        var list = new List<T>();
        foreach (DataRow row in dt.Rows)
        {
            var t = new T();
            foreach (PropertyInfo p in propertyInfos)
            {
                if (dt.Columns.IndexOf(p.Name) != -1 && row[p.Name] != DBNull.Value)
                    p.SetValue(t, row[p.Name], null);
            }
            list.Add(t);
        }
        return list;
    }
}




ef core执行原生sql的增加,删除修改的方法:
方法1:

int count =Database.ExecuteSqlRaw(sql,params);

方法2:

context.Database.ExecuteSqlInterpolated()



未完待续,先简单记录一下


linq方式的动态条件:https://www.tnblog.net/aojiancc2/article/details/270


欢迎加群讨论技术,群:677373950(满了,可以加,但通过不了),2群:656732739

评价