파이썬 - pymysql 기본 예제 코드
MySQLdb를 사용해 본 김에,
파이썬 - MySQLdb 기본 예제 코드
; https://www.sysnet.pe.kr/2/0/12851
환경 구성도 모두 되었을 테니 pymysql도 빠르게 다뤄보겠습니다.
MySQL 쿼리
; http://pythonstudy.xyz/python/article/202-MySQL-%EC%BF%BC%EB%A6%AC
^^ 당연히 pypi로부터 pymysql을 설치한 후,
$ pip install pymysql
이것 역시
dbapi2를 따르므로 지난 글의 MySQLdb 예제를 거의 그대로 재사용할 수 있습니다.
import pymysql
con = pymysql.connect(host="127.0.0.1", user="testusr", password="testusr@100420", db="test", charset='utf8')
# cursor = con.cursor()
cursor = con.cursor(pymysql.cursors.DictCursor)
query = "DELETE FROM test"
cursor.execute(query)
for idx in range(1, 5):
query = "INSERT INTO test(name, age, enable) VALUES('테스터{0}', {1}, {2});".format(idx, idx, idx * 10)
cursor.execute(query)
con.commit()
query = "SELECT * FROM test"
cursor.execute(query)
record_text = ""
all_rows = cursor.fetchall()
for row in all_rows:
# record_text += str(row)
field_name = row['name']
field_age = row['age']
field_enable = row['enable']
# while True:
# record = cursor.fetchone()
# if not record:
# break
#
# record_text += str(record)
cursor.close()
con.close() # 이 코드가 없으면 이후 누적돼 connect 시에 (1040, 'Too many connections') 오류 발생
import pymysql
with pymysql.connect(....[생략]...) as con:
with con.cursor() as cursor:
query = "SELECT * FROM test;"
cursor.execute(query)
MySQLdb 글의 내용이 그대로 적용되므로 딱히 별다르게 더 쓸 내용이 없군요. ^^ 단지, MySQLdb와 PyMySQL과 다른 점을 다음 글에서 찾을 수 있습니다.
What's the difference between MySQLdb, mysqlclient and MySQL connector/Python?
; https://stackoverflow.com/questions/43102442/whats-the-difference-between-mysqldb-mysqlclient-and-mysql-connector-python
정리해 보면, MySQLdb는 C API를 사용하는 방식이고, pymysql은 순수 Python으로 제작한 DB provider입니다. 그리고 mysqlclient가 나오는데, 이것은 기존의 MySQLdb로부터 Python 3.3+ 이후의 지원을 위해 fork되어 파생된 버전입니다. 아하~~~ 그래서 지난 글의 MySQLdb를 pip으로 설치하는데 "mysqlclient"라고 했던 것이군요. ^^ (위의 글이 쓰인 2017년 기준으로 기존 MySQLdb도 Python3 지원을 포함하며 MySQLDb2 버전으로 진행 중이라고 합니다.)
어쨌든, 그래서 속도 면에서 본다면 pymysql보다 mysqlclient(MySQLdb)가 더 빠르다고!
또 하나 다른 점은,
MySQLdb를 사용한 소스 코드에서는 오류가 없었는데 동일하게 dbapi2를 따르도록 작성한 pymysql은 connect 시에,
import pymysql
con = pymysql.connect(host=mysql_ip, user="...", password="...", db="...", charset='utf8')
"'cryptography' package is required for sha256_password or caching_sha2_password auth methods"라는 RuntimeError 오류가 발생합니다.
오류 메시지에서 나오듯이 그냥 cryptography 패키지를 추가 설치하면 됩니다.
$ pip install cryptography
아마도 MySQLdb의 경우 C API 라이브러리 측에서 이미 cryptography 처리를 해줘서 문제가 없었던 것이 아닌가 싶습니다.
[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]