src/sqlancer/sqlite3/gen/dml/SQLite3UpdateGenerator.java - master - NikolayIvkin/sqlancer2

src/sqlancer/sqlite3/gen/dml/SQLite3UpdateGenerator.java
122 строки5 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.gen.dml;

import java.util.List;
import java.util.stream.Collectors;

import sqlancer.Randomly;
import sqlancer.common.query.ExpectedErrors;
import sqlancer.common.query.SQLQueryAdapter;
import sqlancer.sqlite3.SQLite3Errors;
import sqlancer.sqlite3.SQLite3GlobalState;
import sqlancer.sqlite3.SQLite3Visitor;
import sqlancer.sqlite3.ast.SQLite3Constant;
import sqlancer.sqlite3.gen.SQLite3ExpressionGenerator;
import sqlancer.sqlite3.schema.SQLite3Schema.SQLite3Column;
import sqlancer.sqlite3.schema.SQLite3Schema.SQLite3Table;

public class SQLite3UpdateGenerator {

    private final StringBuilder sb = new StringBuilder();
    private final Randomly r;
    private final ExpectedErrors errors = new ExpectedErrors();
    private final SQLite3GlobalState globalState;

    public SQLite3UpdateGenerator(SQLite3GlobalState globalState, Randomly r) {
        this.globalState = globalState;
        this.r = r;
    }

    public static SQLQueryAdapter updateRow(SQLite3GlobalState globalState) {
        SQLite3Table randomTableNoViewOrBailout = globalState.getSchema()
                .getRandomTableOrBailout(t -> !t.isView() && !t.isReadOnly());
        return updateRow(globalState, randomTableNoViewOrBailout);
    }

    public static SQLQueryAdapter updateRow(SQLite3GlobalState globalState, SQLite3Table table) {
        SQLite3UpdateGenerator generator = new SQLite3UpdateGenerator(globalState, globalState.getRandomly());
        return generator.update(table);
    }

    private SQLQueryAdapter update(SQLite3Table table) {
        sb.append("UPDATE ");
        if (Randomly.getBoolean()) {
            sb.append("OR IGNORE ");
        } else {
            if (Randomly.getBoolean()) {
                String fromOptions = Randomly.fromOptions("OR ROLLBACK", "OR ABORT", "OR REPLACE", "OR FAIL");
                sb.append(fromOptions);
                sb.append(" ");
            }
            errors.add("[SQLITE_CONSTRAINT]");
        }
        // TODO Beginning in SQLite version 3.15.0 (2016-10-14), an assignment in the
        // SET clause can be a parenthesized list of column names on the left and a row
        // value of the same size on the right.

        sb.append(table.getName());
        sb.append(" SET ");
        List<SQLite3Column> columnsToUpdate = Randomly.nonEmptySubsetPotentialDuplicates(table.getColumns());
        if (Randomly.getBoolean()) {
            sb.append("(");
            sb.append(columnsToUpdate.stream().map(c -> c.getName()).collect(Collectors.joining(", ")));
            sb.append(")");
            sb.append("=");
            sb.append("(");
            for (int i = 0; i < columnsToUpdate.size(); i++) {
                if (i != 0) {
                    sb.append(", ");
                }
                getToUpdateValue(columnsToUpdate, i);
            }
            sb.append(")");
            // row values
        } else {
            for (int i = 0; i < columnsToUpdate.size(); i++) {
                if (i != 0) {
                    sb.append(", ");
                }
                sb.append(columnsToUpdate.get(i).getName());
                sb.append(" = ");
                getToUpdateValue(columnsToUpdate, i);
            }
        }

        if (Randomly.getBoolean()) {
            sb.append(" WHERE ");
            String whereClause = SQLite3Visitor.asString(
                    new SQLite3ExpressionGenerator(globalState).setColumns(table.getColumns()).generateExpression());
            sb.append(whereClause);
        }

        // ORDER BY and LIMIT are only supported by enabling a compile-time option
        // List<Expression> expressions = QueryGenerator.generateOrderBy(table.getColumns());
        // if (!expressions.isEmpty()) {
        // sb.append(" ORDER BY ");
        // sb.append(expressions.stream().map(e -> SQLite3Visitor.asString(e)).collect(Collectors.joining(", ")));
        // }

        SQLite3Errors.addInsertUpdateErrors(errors);

        errors.add("[SQLITE_ERROR] SQL error or missing database (parser stack overflow)");
        errors.add(
                "[SQLITE_ERROR] SQL error or missing database (second argument to likelihood() must be a constant between 0.0 and 1.0)");
        // for views
        errors.add("ORDER BY term out of range");
        errors.add("unknown function: json_type");

        SQLite3Errors.addInsertNowErrors(errors);
        SQLite3Errors.addExpectedExpressionErrors(errors);
        SQLite3Errors.addDeleteErrors(errors);
        return new SQLQueryAdapter(sb.toString(), errors, true /* column could have an ON UPDATE clause */);

    }

    private void getToUpdateValue(List<SQLite3Column> columnsToUpdate, int i) {
        if (columnsToUpdate.get(i).isIntegerPrimaryKey()) {
            sb.append(SQLite3Visitor.asString(SQLite3Constant.createIntConstant(r.getInteger())));
        } else {
            sb.append(SQLite3Visitor.asString(SQLite3ExpressionGenerator.getRandomLiteralValue(globalState)));
        }
    }

}