OraCommon.py

程式列表

from oracle.jdbc.driver import OracleDriver from java.sql import DriverManager from OraLib import * class OraCommon: myOraConnection = None def __init__(self, OraConnection): self.myOraConnection = OraConnection def doQueryDEPT(self): myOraStatement = self.myOraConnection.createStatement() myOraResultSet = myOraStatement.executeQuery("SELECT * FROM DEPT ORDER BY DEPTNO") while (myOraResultSet.next()): print myOraResultSet.getInt(1), '\t', \ myOraResultSet.getString(2).encode("iso-8859-8"), '\t', \ myOraResultSet.getString(3).encode("iso-8859-8") myOraStatement.close() def doQueryEMP(self): myOraStatement = self.myOraConnection.createStatement() myOraResultSet = myOraStatement.executeQuery("SELECT * FROM EMP ORDER BY EMPNO") while (myOraResultSet.next()): print myOraResultSet.getInt(1), '\t', \ myOraResultSet.getString(2).encode("iso-8859-8"), '\t', \ myOraResultSet.getString(3).encode("iso-8859-8"), '\t', \ myOraResultSet.getInt(4), '\t', \ myOraResultSet.getDate(5), '\t', \ myOraResultSet.getFloat(6), '\t', \ myOraResultSet.getFloat(7), '\t', \ myOraResultSet.getInt(8) myOraStatement.close() def doDeleteDEPT_EMP(self): myOraStatement = self.myOraConnection.createStatement() for DEPTNO in (90, 91, 92, 93, 94, 95, 96, 97, 98, 99): mySQL = 'DELETE FROM EMP WHERE DEPTNO=' + str(DEPTNO) myOraResultSet = myOraStatement.execute(mySQL) mySQL = 'DELETE FROM DEPT WHERE DEPTNO=' + str(DEPTNO) myOraResultSet = myOraStatement.execute(mySQL) print DEPTNO myOraStatement.close() def doInsertDEPT_EMP(self): for DEPTNO in (90, 91, 92, 93, 94, 95, 96, 97, 98, 99): mySQL = "{CALL STRESSTEST0(" + str(DEPTNO) + ")}" try: myCallableStatement = self.myOraConnection.prepareCall(mySQL) myCallableStatement.executeUpdate() print DEPTNO except Exception: pass