### 기본 코드 실행 순서
# 1. 라이브러리 가져오기
# 2. 접속하기
# 3. 커서 가져오기
# 4. SQL 구문 만들기
# 5. SQL 구문 실행하기
# 6. commit 하기
# 7. close 하기
# 1. 라이브러리 가져오기
import pymysql
# 2. 접속하기
db = pymysql.connect(
host='**.**.***.**',
port=*****,
user='******',
passwd='******',
db='**********',
charset='utf8'
)
# 3. 커서 가져오기
cursor = db.cursor()
# 4. SQL 구문 만들기
sql = """
SELECT * FROM `************`.`tbl_******` WHERE `useridx` = '10055';
"""
# 5. SQL 구문 실행하기
cursor.execute(sql)
# 6. 쿼리 실행 결과 가져오기 (튜플)
# fetchall() 모든 데이터를 한 번에 가져올 때 사용
# fetchone() 한 번 호출에 하나의 행만 가져올 때 사용 (결과에서 맨 위)
# fetchmany(n) n개만큼의 데이터를 가져올 때 사용
rows = cursor.fetchall()
print(rows)
# 튜플로 저장된 로우 한줄씩 가져오기
for item in rows:
print(item)
# 튜플로 저장된 0번 인덱스만 가져오기
for item in rows:
print(item[0])
# 7. close 하기
db.close()
원본 테이블
# print(rows) 결과
((2795, 10055, 1, 500000, datetime.datetime(2018, 10, 24, 10, 38, 22)), (2798, 10055, 1, 500000, datetime.datetime(2018, 10, 24, 11, 39, 38)), (3226, 10055, 2, 50000, datetime.datetime(2019, 11, 20, 18, 28, 59)), (3238, 10055, 2, 50000, datetime.datetime(2019, 11, 27, 14, 14, 37)), (3243, 10055, 2, 50000, datetime.datetime(2019, 11, 27, 14, 22, 37)))
# for item in rows:
# print(item) 결과
(2795, 10055, 1, 500000, datetime.datetime(2018, 10, 24, 10, 38, 22))
(2798, 10055, 1, 500000, datetime.datetime(2018, 10, 24, 11, 39, 38))
(3226, 10055, 2, 50000, datetime.datetime(2019, 11, 20, 18, 28, 59))
(3238, 10055, 2, 50000, datetime.datetime(2019, 11, 27, 14, 14, 37))
(3243, 10055, 2, 50000, datetime.datetime(2019, 11, 27, 14, 22, 37))
# for item in rows:
# print(item[0]) 결과
2795
2798
3226
3238
3243
# 1. 라이브러리 가져오기
import pymysql
# 2. 접속하기
db = pymysql.connect(
host='**.**.***.**',
port=*****,
user='******',
passwd='******',
db='**********',
charset='utf8'
)
# 3. 커서 가져오기
cursor = db.cursor()
# 4. SQL 구문 만들기
# 반복문을 통해 insert 문을 반복
for index in range(10):
insert_num = 10 + index
sql = """INSERT INTO `******`.`tbl_*******` (`useridx`, `type`, `amount`, `writedate`) VALUES ('10055', '""" + str(insert_num) + """', '10', '2021-08-31 15:12:18');"""
print(sql) # 출력해보기
# 5. SQL 구문 실행하기
cursor.execute(sql)
# 6. commit 하기
db.commit()
# 7. close 하기
db.close()
원본 테이블에 생성된 INSERT 구문에 따라 데이터 INSERT