Class SqlCompilerImpl

core/src/main/java/io/questdb/griffin/SqlCompilerImpl.java:154–5520

public class SqlCompilerImpl implements SqlCompiler, Closeable, SqlParserCallback {
    public static final String ALTER_TABLE_EXPECTED_TOKEN_DESCR =
            "'add', 'alter', 'attach', 'detach', 'drop', 'convert', 'resume', 'rename', 'set' or 'squash'";
    static final ObjList<String> sqlControlSymbols = new ObjList<>(8);
    // null object used to skip null checks in batch method
    private static final BatchCallback EMPTY_CALLBACK = new BatchCallback() {
        @Override
        public void postCompile(SqlCompiler compiler, CompiledQuery cq, CharSequence queryText) {
        }

        @Override
        public boolean preCompile(SqlCompiler compiler, CharSequence sqlText) {
            return true;
        }
    };
    private static final Log LOG = LogFactory.getLog(SqlCompilerImpl.class);
    private static final boolean[][] columnConversionSupport = new boolean[ColumnType.NULL][ColumnType.NULL];
    protected final AlterOperationBuilder alterOperationBuilder;
    protected final SqlCodeGenerator codeGenerator;
    protected final CompiledQueryImpl compiledQuery;
    protected final CairoConfiguration configuration;
    protected final GenericDropOperationBuilder dropOperationBuilder;
    protected final CairoEngine engine;
    protected final LowerCaseAsciiCharSequenceObjHashMap<KeywordBasedExecutor> keywordBasedExecutors = new LowerCaseAsciiCharSequenceObjHashMap<>();
    protected final GenericLexer lexer;
    protected final SqlOptimiser optimiser;
    protected final Path path;
    protected final QueryRegistry queryRegistry;
    private final BytecodeAssembler asm = new BytecodeAssembler();
    private final BlockFileWriter blockFileWriter;
    private final CharacterStore characterStore;
    private final ObjList<CharSequence> columnNames = new ObjList<>();
    private final ViewCompilerExecutionContext compileViewContext;
    private final CharSequenceObjHashMap<String> dropAllTablesFailures = new CharSequenceObjHashMap<>();
    private final EntityColumnFilter entityColumnFilter = new EntityColumnFilter();
    private final FilesFacade ff;
    private final FunctionParser functionParser;
    private final ListColumnFilter listColumnFilter = new ListColumnFilter();
    private final int maxRecompileAttempts;
    private final MemoryMARW mem = Vm.getCMARWInstance();
    private final MessageBus messageBus;
    private final SqlParser parser;
    private final TimestampValueRecord partitionFunctionRec = new TimestampValueRecord();
    private final QueryBuilder queryBuilder;
    private final ObjectPool<QueryColumn> queryColumnPool;
    private final ObjectPool<QueryModel> queryModelPool;
    private final ObjectPool<QueryModelWrapper> queryModelWrapperPool;
    private final Path renamePath;
    private final ObjectPool<ExpressionNode> sqlNodePool;
    private final ObjHashSet<TableToken> tableTokenBucket = new ObjHashSet<>();
    private final ObjList<TableWriterAPI> tableWriters = new ObjList<>();
    private final VacuumColumnVersions vacuumColumnVersions;
    private final ObjList<CharSequence> views = new ObjList<>();
    protected CharSequence sqlText;
    private boolean closed = false;
    // Helper var used to pass back count in cases it can't be done via method result.
    private long insertCount;
    //determines how compiler parses query text