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

비밀번호

댓글 작성자
 




1  2  3  4  5  6  7  8  9  10  [11]  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
13712정성태8/14/20248731개발 환경 구성: 720. Synology NAS - docker 원격 제어를 위한 TCP 바인딩 추가
13711정성태8/13/20249272Linux: 77. C# / Linux - zombie process (defunct process) [1]파일 다운로드1
13710정성태8/8/20249836닷넷: 2294. C# 13 - (6) iterator 또는 비동기 메서드에서 ref와 unsafe 사용을 부분적으로 허용파일 다운로드1
13709정성태8/7/20249109닷넷: 2293. C# - safe/unsafe 문맥에 대한 C# 13의 (하위 호환을 깨는) 변화파일 다운로드1
13708정성태8/7/20249374개발 환경 구성: 719. ffmpeg / YoutubeExplode - mp4 동영상 파일로부터 Audio 파일 추출
13707정성태8/6/20249296닷넷: 2292. C# - 자식 프로세스의 출력이 4,096보다 많은 경우 Process.WaitForExit 호출 시 hang 현상파일 다운로드1
13706정성태8/5/20249006개발 환경 구성: 718. Hyper-V - 리눅스 VM에 새로운 디스크 추가
13705정성태8/4/20249233닷넷: 2291. C# 13 - (5) params 인자 타입으로 컬렉션 허용 [2]파일 다운로드1
13704정성태8/2/202410172닷넷: 2290. C# - 간이 dotnet-dump 프로그램 만들기파일 다운로드1
13703정성태8/1/20248575닷넷: 2289. "dotnet-dump ps" 명령어가 닷넷 프로세스를 찾는 방법
13702정성태7/31/20249610닷넷: 2288. Collection 식을 지원하는 사용자 정의 타입을 CollectionBuilder 특성으로 성능 보완파일 다운로드1
13701정성태7/30/202410085닷넷: 2287. C# 13 - (4) Indexer를 이용한 개체 초기화 구문에서 System.Index 연산자 허용파일 다운로드1
13700정성태7/29/202410043디버깅 기술: 200. DLL Export/Import의 Hint 의미
13699정성태7/27/202410033닷넷: 2286. C# 13 - (3) Monitor를 대체할 Lock 타입파일 다운로드1
13698정성태7/27/20249780닷넷: 2285. C# - async 메서드에서의 System.Threading.Lock 잠금 처리파일 다운로드1
13697정성태7/26/20248946닷넷: 2284. C# - async 메서드에서의 lock/Monitor.Enter/Exit 잠금 처리파일 다운로드1
13696정성태7/26/20248796오류 유형: 920. dotnet publish - error NETSDK1047: Assets file '...\obj\project.assets.json' doesn't have a target for '...'
13695정성태7/25/20249080닷넷: 2283. C# - Lock / Wait 상태에서도 STA COM 메서드 호출 처리파일 다운로드1
13694정성태7/25/20249236닷넷: 2282. C# - ASP.NET Core Web App의 Request 용량 상한값 (Kestrel, IIS)
13693정성태7/24/20248437개발 환경 구성: 717. Visual Studio - C# 프로젝트에서 레지스트리에 등록하지 않은 COM 개체 참조 및 사용 방법파일 다운로드1
13692정성태7/24/20249655디버깅 기술: 199. Windbg - 리눅스에서 뜬 닷넷 응용 프로그램 덤프 파일에 포함된 DLL의 Export Directory 탐색
13691정성태7/23/20248573디버깅 기술: 198. Windbg - 스레드의 Win32 Message Queue 정보 조회
13690정성태7/23/20248021오류 유형: 919. Visual C++ 리눅스 프로젝트 - error : ‘u8’ was not declared in this scope
13689정성태7/22/202410624디버깅 기술: 197. Windbg - PE 포맷의 Export Directory 탐색
13688정성태7/21/20248796닷넷: 2281. C# - Lock / Wait 상태에서도 일부 Win32 메시지 처리파일 다운로드1
13687정성태7/19/20249834닷넷: 2280. C# - PostThreadMessage로 보낸 메시지를 Windows Forms에서 수신하는 방법파일 다운로드1
1  2  3  4  5  6  7  8  9  10  [11]  12  13  14  15  ...