Microsoft MVP성태의 닷넷 이야기
스크립트: 72. 파이썬 - SQLAlchemy + oracledb 연동 [링크 복사], [링크+제목 복사],
조회: 7173
글쓴 사람
정성태 (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)
11347정성태10/28/201725634오류 유형: 424. Visual Studio - "클래스 다이어그램 보기" 시 "작업을 완료할 수 없습니다. 해당 인터페이스를 지원하지 않습니다." 오류 발생
11346정성태10/25/201722155오류 유형: 423. Windows Server 2003 - The client-side extension could not remove user policy settings for 'Default Domain Policy {...}' (0x8007000d)
11338정성태10/25/201718693.NET Framework: 697. windbg - SOS DumpMT의 "BaseSize", "ComponentSize" 값에 대한 의미파일 다운로드1
11337정성태10/24/201722094.NET Framework: 696. windbg - SOS DumpClass/DumpMT의 "Vtable Slots", "Total Method Slots", "Slots in VTable" 값에 대한 의미파일 다운로드1
11336정성태10/20/201723939.NET Framework: 695. windbg - .NET string의 x86/x64 메모리 할당 구조
11335정성태10/18/201722541.NET Framework: 694. 닷넷 - <Module> 클래스의 용도
11334정성태10/18/201722801디버깅 기술: 105. windbg - k 명령어와 !clrstack을 조합한 호출 스택을 얻는 방법
11333정성태10/17/201722249오류 유형: 422. 윈도우 업데이트 - Code 9C48 Windows update encountered an unknown error.
11332정성태10/17/201722616디버깅 기술: 104. .NET Profiler + 디버거 연결 + .NET Exceptions = cpu high
11331정성태10/16/201720590디버깅 기술: 103. windbg - .NET 4.0 이상의 환경에서 모든 DLL에 대한 심벌 파일을 로드하는 파이썬 스크립트
11330정성태10/16/201719313디버깅 기술: 102. windbg - .NET 4.0 이상의 환경에서 DLL의 심벌 파일 로드 방법 [1]
11329정성태10/15/201725157.NET Framework: 693. C# - 오피스 엑셀 97-2003 .xls 파일에 대해 32비트/64비트 상관없이 접근 방법파일 다운로드1
11328정성태10/15/201728345.NET Framework: 692. C# - 하나의 바이너리로 환경에 맞게 32비트/64비트 EXE를 실행하는 방법파일 다운로드1
11327정성태10/15/201722028.NET Framework: 691. AssemblyName을 .csproj에서 바꾼 경우 빌드 오류 발생하는 문제파일 다운로드1
11326정성태10/15/201721345.NET Framework: 690. coreclr 소스코드로 알아보는 .NET 4.0의 모듈 로딩 함수 [1]
11325정성태10/14/201722037.NET Framework: 689. CLR 4.0 환경에서 DLL 모듈의 로드 주소(Base address) 알아내는 방법
11324정성태10/13/201723527디버깅 기술: 101. windbg - "*** WARNING: Unable to verify checksum for" 경고 없애는 방법
11322정성태10/13/201722732디버깅 기술: 100. windbg - .NET 4.0 응용 프로그램의 Main 메서드에 Breakpoint 걸기
11321정성태10/11/201723792.NET Framework: 688. NGen 모듈과 .NET Profiler
11320정성태10/11/201725053.NET Framework: 687. COR_PRF_USE_PROFILE_IMAGES 옵션과 NGen의 "profiler-enhanced images" [1]
11319정성태10/11/201732459.NET Framework: 686. C# - string 배열을 담은 구조체를 직렬화하는 방법
11318정성태10/7/201723805VS.NET IDE: 122. 비주얼 스튜디오에서 관리자 권한을 요구하는 C# 콘솔 프로그램 제작 [1]
11317정성태10/4/201729503VC++: 120. std::copy 등의 함수 사용 시 _SCL_SECURE_NO_WARNINGS 에러 발생
11316정성태9/30/201726622디버깅 기술: 99. (닷넷) 프로세스(EXE)에 디버거가 연결되어 있는지 아는 방법 [4]
11315정성태9/29/201743813기타: 68. "시작하세요! C# 6.0 프로그래밍: 기본 문법부터 실전 예제까지" 구매하신 분들을 위한 C# 7.0/7.1 추가 문법 PDF [8]
11314정성태9/28/201724892디버깅 기술: 98. windbg - 덤프 파일로부터 닷넷 버전 확인하는 방법
... 106  [107]  108  109  110  111  112  113  114  115  116  117  118  119  120  ...