Microsoft MVP성태의 닷넷 이야기
스크립트: 72. 파이썬 - SQLAlchemy + oracledb 연동 [링크 복사], [링크+제목 복사],
조회: 4705
글쓴 사람
정성태 (seongtaejeong at gmail.com)
홈페이지
첨부 파일
 

(시리즈 글이 3개 있습니다.)
스크립트: 39. Python에서 cx_Oracle 환경 구성
; https://www.sysnet.pe.kr/2/0/13071

스크립트: 70. 파이썬 - oracledb 패키지 연동 시 Thin / Thick 모드
; https://www.sysnet.pe.kr/2/0/13882

스크립트: 72. 파이썬 - SQLAlchemy + oracledb 연동
; https://www.sysnet.pe.kr/2/0/13900




파이썬 - SQLAlchemy + oracledb 연동

지난 글에서 oracledb 연동을 설명했는데요,

파이썬 - oracledb 패키지 연동 시 Thin / Thick 모드
; https://www.sysnet.pe.kr/2/0/13882

SQLAlchemy를 그 위에 얹고 싶다면,

Installation Guide
; https://docs.sqlalchemy.org/en/20/intro.html#installation

$ python3 -m pip install SQLAlchemy

import sqlalchemy
print(sqlalchemy.__version__)

create_engine 함수에 적당한 DSN을 넣어주면 됩니다.

Establishing Connectivity - the Engine
; https://docs.sqlalchemy.org/en/20/tutorial/engine.html

# oracledb인 경우
from sqlalchemy import create_engine
engine = create_engine("oracle+oracledb://hr:hr_password@:192.168.100.50:1521/?service_name=XE")

# cx_Oracle인 경우
from sqlalchemy import create_engine
engine = create_engine("oracle+cx_oracle://hr:hr_password@:192.168.100.50:1521/?service_name=XE")

이후 적당하게 자신의 상황에 맞게 쿼리를 날리면 되겠습니다. ^^

Working with Transactions and the DBAPI
; https://docs.sqlalchemy.org/en/20/tutorial/dbapi_transactions.html

from sqlalchemy import text

record_text = ""

with engine.connect() as conn:
    result = conn.execute(text("select * from departments"))
    for row in result:
        record_text += str(row) + "\n"




비동기 버전을 사용하고 싶다면, create_async_engine을 이용할 수 있습니다.

Asynchronous I/O (asyncio)
; https://docs.sqlalchemy.org/en/20/orm/extensions/asyncio.html

코딩 방식은 동기를 사용했을 때와 비교해 await를 지정해야 한다는 정도의 차이만 있어서 변환도 어렵지 않습니다.

from sqlalchemy.ext.asyncio import create_async_engine

async_engine = create_async_engine("oracle+oracledb://hr:hr_password@192.168.100.50:1521/?service_name=XE")

async with async_engine.connect() as conn:
    result = await conn.execute(text("select * from departments"))
    for row in result:
        record_text += str(row) + "\n"

oracle과 연동한 비동기의 한 가지 제약이 있다면, thin mode로만 동작한다는 점입니다. 그래서 init_oracle_client를 호출한 경우에는 실행 시 이런 오류가 발생합니다.

Traceback (most recent call last):
  File "/home/testusr/py38v/debug_fastapi_router/lib/python3.8/site-packages/uvicorn/protocols/http/h11_impl.py", line 406, in run_asgi
    result = await app(  # type: ignore[func-returns-value]
  ...[생략]...
  File "/mnt/c/temp/main.py", line 356, in sqlalchemy_test
    with engine.connect() as conn:
  ...[생략]...
  File "/home/testusr/py38v/debug_fastapi_router/lib/python3.8/site-packages/sqlalchemy/event/attr.py", line 497, in __call__
    fn(*args, **kw)
  File "/home/testusr/py38v/debug_fastapi_router/lib/python3.8/site-packages/sqlalchemy/engine/create.py", line 724, in on_connect
    do_on_connect(dbapi_connection)
  File "/home/testusr/py38v/debug_fastapi_router/lib/python3.8/site-packages/sqlalchemy/dialects/oracle/cx_oracle.py", line 1383, in on_connect
    conn.outputtypehandler = output_type_handler
AttributeError: 'NoneType' object has no attribute 'outputtypehandler'

따라서, 비동기를 사용하고 싶다면 오라클 서버의 버전을 높여야만 하고, 그렇게 할 수 없다면 동기 + thick mode로 사용해야만 합니다.




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 3/8/2025]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




... 106  107  108  109  110  111  112  113  114  [115]  116  117  118  119  120  ...
NoWriterDateCnt.TitleFile(s)
11091정성태11/3/201627445VC++: 104. std::call_once를 이용해 thread-safe한 Singleton 객체 생성파일 다운로드1
11090정성태11/1/201628927VC++: 103. C++ CreateTimerQueue, CreateTimerQueueTimer 예제 코드 [9]파일 다운로드1
11089정성태11/1/201628914디버깅 기술: 82. Windows 10을 위한 Symbol(PDB) 파일 내려받는 방법 [2]
11088정성태11/1/201631899.NET Framework: 617. C# - AForge.NET을 이용한 MP4 동영상 파일 재생 [7]파일 다운로드1
11087정성태11/1/201626191.NET Framework: 616. AForge.Video.FFMPEG를 최신 버전의 ffmpeg 파일로 의존성을 변경하는 방법파일 다운로드1
11086정성태11/1/201620635오류 유형: 366. The Microsoft Passport Container service terminated with the following error: General access denied error
11085정성태10/27/201635629.NET Framework: 615. C# - AForge.NET을 이용한 웹캠 영상 출력 [2]파일 다운로드1
11084정성태10/26/201623253오류 유형: 365. The User Profile Service service failed to the sign-in.
11083정성태10/26/201629702Windows: 131. 윈도우 10에서 사라진 "Adapters and Bindings" 네트워크 우선 순위 조정 기능 [1]
11082정성태10/26/201632230.NET Framework: 614. C# - DateTime.Ticks의 정밀도 [4]파일 다운로드1
11081정성태10/26/201622128오류 유형: 364. You need to fix your Microsoft Account for apps on your other devices to be able to launch apps and continue experiences on this device.
11080정성태10/24/201625804Windows: 130. Windows Server 2016 Nano 서버 설치 방법
11079정성태10/21/201622923Windows: 129. Windows Server 2016 설치 CD에 있는 Convert-WindowsImage.ps1 사용 방법 정리
11078정성태10/21/201624131Windows: 128. Windows Server 2016 Nano 서버 VHD 이미지 만드는 방법 - TP5 기준
11077정성태10/21/201622269오류 유형: 363. Active Directory 서버의 NETLOGON 서비스가 멈췄을 때 발생하는 문제
11076정성태10/21/201622039오류 유형: 362. 윈도우 백업 시 오류 - 0x80780040
11075정성태10/20/201622119Windows: 127. Convert-WindowsImage.ps1 사용 방법 정리
11074정성태10/20/201631404Windows: 126. Windows Server 2016 평가판을 정식 버전으로 라이선스 변경하는 방법
11073정성태10/20/201627681.NET Framework: 613. 윈도우 데스크톱 응용 프로그램(예: Console)에서 알림 메시지(Toast notifications) 띄우기 [1]파일 다운로드1
11072정성태10/20/201624576VC++: 102. 새로 추가한 ATL COM 객체가 regsvr32.exe로 등록이 안 되는 문제
11071정성태10/20/201627562.NET Framework: 612. UWP(유니버설 윈도우 플랫폼) 앱에서 콜백 함수 내에서의 UI 요소 접근 방법 [1]
11070정성태10/20/201620850Windows: 125. 윈도우 서버 2016 마이그레이션
11069정성태10/19/201629063.NET Framework: 611. C++ 개발자들을 위한 C# Thread 동작 방식 [2]
11068정성태10/19/201632187Windows: 124. 윈도우 운영체제의 시간 함수 (5) - TSC(Time Stamp Counter)와 QueryPerformanceCounter [12]파일 다운로드1
11067정성태10/18/201627938Windows: 123. 윈도우 운영체제의 시간 함수 (4) - RTC, TSC, PM Clock, HPET Timer [2]
11066정성태10/17/201626621Windows: 122. 윈도우 운영체제의 시간 함수 (3) - QueryInterruptTimePrecise, QueryInterruptTime 함수파일 다운로드1
... 106  107  108  109  110  111  112  113  114  [115]  116  117  118  119  120  ...