重庆分公司
重庆分公司，新征程启航
为企业提供网站建设、域名注册、服务器等服务
python使用jt400.jar包的方法-创新互联
这篇文章主要介绍了python使用jt400.jar包的方法，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。
代码如下
jt400helper.py
#coding=utf-8
import jpype
import os
class JT400Helper(object):
def __init__(self, server,username,pwd):
jvmpath=r"C:\Program Files\Java\jre1.8.0_60\bin\server\jvm.dll"
jarpath=r'd:\temp\jt400.jar'
jvmArg = "-Djava.class.path=%s" % jarpath
jpype.startJVM(jvmpath,jvmArg)
#jt400
AS400=jpype.JClass('com.ibm.as400.access.AS400')
CommandCall=jpype.JClass('com.ibm.as400.access.CommandCall')
ProgramCall=jpype.JClass('com.ibm.as400.access.ProgramCall')
SpooledFileList=jpype.JClass('com.ibm.as400.access.SpooledFileList')
AS400Text=jpype.JClass('com.ibm.as400.access.AS400Text')
AS400JDBCDriver=jpype.JClass('com.ibm.as400.access.AS400JDBCDriver')
#java
Connection=jpype.JClass('java.sql.Connection')
DatabaseMetaData=jpype.JClass('java.sql.DatabaseMetaData')
Statement=jpype.JClass('java.sql.Statement')
self.ResultSet=jpype.JClass('java.sql.ResultSet')
self.server,self.username,self.pwd = server,username,pwd
self.RJobLog=jpype.JClass('com.ibm.as400.resource.RJobLog')
self.AS400FTP=jpype.JClass('com.ibm.as400.access.AS400FTP')
self.IFSFile=jpype.JClass('com.ibm.as400.access.IFSFile')
self.ObjectDescription=jpype.JClass('com.ibm.as400.access.ObjectDescription')
self.ProgramParameter=jpype.JClass('com.ibm.as400.access.ProgramParameter')
self.DriverManager=jpype.JClass('java.sql.DriverManager')
self.DriverManager.registerDriver(AS400JDBCDriver())
self.system=AS400(server,username,pwd)
self.cc=CommandCall(self.system)
self.outqueue = SpooledFileList(self.system)
self.pc = ProgramCall(self.system)
def ShowIfs(self,ifspath):
ifs=self.IFSFile(self.system,ifspath)
print 'exists : ',ifs.exists()
print 'isDirectory : ',ifs.isDirectory()
print 'isFile : ',ifs.isFile()
fs=ifs.listFiles()
if len(fs)>0:
for f in fs:
print f.name
def ShowObj2(self,lib,obj):
od = self.ObjectDescription(system,lib,obj,"FILE")
print od.CHANGE_DATE_AND_TIME
def ShowObj(self,lib,obj,tmplib):
cmdstr = "DSPOBJD OBJ(%s/%s) OBJTYPE(*PGM) OUTPUT(*OUTFILE) OUTFILE(%s/OBJD)" % (lib,obj,tmplib)
msg = self.GetCmdMsg(cmdstr)
if msg == "":
cmdstr = "SELECT ODLBNM, ODOBNM, ODOBTP, ODOBAT,ODOBSZ , ODOBTX, ODLDAT, ODLTIM, ODOBSY, ODCRTU, ODJRST, ODJRNM, ODJRLB, ODJRIM, ODJREN,ODJRCN, ODJRDT, ODJRTI FROM %s.objd" % tmplib
self.GetSQLResult(cmdstr)
def SaveFieldDef(self,flib,file,tmplib,ofile):
cmdstr = "DSPFFD FILE(%s/%s) OUTPUT(*OUTFILE) OUTFILE(%s/FIELDDEF)" % (flib,file,tmplib)
msg = self.GetCmdMsg(cmdstr)
if msg == "":
cmdstr = "SELECT WHFLDI, WHFTXT, WHFLDT, WHFLDD, WHFLDP,WHFLDB, WHFOBO FROM %s.FIELDDEF WHERE WHFLDI <> ' ' ORDER BY WHFOBO" % tmplib
self.GetSQLResult(cmdstr,ofile)
def SaveJobLog(self,jobstr,ofile):
msg = self.GetJobLog(jobstr)
with open(ofile,'w') as f:
f.write(msg)
def GetJobLog(self,jobstr):
jobarr = jobstr.split('/')
jobnum,jobuser,jobname=jobarr[0],jobarr[1],jobarr[2]
return self.GetJobLogByNum(jobnum,jobuser,jobname)
def GetJobLogByNum(self,jobnum,jobuser,jobname):
joblog=self.RJobLog(self.system,jobname,jobuser,jobnum)
joblog.open()
joblog.waitForComplete()
num=joblog.getListLength()
msgs = []
for i in range(0,num):
qmsg=joblog.resourceAt(i)
msgs.append(qmsg.getAttributeValue("MESSAGE_TEXT"))
msg = '\n'.join(msgs)
return msg
def GetSQLResult(self,cmdstr,ofile=""):
connection = self.DriverManager.getConnection("jdbc:as400://" + self.server, self.username, self.pwd)
dmd = connection.getMetaData()
select = connection.createStatement(self.ResultSet.TYPE_SCROLL_SENSITIVE,self.ResultSet.CONCUR_UPDATABLE)
print cmdstr
rs = select.executeQuery(cmdstr)
strs = ""
cols = rs.getMetaData().getColumnCount()
while (rs.next()):
rowstrs = []
for i in range(1,cols+1):
value = rs.getString(i)
if ' ' in value:
value = '"%s"' % value
rowstrs.append(rs.getString(i))
strs+=','.join(rowstrs)+'\n'
connection.close();
if ofile <> "":
with open(ofile,'w') as f:
f.write(strs)
else:
print strs
def CallProgram(self,plib,pgm,paras):
#WRKACTJOB SBS(QUSRWRK) JOB(QZRCSRVS) - dump not work
#paras=["Y","12345"," "]
pgmparas=[]
for para in paras:
pgmparas.append(ProgramParameter(para))
print str(pgmparas.getInputData())
self.pc.setProgram("/QSYS.LIB/%s.LIB/%s.PGM" % (plib,pgm),pgmparas)
successfully = self.pc.run()
msg = ''
job = pc.getJob()
print pc.toString()
print job.toString()
if successfully <> True:
ml=self.pc.getMessageList()
for m in ml:
msg += m.getText() +'\n'
print msg
self.system.disconnectAllServices()
return msg
def GetCmdMsg(self,cmdstr):
msg = ''
print cmdstr
successfully = self.cc.run(cmdstr)
if successfully <> True:
ml=self.cc.getMessageList()
for m in ml:
msg += m.getText() +'\n'
print msg
return msg
def CheckObjExists(self,lib,file,type="*FILE"):
str = "CHKOBJ OBJ(%s/%s) OBJTYPE(%s)" % (lib,file,type)
return self.GetCmdMsg(str)
def DeleteObj(self,lib,file):
str = "DLTF FILE(%s/%s)" % (lib,file)
return self.GetCmdMsg(str)
def FileToIfs(self,lib,file,mem,ifspath):
# don't use RMVBLANK(*TRAILING) ,will cause numeric field contains blank characters error when put ifs to file
str = "CPYTOIMPF FROMFILE(%s/%s %s) TOSTMF('%s') MBROPT(*REPLACE) STMFCCSID(*STMF) RCDDLM(*CRLF) DTAFMT(*DLM) STRDLM(*NONE)" % (lib,file,mem,ifspath)
print lib,file,mem,"->",ifspath
return self.GetCmdMsg(str)
def IfsToFile(self,ifspath,lib,file,mem):
str = "CPYFRMIMPF FROMSTMF('%s') TOFILE(%s/%s %s) MBROPT(*REPLACE) RCDDLM(*CRLF) STRDLM(*NONE) FLDDLM(',') ERRRCDOPT(*REPLACE) RPLNULLVAL(*FLDDFT)" % (ifspath,lib,file,mem)
print ifspath,"->",lib,file,mem
return self.GetCmdMsg(str)
def FileToPc(self,lib,file,mem,ofile):
tmpifs = "QDLS/TEMP/%s.CSV" % mem
self.FileToIfs(lib,file,mem,tmpifs)
self.FtpGetIfsFile(tmpifs,ofile)
def PcToFile(self,ifile,lib,file,mem):
tmpifs = "QDLS/TEMP/%s.CSV" % mem
self.FtpPutIfsFile(ifile,tmpifs)
self.IfsToFile(tmpifs,lib,file,mem)
def FtpGetIfsFile(self,ifspath,ofile):
ftp=self.AS400FTP(self.system)
successfully = ftp.get(ifspath,ofile)
print ifspath,"->",ofile
return successfully
def FtpGetText(self,lib,srcf,mem,dest=r"d:\temp"):
ftp=self.AS400FTP(self.system)
target="/QSYS.LIB/%s.LIB/%s.FILE/%s.MBR" % (lib,srcf,mem)
if os.path.isdir(dest):
dest=os.path.join(dest,mem+".txt")
print target,"->",dest
successfully = ftp.get(target,dest)
return successfully
def FtpGetSavf(self,lib,savf,dest=r"d:\temp"):
ftp=self.AS400FTP(self.system)
target="/QSYS.LIB/%s.LIB/%s.SAVF" % (lib,savf)
# QUOTE SITE NAMEFMT 0 QGPL/QCLSRC.TEST
# QUOTE SITE NAMEFMT 1 /QSYS.lib/Libname.lib/Fname.file/Mname.mbr
ftp.issueCommand("quote site namefmt 1")
if os.path.isdir(dest):
dest=os.path.join(dest,savf+".SAVF")
# can not get it if not set data transfer type
ftp.setDataTransferType(1)
successfully = ftp.get(target,dest)
return successfully
def FtpPutIfsFile(self,ifile,ifspath):
ftp=self.AS400FTP(self.system)
successfully = ftp.put(ifile,ifspath)
print ifile,"->",ifspath
return successfully
def FtpPutText(self,ifile,lib,srcf,mem):
ftp=self.AS400FTP(self.system)
dest="/QSYS.LIB/%s.LIB/%s.FILE/%s.MBR" % (lib,srcf,mem)
successfully = ftp.put(ifile,dest)
print ifile,"->",lib,srcf,mem
return successfully
def GetOutQList(self,outqlib,outq):
print "OutQueue : %s/%s" % (outqlib,outq)
self.outqueue.setQueueFilter("/QSYS.LIB/%s.LIB/%s.OUTQ" % (outqlib,outq))
self.outqueue.setUserFilter("*ALL")
self.outqueue.openSynchronously()
enums=self.outqueue.getObjects()
i = 1
info = ""
while (enums.hasMoreElements()):
splf=enums.nextElement()
if(splf<>None):
strs=[]
strs.append("System :%s , File : %s , File Number : %s , Progarm :%s , Date : %s" % (splf.getStringAttribute(271),splf.getStringAttribute(104),splf.getIntegerAttribute(105).toString(),splf.getStringAttribute(272),splf.getStringAttribute(34)))
strs.append("Number/User/Job : %s/%s/%s" % (splf.getStringAttribute(60),splf.getStringAttribute(62),splf.getStringAttribute(59)))
strs.append("File Pages: %s , Print quality : %s , Printer device type : %s , Page size length : %d " % (splf.getIntegerAttribute(111).toString(),splf.getStringAttribute(48),splf.getStringAttribute(90),splf.getFloatAttribute(78).intValue()))
info += '\n'.join(strs)+'\n'
i+=1
self.system.disconnectAllServices()
print "total spool files : ",i
print info
def GetSpoolFile(self,sflib,sffile,sfname,sfjobnum,fnum,dest):
if self.CheckObjExists(sflib,sffile)<>"":
# IGCDTA parameter is for DBCS file
self.GetCmdMsg("CRTPF FILE(%s/%s) RCDLEN(160) IGCDTA(*YES)" % (sflib,sffile))
str = "CPYSPLF FILE(%s) TOFILE(%s/%s) JOB(%s) SPLNBR(%d)" % (sfname,sflib,sffile,sfjobnum,fnum)
msg = self.GetCmdMsg(str)
if msg == "":
self.FtpGetText(sflib,sffile,sffile,dest)
print "download successfully!"
def PutMsg(self,qlib,qname,msg): qstr = "/QSYS.LIB/%s.LIB/%s.DTAQ" % (qlib,qname) dataqueue=self.DataQueue(self.system,qstr) dataqueue.write(msg) def GetMsg(self,qlib,qname): qstr = "/QSYS.LIB/%s.LIB/%s.DTAQ" % (qlib,qname) dataqueue=self.DataQueue(self.system,qstr) dqdata = dataqueue.read() dqdatastr = 'No data' if dqdata <> None: dqdatastr = dqdata.getString() print dqdatastr return dqdatastr
if __name__ == '__main__':
pass感谢你能够认真阅读完这篇文章，希望小编分享的“python使用jt400.jar包的方法”这篇文章对大家有帮助，同时也希望大家多多支持创新互联成都网站设计公司，关注创新互联成都网站设计公司行业资讯频道，更多相关知识等着你来学习!
另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、网站设计器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
网页名称：python使用jt400.jar包的方法-创新互联
浏览地址：http://cqcxhl.com/article/cocsdp.html