# vi jobs2.py
import mysql.connector # 파이썬과 mysql 을 연동하기 위한 모듈을 임폴트 합니다.
# 데이터 베이스의 정보를 config 딕셔너리에 담습니다.
config = {
"user": "scott",
"password": "tiger",
"host": "192.168.122.1", #local
"database": "orcl", #Database name
"port": "3306" #port는 최초 설치 시 입력한 값(기본값은 3306)
}
# 위의 데이터 베이스 정보를 가지고 접속을 합니다.
conn = mysql.connector.connect(**config)
# db에서 select, insert, update, delete 등의 작업을 할 수 있는 객체를 생성합니다.
cursor = conn.cursor()
# 실행할 select 문 구성
sql = "SELECT * FROM emp where job in('salesman','analyst')"
# cursor 객체를 이용해서 수행한다.
cursor.execute(sql)
# select 된 결과를 rows 라는 변수에 넣습니다.
rows= cursor.fetchall() # tuple 이 들어있는 list
colname = cursor.description
col = []
for i in colname:
col.append(i[0].lower())
import pandas as pd
emp = pd.DataFrame( list(rows) , columns=col)
emp.to_csv('/home/oracle/jobs2.csv')
# python jobs2.py