python 实现oracle查询结果入gp数据库片断

def Str_To_gp(self,table_name,Res):
    self.logger.info('开始写入内存')
    output = StringIO()
    writer = csv.writer(output, delimiter='^',quoting =csv.QUOTE_MINIMAL)
    writer.writerows(Res)
    self.logger.info('写入内存完成')
    #过虑数据返回结果中带有\,\u0000,"特殊字符
    output1 = output.getvalue().replace('\\','/').replace('\u0000','').replace('"','')
    try:
        gp_conn = self.pool.connection()
        gp_cur=gp_conn.cursor()
        self.logger.info('数据开始写入库')
        gp_cur.copy_from(StringIO(output1), table_name,sep='^',null='',size = 8192)
        gp_conn.commit();
        self.logger.info('入库完成')
        return True
    except (Exception) as e:
        self.logger.warning("导入报错%s"%e)
        gp_conn.rollback()
        return False
    finally:
        #释放数据库连接
        self.__reset_conn(gp_conn,gp_cur)