oracledb.py 文件源码

def __init__(self, ip = IP, port = PORT, db = DB, user_name = USER_NAME, user_pass = USER_PASS):
        super(OracleDB, self).__init__()

        if STOP_ORCL:
            return

        if not hasattr(self,'conn'):
            try:
                self.conn = cx_Oracle.connect(user_name, user_pass, '%s:%d/%s'%(ip, port, db))#, threaded=True,events = True)
                self.cursor = self.conn.cursor()
            except Exception as e:
                raise
            else:
                log.debug('?????? %s'%db)