从oracle获取数据插入mysql的脚本,大神帮忙看一下代码哪里有问题
sql语句:Insert_dblinkSql = insert into kt_collectoracle (owner,db_link,username,host,created) values ('%s','%s','%s','%s','%s')
def insertMysqlseghist(self,oracleDatadb,oracleDatacur,OracleDataTuple):
for OracleData in OracleDataTuple:
try:
oracleDatacur.execute(self.Insert_dblinkSql%(OracleData[0],
OracleData[1],OracleData[2],OracleData[3],OracleData[4]))
oracleDatadb.commit()
except Exception as e:
oracleDatadb.rollback()
logger_data_message.debug('error: '+str(e)+'\n')
根据代码和错误信息,可以看到问题出在 insertMysqlseghist 函数中。具体来说,这个函数定义时只有 3 个参数(self、oracleDatadb 和 oracleDatacur),但是在调用时却传入了 4 个参数(self、oracleDatadb、oracleDatacur 和 OracleDataTuple)。这样的话,Insert_dblinkSql 中的 %s 占位符无法正确地与 OracleDataTuple 中的数据匹配,从而报出了错误信息:insertMysqlseghist() takes 4 positional arguments but 5 were given。
为了解决这个问题,你需要修改 insertMysqlseghist 函数的定义,让它接受 4 个参数,或者在函数调用时只传入前 3 个参数。另外,你也需要检查 OracleDataTuple 中的数据是否与 Insert_dblinkSql 中的占位符顺序和个数一致,否则可能会引起其他的错误。