Analytics Software

Hi All,

In my Process i need to convert my error table data into csv file,my data is converted as csv file by using OdisqlUnload function,but the column headers are not converted,i use another procedure for converting column headers but iam getting below error ...

com.sunopsis.sql.SnpsMissingParametersException: Missing parameter string.find, string.find
SQL: import string import java.sql as sql import java.lang as lang import re sourceConnection = odiRef.getJDBCConnection("SRC") output_write=open('C:/Oracle/Middleware/Oracle_ODI2/oracledi/pro/PRO.txt','r+') myStmt = sourceConnection.createStatement() my_query = "select * FROM E$_LOCAL_F0911Z1" my_query=my_query.upper() if string.find(my_query, '*') > 0: myRs = myStmt.executeQuery(my_query) md=myRs.getMetaData() collect=[] i=1 while (i <= md.getColumnCount()): collect.append(md.getColumnName(i)) i += 1 header=','.join(map(string.strip, collect)) elif string.find(my_query,'||') > 0: header = my_query[7:string.find(my_query, 'FROM')].replace("||','||",',') else: header = my_query[7:string.find(my_query, 'FROM')] print header old=output_write.read() output_write.seek(0) output_write.write (header+'\n'+old) sourceConnection.close() output_write.close()


And i used below code for converting.......



import string


import java.sql as sql


import java.lang as lang


import re

sourceConnection = odiRef.getJDBCConnection("SRC")


output_write=open('C:/Oracle/Middleware/Oracle_ODI2/oracledi/pro/PRO.txt','r+')


myStmt = sourceConnection.createStatement()


my_query = "select FROM E$_COMPANY"*


*my_query=my_query.upper()*


*if string.find(my_query, '*') > 0:*


*myRs = myStmt.executeQuery(my_query)*


*md=myRs.getMetaData()*


*collect=[]*


*i=1*


*while (i <= md.getColumnCount()):*


*collect.append(md.getColumnName(i))*


*i += 1*




*header=','.join(map(string.strip, collect))*


*elif string.find(my_query,'||') > 0:*


*header = my_query[7:string.find(my_query, 'FROM')].replace("||','||",',')*


*else:*


*header = my_query[7:string.find(my_query, 'FROM')]*




*print header*


*old=output_write.read()*


*output_write.seek(0)*


*output_write.write (header+'\n'+old)*




*sourceConnection.close()*


*output_write.close()*

Any one can you help regarding this

Edited by: 30021986 on Oct 1, 2012 6:04 PM