package gudusoft.gsqlparser.stmt;

import gudusoft.gsqlparser.*;
import gudusoft.gsqlparser.nodes.*;
import gudusoft.gsqlparser.nodes.EHiveInsertType;
import gudusoft.gsqlparser.nodes.EOnConflictActionType;
import gudusoft.gsqlparser.nodes.oracle.TErrorLoggingClause;
import gudusoft.gsqlparser.stmt.mssql.TMssqlExecute;

import java.util.ArrayList;

/**
 * SQL insert statement.
 * <br>
 * <br> {@link #getTargetTable} returns the table or view that receive the data.
 * <br> {@link #getColumnList()} returns the list of columns in target table if specified.
 * <br> Usually, the data comes from a value clause, you can get those values from {@link #getValues()}.
 * <br> Always checking {@link #getInsertSource} before fetch the data source which may various from value clause
 * to subquery and other forms. Below are some data source types:
 * <ul>
 *     <li>{@link EInsertSource#values} -&gt; {@link #getValues()}</li>
 *     <li>{@link EInsertSource#subquery} -&gt; {@link #getSubQuery()}</li>
 * </ul>
 *
 * <br>Examples:
 * <pre>
 * INSERT INTO Production.UnitMeasure (Name, UnitMeasureCode,ModifiedDate)
 * VALUES (N'Square Yards', N'Y2', GETDATE());
 * </pre>
 * Table name: Production.UnitMeasure. Fetched from {@link #getTargetTable} or the first element of {@link #tables}
 * <br>column list: (Name, UnitMeasureCode,ModifiedDate). Fetch from {@link #getColumnList}
 * <br>value list: (N'Square Yards', N'Y2', GETDATE()). Fetch from {@link #getValues}
 * <br>
 * <pre>
 * INSERT INTO dbo.EmployeeSales
 * SELECT 'SELECT', sp.BusinessEntityID, c.LastName, sp.SalesYTD
 * FROM Sales.SalesPerson AS sp
 * INNER JOIN Person.Person AS c
 * ON sp.BusinessEntityID = c.BusinessEntityID
 * WHERE sp.BusinessEntityID LIKE '2%'
 * ORDER BY sp.BusinessEntityID, c.LastName;
 * </pre>
 * select query in above insert statement can be fetched from {@link #getSubQuery}
 *
 * @see TCustomSqlStatement#cteList
 * @see TCustomSqlStatement#targetTable
 * @see TCustomSqlStatement#outputClause
 * @see TCustomSqlStatement#returningClause
 *
 */
public class TInsertSqlStatement extends TCustomSqlStatement {

    private ArrayList<TInsertSqlStatement> multiInsertStatements;

    /**
     * Hive, from table insert..., insert ...
     * @return
     */
    public ArrayList<TInsertSqlStatement> getMultiInsertStatements() {
        if (this.multiInsertStatements == null){
            this.multiInsertStatements = new ArrayList<>();
        }
        return multiInsertStatements;
    }

    private String fileFormat;
    private String fileOptions = null;

    public String getFileFormat() {
        return fileFormat;
    }

    public String getFileOptions() {
        return fileOptions;
    }

    private TObjectName sourceValueTable;

    public TObjectName getSourceValueTable() {
        return sourceValueTable;
    }

    private boolean insertAll = false;
    private boolean insertFirst = false;

    public void setInsertAll(boolean insertAll) {
        this.insertAll = insertAll;
    }

    public void setInsertFirst(boolean insertFirst) {
        this.insertFirst = insertFirst;
    }

    /**
     * Oracle insert all
     * @return Oracle insert all
     */
    public boolean isInsertAll() {

        return insertAll;
    }

    /**
     * Oracle insert first
     * @return Oracle insert first
     */
    public boolean isInsertFirst() {
        return insertFirst;
    }

    private TErrorLoggingClause errorLoggingClause;

    /**
     * Oracle error logging clause
     * @return Oracle error logging clause
     */
    public TErrorLoggingClause getErrorLoggingClause() {
        return errorLoggingClause;
    }

    /**
     * Hive insert type
     * @return Hive insert type
     */
    public EHiveInsertType getHiveInsertType() {
        return hiveInsertType;
    }

    /**
     * Hive directory name
     * @return directory name
     */
    public TObjectName getDirectoryName() {
        if( (directoryName == null)&&(fileOptions != null)){
            String a[] = fileOptions.split("[,]");
            for(String s:a){
                if (s.trim().startsWith("\'path\'")){
                    directoryName = TObjectName.createObjectName (this.dbvendor, EDbObjectType.directory_path, new TSourceToken(s.split("[ ]")[1]));
                    break;
                }
            }
        }
        return directoryName;
    }


    private EHiveInsertType hiveInsertType = EHiveInsertType.intoUnknown;
    private TObjectName directoryName = null;

    private TPTNodeList<TInsertCondition>  insertConditions;
    private TPTNodeList<TInsertIntoValue> insertIntoValues;

    /**
     * Oracle insert condition
     * @return Oracle insert condition
     */
    public TPTNodeList<TInsertCondition> getInsertConditions() {
        return insertConditions;
    }

    /**
     * Oracle insert into values used after insert all/first clause
     * @return Oracle insert into values used after insert all/first clause
     */
    public TPTNodeList<TInsertIntoValue> getInsertIntoValues() {
        return insertIntoValues;
    }

    public void setInsertToken(TSourceToken insertToken) {
        this.insertToken = insertToken;
    }

    /**
     * INSERT keyword
     * @return INSERT keyword
     */
    public TSourceToken getInsertToken() {

        return insertToken;
    }

    private TSourceToken insertToken = null;
    
    /**
     * value clause valid when {@link #getInsertSource} is {@link gudusoft.gsqlparser.EInsertSource#subquery}.
     * @return {@link gudusoft.gsqlparser.stmt.TSelectSqlStatement sub-query}
     */
    public TSelectSqlStatement getSubQuery() {
        return subQuery;
    }

    private TSelectSqlStatement subQuery = null;

    private TFunctionCall functionCall = null;

    private TMssqlExecute executeStmt = null;

    /**
     * value clause valid when {@link #getInsertSource} is {@link gudusoft.gsqlparser.EInsertSource#values_function}.
     * @return row value was constructed by a function.
     */
    public TFunctionCall getFunctionCall() {
        return functionCall;
    }

    /**
     * Oracle PLSQL record name in values clause, {@link #getInsertSource} returns {@link  EInsertSource#values_oracle_record}
     * @return record name in plsql.
     */
    public TObjectName getRecordName() {
        return recordName;
    }

    private  TObjectName recordName = null;

    /**
     * Type of the source from where the data is coming for this insert statement.
     * @return Type of the data source
     */
    public EInsertSource getInsertSource() {
        return insertSource;
    }

    private EInsertSource insertSource = EInsertSource.values;

    /**
     * @deprecated As of v1.6.4.9, use {@link #getInsertSource} instead.
     *
     * @return how rows was insert into table. value can be one of
     * <p>vt_values,  {@link #getValues}
     * <p>vt_values_empty, syntax like: value ()
     * <p>vt_query,   {@link #getSubQuery}
     * <p>vt_default_values,
     * <p>vt_execute,
     * <p>vt_values_function, {@link #getFunctionCall} 
     */
    public int getValueType() {
        return valueType;
    }

    /**
     * value clause, valid when {@link #getInsertSource} is {@link EInsertSource#values}.
     * represents in format like this: ((1,2,3),(4,5),(6,7,8)),
     * if even value clause is (1,2,3), it will be saved in {@link TMultiTargetList} like ((1,2,3))
     * <br>
     * @return a single row value, or multi row values returned by query or value constructor.
     */
    public TMultiTargetList getValues() {
        return values;
    }

    private TMultiTargetList values = null;

    private int valueType = TBaseType.vt_values;

    private TResultColumnList setColumnValues = null;

    private TSourceToken ignore;
    private TSourceToken priority_delayed;

    private TResultColumnList onDuplicateKeyUpdate = null;

    /**
     * MySQL on duplicate key update column list.
     * @return MySQL on duplicate key update column list
     */
    public TResultColumnList getOnDuplicateKeyUpdate() {
        return onDuplicateKeyUpdate;
    }

    /**
     * MySQL 8.0.20+ row alias for INSERT ... ON DUPLICATE KEY UPDATE.
     * Allows referencing the inserted row values without using VALUES() function.
     * Example: INSERT INTO t1 (a,b,c) VALUES (1,2,3) AS new ON DUPLICATE KEY UPDATE c = new.a+new.b;
     */
    private TObjectName insertRowAlias = null;

    /**
     * MySQL 8.0.20+ optional column aliases for the row alias.
     * Example: INSERT INTO t1 (a,b,c) VALUES (1,2,3) AS new(m,n,p) ON DUPLICATE KEY UPDATE c = m+n;
     */
    private TObjectNameList insertRowAliasColumnList = null;

    /**
     * Get MySQL 8.0.20+ row alias for INSERT ... ON DUPLICATE KEY UPDATE.
     * @return the row alias name, or null if not specified
     */
    public TObjectName getInsertRowAlias() {
        return insertRowAlias;
    }

    /**
     * Get MySQL 8.0.20+ optional column aliases for the row alias.
     * @return the column alias list, or null if not specified
     */
    public TObjectNameList getInsertRowAliasColumnList() {
        return insertRowAliasColumnList;
    }

    private TOnConflictClause onConflictClause;

    /**
     * PostgreSQL ON CONFLICT clause (UPSERT).
     * <p>Provides access to the conflict target (columns or constraint name),
     * the action type (DO NOTHING or DO UPDATE), and the SET/WHERE clauses
     * for DO UPDATE actions.
     *
     * <p>Example:
     * <pre>
     * INSERT INTO tbl VALUES (1, 2) ON CONFLICT (id) DO UPDATE SET col = EXCLUDED.col;
     * </pre>
     *
     * @return the ON CONFLICT clause, or null if not present
     */
    public TOnConflictClause getOnConflictClause() {
        return onConflictClause;
    }

    /**
     * IGNORE keyword used in the insert statement.
     * @return IGNORE keyword if used, otherwise, returns null.
     */
    public TSourceToken getIgnore() {

        return ignore;
    }

    /**
     * DELAY, LOW_PRIORITY, HIGH_PRIORITY keyword used in insert statement.
     * @return null if none of those keywords is used: DELAY, LOW_PRIORITY, HIGH_PRIORITY
     */
    public TSourceToken getPriority_delayed() {
        return priority_delayed;
    }

    /**
     * set column value clauses in MySQL insert statement.
     * @return MySQL specific column value list.
     */
    public TResultColumnList getSetColumnValues() {
        return setColumnValues;
    }

    public TInsertSqlStatement(EDbVendor dbvendor) {
        super(dbvendor);
        sqlstatementtype = ESqlStatementType.sstinsert;
    }

    void buildsql() {
    }

    void clear() {
    }

    String getasprettytext() {
        return "";
    }

    void iterate(TVisitorAbs pvisitor) {
    }

    /**
     * columns of the target table.
     * @return column name list in insert into clause.
     */
    public TObjectNameList getColumnList() {
        return columnList;
    }

    private TObjectNameList columnList = null;

    public void setValues(TMultiTargetList values) {
        this.values = values;
    }

    public void setColumnList(TObjectNameList columnList) {
        this.columnList = columnList;
    }

    public void setSubQuery(TSelectSqlStatement subQuery) {
        insertSource = EInsertSource.subquery;
        this.subQuery = subQuery;
    }

    /**
     * SQL Server, execute statement used in the insert statement.
     * {@link #getInsertSource()} returns {@link EInsertSource#execute}
     *
     * @return SQL Server, execute statement
     */
    public TMssqlExecute getExecuteStmt() {
        return executeStmt;
    }

    private TPTNodeList<TInsertIntoValue> elseIntoValues;

    /**
     * Oracle,  values in else clause
     * @return values in else clause
     */
    public TPTNodeList<TInsertIntoValue> getElseIntoValues() {
        return elseIntoValues;
    }

    public int doParseStatement(TCustomSqlStatement psql) {
        if (rootNode == null) return -1;
        TInsertSqlNode insertNode = (TInsertSqlNode)rootNode;

        if (this.sourcetokenlist.size() == 0){
            // subquery nested in other statements.
            this.setStartToken(insertNode.getStartToken());
            this.setEndToken(insertNode.getEndToken());
        }

        super.doParseStatement(psql);

        if (insertNode.hasInvalidColumnList()) {
            TSourceToken errorToken = insertNode.getInsertToken();
            if (errorToken != null) {
                parseerrormessagehandle(new TSyntaxError(errorToken,
                        "invalid INSERT column list", EErrorType.sperror,
                        TBaseType.MSG_ERROR_SYNTAX_ERROR, this));
            } else {
                parseerrormessagehandle(new TSyntaxError("INSERT", 0, 0,
                        "invalid INSERT column list", EErrorType.sperror,
                        TBaseType.MSG_ERROR_SYNTAX_ERROR, this, -1));
            }
            return TBaseType.MSG_ERROR_SYNTAX_ERROR;
        }

        this.insertToken = insertNode.getInsertToken();
        this.ignore = insertNode.getIgnore();
        this.priority_delayed = insertNode.getPriority_delayed();
        this.insertAll = insertNode.isInsertAll();
        this.insertFirst = insertNode.isInsertFirst();
        this.hiveInsertType = insertNode.getHiveInsertType();

        this.valueType = insertNode.getValueType();

        // Databricks supports INSERT OVERWRITE [LOCAL] DIRECTORY as well (Mantis 4646)
        if((dbvendor == EDbVendor.dbvhive)||(dbvendor == EDbVendor.dbvsparksql)||(dbvendor == EDbVendor.dbvdatabricks)){

            this.hiveInsertType = insertNode.getHiveInsertType();
            this.directoryName = insertNode.getDirectoryName();
            this.fileFormat = insertNode.getFileFormat();
            this.fileOptions = insertNode.getFileOptions();
            if (insertNode.getInsertSqlNodes() != null){
                for(int i=1;i<insertNode.getInsertSqlNodes().size();i++){
                    // i=1, start from the second insert statement, the first is this insert statement itself.
                    TInsertSqlStatement newInsert = new TInsertSqlStatement(this.dbvendor);
                    newInsert.rootNode = insertNode.getInsertSqlNodes().get(i);
                    newInsert.setFrameStack(this.getFrameStack());
                    newInsert.doParseStatement(psql);
                    this.getMultiInsertStatements().add(newInsert);
                }
            }
        }

        if (insertNode.cteList != null){
            this.setCteList( insertNode.cteList);
            this.getCteList().doParse(this, ESqlClause.cte);
        }


        if (insertNode.getTopClause() != null){
           insertNode.getTopClause().doParse(this,ESqlClause.top);
           this.setTopClause(insertNode.getTopClause());
        }

        if ((this.valueType != TBaseType.vt_values_multi_table)
                &&(insertNode.getTargetTable() != null)
            )
        {
           // System.out.println(insertNode.getTargetTable().toString());
           TTable lcTable = analyzeFromTable(insertNode.getTargetTable(),true);
           lcTable.setEffectType(ETableEffectType.tetInsert);
           setTargetTable(lcTable);
           this.getRelations().add(lcTable);
        }

        if (insertNode.getColumnList() != null){
            this.columnList = insertNode.getColumnList(); 
            TObjectName crf ;
            for (int i=0;i< insertNode.getColumnList().size();i++){
                crf =insertNode.getColumnList().getObjectName(i);
                // link this column to last 2 tables
                crf.setLocation(ESqlClause.insertColumn);
                getTargetTable().getObjectNameReferences().addObjectName(crf);
                getTargetTable().getLinkedColumns().addObjectName(crf);
                crf.setSourceTable(getTargetTable());
            }

            //insertNode.getColumnList().doParse(this,TBaseType.insertColumnClause);
        }

        if (insertNode.getOutputClause() != null){
            insertNode.getOutputClause().doParse(this,ESqlClause.output);
            this.setOutputClause(insertNode.getOutputClause());
        }

        switch(valueType){
            case TBaseType.vt_values:
                insertSource = EInsertSource.values;
                insertNode.getValues().doParse(this,ESqlClause.insertValues);
                this.values = insertNode.getValues();
                // check is count of value list is the same as column list
                if (columnList != null){
                    TMultiTarget mt;
                    TSourceToken st1;
                    // Hive/Impala INSERT ... (cols) PARTITION (p1, p2=v) VALUES (...):
                    // each dynamic partition column (no '=value') is supplied by the
                    // VALUES row, so it raises the expected value count by one.
                    // Scoped to the Hive family, where dynamic partition columns are
                    // part of the row; Oracle-style PARTITION (name) does not add values.
                    int dynamicPartitionCols = 0;
                    if ((this.dbvendor == EDbVendor.dbvimpala || this.dbvendor == EDbVendor.dbvhive
                            || this.dbvendor == EDbVendor.dbvsparksql)
                            && (getTargetTable() != null)
                            && (getTargetTable().getPartitionExtensionClause() != null)
                            && (getTargetTable().getPartitionExtensionClause().getKeyValues() != null)){
                        TExpressionList lcPartitionVals = getTargetTable().getPartitionExtensionClause().getKeyValues();
                        for(int k=0;k<lcPartitionVals.size();k++){
                            if (lcPartitionVals.getExpression(k).getExpressionType() != EExpressionType.assignment_t){
                                dynamicPartitionCols++;
                            }
                        }
                    }
                    for(int k=0;k<values.size();k++){
                        mt = values.getMultiTarget(k);
                        if (mt.getColumnList() == null) continue;
                        if (mt.getColumnList().size() == 0) continue;
                        if (mt.getColumnList().getResultColumn(0).getExpr() == null) continue;
                        if (mt.getColumnList().getResultColumn(0).getExpr().getExpressionType() == EExpressionType.subquery_t) continue;
                        if (mt.getColumnList().size() == columnList.size() + dynamicPartitionCols) continue;
                        if (mt.getColumnList().size() != columnList.size()){
                            st1 = mt.getColumnList().getStartToken();
                            TSyntaxError err = new TSyntaxError(st1.toString()
                                    ,st1.lineNo,st1.columnNo
                                    ,String.format("value count(%d) is not the same as column list(%d)",mt.getColumnList().size(),columnList.size())
                                    ,EErrorType.sperror ,TBaseType.MSG_ERROR_INSERT_VALUE_COLUMN_NUMBER_NOT_MATCH,this,st1.posinlist);
                            this.parseerrormessagehandle( err);
                        }
                    }
                }
                break;
            case TBaseType.vt_values_empty:
                insertSource = EInsertSource.values_empty;
                break;
            case TBaseType.vt_values_multi_table:
                insertSource = EInsertSource.values_multi_table;
                if (subQuery == null){
                    subQuery = new TSelectSqlStatement(this.dbvendor);
                    subQuery.rootNode = insertNode.getSubQueryNode();
                }
                subQuery.doParseStatement(this);

                break;
            case TBaseType.vt_query:
                insertSource = EInsertSource.subquery;
                if (subQuery == null){
                    subQuery = new TSelectSqlStatement(this.dbvendor);
                    subQuery.rootNode = insertNode.getSubQueryNode();
                }
                subQuery.doParseStatement(this);
                break;
            case TBaseType.vt_hive_query:
                insertSource = EInsertSource.hive_query;
                if (subQuery == null){
                    subQuery = new TSelectSqlStatement(this.dbvendor);
                    subQuery.rootNode = insertNode.getSubQueryNode();
                }
                subQuery.doParseStatement(this);
                break;
            case TBaseType.vt_default_values:
                insertSource = EInsertSource.default_values;
                break;
            case TBaseType.vt_execute:
                insertSource = EInsertSource.execute;
                executeStmt = new TMssqlExecute(EDbVendor.dbvmssql);
                executeStmt.rootNode = insertNode.getExecuteSqlNode();
                executeStmt.doParseStatement(this);
                break;
            case TBaseType.vt_values_function:
                insertSource = EInsertSource.values_function;
                insertNode.getFunctionCall().doParse(this,ESqlClause.insertValues);

                this.functionCall = insertNode.getFunctionCall(); 
                break;
            case TBaseType.vt_values_oracle_record:
                insertSource = EInsertSource.values_oracle_record;
                insertNode.getRecordName().doParse(this,ESqlClause.insertValues);
                this.recordName = insertNode.getRecordName();
                break;
            case TBaseType.vt_set_column_value:
                insertSource = EInsertSource.set_column_value;
                this.setColumnValues = insertNode.getSetColumnValues();
                this.setColumnValues.doParse(this,ESqlClause.insertValues);
                break;
            case TBaseType.vt_table:
                insertSource = EInsertSource.value_table;
                this.sourceValueTable = insertNode.getSourceValueTable();
                break;
        }

        if (insertNode.getInsertConditions() != null){
            this.valueType = TBaseType.vt_values_multi_table;
            this.insertConditions = insertNode.getInsertConditions();
            this.insertConditions.doParse(this,ESqlClause.insertValues);
            setTargetTable(insertConditions.getElement(0).getInsertIntoValues().getElement(0).getTable() );
        }

        if (insertNode.getInsertIntoValues() != null){
            this.valueType = TBaseType.vt_values_multi_table;
            this.insertIntoValues = insertNode.getInsertIntoValues();
            this.insertIntoValues.doParse(this,ESqlClause.insertValues);
            setTargetTable(insertIntoValues.getElement(0).getTable());
        }

        if (insertNode.getElseIntoValues() != null){
            this.valueType = TBaseType.vt_values_multi_table;
            this.elseIntoValues = insertNode.getElseIntoValues();
            this.elseIntoValues.doParse(this,ESqlClause.insertValues);
            setTargetTable(elseIntoValues.getElement(0).getTable());
        }

        if (insertNode.getReturningClause() != null){
            insertNode.getReturningClause().doParse(this,ESqlClause.returning);
            this.setReturningClause(insertNode.getReturningClause());
        }

        if (insertNode.getOnDuplicateKeyUpdate() != null){
            this.onDuplicateKeyUpdate = insertNode.getOnDuplicateKeyUpdate();
            onDuplicateKeyUpdate.doParse(this,ESqlClause.unknown);
        }

        // MySQL 8.0.20+ row alias for INSERT ... ON DUPLICATE KEY UPDATE
        this.insertRowAlias = insertNode.getInsertRowAlias();
        this.insertRowAliasColumnList = insertNode.getInsertRowAliasColumnList();

        // PostgreSQL ON CONFLICT clause
        if (insertNode.getOnConflictClause() != null){
            this.onConflictClause = insertNode.getOnConflictClause();
            onConflictClause.doParse(this, ESqlClause.unknown);
        }

        errorLoggingClause = insertNode.getErrorLoggingClause();
        return 0;
    }

    public void accept(TParseTreeVisitor v){
        v.preVisit(this);

        v.postVisit(this);
    }

    public void acceptChildren(TParseTreeVisitor v){
        v.preVisit(this);

        if (this.getCteList() != null){
            this.getCteList().acceptChildren(v);
        }

        if (this.getTopClause() != null){
            this.getTopClause().acceptChildren(v);
        }

        if (this.getTargetTable() != null){
            this.getTargetTable().acceptChildren(v);
        }

        if (this.getColumnList() != null){
            this.getColumnList().acceptChildren(v);
        }

        if (this.getOutputClause() != null){
            this.getOutputClause().acceptChildren(v);
        }

        switch(this.getValueType()){
            case TBaseType.vt_values:
                if (this.getValues() != null) {
                    this.getValues().acceptChildren(v);
                }
                break;
            case TBaseType.vt_values_empty:
                break;
            case TBaseType.vt_query:
                if (this.getSubQuery() != null) {
                    this.getSubQuery().acceptChildren(v);
                }
                break;
            case TBaseType.vt_values_function:
                if (this.getFunctionCall() != null) {
                    this.getFunctionCall().acceptChildren(v);
                }
                break;
            case TBaseType.vt_values_oracle_record:
                if (this.getRecordName() != null) {
                    this.getRecordName().acceptChildren(v);
                }
                break;
            case TBaseType.vt_set_column_value:
                if (this.getSetColumnValues() != null) {
                    this.getSetColumnValues().acceptChildren(v);
                }
                break;
            case TBaseType.vt_values_multi_table:
                // Oracle INSERT ALL/FIRST: traverse conditional inserts, unconditional inserts, else clause, and source subquery
                if (this.getInsertConditions() != null) {
                    this.getInsertConditions().acceptChildren(v);
                }
                if (this.getInsertIntoValues() != null) {
                    this.getInsertIntoValues().acceptChildren(v);
                }
                if (this.getElseIntoValues() != null) {
                    this.getElseIntoValues().acceptChildren(v);
                }
                if (this.getSubQuery() != null) {
                    this.getSubQuery().acceptChildren(v);
                }
                break;
            default:
                break;
        }

        if (this.onConflictClause != null){
            this.onConflictClause.acceptChildren(v);
        }

        if (this.getReturningClause() != null){
            this.getReturningClause().acceptChildren(v);
        }

        v.postVisit(this);
    }

    public void setErrorLoggingClause(TErrorLoggingClause errorLoggingClause) {
        this.errorLoggingClause = errorLoggingClause;
    }

    public void setHiveInsertType(EHiveInsertType hiveInsertType) {
        this.hiveInsertType = hiveInsertType;
    }

    public void setDirectoryName(TObjectName directoryName) {
        this.directoryName = directoryName;
    }

    public void setInsertConditions(TPTNodeList<TInsertCondition> insertConditions) {
        this.insertConditions = insertConditions;
    }

    public void setInsertIntoValues(TPTNodeList<TInsertIntoValue> insertIntoValues) {
        this.insertIntoValues = insertIntoValues;
    }

    public void setFunctionCall(TFunctionCall functionCall) {
        this.functionCall = functionCall;
    }

    public void setExecuteStmt(TMssqlExecute executeStmt) {
        this.executeStmt = executeStmt;
    }

    public void setRecordName(TObjectName recordName) {
        this.recordName = recordName;
    }

    public void setInsertSource(EInsertSource insertSource) {
        this.insertSource = insertSource;
    }

    public void setValueType(int valueType) {
        this.valueType = valueType;
    }

    public void setSetColumnValues(TResultColumnList setColumnValues) {
        this.setColumnValues = setColumnValues;
    }

    public void setOnDuplicateKeyUpdate(TResultColumnList onDuplicateKeyUpdate) {
        this.onDuplicateKeyUpdate = onDuplicateKeyUpdate;
    }
}