rs6000¤ÎWiki

from java.io import *
from java.lang  import *
from com.ibm.as400.access import *
from com.ziclix.python.sql import zxJDBC
from com.ziclix.python.sql import PyConnection

def runCom(as,c):
    commandCall = CommandCall(as)
    print c
    commandCall.run(c)
    ml = commandCall.getMessageList()
    for m in ml:
        System.out.println(m.getID() + ":" + m.getText())

def runSql(as,sql):
    try:
        datasource = AS400JDBCDataSource(as)
        connection = datasource.getConnection()
        con = PyConnection(connection)
    except zxJDBC.DatabaseError, e:
        print "¥Ç¡¼¥¿¥Ù¡¼¥¹¤ËÀܳ¤Ç¤­¤Þ¤»¤ó¤Ç¤·¤¿"
        print "¸¶°ø¡§" + e[0]
        sys.exit(1)

    cur = con.cursor()
    cur.execute(sql)
    rset = cur.fetchall()
    cur.close()
    con.close()
    return rset