ef ,ef core 使用原生 SQL 查询

有时候在执行一个赋值一点的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