SQlite와 python

python과 sqlite의 연결

python과 sqlite의 연결을 위해 python의 sqlite3 모듈을 사용합니다.
SQlite는 별도의 서버가 필요하지 않습니다. 그러므로 다음과 같이 간단히 두 언어의 연결이 이루어 집니다.

sqlite의 운영은 다음 과정으로 이루어집니다.
1) 선택한 데이터베이스에 대한 연결 : connection
2) 데이터 전달을 위한 커서 설정: cursor
3) SQL을 이용해 데이터를 조작: 상호작용
4) SQL 조작을 데이터에 적용한 후 이를 영구적으로 반영(커밋)
5) 그러한 조작을 중단(롤백) 상호작용이 발생하기 전의 상태로 데이터를 되돌리도록  연결에 지시
6) 데이터 베이스에 대한 연결을 닫음: close

conn=sqlite3.connect("C:/~/test.db")
cur=conn.cursor()
#table 생성
cur.execute('''create table ex1(id integer primary key, name text, phone text, email text unique, password text)''')
#연결 닫기
conn.close()

#생성한 데이블 삭제
cur.execute('''drop table ex1''')
conn.commit()
#commit() 명령은 테이블이 아닌 연결된 db(여기서는 conn)차원에서 이루어집니다.
#다음은 동일한 db에서 테이블을 생성하고 데이터를 입력합니다.
conn=sqlite3.connect("C:/Users/hp/Documents/stock/DB/test.db")
cur=conn.cursor()
cur.execute('''create table ex1(id integer primary key, name text, phone text, email text unique, password text)''')
val=[(1, 'a', '2341234', 'a@exam.com', '1234'), (2, 'b', '6740980', 'b@exam.com', '7658')]
cur.execute("insert into ex1 values(?,?,?,?,?)", val[0])
cur.execute("insert into ex1 values(?,?,?,?,?)", val[1])
conn.commit()
#python 변수의 값들은 튜플로 전달됩니다.  다른 방식으로는 사전과 같이 전달할 수 있습니다.
id3=3
name3='c'
phone3="4538901"
email3='callable@exam.com'
password3="7852"
cur.execute("insert into ex1(id, name, phone, email, password) values(:id, :name, :phone, :email, :password)",
            {'id':id3, 'name': name3, 'phone':phone3, 'email':email3, 'password':password3})
conn.commit()
#여러개의 자료를 동시에 삽입할 경우는 executemany() 메소드를 사용합니다.
val2=[(4, 'd', '2341234', 'd@exam.com', '1234'), (5, 'e', '6740980', 'e@exam.com', '7658')]
cur.executemany("insert into ex1(id, name, phone, email, password) values(?,?,?,?,?)", val2)
conn.commit()
id=cur.lastrowid
id
'''
입력된 데이터를 호출하기 위해서는 cursor 객체에 select 문을 실행하고
한 행을 가져오기 위해서는 fetchone()
모든 행을 가져오기 위해서는 fetchall() 메소드를 사용합니다.
'''
cur.execute("select id, name, phone, email, password from ex1")
item1=cur.fetchone()
item1
#다음 코드의 결과는 위와 같이 호출된 데이터는 제외됩니다.
item_all=cur.fetchall()
item_all
#반복문을 사용하여 호출
for row in item_all:
    print("{0}:{1},{2}".format(row[0], row[1], row[2]))
#특정한 부분을 호출할 경우 '?'(placeholder)를 사용합니다.
spec_id=3
cur.execute('select name, email, phone from ex1 where id=?', (spec_id,))
cur.fetchone()
#데이터를 업데이트, 제거할 경우는 각각 update, delete를 사용합니다.
new=7098931
repid=1
cur.execute('update ex1 set phone=? where id=?', (new, repid))
cur.execute('delete from ex1 where id=4')
conn.commit()
'''
마지막에 수정한 변화는 취소하기 위해서는 rollback()을 사용합니다.
어떤 명령후에 그 결과를 저장하기 위해서는 commit()를 실행해야 하는데
rollback()은 commit()을 실행하기 직전의 마지막 명령을 취소하는 역할을 합니다.
'''
conn.rollback()
conn.close()