modelSqlBuilder.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_SQL_BUILDER_H
#define MODEL_SQL_BUILDER_H
 
#include <fstream>
#include <streambuf>
#include "helper.h"
#include "crc32.h"
#include "md5.h"
#include "dbExec.h"
#include "libopenm/common/omFile.h"
#include "libopenm/common/iniReader.h"
#include "libopenm/db/modelBuilder.h"
#include "dbMetaTable.h"
#include "modelSqlWriter.h"
#include "modelInsertSql.h"
#include "modelExpressionSql.h"
 
using namespace std;
 
namespace openm
{
    class ModelSqlBuilder : public IModelBuilder
    {
    public:
        ModelSqlBuilder(const string & i_providerNames, const string & i_sqlDir, const string & i_outputDir, const string & i_sqliteDir);
 
        ~ModelSqlBuilder() noexcept { }
 
        bool isSqliteDb(void) const override { return isSqlite; }
 
        void setModelMetaRows(MetaModelHolder & io_metaRows) const override;
 
        void build(MetaModelHolder & io_metaRows) override;
 
        void beginWorkset(const MetaModelHolder & i_metaRows, MetaSetLangHolder & io_metaSet) override;
 
        void addWorksetParameter(
            const MetaModelHolder & i_metaRows, const MetaSetLangHolder & i_metaSet, const string & i_name, int i_subId, const string & i_value
        ) override;
 
        void addWorksetParameter(
            const MetaModelHolder & i_metaRows, const MetaSetLangHolder & i_metaSet, const string & i_name, int i_subId, const list<string> & i_valueLst
        ) override;
 
        void endWorkset(const MetaModelHolder & i_metaRows, const MetaSetLangHolder & i_metaSet) override;
 
        void buildCompatibilityViews(const MetaModelHolder & i_metaRows) const override;
 
    private:
        string sqlDir;                  // sql scripts directory to create database
        string sourceDir;               // source code directory
        string outputDir;               // output directory to write sql script files
        string sqliteDir;               // output directory to create model.sqlite database
        bool isSqlite;                  // if true then create SQLite database
        list<string> dbProviderLst;     // list of db provider names, ie: sqlite,postgresql,mysql
        unique_ptr<IDbExec> dbExec;     // database connection
 
        struct DbTblInfo
        {
            int modelId;
 
            int id;
 
            string name;
 
            vector<string> dimVec;
 
            vector<string> colVec;
 
            vector<int> typeIdVec;
 
            DbTblInfo(void) : id(-1) { }
        };
 
        struct ParamTblInfo : DbTblInfo
        {
            vector<TypeDicRow>::const_iterator valueTypeIt;
 
            bool isAdded;
 
            bool isNullable;
        };
 
        struct OutTblInfo : DbTblInfo
        {
            vector<int> accIdVec;
 
            vector<string> accNameVec;
 
            vector<string> accColVec;
        };
 
        vector<ParamTblInfo> paramInfoVec;
 
        vector<OutTblInfo> outInfoVec;
 
        void prepare(MetaModelHolder & io_metaRows) const;
 
        void buildCreateModel(const string & i_sqlProvider, const MetaModelHolder & i_metaRows, const string & i_filePath) const;
 
        static void createModel(IDbExec * i_dbExec, MetaModelHolder & io_metaRows);
 
        void buildCreateModelTables(const string & i_sqlProvider, const MetaModelHolder & i_metaRows, const string & i_filePath) const;
 
        void buildDropModelTables(const MetaModelHolder & i_metaRows, const string & i_filePath) const;
 
        void prepareWorkset(const MetaModelHolder & i_metaRows, MetaSetLangHolder & io_metaSet) const;
 
        void doAddScalarWorksetParameter(
            int i_setId,
            const string & i_name, 
            const string & i_dbTableName, 
            const vector<ParamTblInfo>::const_iterator & i_paramInfo,
            int i_subId,
            const string & i_value
        );
 
        const void paramCreateTable(
            const string & i_sqlProvider, 
            const string & i_dbTableName, 
            const string & i_runSetId, 
            const ParamTblInfo & i_tblInfo, 
            ModelSqlWriter & io_wr
        ) const;
 
        const void accCreateTable(
            const string & i_sqlProvider, 
            const string & i_dbTableName, 
            const OutTblInfo & i_tblInfo, 
            ModelSqlWriter & io_wr
        ) const;
 
        const void valueCreateTable(
            const string & i_sqlProvider, 
            const string & i_dbTableName, 
            const OutTblInfo & i_tblInfo, 
            ModelSqlWriter & io_wr
        ) const;
 
        const void accAllCreateView(
            const string & i_sqlProvider, 
            const string & i_viewName, 
            const OutTblInfo & i_tblInfo,
            const string & i_accTablName,
            const vector<TableAccRow> & i_accVec,
            ModelSqlWriter & io_wr
        ) const;
 
        const void paramCompatibilityView(
            const string & i_sqlProvider, 
            const ModelDicRow & i_modelRow,
            const string & i_viewName, 
            const string & i_srcTableName, 
            const vector<string> & i_colNames,
            const vector<int> & i_dimsLowerBound,
            int i_valueLowerBound,
            ModelSqlWriter & io_wr
        ) const;
 
        const void outputCompatibilityView(
            const string & i_sqlProvider, 
            const ModelDicRow & i_modelRow, 
            const string & i_viewName, 
            const string & i_srcTableName, 
            const vector<string> & i_colNames,
            const vector<int> & i_dimsLowerBound,
            ModelSqlWriter & io_wr
        ) const;
 
        void setWorksetRow(WorksetLstRow & io_wsRow) const;
 
        void setTypeDicRows(MetaModelHolder & io_metaRows) const;
 
        void setParamTableInfo(MetaModelHolder & io_metaRows);
 
        void setOutTableInfo(MetaModelHolder & io_metaRows);
 
        void setParamDicRows(MetaModelHolder & io_metaRows) const;
 
        void setTableDicRows(MetaModelHolder & io_metaRows) const;
 
        void setEntityDicRows(MetaModelHolder& io_metaRows) const;
 
        void setModelProfileRows(MetaModelHolder & io_metaRows) const;
 
        static void trimModelRows(MetaModelHolder & io_metaRows);
 
        static void sortModelRows(MetaModelHolder & io_metaRows);
 
        static void sortWorksetRows(MetaSetLangHolder & io_metaSet);
 
        static void setColumnNames(MetaModelHolder & io_metaRows);
 
        void setModelDicRow(ModelDicRow & io_mdRow) const;
 
        static const string makeTypeDigest(const TypeDicRow & i_typeRow, const MetaModelHolder & i_metaRows);
 
        static const tuple<string, string> makeParamDigest(const ParamDicRow & i_paramRow, const MetaModelHolder & i_metaRows);
        
        static const tuple<string, string> makeOutTableDigest(const TableDicRow i_tableRow, const MetaModelHolder & i_metaRows);
 
        static const string makeEntityDigest(const EntityDicRow i_entityRow, const MetaModelHolder& i_metaRows);
 
        static const string makeModelDigest(const MetaModelHolder & i_metaRows);
    };
}
 
#endif  // MODEL_SQL_BUILDER_H