mysql와 python의 연동

1. 라이브러리 설치
2. sql 서버의 정보 입력
3. sql서버에 접속
4. sql 쿼리문을 이용하여 데이터를 CRUD 작업

   import pymysql
   import pandas as pd

sql 서버 정보 입력 -> DB접속

_db = pymysql.connect(
user = 'root',
password = '1234',
host = 'localhost',
db = 'database',
port = 3306
)

cursor 변수

sql 쿼리문을 실행 시키기 위해서 만들어야 되는 필수 변수

DicCursor는 sql쿼리문을 실행되고 나온 결과물을 딕셔너리 형태로 받겠다.

cursor = _db.cursor(pymysql.cursors.DictCursor)

sql = """
select
*
from
user_info
"""

cursor.execute(sql)

result = cursor.fetchall() ## 결과값 가져오기
print(result)

df = pd.DataFrame(result)
df

sql = """
insert into
user_info(id,name,age)
values
('test2','kim',30)
"""
cursor.execute(sql)

_db.commit() ## 변경한 데이터 저장, 적용

sql = """
select
createDt as 날짜,
deathCnt as 시망자,
decideCnt as 확진자
from
corona
order by
createDt
"""
cursor.execute(sql)
result = cursor.fetchall()
df =pd.DataFrame(result)
df

### input 을 이용하여 입력받은 데이터 값을 insert
1. input 함수를 이용하여 데이터를 4개받는다
2. insert문을 이용하여 user_info테이블에 ID,NAME,AGE,ADRESS 항목에 삽입

_id = input("id: ")
_name = input("NAME: ")
_age = input("AGE :")
_adress = input("ADRESS :" )
sql = f"""
insert into
user_info
values
('{_id}','{_name}','{_age}','{_adress}')

"""

cursor.execute(sql)
_db.commit()

def insert(sql, data): ### 변수의 개수를 정하지 않음
cursor.execute(sql,data)
_db.commit()
return cursor.fetchall()

sql = """
insert into
user_info
values
()
"""

데이터베이스와의 접속을 종료

_db.close()