Computer Science/Database
[Python] MySQL connector를 이용한 Database 연결
⛅
2021. 3. 9. 14:46
라이브러리 설치
>> 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
# mysql insert, #mysql select, #mysql update, #mysql delete, # mysql python
728x90
반응형