sqlDB와 파이썬 연동 pymysql

pymysql 설치하기

pip install pymysql

파이썬과 연동하기

가상머신위에 mysql설치 

2023.03.07 - [데이터 엔지니어링/가상환경] - 가상환경 MySQL 설치하기

가상환경 MySQL 설치하기

connection 에 cursor를 생성해준다.

try :
    con = pymysql.connect(host='호스트ip', user='사용자',password='비밀번호',charset='utf8',db = '테이블')
    cur = con.cursor()
except Exception as e:
    print("error->",e)

heidiSQL로 잘 연결 되었는지 확인!

 

cur.execute로 database, table 생성해보기

cur.execute("create database play")

cur.execute("use play

cur.execute("""CREATE TABLE `class3` (
 	`InvoiceNo` VARCHAR(30), 
  	`StockCode` VARCHAR(30),
  	`Description` VARCHAR(255),
  	`Quantity` INT(3),
  	`UnitPrice` FLOAT(5,2),
  	`CustomerID` VARCHAR(30),
  	`Country` VARCHAR(45),
  	`InvoiceDate` DATE 
 )""")

dataset3파일을 db에 넣기

con.commit() 해주기!

# value값 설정
sql = "INSERT INTO class3 VALUES(%s,%s,%s,%s,%s,%s,%s,%s)"

# sql형태로 데이터 DB에 저장하기
with open("./data/dataset3.csv","r",encoding='utf-8') as f:
    for idx,line in enumerate(f):
        if idx > 0:
            cur.execute(sql,[x.replace('"',"") for x in line.split(";")])

# commit 해주기
con.commit()

 

참고

* sql명령문 확인 사이트
https://www.w3schools.com/mysql/mysql_create_table.asp

MySQL CREATE TABLE Statement