[Python] MySQL connector를 이용한 Database 연결

라이브러리 설치

>> pip install mysql-connector-python

 

실행 코드

SELECT

import mysql.connector

con = mysql.connector.connect(host='URL',
                              port='PORT', 
                              database='DBNAME',
                              user='USER',
                              password='PWD')
cursor = con.cursor(dictionary=True) # True로 해야 row에서 column 이름으로 값을 불러올 수 있다.

sql="SELECT * FROM table1 WHERE column1 = %s ;"

cursor.execute(sql, ("value1",))

for row in cursor:
    print(str(row['column2']))

cursor.close()


'''
# Parameter가 두 개일 때,

sql="SELECT * FROM table1 WHERE column1 = %s AND column2 = %s ;"
cursor.execute(sql, ("value1","value2"))

'''

 

UPDATE

commit()을 해야 table이 변경된다.

sql="UPDATE table1 SET column1='value 2' WHERE column1='value 1'"

cursor.execute(sql)

con.commit()

print(cursor.rowcount, "record(s) affected")
# OR print(len(list(cursor)), "record(s) affected")

cursor.close()

 

DELETE

commit()을 해야 table이 변경된다.

sql="DELETE FROM table1 WHERE column1='value 1';"

cursor.execute(sql)

con.commit()

print(cursor.rowcount, "record(s) affected")

cursor.close()

 

INSERT

commit()을 해야 table이 변경된다.

sql="INSERT INTO table1(column1, column2) VALUES('value 1',100);"

cursor.execute(sql)

con.commit()

print(cursor.rowcount, "record(s) affected")

cursor.close()

 

Reference

• gem1n1.tistory.com/65

 

 

 

 

 

# mysql insert, #mysql select, #mysql update, #mysql delete, # mysql python