Python에서 Oracle 연결하기

필자는 전처리 후, csv 파일을 DB에 insert 하려고 하는데, 계속 여러 오류가 났었다.

오류 처리를 대체 어떻게 하면 좋을지, 막막하던 도중 파일을 한줄씩 insert 해서 오류가 나는 것은 로그로 남기기로 했다. 

 

이때, 먼저 Oracle DB를 연결하기로 했다. 

필자는 DBeaver 을 이용하였으며, DBeaver 설치 부터 시작됨! 

 

1. DBeaver 를 먼처 설치함 -> 아래 링크에서 download를 진행 (os에 맞춰서 설치할 것) 

https://dbeaver.io/download/  

 

2. 이 후 oracle 계정이 있다면, oracle 계정을 따로 기록해둔다. 

 

3. 그리고 파이썬에서 DB에 연결할 수 있는 오라클 인스턴스 클라이언트를 설치한다. ->  cx_Oracle

설치 방법 참고 url : https://cubenuri.tistory.com/202

python3 cx_Oracle 설치

 

import pandas as pd

import numpy as np

import json as js

import datetime

import csv

from tqdm.auto import tqdm

import cx_Oracle as cx

import logging

import datetime

#oracle 설정

host_name = 'localhost2'

oracle_port = 1521

service_name = 'xe'

dsn = cx.makedsn(host_name, oracle_port)

conn = cx.connect('user', 'password')

cursor = conn.cursor()

# oracle db 연결하기

def ExecuteQuery(Query):

    try:

        dsn = cx.makedsn(host_name, oracle_port)

        conn = cx.connect('user', 'password')

        cursor = conn.cursor()

       

        cursor.execute(Query)  

        cursor.close()    

        conn.commit()    

        conn.close()

        return True

   

    except Exception as e:

        logging.error(RuntimeError(f'[ERROR][ExecuteQuery] : {Query} {e}'))

        return False

   

 

4. 설치를 완료 했다면, 파이썬에 적용하기 

필자의 경우, executequery를 함수화 하였음 왜냐하면 csv내 데이터를 한줄씩 insert 할 예정이기 때문임! 

이 후 전체적인 파이프라인은 다음에서!