2019. szeptember 6., péntek

ODI hasznos sql-ek

--- ODI KM helye WIN: c:\Oracle\ODI122\odi\sdk\xml-reference\ACT_Add_Alternate_Key.xml



--- munkamenet futtáskor futtatott SQL maszk

select sess_no, def_txt as sqltxt, NNO,               NB_RUN,            SCEN_TASK_NO,             TASK_BEG,         TASK_END,                TASK_DUR,        TASK_STATUS, NB_ROW, NB_INS

from ebh_odi_repo.SNP_sess_task_log where 1=1

and sess_no = 39

and def_txt is not null and def_txt like 'insert%'

--  order by length(def_txt) desc

-----------------

--- munkamenethez tartozó paraméterek

select sess_no, startup_variables as act_vars, SESS_NAME, SESS_BEG, SESS_END, SCEN_NAME, NB_ROW, NB_INS, NB_UPD, NB_DEL, NB_ERR, SB_NO

from EBH_ODI_REPO.SNP_SESSION

where sess_no = 39





import groovy.sql.Sql

import oracle.odi.domain.project.finder.IOdiVariableFinder

import oracle.odi.domain.project.finder.IOdiSequenceFinder



import groovy.swing.SwingBuilder



tme = odiInstance.getTransactionalEntityManager()

varList = ((IOdiVariableFinder) tme.getFinder(OdiVariable.class)).findAll()

seqList = ((IOdiSequenceFinder) tme.getFinder(OdiSequence.class)).findAll()

actVarMap = new HashMap<String,String>()



// SQL

url = "jdbc:oracle:thin://@Aszerver:1152/D10"

user = "REPO"

pw = "Ejelszo"

sql = Sql.newInstance(url, user, pw, "oracle.jdbc.driver.OracleDriver")



// ehhez a sessionhoz tartozó logot dolgozza fel (régi működés)

// *** ha -1, akkor az sqltxt változóban megadott stringet dolgozza fel ***

tmp_sess_id = 11611 //-1

actual_vars_fl = true // ha igen, akkor az aktuális paraméterekkel helyettesít, egyébként az alapértelmezettekkel



if ( tmp_sess_id < 0 ) {



  sqltxt = """



  """



} else {



  stmt = """

         select def_txt as sqltxt

         from SNP_sess_task_log

         where sess_no = :p_sess_id

           and def_txt is not null

         order by length(def_txt) desc

         """;



  stmt2 = """

        select startup_variables as act_vars

        from EBH_ODI_REPO.SNP_SESSION

        where sess_no = :p_sess_id

        """;



  sqltxt = sql.firstRow(stmt, [p_sess_id: tmp_sess_id]).sqltxt.getAsciiStream().getText() // SQL log

  tmp = sql.firstRow(stmt2, [p_sess_id: tmp_sess_id]).act_vars.getAsciiStream().getText() // aktuális paraméterek

  sql.close()



  for ( l in tmp.split('\n') ) {



    tmp2 = l.split('=')



    try {

      actVarMap.put(tmp2[0], tmp2[1]) 

    } catch (Exception e) { null }

  }



}







sqltxt = sqltxt.replace(':', '')

sqltxt = sqltxt.replace('#', '')





if ( actual_vars_fl == true ) {

 

    // legújabb működés

    // aktuális változók

    for ( i in actVarMap ) {

 

      from = i.key

      to = i.value + ' /*' + i.key + '*/'

      sqltxt = sqltxt.replaceAll('\\b' + from + '\\b', to) // regexp word boundary check

    }



}

else {

    // változók

    for ( i in varList ) {

   

      from = i.getQualifiedName()

   

    /* a régi KM modulhoz kellett

      if ( from == 'GLOBAL.P_EFFECTIVE_LOAD_DATE' ) {

        pre = "to_date('"

        post = "', 'YYYYMMDDHH24MISS')"

      } else {

        pre = ''

        post = ''

      }

    */

   

      //to = pre + i.getDefaultValue() + post + ' /*' + i.getQualifiedName() + '*/'

      to = i.getDefaultValue() + ' /*' + i.getQualifiedName() + '*/'

   

      //sqltxt = sqltxt.replace(from, to)

      sqltxt = sqltxt.replaceAll('\\b' + from + '\\b', to) // regexp word boundary check

    }

}



// szekvenciák

for (i in seqList ) {



  from = i.getQualifiedName() + '_NEXTVAL'

  to = 'EBH_DW.' + i.getNativeSequenceName() + '.nextval'



  //sqltxt = sqltxt.replace(from, to)

  sqltxt = sqltxt.replaceAll('\\b' + from + '\\b', to) // regexp word boundary check



}



print sqltxt + '\n;\n\n'



def swing = new SwingBuilder()







// ez nem is kell

swing.edt{

    frame( title: 'Session: ' + tmp_sess_id, pack:true, show:true ){

        panel(){

            scrollPane( preferredSize:[800, 800] ){

                editorPane( contentType: ("text/sql"), text: sqltxt)

            }

        }

    }

}


------

import groovy.sql.Sql

import java.sql.Driver

//---------------------

class kl_db_minta_csere {

   static void main(String[] args) {

//-------------------

def words = []

def readies = []

def di_words =[][]

//-------------------

try {

def driver = Class.forName('oracle.jdbc.OracleDriver').newInstance() as Driver

def props = new Properties()

props.setProperty("user", "user")

props.setProperty("password", "KLjelszo")

def conn = driver.connect("jdbc:oracle:thin:@ora:1152: T10", props)

def sql = new Sql(conn)

def sql_parancs ="""

Select a.object_name,

       a.object_long_name,

       se.startup_variables,

       st.def_txt,

       st.error_message     As task_error

  From ebh_odi_repo.snp_step_log      s,

       ebh_meta.mt_lp_all_executions  a,

       ebh_odi_repo.snp_step_report   sr,

       ebh_odi_repo.snp_scen          sc,

       ebh_odi_repo.snp_session       se,

       ebh_odi_repo.snp_sess_task_log st

Where s.sess_no = a.external_session_id(+)

   And s.sess_no = sr.scen_run_no

   and SR.SCEN_NO = SC.SCEN_NO(+)

   And s.step_beg > Date '2019-03-16'

   And s.sess_no = se.sess_no

   and S.SESS_NO = ST.SESS_NO

   and sc.scen_name like 'MAP_B%'

   and st.col_conn_name ='EDW' and st.def_conn_name ='EDW'

   and DEF_TXT like 'insert %'

   and OBJECT_TYPE_NAME ='SCENARIO'

   and s.nb_row = 22065

   """

//--------------------------

def results = sql.firstRow( sql_parancs )  ///sql.rows( sql_parancs )

def parameters = " "

def sql_nyers = " "

sql_nyers = results['def_txt'].asciiStream.text                           /// sql (CLOB tipusu mező miatt konverzió

parameters = results['startup_variables'].asciiStream.text.split(/\n/)    /// parameter tömbösítás



//---------------------

   parameters.each { parameter ->

//      println(parameter)

      di_words.add(parameter.split(/=/))

   }



//--------------------

      di_words.each { csere ->

        if ( csere[0].length() > 1 ){

            sql_nyers = sql_nyers.replaceAll(":" + csere[0], csere[1])

//            print( csere[0])

//            print(' --> ')

//            println( csere[1])

        }     

      }

      readies.add(sql_nyers + "\n")

 



//------------------------

/*

readies.each {

    println it    //// tartalmának kiírása

}

*/

///------------------------



def file = new File("out2.txt")

file.write ""

readies.each {

   file.append(it)

}

//---------------------------

println file.text  //// file tartalmának kiírása

//---------------------------



conn.close()



} catch(Exception ex) {

         println("HIBA: az adat nincs meg");

}



/// Erőforrás felszabadítás

//sql.close()



}

}


-----


 Select a.object_name,

       a.object_type_name,

       a.object_long_name,

       sr.step_name,

       sc.scen_name,

       s.step_beg,

       s.step_end,

       s.step_dur,

       s.step_status,

       s.nb_row,

       s.error_message      As error_msg,

       se.startup_variables,

       s.sess_no,

       a.id,

       a.parent_id,

       a.sid,

       a.status,

       a.error_message,

       a.record_count,

       sr.lschema_name,

       sr.mod_code,

       sr.table_name,

       sr.res_name,

       st.task_name3,

       st.col_conn_name,

       st.def_conn_name,

       st.task_beg,

       st.task_end,

       st.task_status,

       st.nb_row,

       st.def_txt,

       st.error_message     As task_error

  From ebh_odi_repo.snp_step_log      s,

       ebh_meta.mt_lp_all_executions  a,

       ebh_odi_repo.snp_step_report   sr,

       ebh_odi_repo.snp_scen          sc,

       ebh_odi_repo.snp_session       se,

       ebh_odi_repo.snp_sess_task_log st

Where s.sess_no = a.external_session_id(+)

   And s.sess_no = sr.scen_run_no

   and SR.SCEN_NO = SC.SCEN_NO(+)

   And s.step_beg > Date '2019-03-16'

   And s.sess_no = se.sess_no

   and S.SESS_NO = ST.SESS_NO

   and sc.scen_name like 'MAP_BPI_T%'

   and st.col_conn_name ='EDW' and st.def_conn_name ='EDW'

   and DEF_TXT like 'insert %'

   and OBJECT_TYPE_NAME ='SCENARIO'

   and sr.table_name ='BPI_FE_BEA_TRAN_HISTORY'





def words = []

def readies = []

def di_words =[][]

//-------------------

new File( 'star_values.txt' ).eachLine { ///// line ->  || it

                                         ///// words << it || words.add(it)

    if ( ( it.substring(0,1) == '"') && (it) )  {

       words.add(it.substring(1,))       // Idézőjel kezdet kihagyása

       di_words.add(it.substring(1,).split(/=/))

    } else {   

       words.add(it)

       di_words.add(it.split(/=/))

    }

}

//--------------------

new File( 'def_txt.txt' ).eachLine { line ->

      di_words.each { csere ->

        if ( csere[0].length() > 1 ){

            line = line.replaceAll(":" + csere[0], csere[1])

        }     

      }

      readies.add(line + "\n")

}

readies.each {

    println it

}

///------------------------



def file = new File("out.txt")

file.write ""

readies.each {

  //// file.write "First line\n"

  //// file << "Second line\n"

  //// file.append("hello\n")

   file.append(it)

}

//---------------------------

println file.text

Django alapok

Django installálás és használatba vétel Release naptár : (forrása  https://www.djangoproject.com/download/ ) Lépések: rem install conda inst...