oracle

#获取数据库连接
def Avaiable(self):
try:
conn=cx_Oracle.connect(self.Oracle_Conn)
except cx_Oracle.DatabaseError as msg:
logging.exception(msg)
print(msg)
return conn

#数据查询操作
def DataSelect(self,sql):
db=self.Avaiable()
try:
cur=db.cursor()
res = cur.execute(sql)
result=res.fetchall()
except Exception as e:
logging.exception(e)
print(e)
finally:
cur.close()
db.close()
return result

sql_preclose_1 = 'select s_info_windcode,trade_dt,s_dq_preclose from ' + gl.TABLE_PRICES +
' where trade_dt between %s and %s order by trade_dt desc' %(date_list[-1], date_list[0])
preclose_1 = pd.DataFrame(oracle.DataSelect(sql_preclose_1))
preclose = self._get_transform_df(preclose_1)