Microsoft MVP성태의 닷넷 이야기
스크립트: 72. 파이썬 - SQLAlchemy + oracledb 연동 [링크 복사], [링크+제목 복사],
조회: 4732
글쓴 사람
정성태 (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

비밀번호

댓글 작성자
 




... 76  77  78  79  80  81  82  83  84  [85]  86  87  88  89  90  ...
NoWriterDateCnt.TitleFile(s)
11854정성태3/25/201919595VS.NET IDE: 133. IIS Express로 호스팅하는 사이트를 https로 접근하는 방법
11853정성태3/24/201922640개발 환경 구성: 435. 존재하지 않는 IP 주소에 대한 Dns.GetHostByAddress/gethostbyaddr/GetNameInfoW 실행이 느리다면? - 두 번째 이야기 [1]
11852정성태3/20/201920797개발 환경 구성: 434. 존재하지 않는 IP 주소에 대한 Dns.GetHostByAddress/gethostbyaddr/GetNameInfoW 실행이 느리다면?파일 다운로드1
11851정성태3/19/201924667Linux: 8. C# - 리눅스 환경에서 DllImport 대신 라이브러리 동적 로드 처리 [2]
11850정성태3/18/201924631.NET Framework: 813. C# async 메서드에서 out/ref/in 유형의 인자를 사용하지 못하는 이유
11849정성태3/18/201923520.NET Framework: 812. pscp.exe 기능을 C#으로 제어하는 방법파일 다운로드1
11848정성태3/17/201920666스크립트: 14. 윈도우 CMD - 파일이 변경된 경우 파일명을 변경해 복사하고 싶다면?
11847정성태3/17/201925005Linux: 7. 리눅스 C/C++ - 공유 라이브러리 동적 로딩 후 export 함수 사용 방법파일 다운로드1
11846정성태3/15/201923840Linux: 6. getenv, setenv가 언어/운영체제마다 호환이 안 되는 문제
11845정성태3/15/201923222Linux: 5. Linux 응용 프로그램의 (C++) so 의존성 줄이기(ReleaseMinDependency) [3]
11844정성태3/14/201925270개발 환경 구성: 434. Visual Studio 2019 - 리눅스 프로젝트를 이용한 공유/실행(so/out) 프로그램 개발 환경 설정 [1]파일 다운로드1
11843정성태3/14/201919991기타: 75. MSDN 웹 사이트를 기본으로 영문 페이지로 열고 싶다면?
11842정성태3/13/201917475개발 환경 구성: 433. 마이크로소프트의 CoreCLR 프로파일러 예제를 Visual Studio CMake로 빌드하는 방법 [1]파일 다운로드1
11841정성태3/13/201918100VS.NET IDE: 132. Visual Studio 2019 - CMake의 컴파일러를 기본 g++에서 clang++로 변경
11840정성태3/13/201920290오류 유형: 526. 윈도우 10 Ubuntu App 환경에서는 USB 외장 하드 접근 불가
11839정성태3/12/201924546디버깅 기술: 124. .NET Core 웹 앱을 호스팅하는 Azure App Services의 프로세스 메모리 덤프 및 windbg 분석 개요 [3]
11838정성태3/7/201928352.NET Framework: 811. (번역글) .NET Internals Cookbook Part 1 - Exceptions, filters and corrupted processes [1]파일 다운로드1
11837정성태3/6/201941779기타: 74. 도서: 시작하세요! C# 7.3 프로그래밍 [10]
11836정성태3/5/201925711오류 유형: 525. Visual Studio 2019 Preview 4/RC - C# 8.0 Missing compiler required member 'System.Range..ctor' [1]
11835정성태3/5/201923420.NET Framework: 810. C# 8.0의 Index/Range 연산자를 .NET Framework에서 사용하는 방법 및 비동기 스트림의 컴파일 방법 [3]파일 다운로드1
11834정성태3/4/201922114개발 환경 구성: 432. Visual Studio 없이 최신 C# (8.0) 컴파일러를 사용하는 방법
11833정성태3/4/201923423개발 환경 구성: 431. Visual Studio 2019 - CMake를 이용한 공유/실행(so/out) 리눅스 프로젝트 설정파일 다운로드1
11832정성태3/4/201918100오류 유형: 524. Visual Studio CMake - rsync: connection unexpectedly closed
11831정성태3/4/201919048오류 유형: 523. Visual Studio 2019 - 새 창으로 뜬 윈도우를 닫을 때 비정상 종료
11830정성태2/26/201918086오류 유형: 522. 이벤트 로그 - Error opening event log file State. Log will not be processed. Return code from OpenEventLog is 87.
11829정성태2/26/201919405개발 환경 구성: 430. 마이크로소프트의 CoreCLR 프로파일러 예제 빌드 방법 - 리눅스 환경 [1]
... 76  77  78  79  80  81  82  83  84  [85]  86  87  88  89  90  ...