config.py
# 数据库测试环境 name = '***' password = '******' host_port_sid = '10.**.*.**:1521/bidbuat'
OracleOperation.py
import cx_Oracle import configclass OracleOperation(object):# 执行下面的execute_sql方法时会自动执行该初始化方法进行连接数据库def __init__(self):# 建立连接self.conn = cx_Oracle.connect(config.name, config.password, config.host_port_sid)# 创建游标self.cursor = self.conn.cursor()def execute_sql(self, sql):"""执行sql语句,并commit提交:param sql:需要执行的sql语句:return:"""self.cursor.execute(sql)self.conn.commit()def get_data(self):"""获得查询数据:return: 返回查到的数据"""data = self.cursor.fetchall()return datadef close_oracle(self):# 关闭游标 self.cursor.close()# 关闭数据库连接self.conn.close()