Я хочу передать идентификаторы (в sampledata.csv) в качестве аргумента в запросе SQL и извлечь идентификаторы и соответствующий CREATED_TIME из таблицы Oracle.
sampledata.csv (у меня больше 5Kзаписей в исходном файле)
ID
909650124
905901916
908667528
907963151
908610211
907671207
909164586
905595841
908785942
908785942
Данные таблицы БД
ID CREATED_DATE
909650124 03/18/2019 04:37:43 PM
905901916 03/15/2019 11:20:55 PM
908667528 03/15/2019 02:37:16 PM
907963151 03/08/2019 03:19:09 PM
908610211 03/08/2019 03:06:17 PM
907671207 03/07/2019 01:06:58 AM
909164586 03/06/2019 01:42:20 AM
905595841 03/04/2019 11:24:31 PM
908785942 03/03/2019 10:09:40 PM
908785942 03/01/2019 07:51:51 AM
Я попытался извлечь данные с помощью простого оператора SQL, используя Toad, но записи больше 10 КБ, и я хочуавтоматизируйте его.
скрипт first.py
import os
import csv
import cx_Oracle
conn = cx_Oracle.connect(user='USER_NAME', password='USER_PASSWORD', dsn=r'DSN_STRING')
db = conn.cursor()
def main():
f = open("sampledata.csv")
reader = csv.reader(f)
for id in reader:
db.execute("SELECT id, created_date FROM userdata_table WHERE merch_order_id = :id",
{'id': id})
print(f"{id} {created_date}")
conn.close()
if __name__ == "__main__":
main()
скрипт second.py
import os
import csv
import cx_Oracle
from sqlalchemy import create_engine
from sqlalchemy.orm import scoped_session, sessionmaker
engine = create_engine(r'oracle+cx_oracle://USER_NAME:USER_PASSWORD@DSN_STRING'))
db = scoped_session(sessionmaker(bind=engine))
def main():
f = open("sampledata.csv")
reader = csv.reader(f)
print(reader)
for id in reader:
db.execute("SELECT id, created_date FROM userdata_table WHERE id = :id",{'id': id})
print(f"{id} {created_date}")
if __name__ == "__main__":
main()
В приведенном выше коде я попытался прочитать идентификаторы в файле CSVа затем передал идентификаторы в оператор SQL, но ошибка ниже.Может кто-нибудь, пожалуйста, помогите мне в этом, чтобы понять, где это пошло не так и как это исправить?
=======================================================================
cx_Oracle.DatabaseError: ORA-01484: массивы могут быть связаны только с инструкциями PL / SQL