잡동사니

반응형

질문

  data=[]
  dataToInsert = [ ]
  for index, row in df.iterrows():
   contentid = row['CONTENTID']
   Objectsummary = row['OBJECT_SUMMARY']
   Title=row['TITLE']
   if Title is None:
    Title = ""
   if Objectsummary is None:
    Objectsummary = ""
   allSummeries =Title  + ' ' + Objectsummary
   lists=function_togetNounsAndVerbs(allSummeries)
   verbList =lists[0]
   nounList =lists[1]

   NounSet = set(nounList)
   VerbSet = set(verbList)

   verbs = " "
   verbs=verbs.join(VerbSet)

   nouns=" "
   nouns=nouns.join(NounSet)
   verbs=re.sub(r" ", ", ", verbs)
   nouns=re.sub(r" ", ", ", nouns)
 
  # Here we are going to create the data sdet to be updated in database table in batch form.
   data.append(nouns)
   data.append(verbs)
   data.append('PROCESSED')
   data.append(contentid)
   dataToInsert.append([data[0],  data[1], data[2], data[3]])

  print("ALL DATA TO BE UPDATED IN TABLE IS :---> ",dataToInsert)
  statement = """UPDATE test_batch_update_python SET NOUNS = ?, Verbs = ?  where CONTENTID = ?"""
  a = cursor.executemany(statement, dataToInsert)
  connection.commit()

위 코드에서 function_togetNounsAndVerbs (allSummeries)이 함수는 목록을 반환합니다.다음 예외가 발생합니다.

 **a = cursor.executemany(statement, dataToInsert)
cx_Oracle.DatabaseError: ORA-01036: illegal variable name/number**

이걸 도와주세요.또는 내가 할 수있는 다른 방법은 무엇입니까? 처음에는 cursor.execute () 를 사용하여 한 번에 하나의 행을 업데이트했지만 시간이 많이 소요되었습니다. 시간을 최소화하기 위해 대량 업로드를 사용하고 있습니다 (예 : cursor.executemany ()).


답변1

다음은 작동하는 관련 예입니다. 테이블은 다음과 같이 생성됩니다.

DROP table test_batch_update_python;
CREATE TABLE test_batch_update_python (contentid NUMBER, nouns VARCHAR2(20), verbs VARCHAR2(20));
INSERT INTO test_batch_update_python (contentid) VALUES (1);
INSERT INTO test_batch_update_python (contentid) VALUES (2);
COMMIT;
cursor = connection.cursor()

dataToInsert = [
       ('shilpa', 'really fast', 1),
       ('venkat', 'also really fast', 2),
   ]

print("ALL DATA TO BE UPDATED IN TABLE IS :---> ", dataToInsert)

connection.autocommit = True;
statement = """UPDATE test_batch_update_python SET nouns=:1, verbs=:2 WHERE contentid=:3"""
cursor.setinputsizes(20, 20, None)
cursor.executemany(statement, dataToInsert)

출력은 다음과 같습니다.

ALL DATA TO BE UPDATED IN TABLE IS :--->  [('shilpa', 'really fast', 1), ('venkat', 'also really fast', 2)]

그런 다음 데이터를 쿼리하면 다음이 제공됩니다.

SQL> select * from test_batch_update_python;

 CONTENTID NOUNS                VERBS
---------- -------------------- --------------------
         1 shilpa               really fast
         2 venkat               also really fast


답변2

이 링크에서 및 업데이트 문을 확인하십시오.

https://blogs.oracle.com/oraclemagazine/perform-basic-crud-operations-with-cx-oracle-part-3

감사



 

 

 

 

출처 : https://stackoverflow.com/questions/62694145/python-bulk-upload-records-of-oracle-table-with-executemany-in-python

반응형

이 글을 공유합시다

facebook twitter googleplus kakaoTalk kakaostory naver band