import mysql.connector
def get_connection() :
connection = mysql.connector.connect(
host = '호스트이름',
database = 'DB이름',
user = 'USER명',
password = '비밀번호',
)
return connection
try :
# 데이터 insert
# 1. DB에 연결
connection = get_connection()
# 2. 쿼리문 만들기
query = '''insert into mysql_table
(col1, col2, ...)
values
(value1, value2, ...);'''
# 3. 커서를 가져온다.
cursor = connection.cursor()
# 4. 쿼리문을 커서를 이용해서 실행한다.
cursor.execute(query)
# 5. 커넥션을 커밋해줘야 한다 => 디비에 영구적으로 반영하라는 뜻
connection.commit()
# 6. 자원 해제
cursor.close()
connection.close()
except mysql.connector.Error as e :
cursor.close()
connection.close()
print(e)