Python과 DBMS를 연동함에 각 DB에 맞는 module이 제공되고 있다. 이중 많이 사용하는 Oracle, MySQL과 CUBRID의 연동 방법 및 사용 방법을 비교하여 python과 타DBMS와의 사용 경험이 있는 개발자에 이해의 편의를 제공해 주고자 한다. (부분 상세 설명은 CUBRID만 하도록 한다.)
각 DBMS와 Python의 연동이 가능하게 할 module을 다운받는다. 각각의 module은 아래의 경로에서 다운로드 받을 수 있다.
1. CUBRID - http://dev.naver.com/projects/cubrid/
2. MySQL - http://sourceforge.net/project/showfiles.php?group_id=22307&package_id=15775&release_id=491012
3. Oracle - http://sourceforge.net/project/showfiles.php?group_id=84168
각 DBMS의 필요 module과 DB접속 설정 방법 등을 간략하게 기술한다. 확인 방법 및 테스트는 같은 구조와 같은 이름의 테이블을 이용한다. 선행 작업의 각 위치에서 다운로드 받은 파일의 압축을 푼 후 해당 디렉토리에서 아래와 같이 수행하여 module을 설치한 후 각DBMS에서 따라 아래와 같이 확인한다.
$python setup.py build
$python setup.py install
아래와 같은 동일한 테이블 구조를 예시한다. (data type에 대한 DBMS마다 약간의 차이가 있다)
create table posts (
id integer,
title varchar(255),
body string, # MySQL이나 Oracle의 경우 varchar(3000)로 수정
last_updated timestamp #MySQL이나 Oracle의 경우 date로 수정
);
insert into posts values(1, 'aaa', 'hello, cubrid', systimestamp); #MySQL의 경우 now(), Oracle은 sysdate를 넣는다.
insert into posts values(2, 'bbb', 'good database system', systimestamp);
insert into posts values(3, 'ccc', 'happy python', systimestamp);
systimestamp, now(), sysdate는 각각의 DBMS의 현재 시스템 시간을 넣는 함수이다.
다운로드 받을 파일의 이름은 cubrid-python_0.5.zip이다. 확인 방법은 아래와 같다.
import cubriddb #CUBRID의 python연동 module이름
con = cubriddb.conncet(‘localhost’,30000,’demodb’)
c = con.cursor()
c.execute(‘select * from history’)
rows = c.fetchall()
for r in rows:
print r
c.close()
con.close()
CUBRID의 connect()함수는 cubriddb.conncet(hostname or IP, broker_port, db_name, user_name, password)의 형식으로 기록한다.
hostname or IP - host이름이나 IP를 ‘로 묶어서 기록한다.
Broker_port - APP와 DB를 연결하는 broker의 연결 port번호를 기록한다 default로30000, 33000이 설정되어 있으며, ‘없이 그냥 기록 한다.
db_name - 생성되어 있는 데이터베이스의 이름을 ‘로 묶어서 기록한다.
user_name - 사용자 이름을 ‘로 묶어서 기록하며, default는 PUBLIC이며 이는 기록하지 않을 경우 자동 선택된다.
password - 비밀번호를 ‘로 묶어서 기록한다. default는’’(공백)이며, 이는 PUBLIC의 비밀번호이기도 하다.
* 결과값 형식
[1, 'aaa', '2006-11-2 23:53:0', 'hello, cubrid']
[2, 'bbb', '2006-11-3 0:14:0', 'good database system']
[3, 'ccc', '2006-11-15 0:5:23', 'happy python']
...
다운로드 받을 파일의 이름은 MySQL-python-1.2.2.tar.gz 이다. 확인 방법은 아래와 같다.
import MySQLdb #MySQL의 python연동 module이다
con = MySQLdb.connect(host = "hostname or IP", user = "username", passwd = "password", db = "db_name")
c = con.cursor()
c.execute('select * from test_1')
rows = c.fetchall()
for r in rows:
print r
c.close()
con.close()
*결과값 형식
(0L, 0L, 'NONE', None, None, None, None)
(1L, 1L, 'NONE', None, None, None, None)
(2L, 2L, 'NONE', None, None, None, None)
...
다운로드 받을 파일의 이름은 cx_Oracle-5.0.1.tar.gz 이다. 확인 방법은 아래와 같다.
import cx_Oracle #Oracle의 python연동 module이다
con = cx_Oracle.connect('user_name/password@tns_SERVICE_NAME')
c = con.cursor()
c.execute('select * from emp')
rows = c.fetchall()
for r in rows:
print r
c.close()
con.close()
*결과값 형식
(7369, 'SMITH', 'CLERK', 7902, datetime.datetime(1980, 12, 17, 0, 0), 800.0, None, 20)
(7499, 'ALLEN', 'SALESMAN', 7698, datetime.datetime(1981, 2, 20, 0, 0), 1600.0, 300.0, 30)
(7521, 'WARD', 'SALESMAN', 7698, datetime.datetime(1981, 2, 22, 0, 0), 1250.0, 500.0, 30)
…
연결방법은 connect()의 차이와 결과 값을 보여주는 것의 차이가 있을 뿐 비슷하다. 하지만 입력 방법은 조금 더 다르게 느껴질 것이다. 우선 기본적으로 공통적인 insert의 스타일을 소개하고 binding과정에서의 차이를 각각의 DBMS에 대하여 살펴보겠다. 입출력에 관한 응용샘플은 추가문서로 제공하겠다.
기본적인 값의 입력 방법은 아래와 같다.
import cubriddb #MySQL은 MySQLdb, Oracle은 cx_Oracle을 사용한다.
con = cubriddb. conncet(‘localhost’,30000,’demodb’) #MySQL, Oracle은 위의 연결 부분을 참조할 것.
c = con.cursor()
c.execute('insert into posts(id, title, body, created_at) values( 4, 'ddd', 'CUBRID-Python is Open Source!!', SYSTIMESTAMP)')
con.commit()
c.close()
con.close()
위와 같이 사용한다면 프로그램으로써의 의미가 없을 것이다. 기본 틀이 위와 같을 뿐 변수 binding을 통하여 사용하게 되며 각DBMS마다 사용 방법 약간씩 다르다. 각각의 차이를 DBMS별로 구분하여 설명하도록 한다.
CUBRID의 기본적인 변수 데이터 입력 방법은 아래와 같다. 사용의 활용을 위해 while문을 사용한다.
import cubriddb, random
con = cubriddb.connect('localhost',33000,'demodb')
c = con.cursor()
a = 4
while (a <=10):
b= (random.choice(['DDD','EEE','FFF','GGG']))
d= (random.randrange(1000000000000000000,9999999999999999999))
e= ("%s"%d); args=(a,b,e)
c.execute('insert into posts values(?,?,?,systimestamp)',args)
a = a+1
con.commit()
c.close()
con.close()
MySQL의 기본적인 변수 데이터 입력 방법은 아래와 같다.
import MySQLdb, random
con = MySQLdb.connect(host ="localhost",db="test")
c = con.cursor()
a = 4
while (a <=10):
b= (random.choice(['DDD','EEE','FFF','GGG']))
d= (random.randrange(1000000000000000000,9999999999999999999))
e= ("%s"%d); args=(a,b,e)
c.execute(“””insert into posts values(%s,%s,%s,now())”””,args)
a = a+1
con.commit()
c.close()
con.close()
Oracle의 기본적인 변수 데이터 입력 방법은 아래와 같다.
import cx_Oracle, random
con = cx_Oracle.connect('user_name/password@tns_SERVICE_NAME')
c = con.cursor()
a = 4
while (a <=10):
b= (random.choice(['DDD','EEE','FFF','GGG']))
d= (random.randrange(1000000000000000000,9999999999999999999))
e= ("%s"%d); args=({‘s1’:a,’s2’:b,’s3’:e})
c.execute(“””insert into posts values(:s1,:s2,:s3,sysdate)”””,args)
a = a+1
con.commit()
c.close()
con.close()