modelExpressionSql.h

Go to the documentation of this file.

 
// Copyright (c) 2013-2015 OpenM++
// This code is licensed under the MIT license (see LICENSE.txt for details)
 
#ifndef MODEL_EXPRESSION_SQL_H
#define MODEL_EXPRESSION_SQL_H
 
#include "libopenm/db/dbMetaRow.h"
using namespace std;
 
namespace openm
{
    enum class FncCode
    {
        undefined = 0,
 
        if_case,
 
        div_by,
 
        avg,
 
        sum,
 
        count,
 
        min,
 
        max,
 
        var,
 
        sd,
 
        se,
 
        cv
    };
 
    struct AggregationColumnExpr
    {
        string colName;
 
        string srcExpr;
 
        string sqlExpr;
 
        static int nextExprNumber;
 
        AggregationColumnExpr(const string & i_colName, const string & i_srcExpr) :
            colName(i_colName), srcExpr(i_srcExpr)
        { }
        AggregationColumnExpr(const string & i_srcExpr) :
            colName("ex" + to_string(nextExprNumber++)), srcExpr(i_srcExpr)
        { }
    };
 
    class ModelBaseExpressionSql
    {
    public:
        ModelBaseExpressionSql(
            const string & i_accTableName, const vector<string> & i_dimCols, const vector<int> & i_accIds, const vector<string> & i_accNames, const vector<string> & i_accCols
        ) :
            accTableName(i_accTableName),
            dimCols(i_dimCols),
            accIds(i_accIds),
            accNames(i_accNames),
            accCols(i_accCols)
        {
            accCount = (int)accIds.size();
        }
 
        ~ModelBaseExpressionSql() noexcept { }
 
    protected:
        const string accTableName;
 
        const vector<string> dimCols;
 
        const vector<int> accIds;
 
        const vector<string> accNames;
 
        const vector<string> accCols;
 
        int accCount;
 
        const string translateAllSimpleFnc(const string & i_srcMsg, bool i_isSkipAggr, const string & i_expr);
 
        static const string translateSimpleFnc(const string & i_srcMsg, FncCode i_code, const string & i_arg);
 
    private:
        ModelBaseExpressionSql(const ModelBaseExpressionSql & i_other) = delete;
        ModelBaseExpressionSql & operator=(const ModelBaseExpressionSql & i_other) = delete;
    };
 
    class ModelAccumulatorSql : public ModelBaseExpressionSql
    {
    public:
        ModelAccumulatorSql(
            const string & i_accTableName,
            const vector<string> & i_dimCols,
            const vector<int> & i_accIds, 
            const vector<string> & i_accNames,
            const vector<string> & i_accCols,
            const vector<TableAccRow> & i_tableAcc
            ) :
            ModelBaseExpressionSql(i_accTableName, i_dimCols, i_accIds, i_accNames, i_accCols),
            tableAccVec(i_tableAcc)
        { }
 
        ~ModelAccumulatorSql() noexcept { }
 
        const string translateNativeAccExpr(const string & i_outTableName, const string & i_accName, int i_accId);
 
        const string translateDerivedAccExpr(const string & i_outTableName, const string & i_accName, const string & i_expr, const map<string, size_t> & i_nativeMap);
 
    private:
        string srcMsg;
 
        const vector<TableAccRow> & tableAccVec;
 
        vector<bool> isAccUsedArr;
 
    private:
        ModelAccumulatorSql(const ModelAccumulatorSql & i_other) = delete;
        ModelAccumulatorSql & operator=(const ModelAccumulatorSql & i_other) = delete;
    };
 
    class ModelAggregationSql : public ModelBaseExpressionSql
    {
    public:
        ModelAggregationSql(
            const string & i_accTableName, 
            const vector<string> & i_dimCols,
            const vector<int> & i_accIds, 
            const vector<string> & i_accNames,
            const vector<string> & i_accCols
            ) :
            ModelBaseExpressionSql(i_accTableName, i_dimCols, i_accIds, i_accNames, i_accCols)
        { }
 
        ~ModelAggregationSql() noexcept { }
 
        const string translateAggregationExpr(const string & i_outTableName, const string & i_name, const string & i_colName, const string & i_expr);
 
    private:
        string srcMsg;
 
        vector<bool> isAccUsedArr;
 
        vector<AggregationColumnExpr> nextExprArr;
 
        const string translateAggregationFnc(FncCode i_code, const string & i_nextInnerAlias, const string & i_arg);
 
        const string translateArg(const string & i_nextInnerAlias, const string & i_arg);
 
        const string processAccumulators(const string & i_expr);
 
        const string processAccumulators(bool i_isTranslate, int i_level, const string & i_fromAlias, const string & i_expr);
 
        const string pushAvgToNextLevel(const string & i_arg) { return pushToNextLevel("OM_AVG(" + i_arg + ")"); }
 
        const string pushToNextLevel(const string & i_fncExpr);
 
        bool isFirstUsedAcc(int i_accPos, const vector<bool> & i_accUsage) const;
 
        const string makeAccTableAlias(int i_accPos, const vector<bool> & i_accUsage, int i_level, const string i_firstAlias) const;
 
    private:
        ModelAggregationSql(const ModelAggregationSql & i_other) = delete;
        ModelAggregationSql & operator=(const ModelAggregationSql & i_other) = delete;
    };
}
 
#endif  // MODEL_EXPRESSION_SQL_H