DongGukS Wiki: DatabaseProgrammingPython

More...

데이터베이스 생성및 샘플 데이터 입력#


create database python;



CREATE TABLE `animals` (

  `name` varchar(20) default NULL,

  `species` varchar(20) default NULL

) ENGINE=InnoDB DEFAULT CHARSET=utf8;



insert into `animals`(`name`,`species`) values ('Wallace','Walrus');

insert into `animals`(`name`,`species`) values ('Polly','Parrot');

insert into `animals`(`name`,`species`) values ('Freddie','Frog');

insert into `animals`(`name`,`species`) values ('Sammy','Skunk');

간단한 조회 애플리케이션#

데이터를 모두 가져와서 반복적으로 처리하기


# MySQL 모듈 import

import MySQLdb



# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행

cursor.execute("SELECT * FROM animals")

# 결과데이터를 튜플 형태로 추출

result = cursor.fetchall()

# 결과데이터를 반복적으로 처리

for record in result:

    print record[0] , "-->", record[1]

데이터를 한건씩 가져와서 처리하기


# -*- coding: utf-8 -*-

# MySQL 모듈 import

import MySQLdb



# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행

cursor.execute("SELECT * FROM animals")

# 결과데이터의 총 갯수를 추출

numrows = int(cursor.rowcount)

# 한번에 한개의 데이터를 추출해서 표기

for x in range(0, numrows):

    row = cursor.fetchone()

    print row[0], "-->", row[1]

데이터를 제한된 건수만큼만 가져와서 처리하기


# -*- coding: utf-8 -*-

# MySQL 모듈 import

import MySQLdb



# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행

cursor.execute("SELECT * FROM animals")

# 추출한 결과 데이터를 3건으로 제한

result = cursor.fetchmany(3)

# 결과데이터를 반복적으로 처리

for record in result:

    print record[0] , "-->", record[1]

트랜잭션#

connection.begin() - 트랜잭션 시작
connection.apilevel() - 현재 DB API레벨을 리턴
connection.conv() - MySQL과 파이썬간의 타입 변환 옵션을 셋팅
connection.commit() - 트랜잭션 커밋
connection.rollback() - 트랜잭션 롤백

간단한 입력 애플리케이션#


# -*- coding: utf-8 -*-

# MySQL 모듈 import

import MySQLdb



# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행하기

cursor.execute("""INSERT INTO animals (name, species) VALUES ("Harry","Hamster")""")

cursor.connection.commit();

튜플을 이용하여 데이터 입력


# -*- coding: utf-8 -*-

# MySQL 모듈 import

import MySQLdb



name = raw_input("Please enter a name: ")

species = raw_input("Please enter a species: ")

# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행하기

cursor.execute("INSERT INTO animals (name, species) VALUES (%s, %s)",(name, species))

cursor.connection.commit();

튜플 리스트를 이용하여 데이터 입력


# -*- coding: utf-8 -*-

# MySQL 모듈 import

import MySQLdb



# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행하기

# dynamically generate SQL statements from  list

cursor.executemany("INSERT INTO animals (name, species) VALUES (%s,%s)",

[('Rollo', 'Rat'), ('Dudley', 'Dolphin'), ('Mark', 'Marmoset')])

cursor.connection.commit();

간단한 수정 애플리케이션#


# -*- coding: utf-8 -*-

# MySQL 모듈 import

import MySQLdb



# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행하기

cursor.execute("UPDATE animals SET species=%s WHERE name=%s",('TEST', 'Rollo'))

cursor.connection.commit();

간단한 삭제 애플리케이션#


# -*- coding: utf-8 -*-

# MySQL 모듈 import

import MySQLdb



# 데이터베이스 연결

db = MySQLdb.connect(host="localhost", user="root", passwd="c12345", db="python")

# 커서 생성

cursor = db.cursor()

# SQL구문 실행하기

cursor.execute("DELETE FROM animals WHERE name=%s", 'Rollo')

cursor.connection.commit();