zOs/REXX/SQLS

/* copy sqlS   begin **************************************************
               sqlStmts **********************************************/
sqlConClass_S: procedure expose m.
    if m.sqlS_ini == 1 then
        return m.class_SqlConnS
    m.sqlS_ini = 1
    call sqlConClass_R
    call scanWinIni
    return classNew('n SqlConnS u SqlConn', 'm',
        , "sqlsOut return sqlsOutSql(rdr, retOk, ft)")
endProcedure sqlConClass_S

/*** execute sql's in a stream (separated by ;) and output as tab    */
sqlStmts: procedure expose m.
parse arg sqlSrc, retOk, wOpt, sOpt, fOpt
   return sqlsOut(scanSqlStmtRdr(sqlSrc, wOpt, sOpt), retOk, fOpt)
endProcedure sqlStmts

/*--- output sql as table -------------------------------------------*/
sql2tab: procedure expose m.
parse arg src, retOk, ft
    cx = m.sql_defCurs
    if ft == '' then
        ft = sqlFTabOpts(fTabReset('SQL.'cx'.2Tab', 'c 1','1 c' , '-'))
    else if objClass(ft) == m.class_s then
        ft = sqlFTabOpts(fTabReset('SQL.'cx'.2Tab', 'c 1','1 c','-'ft))
    call sqlQuery cx, in2str(src, ' '), retOk
    call sqlFTab ft, cx
    return
endProcedure sql2tab

/*--- result of each sql read from rdr to out
           oo='a' autoTab, 't'=sqlTab, 'o'=object, 'c'=csv ----------*/
sqlsOut: procedure expose m.
parse arg rdr, retOk, ft
    if ft = '' then
        ft = sqlFTabOpts(fTabReset(sql_outFTab, 'c 1', , 'a'))
    else if objClass(ft) == m.class_s then
        ft = sqlFTabOpts(fTabReset(sql_outFTab, 'c 1', , ft))
    interpret classMet(m.sql_ConCla, 'sqlsOut')

sqlsOutSql: procedure expose m.
parse arg rdr, retOk, ft
    m.sql_errRet = 0
    cx = m.sql_defCurs
    r = jOpen(in2file(rdr), '<')

    do while jRead(r)
        sqlC = sqlExecute(cx, m.r, retOk)
        if m.sql_errRet then
            leave
        if m.sql.cx.resultSet == '' | m.sql.cx.fun == 'CALL' then
            if m.ft.verbose then
                call outNl(m.sql_HaHi ,
                    || sqlMsgLine(sqlC, m.sql.cx.updateCount, m.r))
        if m.sql.cx.resultSet == '' then
             iterate
        do until \ sqlNextResultSet(cx) | m.sql_errRet
            m.sql.cx.sqlClosed = 0
            call sqlFTab fTabResetCols(ft), cx
            if m.ft.verbose & m.sql.cx.sqlClosed then/* sql finished*/
                call out sqlMsgLine(m.sql.cx.fetchCount ,
                        'rows fetched', , m.r)
            end
        end
    call jClose r
    if m.sql_errRet then do
        call sqlClose cx, '*'
        say 'sqlsOut terminating because of sql error'
        end
    return \ m.sql_errRet
endProcedure sqlsOutSql

/*--- sql hook ------------------------------------------------------
      hook paramter db | windowSpec |  db? , windowSpec? , fTabOpt?
          db: dbSys, rz/dbSysAbkürzung, 1 oder 2 chars
          windowSpec: 0 = variable len, 123 = window123
                      default spufi = window72 ---------------------*/
wshHook_S: procedure expose m.
parse arg m, spec
    parse var spec ki 2 rest
    call errSetSayOut 'so'
    if ki == '/' then do
        inp = m.m.in
        end
    else do
        call compIni
        if pos(ki, m.comp_chKind) <= 0 then do
            ki = '='
            rest = spec
            end
        inp = wshCompile(m, ki)
        end
    if pos('@',rest)>0  then call err 'was ist das??????' spec
    if words(rest)==1 & (datatype(rest, 'n') | pos('@',rest)>0) then
         rest = ','rest
    parse var rest dbSy ',' wOpt ',' fOpt
    d2 = ii2rzDb(dbSy, 1)
    call sqlConnect d2
    m.m.info = 'runSQL'
    if \ sqlStmts(inp, 'rb ret', strip(wOpt), , strip(fOpt)) then do
        m.m.end = 1
        m.m.exitCC = 8
        end
    call sqlDisConnect
    return ''
endProcedure wshHook_s

/*--- wshHook for sqlRdr read from dd wsh --------------------------*/
wshHook_sqlRdr: procedure expose m.
parse arg m, dbSys
    call errSetSayOut 'so'
    call sqlIni
    m.sql_retOk = m.sql_retOk 'rb ret'
    m.sql_errRet = 0
    call sqlConnect dbSys
    if \ m.sql_errRet then
        r = sqlRdr(m.m.in)
    if \ m.sql_errRet then
        call jOpen r, '<'
    if \ m.sql_errRet then do
        call pipeWriteAll r
        call jClose r
        end
    if m.sql_errRet then do
        call out 'from' sysvar(sysnode) mvsVar(sysName) m.sql_ConRzdb
        m.m.end = 1
        m.m.exitCC = 4
        end
 /* else
        call out sqlMsgLine(m.r.bufI0 'rows fetched', , m.r.srcTxt) */
    call sqlDisConnect
    return ''
endProcedure wshHook_sqlRdr

/*--- wshHook for sqlsOut read from dd wsh --------------------------*/
wshHook_sqlsOut: procedure expose m.
parse arg m, dbSys oo retOk
    call errSetSayOut 'so'
    call sqlIni
    m.sql_retOk = m.sql_retOk 'rb ret'
    m.sql_errRet = 0
    call sqlConnect dbSys
    if oo == 'a' | oo == 't' then do
        myOut = m.j.out
        m.myOut.truncOk = 1
        end
    if \ m.sql_errRet then
        call sqlsOut m.m.in, retOk, oo
    if m.sql_errRet then do
        call out 'from' sysvar(sysnode) mvsVar(sysName) m.sql_ConRzdb
        m.m.end = 1
        m.m.exitCC = 4
        end
    call sqlDisConnect
    return ''
endProcedure wshHook_sqlsOut
/* copy sqlS   end   *************************************************/