DAY40. Python DB연동, CRUD, table

db 연결 테스트 

 

import pymysql # driver = p/g + DB

DB 연결 환경 

config = {
    'host' : '127.0.0.1',
    'user' : 'scott',
    'password' : 'tiger',
    'database' : 'work',
    'port' : 3306,
    'charset':'utf8',
    'use_unicode' : True} #dict 


try :
    #db 연동 객체 생성 
    conn = pymysql.connect(**config)    
    #sql문 실행 객체 생성 
    cursor = conn.cursor()
    sql = "select * from goods"
    
    cursor.execute(sql) #sql문 실행    
    dataset = cursor.fetchall() #조회된 모든 레코드 가져오기
    
    for row in dataset :
        print(row)
    
    
except Exception as e:
    print('예외발생 : ', e)
finally :
    pass

 

 

 

 

 

크루드(CRUD)

Create(insert), Read(select), Update, Delete

import pymysql

 

config = {
    'host' : '127.0.0.1',
    'user' : 'scott',
    'password' : 'tiger',
    'database' : 'work',
    'port' : 3306,
    'charset':'utf8',
    'use_unicode' : True}

try :
    #db 연동 객체 
    conn = pymysql.connect(**config)
    #sql문 실행 객체 
    cursor = conn.cursor()
    
    #4. 레코드 삭제 : Delete(code -> 레코드 삭제)
    '''
    code = int(input('delete code input : '))
    query = f"select * from goods where code = {code}"
    cursor.execute(query) 
    row = cursor.fetchone() #1개 레코드 가져오기 
    
    if row : #code 있는 경우 
        cursor.execute(f"delete from goods where code = {code}")# 삭제 
        conn.commit()  #db 반영
    else :
        print('해당 code는 없습니다.')
    '''
        
    #3. 레코드 수정 : Update(code -> su, dan 수정)
    '''
    code = int(input('update code input : ')) #4
    su = int(input('update su input : ')) #3
    dan = int(input('update dan input : ')) #550000
    query = f"""update goods 
                set su = {su}, dan = {dan} 
                where code={code}"""
    cursor.execute(query) # 레코드 수정 
    conn.commit() #db 반영     
    '''
    
    #2. 레코드 추가 : Create
    '''
    code = int(input('code input : ')) #4
    name = input('name input : ') #test
    su = int(input('su input : ')) #4 
    dan = int(input('dan input : ')) #500000
    
    query = f"insert into goods values({code},'{name}',{su},{dan})"
    cursor.execute(query) # 레코드 추가 
    conn.commit()  #db 반영  
    '''
    
    #1. 레코드 조회 : Read
    query = "select * from goods"
    cursor.execute(query) #sql문 실행 
    dataset = cursor.fetchall() #전체 레코드 가져오기 
    print('-'*30)
    for row in dataset :
        print(row[0], row[1], row[2], row[3])
    print('-'*30)
    print('전체 레코드 수 : ', len(dataset))
except Exception as e:
    print('예외발생 : ', e)
    conn.rollback() #이전 상태 리턴 
finally :
    cursor.close(); conn.close()

 

 

 

 

 

emp table

1. emp table 생성 : HidiSQL 이용 
2. python + DB 연동 
table 유무 판단 : show tables
- table 있는 경우 : 레코드 추가/조회 
- table 없는 경우 : 'table 없음' 경고 메시지 

import pymysql # driver = python + DB

DB 연결 환경 

config = {
    'host' : '127.0.0.1',
    'user' : 'scott',
    'password' : 'tiger',
    'database' : 'work',
    'port' : 3306,
    'charset':'utf8',
    'use_unicode' : True} #dict
    
try :
    #db 연동 객체 
    conn = pymysql.connect(**config)
    #query 실행 객체 
    cursor = conn.cursor()
    
    #1. table 유무 판단 : emp 
    cursor.execute("show tables") #table 목록 조회 
    tables = cursor.fetchall()
    
    #sw기법 
    sw = False #off
    for table in tables :
        if 'emp' in table :
            sw = True #on 
        
    if sw : #emp 테이블 존재 
        query = "select * from emp"
        cursor.execute(query) # 레코드 조회
        dataset = cursor.fetchall() # 전체 레코드 가져오기 
        
        if dataset : #레코드 있음 
            for row in dataset :
                print(row[0], row[1], row[2], row[3], row[4], row[5], row[6])   
                
            print('전체 레코드 개수 : ', len(dataset))
        else : #레코드 없음 
            print('조회된 레코드 없음')
            
    else : #emp 테이블 없음 
        print('table 없음')
        
except Exception as e :
    print('db error :', e)
finally:
    cursor.close(); conn.close()