src/sqlancer/sqlite3/ast/SQLite3WindowFunction.java - master - NikolayIvkin/sqlancer2

src/sqlancer/sqlite3/ast/SQLite3WindowFunction.java
143 строки4 KB
Manuel Rigger
Extract the SQLite3GlobalState to a separate class to fix a JavaDoc issue
21 янв 2021, 01:52
21 янв 2021, 01:52cb9833d
package sqlancer.sqlite3.ast;

import java.util.List;

import sqlancer.IgnoreMeException;
import sqlancer.Randomly;
import sqlancer.sqlite3.SQLite3GlobalState;
import sqlancer.sqlite3.SQLite3Provider;
import sqlancer.sqlite3.gen.SQLite3ExpressionGenerator;
import sqlancer.sqlite3.schema.SQLite3Schema.SQLite3Column;
import sqlancer.sqlite3.schema.SQLite3Schema.SQLite3Column.SQLite3CollateSequence;

public class SQLite3WindowFunction extends SQLite3Expression {

    private WindowFunction func;
    private SQLite3Expression[] args;

    public static SQLite3WindowFunction getRandom(List<SQLite3Column> columns, SQLite3GlobalState globalState) {
        WindowFunction func = Randomly.fromOptions(WindowFunction.values());
        SQLite3Expression[] args = new SQLite3Expression[func.nrArgs];
        for (int i = 0; i < args.length; i++) {
            args[i] = new SQLite3ExpressionGenerator(globalState).setColumns(columns).generateExpression();
        }
        return new SQLite3WindowFunction(func, args);
    }

    public enum WindowFunction {

        ROW_NUMBER {
            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                return SQLite3Constant.createIntConstant(1);
            }

        },
        RANK {
            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                return SQLite3Constant.createIntConstant(1);
            }
        },
        DENSE_RANK {
            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                return SQLite3Constant.createIntConstant(1);
            }
        },
        PERCENT_RANK {
            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                return SQLite3Constant.createRealConstant(0.0);
            }
        },
        CUME_DIST {
            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                return SQLite3Constant.createRealConstant(1.0);
            }
        },
        NTILE(1), //
        LAG(3), //
        LEAD(3), //
        FIRST_VALUE(1) {

            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                return args[0];
            }
        },
        LAST_VALUE(1) {
            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                return args[0];
            }
        },
        NTH_VALUE(2) {
            @Override
            public SQLite3Constant apply(SQLite3Constant... args) {
                SQLite3Constant n = SQLite3Cast.castToInt(args[1]);
                if (!n.isNull() && n.asInt() == 1) {
                    return args[0];
                } else {
                    return SQLite3Constant.createNullConstant();
                }
            }
        };

        int nrArgs;

        WindowFunction(int nrArgs) {
            this.nrArgs = nrArgs;
        };

        WindowFunction() {
            this(0);
        }

        public SQLite3Constant apply(SQLite3Constant... args) {
            if (SQLite3Provider.mustKnowResult) {
                throw new AssertionError();
            }
            return null;
        }

        public int getNrArgs() {
            return nrArgs;
        }
    }

    public SQLite3WindowFunction(WindowFunction func, SQLite3Expression... args) {
        this.func = func;
        this.args = args.clone();
    }

    public WindowFunction getFunc() {
        return func;
    }

    public SQLite3Expression[] getArgs() {
        return args.clone();
    }

    @Override
    public SQLite3CollateSequence getExplicitCollateSequence() {
        return null;
    }

    @Override
    public SQLite3Constant getExpectedValue() {
        if (!SQLite3Provider.mustKnowResult) {
            return null;
        }
        SQLite3Constant[] evaluatedConst = new SQLite3Constant[args.length];
        for (int i = 0; i < evaluatedConst.length; i++) {
            evaluatedConst[i] = args[i].getExpectedValue();
            if (evaluatedConst[i] == null) {
                throw new IgnoreMeException();
            }
        }
        return func.apply(evaluatedConst);
    }

}