22년 11월 30일 TIL - 파이썬 mysql 연동하기

1. mysql DB 연동하기

먼저 pymysql 라이브러리를 설치한다.

import pymysql

db_conn = pymysql.connect(
    host='localhost',  #내 컴퓨터 내의 db를 사용하기 때문에 로컬이다.
    port=3306,         #db port번호
    user='자신의 id',     
    password='자신의 db 비밀번호',
    db='users_db',     #자기가 사용할 db이름
    charset='utf8')

print(db_conn)

실행결과 object가 생성되었으므로 연결이 되었음을 알 수 있다.

<pymysql.connections.Connection object at 0x0000022359578D00>

 

2. DB 생성

import pymysql

db_connect = pymysql.connect(
    host='localhost',  #내 컴퓨터 내의 db를 사용하기 때문에 로컬이다.
    port=3306,         #db port번호
    user='자신의 id',     
    password='자신의 db 비밀번호',
    db='users_db',     #자기가 사용할 db이름
    charset='utf8')
)
db_connected = db_connect.cursor()
sql_cmd = 'create database users_db;'  #앞으로의 코드들은 주로 여기가 바뀐다

print(db_connected.execute(sql_cmd))

실행결과가 1이면  DB가 생성되었음을 알 수 있다.

 

3. DB 삭제

import pymysql

db_connect = pymysql.connect(
    host='localhost',  #내 컴퓨터 내의 db를 사용하기 때문에 로컬이다.
    port=3306,         #db port번호
    user='자신의 id',     
    password='자신의 db 비밀번호',
    db='users_db',     #자기가 사용할 db이름
    charset='utf8')
)
db_connected = db_connect.cursor()
sql_cmd = 'drop database users_db;'

print(db_connected.execute(sql_cmd))

실행결과가 0이면 DB가 삭제되었음을 알 수 있다.

 

4. Table 생성

db_connected = db_connect.cursor()
sql_cmd = '''
CREATE table user_info(id int(12) unsigned not null auto_increment, 
user_id varchar(100)Not Null, 
user_email varchar(100)not null,
primary key(id));
'''

print(db_connected.execute(sql_cmd))

5. 테이블에 값 입력하기

db_connected = db_connect.cursor()
sql_cmd = 'INSERT INTO user_info (user_id, user_eMAil) values (%s, %s)'
db_connected.execute(sql_cmd, ('a', 'a@email.com'))
db_connected.execute(sql_cmd, ('b', 'b@email.com'))
db_connect.commit()

 

5. 테이블 데이터 검색하기

db_connected = db_connect.cursor()
sql_cmd = 'select * from user_info where user_id = %s'
db_connected.execute(sql_cmd, ('a'))
print(db_connected.fetchall())

 

6. 테이블 데이터 변경하기

db_connected = db_connect.cursor()
sql_cmd = 'update user_info set user_id = %s where user_email = %s'
db_connected.execute(sql_cmd, ('r', 'kc@email.com'))
db_connect.commit()
db_connect.close()

 

7. 테이블 내용 삭제하기

db_connected = db_connect.cursor()
sql_cmd = 'delete from user_info where user_id = %s'
db_connected.execute(sql_cmd, ('r'))
db_connect.commit()
db_connect.close()

 

DBDBDeep

https://scribblinganything.tistory.com/185

[Python] 파이썬으로 mysql 연동하기 - 윈도우(window)환경