.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架


         当前对象操作数据库写法和EF Core极度类似,因为现在大部分程序员都懒得去写SQL,再一个就是项目作大了或其它原因要改数据库,每次改数据库,那么写的SQL语句大部分要作调整,相当麻烦,并且写SQL时字段极容易写错,所以就出现了好多ORM框架,极大的提高了程序员的开发效率。

        接下来我们讲一下 XiaoFeng.Data.IQueryableX的用法。

        我们在上一节 数据库操作 中有讲过 ConnectionConfig 数据库连接配置对象,不明白的同学可以这节看。本节继续用当前配置对象。

        建立数据库连接配置对象,FayElf.Web可为配置名称,也可以为连接串server=.;data=testdata;uid=da;pwd=123; 后边参数为数据库驱动。

var ConnConfig = new ConnectionConfig("FayElf.Web", DbProviderType.SqlServer);

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

        使用 IQueryableX 可以有两种使用方式,下边模型默认就是数据库中的字段名称,也就是它们两个名称要一一对应。如果不一样,则可以用 XiaoFeng.Column 属性去配置数据库中表字段名称,下边分别举例说明。

        通过 DataHelperX 创建一个 IQueryableX 对象 然后进行 IQueryableX 运算 去查数据库,IQueryableX和EF Core中的 IQueryable 非常类似,但运行效率比 IQueryable 快很多,并支持多数据库切换。

1.继承了 XiaoFeng.Model.Entity 实体模型的,我们暂且叫A方案,如下边模型

/// 
/// 分类模型
/// 
[Table("Category","分类", "CategoryId",ModelType.Model,"FayElf.Web",0)]
public class Category : Entity
{
    #region 构造器
    /// 
    /// 无参构造器
    /// 
    public Category()
    {

    }
    #endregion

    #region 属性
    /// 
    /// 分类名称
    /// 
    [Column(Name="Names")]
    public string Name { get; set; }
    /// 
    /// 分类说明
    /// 
    public string Description { get; set; }
    /// 
    /// 分类ID
    /// 
    public int CategoryId { get; set; }
    /// 
    /// 父节点ID
    /// 
    public int ParentId { get; set; }
    /// 
    /// 添加日期
    /// 
    public DateTime AddDate { get; set; }
    #endregion

    #region 方法

    #endregion
}

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

2.没有继续XiaoFeng.Model.Entity实体模型的,我们暂且叫B方案,如下模型

/// 
/// 用户模型
/// 
public class UserModel
{
    #region 构造器
    /// 
    /// 无参构造器
    /// 
    public UserModel()
    {

    }
    #endregion

    #region 属性
    /// 
    /// Id
    /// 
    public long Id { get; set; }
    /// 
    /// 帐号
    /// 
    public string Account { get; set; }
    /// 
    /// 密码
    /// 
    public string Password { get; set; }
    /// 
    /// 性别
    /// 
    public int Sex { get; set; }
    /// 
    /// 出生日期
    /// 
    public DateTime BirthDay { get; set; }
    /// 
    /// 添加日期
    /// 
    public DateTime AddDate { get; set; }
    #endregion

    #region 方法

    #endregion
}

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

首先我们先举实例讲解一下 A方案 的使用方法

//首选实例化一个 Category 实例
var category = Category.Create;
//查询
var category1 = category.Find(a => a.CategoryId == 2);
var category2 = category.Where(a => a.CategoryId == 2).ToEntity();
//上边两种方式是一样的 都是提取 CategoryId 等于 2 的一条数据
//列表
var category3 = category.Where(a => a.CategoryId == 3).ToList();
var category4 = category.ToList(a => a.CategoryId == 3);
//上边两种方式是一样的 都是提取 CategoryId 等于 3 的列表数据
//删除
//当前语句是删除 CateogryId 等于 4 的这条记录
var delete5 = category.Where(a => a.CategoryId == 4).Delete();
//当前语句是删除查从库中查出来的一条数据给删除掉
var delete6 = category1.Delete();

//插入
new Category
{
    Name="a", ParentId=0
}.Insert();
//更新
//当前语句是更新字段 为 Name ParentId 的字段值 条件是 CategoryId 等于 5 的记录
var update5 = category.Where(a => a.CategoryId == 5).Update(a => a.Name == "aaa" && a.ParentId == 10);
//当前语句是更新 字段 Name ParentId的值 数据是上边查询出来的一条记录
category1.Name = "bbbb";
category1.ParentId = 3;
var update6 = category.Update();

//联表 下边用法就是 通过 左关联 两张表 on 条件是 第一张表的 ParentId 与第二张表的 CategoryId 相同 然后字段显示为 Name,CategoryId,ParentName 的列表
var join1 = category.QueryableX.Join((a, b) => new object[] { JoinType.Left, a.ParentId == b.CategoryId }).Select((a, b) => new
{
    a.Name,
    a.CategoryId,
    ParentName = b.Name
}).ToList();
//更多表关联 有两种方法 第一种是 两张表关联的结果和第三张表关联,再关联的结果与第四经表关联 依次类推
//第二种方法就是 假设一共有5张表关联那么直接实例化 DataHelperX时直接关联5张表,建议用第一种方法。

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

接着我们讲 B 方案用法

//创建一个带数据库的 IQueryableX 对象,下边所有的操作都是基于当前对象来操作。
var data = new DataHelperX(Conn);
//查询  下边三种写法 运行后 结果是一样的
var userModel1 = data.Where(a => a.Account == "jacky" && a.Password == "admin123").ToEntity();
var userModel2 = data.Where(a => a.Account == "jacky").Where(a => a.Password == "admin123").ToEntity();
var userModel3 = data.First(a => a.Account == "jacky" && a.Password == "admin123");
//列表
var userList1 = data.Where(a => a.Sex == 1 || a.Account == "jacky").ToList();
//关联查询
var userList2 = data.Where(a => a.Sex == 1).Join((a, b) => new object[] { a.Account == b.Password }).Select((a, b) => new
{
    a.Account,
    a.Password,
    ParentName = b.Account
}).ToList();
//插入
var userModel4 = new UserModel { Account = "jacky", Password = "admin" };
var insert1 = data.Insert(userModel4);
//如果想返回自增长ID则后边输入接收参数即可如下
var insert2 = data.Insert(userModel4, out var ID);

//批量插入
var insert3 = data.Inserts(new List { userModel4,userModel4 });

//更新
var update1 = data.Where(a => a.Id == 1).Update(a => a.Password == "adminadmin");

//删除
var delete1 = data.Where(a => a.Id == 1).Delete();

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

下边我们说一下 内部函数用法,函数扩展了基本上SQL中用到的函数,以及C#语言中的字符串处理函数的大部分,内部函数扩展方法如下:

/// 
/// 扩展SQL语法
/// Version : 2.0.0
/// Author : jacky
/// Email : jacky@zhuovi.com
/// QQ : 7092734
/// Site : www.zhuovi.com
/// Create Time : 2017/12/20 9:40:00
/// Update Time : 2018/01/19 13:40:00
/// 
public static partial class PrototypeHelper
{
    #region 扩展SQL 语法

    #region 扩展SQL 字段加值+
    /// 
    /// 字段加值
    /// 
    /// 类型
    /// 对象
    /// 值
    /// 
    public static T AddSQL(this T obj, T value) { return obj; }
    #endregion

    #region 扩展SQL 字段减值-
    /// 
    /// 字段减值
    /// 
    /// 类型
    /// 对象
    /// 值
    /// 
    public static T SubtractSQL(this T obj, T value) { return obj; }
    #endregion

    #region 扩展SQL 字段乘值*
    /// 
    /// 字段乘值
    /// 
    /// 类型
    /// 对象
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")]
    public static T MultiplySQL(this T obj, T value) { return obj; }
    #endregion

    #region 扩展SQL 字段除值/
    /// 
    /// 字段除值
    /// 
    /// 类型
    /// 对象
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static T DivideSQL(this T obj, T value) { return obj; }
    #endregion

    #region 扩展SQL Between
    /// 
    /// 扩展SQL Between
    /// 
    /// 对象
    /// 开始值
    /// 结束值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Boolean BetweenSQL(this object obj, object startValue, object endValue) { return true; }
    #endregion

    #region 扩展SQL ISNULL
    /// 
    /// 扩展SQL ISNULL
    /// 
    /// 类型
    /// 对象
    /// 默认值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static T IsNullSQL(this T obj, T defaultValue) { return defaultValue; }
    #endregion

    #region 扩展SQL in 语法
    /// 
    /// 扩展SQL in语法
    /// 
    /// 类型
    /// 对象
    /// 数组织
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool InSQL(this T obj, IEnumerable array) { return true; }
    /// 
    /// 扩展SQL in语法
    /// 
    /// 类型
    /// 对象
    /// 数组织
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool InSQL(this T obj, T[] array) { return true; }
    /// 
    /// 扩展SQL in语法
    /// 
    /// 类型
    /// 类型
    /// 对象
    /// IQueryableX对象
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Boolean InSQL(this T obj, IQueryableX queryableX) { return true; }
    /// 
    /// 扩展SQL in语法
    /// 
    /// 类型
    /// 对象
    /// 数组
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool InSQL(this T obj, object[] array) { return true; }
    /// 
    /// 扩展SQL not in语法
    /// 
    /// 类型
    /// 对象
    /// 数组
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool NotInSQL(this T obj, IEnumerable array) { return true; }
    /// 
    /// 扩展SQL not in语法
    /// 
    /// 类型
    /// 对象
    /// 数组
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool NotInSQL(this T obj, T[] array) { return true; }
    /// 
    /// 扩展SQL not in语法
    /// 
    /// 类型
    /// 类型
    /// 对象
    /// IQueryableX对象
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Boolean NotInSQL(this T obj, IQueryableX queryableX) { return true; }
    /// 
    /// 扩展SQL not in语法
    /// 
    /// 类型
    /// 对象
    /// 数组
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool NotInSQL(this T obj, object[] array) { return true; }
    #endregion

    #region 扩展SQL like 语法
    /// 
    /// 扩展SQL like 语法
    /// 
    /// 字符串
    /// 子串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool LikeSQL(this object str, string likeStr) { return true; }
    /// 
    /// 扩展SQL not like 语法
    /// 
    /// 字符串
    /// 子串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static bool NotLikeSQL(this string str, string likeStr) { return true; }
    /// 
    /// 扩展SQL like 语法
    /// 
    /// 字符串
    /// 子串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")]
    public static bool LikeSQLX(this object str, string likeStr) { return true; }
    /// 
    /// 扩展SQL not like 语法
    /// 
    /// 字符串
    /// 子串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")]
    public static bool NotLikeSQLX(this string str, string likeStr) { return true; }
    #endregion

    #region 扩展SQL DateAdd 语法
    /// 
    /// 扩展SQL DateAdd 语法
    /// 
    /// 日期
    /// 值
    /// 格式 年yy,yyyy 季度qq,q 月mm,m 年中的日dy,y 日dd,d 周wk,ww 星期dw,w 小时hh 分钟mi,n 秒ss,s 毫秒ms 微秒mcs 纳秒ns
    /// 
    public static DateTime DateAddSQL(this DateTime date, long val, string format)
    {
        return date;
    }
    /// 
    /// 扩展SQL DateAdd 语法
    /// 
    /// 日期
    /// 值
    /// 格式 年yy,yyyy 季度qq,q 月mm,m 年中的日dy,y 日dd,d 周wk,ww 星期dw,w 小时hh 分钟mi,n 秒ss,s 毫秒ms 微秒mcs 纳秒ns
    /// 
    public static DateTime DateAddSQL(this DateTime? date, long val, string format)
    {
        return date.GetValueOrDefault();
    }
    #endregion

    #region 扩展SQL DateDiff 语法
    /// 
    /// 扩展SQL DateDiff 语法
    /// 
    /// 第一个时间
    /// 第二个时间
    /// 格式 年yy,yyyy 季度qq,q 月mm,m 年中的日dy,y 日dd,d 周wk,ww 星期dw,w 小时hh 分钟mi,n 秒ss,s 毫秒ms 微秒mcs 纳秒ns
    /// 
    public static int DateDiffSQL(this DateTime? firstDate, DateTime? SecondDate, string format) { return 1; }
    /// 
    /// 扩展SQL DateDiff 语法
    /// 
    /// 第一个时间
    /// 第二个时间
    /// 格式 年yy,yyyy 季度qq,q 月mm,m 年中的日dy,y 日dd,d 周wk,ww 星期dw,w 小时hh 分钟mi,n 秒ss,s 毫秒ms 微秒mcs 纳秒ns
    /// 
    public static int DateDiffSQL(this DateTime firstDate, DateTime SecondDate, string format) { return 1; }
    #endregion

    #region 扩展SQL DatePart 语法
    /// 
    /// 扩展SQL DatePart 语法
    /// 
    /// 当前时间
    /// 格式 年yy,yyyy 季度qq,q 月mm,m 年中的日dy,y 日dd,d 周wk,ww 星期dw,w 小时hh 分钟mi,n 秒ss,s 毫秒ms 微秒mcs 纳秒ns
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int DatePartSQL(this DateTime? Date, string format) { return 0; }
    /// 
    /// 扩展SQL DatePart 语法
    /// 
    /// 当前时间
    /// 格式 年yy,yyyy 季度qq,q 月mm,m 年中的日dy,y 日dd,d 周wk,ww 星期dw,w 小时hh 分钟mi,n 秒ss,s 毫秒ms 微秒mcs 纳秒ns
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int DatePartSQL(this DateTime Date, string format) { return 0; }
    #endregion

    #region 扩展SQL DateFormat 语法
    /// 
    /// 扩展SQL DateFormat 语法
    /// 
    /// 当前时间
    /// 
    /// 
    public static string DateFormatSQL(this DateTime? Date, string format) { return string.Empty; }
    /// 
    /// 扩展SQL DateFormat 语法
    /// 
    /// 当前时间
    /// 
    /// 
    public static string DateFormatSQL(this DateTime Date, string format) { return string.Empty; }
    #endregion

    #region 扩展SQL Charindex 语法
    /// 
    /// 扩展SQL Charindex 语法
    /// 
    /// 字符串
    /// 子串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int CharIndexSQL(this string str, string IndexStr) { return 1; }
    #endregion

    #region 扩展SQL Patindex语法
    /// 
    /// 扩展SQL Patindex语法
    /// 
    /// 字符串
    /// 子串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int PatindexSQL(this string str, string IndexStr) { return 1; }
    #endregion

    #region 扩展SQL Abs 算法
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int AbsSQL(this int value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int AbsSQL(this int? value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Int16 AbsSQL(this Int16? value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Int16 AbsSQL(this Int16 value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Int64 AbsSQL(this Int64? value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Int64 AbsSQL(this Int64 value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double AbsSQL(this Double? value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double AbsSQL(this Double value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal AbsSQL(this decimal? value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal AbsSQL(this decimal value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float AbsSQL(this float? value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float AbsSQL(this float value) { return 1; }
    #endregion

    #region 扩展SQL Floor 算法
    /// 
    /// 扩展SQL Floor 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double FloorSQL(this Double? value) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double FloorSQL(this Double value) { return 1; }
    /// 
    /// 扩展SQL Floor 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal FloorSQL(this decimal? value) { return 1; }
    /// 
    /// 扩展SQL Floor 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal FloorSQL(this decimal value) { return 1; }
    /// 
    /// 扩展SQL Floor 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float FloorSQL(this float? value) { return 1; }
    /// 
    /// 扩展SQL Floor 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float FloorSQL(this float value) { return 1; }
    #endregion

    #region 扩展SQL Ceiling 算法
    /// 
    /// 扩展SQL Ceiling 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double CeilingSQL(this Double? value) { return 1; }
    /// 
    /// 扩展SQL Ceiling 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double CeilingSQL(this Double value) { return 1; }
    /// 
    /// 扩展SQL Ceiling 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal CeilingSQL(this decimal? value) { return 1; }
    /// 
    /// 扩展SQL Ceiling 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal CeilingSQL(this decimal value) { return 1; }
    /// 
    /// 扩展SQL Ceiling 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float CeilingSQL(this float? value) { return 1; }
    /// 
    /// 扩展SQL Ceiling 算法
    /// 
    /// 值
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float CeilingSQL(this float value) { return 1; }
    #endregion

    #region 扩展SQL Round 算法
    /// 
    /// 扩展SQL Round 算法
    /// 
    /// 值
    /// 小数点保留长度
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double RoundSQL(this Double? value, int len) { return 1; }
    /// 
    /// 扩展SQL Round 算法
    /// 
    /// 值
    /// 小数点保留长度
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static Double RoundSQL(this Double value, int len) { return 1; }
    /// 
    /// 扩展SQL Round 算法
    /// 
    /// 值
    /// 小数点保留长度
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal RoundSQL(this decimal? value, int len) { return 1; }
    /// 
    /// 扩展SQL Round 算法
    /// 
    /// 值
    /// 小数点保留长度
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static decimal RoundSQL(this decimal value, int len) { return 1; }
    /// 
    /// 扩展SQL Abs 算法
    /// 
    /// 值
    /// 小数点保留长度
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float RoundSQL(this float? value, int len) { return 1; }
    /// 
    /// 扩展SQL Round 算法
    /// 
    /// 值
    /// 小数点保留长度
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static float RoundSQL(this float value, int len) { return 1; }
    #endregion

    #region 扩展SQL Left
    /// 
    /// 扩展SQL Left
    /// 
    /// 字符串
    /// 第几位
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string LeftSQL(this string str, int num) { return ""; }
    #endregion

    #region 扩展SQL Right
    /// 
    /// 扩展SQL Right
    /// 
    /// 字符串
    /// 第几位
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string RightSQL(this string str, int num) { return ""; }
    #endregion

    #region 扩展SQL Len
    /// 
    /// 扩展SQL Len
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int LengthSQL(this string str) { return 1; }
    #endregion

    #region 扩展SQL Replace
    /// 
    /// 扩展SQL Replace
    /// 
    /// 字符串
    /// 原字符串
    /// 新字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string ReplaceSQL(this string str, string oldString, string replaceString) { return ""; }
    #endregion

    #region 扩展SQL Replicate
    /// 
    /// 扩展SQL Replicate
    /// 
    /// 字符串
    /// 重复次数
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string ReplicateSQL(this string str, int num) { return ""; }
    #endregion

    #region 扩展SQL Reverse
    /// 
    /// 扩展SQL Reverse
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string ReverseSQL(this string str) { return ""; }
    #endregion

    #region 扩展SQL Stuff
    /// 
    /// 扩展SQL Stuff
    /// 
    /// 字符串
    /// 开始位置
    /// 长度
    /// 替换字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string StuffSQL(this string str, int strat, int length, string replaceString) { return ""; }
    #endregion

    #region 扩展SQL Substring
    /// 
    /// 扩展SQL Substring
    /// 
    /// 字符串
    /// 开始位置
    /// 长度
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string SubstringSQL(this string str, int start, int length) { return ""; }
    #endregion

    #region 扩展SQL Trim
    /// 
    /// 扩展SQL Ltrim
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string LTrimSQL(this string str) { return ""; }
    /// 
    /// 扩展SQL Rtrim
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string RTrimSQL(this string str) { return ""; }
    /// 
    /// 扩展SQL Trim
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string TrimSQL(this string str) { return ""; }
    #endregion

    #region 扩展SQL Lower
    /// 
    /// 扩展SQL Lower
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string LowerSQL(this string str) { return ""; }
    #endregion

    #region 扩展SQL Upper
    /// 
    /// 扩展SQL Upper
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static string UpperSQL(this string str) { return ""; }
    #endregion

    #region 扩展SQL Count
    /// 
    /// 扩展SQL Count
    /// 
    /// 字符串
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static int CountSQL(this object str) { return 0; }
    #endregion

    #region 扩展SQL MAX
    /// 
    /// 扩展SQL MAX
    /// 
    /// 类型
    /// 字符串
    /// 
    public static T MaxSQL(this T obj) { return obj; }
    #endregion

    #region 扩展SQL MIN
    /// 
    /// 扩展SQL MIN
    /// 
    /// 类型
    /// 字符串
    /// 
    public static T MinSQL(this T obj) { return obj; }
    #endregion

    #region 扩展SQL SUM
    /// 
    /// 扩展SQL SUM
    /// 
    /// 类型
    /// 字符串
    /// 
    public static T SumSQL(this T obj) { return obj; }
    #endregion

    #region 扩展SQL AVG
    /// 
    /// 扩展SQL AVG
    /// 
    /// 类型
    /// 字符串
    /// 
    public static T AvgSQL(this T obj) { return obj; }
    #endregion

    #region 设置字段别名
    /// 
    /// 设置字段别名
    /// 
    /// 类型
    /// 对象
    /// 别名
    /// 
    [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0060:删除未使用的参数", Justification = "")] 
    public static T As(this T obj, string ColumnName) { return obj; }
    #endregion

    #region 转换类型
    /// 
    /// 转换类型
    /// 
    /// 类型
    /// 对象
    /// 目标类型
    /// 
    public static T CastSQL(this T obj,string dataType) { return obj; }
    #endregion

    #region SQL参数化调整
    /// 
    /// SQL参数化调整
    /// 
    /// SQL语句
    /// 数据库驱动
    /// 
    public static string SQLFormat(this string _, DbProviderType dbProvider)
    {
        switch (dbProvider)
        {
            case DbProviderType.Dameng:
                return _.ReplacePattern(@"@((Sub_(d+_)?)?ParamNamed+)", "?");
            case DbProviderType.Oracle:
                return _.ReplacePattern(@"@((Sub_(d+_)?)?ParamNamed+)", ":$1");
        }
        return _;
    }
    #endregion

    #endregion
}

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

下边举例演示

//内部方法
//查询出分类名称前边包含 字符串 a 的数据
var category5 = category.Where(a => a.Name.StartsWith("a")).ToList();
//查询出分类名第2位开始4个长度的字符是abcd的数据
var category6 = category.Where(a => a.Name.Substring(2, 4) == "abcd").ToList();
//查询 出分类表中添加时间比现在时间少3个时小的 数据
var category7 = category.Where(a => a.AddDate.DateDiffSQL(DateTime.Now, "hh") == 3).ToList();

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

到这里 IQueryableX 基本使用基本上讲完了,以后还有扩展的 IQueryableQ 它是操作SQL体用的 比如 下边的SQL

if(exists(select top 1 from TestTb where ID = 1))
    delete from testTb where ID = 1;

.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架插图

以后会用一节 专一讲 IQueryableQ的使用方法。

 

开源地址:https://github.com/zhuovi/XiaoFeng

语雀地址:https://www.yuque.com/fayelf/xiaofeng

开源不易,多多支持~

文章来源于互联网:.NET Core C#系列之XiaoFeng.Data.IQueryableX ORM框架

THE END
分享
二维码