728x90

Python에서 Mysql 테이블 생성, 데이터 추가, 조회 테이블 삭제 하자.

 

※ 소스

import json
import pymysql

con = pymysql.connect(host='localhost',
                      user='아이디',
                      password='암호',
                      db='디비',
                      charset='utf8', # 한글처리 (charset = 'utf8')
                      #autocommit=True, # 결과 DB 반영 (Insert or update)
                      cursorclass=pymysql.cursors.DictCursor # DB조회시 컬럼명을 동시에 보여줌
                      )

cur = con.cursor()#buffered=True

#테이블 생성
sql = f'''CREATE TABLE test (
  txt1 VARCHAR(10),
  txt2 VARCHAR(10)  
)'''
cur.execute(sql)
con.commit()
 
#데이터 추가
rows = [
  ['11','2'],
  ['22','2']
]
sql = 'INSERT INTO test VALUES (%s, %s)'
#cur.execute(sql, multi=True):
for row in rows:
    cur.execute(sql, tuple(row))
con.commit()
 
# 데이터 조회
sql = "SELECT * FROM test"
cur.execute(sql)
rows = cur.fetchall()
print(rows)
 
# 테이블 삭제
sql = "drop table test"
cur.execute(sql)
con.commit()
con
.close() # DB 연결 종료
 

 

※ 실행

 

728x90
반응형

+ Recent posts