# -*- coding: utf-8 -*-

import java.sql as sql

v_BatchName = "Batch_" + str(fdmContext["LOCATION"])

v_sql_insert = """
INSERT INTO AIF_OPEN_INTERFACE (
BATCH_NAME,
YEAR,
PERIOD,
PERIOD_NUM,
DATAVIEW,
AMOUNT,
COL01,
COL02,
COL03,
COL04,
COL05,
COL06,
COL07,
COL08,
COL09,
COL10,
COL11,
COL12,
COL13,
COL14,
COL15,
COL16,
COL17,
COL18,
COL19,
COL20
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
"""

sourceConn = sql.DriverManager.getConnection("jdbc:oracle:thin:@tsp00019.corpo.toaz.ru:1521:HYPTEST", "EPM_ERPI", "EPM_ERPI");

v_sql_select = "SELECT * FROM DWH.TURNOVER_REST_FACT WHERE rownum < 101"
stmt = sourceConn.prepareStatement(v_sql_select)
stmtRS = stmt.executeQuery()
while(stmtRS.next()):
    params = [ v_BatchName,
        int(stmtRS.getString("YEARS")),
        stmtRS.getString("YEARS") + "-" + stmtRS.getString("PERIODS"),
        int(stmtRS.getString("YEARS") + stmtRS.getString("PERIODS")),
        "YTD",
        stmtRS.getBigDecimal("AMOUNT"),
        stmtRS.getString("BUDGETTYPES"), #COL01
        stmtRS.getString("CURRENCY"),    #COL02
        stmtRS.getString("VERSIONS"),    #COL03
        stmtRS.getString("COMBI_1"),     #COL04
        stmtRS.getString("COMBI_2"),     #COL05
        stmtRS.getString("COMBI_3"),     #COL06
        stmtRS.getString("COMBI_4"),     #COL07
        stmtRS.getString("MEASURES"),    #COL08
        stmtRS.getString("BUDGETITEMS"), #COL09
        stmtRS.getString("CFO"),         #COL10
        stmtRS.getString("CS06_MC_NAME"),           #COL11
        stmtRS.getString("CS29_USL_NAME"),          #COL12
        stmtRS.getString("CS32_OSTR_NAME"),         #COL13
        stmtRS.getString("CS51_66SCH_NAME"),        #COL14
        stmtRS.getString("CS60_AKKREDITIVI_NAME"),  #COL15
        stmtRS.getString("CS61_VEKSEL_NAME"),       #COL16
        stmtRS.getString("CS73_DOGOVORI_NAME"),     #COL17
        stmtRS.getString("CS74_DO_NAME"),           #COL18
        stmtRS.getString("CS76_OS_NAME")[:75],           #COL19
        stmtRS.getString("ID_PROVODKA")]            #COL20

    fdmAPI.executeDML(v_sql_insert, params, False)
fdmAPI.commitTransaction()
stmtRS.close()
stmt.close()
sourceConn.close()