package sqlancer.mysql;

import java.sql.SQLException;

import sqlancer.SQLGlobalState;

public class MySQLGlobalState extends SQLGlobalState<MySQLOptions, MySQLSchema> {

    @Override
    protected MySQLSchema readSchema() throws SQLException {
        return MySQLSchema.fromConnection(getConnection(), getDatabaseName());
    }

    public boolean usesPQS() {
        return getDbmsSpecificOptions().oracles.stream().anyMatch(o -> o == MySQLOracleFactory.PQS);
    }

    public boolean usesEET() {
        return getDbmsSpecificOptions().getTestOracleFactory().stream()
                .anyMatch(o -> o == MySQLOracleFactory.EET || o == MySQLOracleFactory.EET_DML);
    }

    public boolean usesEETDML() {
        return getDbmsSpecificOptions().getTestOracleFactory().stream().anyMatch(o -> o == MySQLOracleFactory.EET_DML);
    }

}