src/02_Data/Data.Core/SqlBuilder/QueryableSqlBuilder.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using Mkh.Data.Abstractions;
using Mkh.Data.Abstractions.Adapter;
using Mkh.Data.Abstractions.Descriptors;
using Mkh.Data.Abstractions.Pagination;
using Mkh.Data.Abstractions.Queryable;
using Mkh.Data.Core.Extensions;
using Mkh.Data.Core.Internal;
using Mkh.Data.Core.Internal.QueryStructure;

namespace Mkh.Data.Core.SqlBuilder;

/// <summary>
/// 查询SQL生成器
/// </summary>
public class QueryableSqlBuilder
{
    public QueryBody QueryBody => _queryBody;

    public bool IsSingleEntity => _queryBody.Joins.Count < 2;

    private readonly QueryBody _queryBody;
    private readonly IDbAdapter _dbAdapter;
    private readonly IDbContext _dbContext;

    public QueryableSqlBuilder(QueryBody queryBody)
    {
        _queryBody = queryBody;
        _dbContext = queryBody.Repository.DbContext;
        _dbAdapter = _dbContext.Adapter;
    }

    #region ==BuildListSql==

    /// <summary>
    /// 生成列表语句
    /// </summary>
    /// <param name="parameters"></param>
    /// <returns></returns>
    public string BuildListSql(out IQueryParameters parameters)
    {
        parameters = new QueryParameters();
        return BuildListSql(parameters);
    }

    /// <summary>
    /// 生成列表语句
    /// </summary>
    /// <param name="parameters"></param>
    /// <returns></returns>
    public string BuildListSql(IQueryParameters parameters)
    {
        var sqlBuilder = new StringBuilder();
        sqlBuilder.Append("SELECT ");
        ResolveSelect(sqlBuilder);
        sqlBuilder.Append(" FROM ");