Python-сообщество

В ODI создаю процедуру на Питоне. Идет подключение к базе данных, где осуществляется проверка таблицы на присутствие записей. Если таблица не пустая данные записываются в файл на лок. компьютере. После подключения на строке rs=executeQuery(sql) выдает ошибку. Есть подозрение что должно использоваться не executeQuery(sql) а что то другое.

def prepareSQL():
con=odiRef.getJDBCConnection(“SRC”)
sql='''<%=odiRef.getOption(“SQL query”)%>'''
sql=sql.decode('cp1251')
return con.prepareStatement(sql)

prep = prepareSQL()

rs=executeQuery(sql) — ругаеться на эту строку

if(not rs.next()):
prep.close()
else:
f = open('C:\Temp\droptab.txt', ‘a’)
f.write(rs)
prep.close()
f.close()