taichino.com

#!/usr/bin/python
# -*- coding: utf-8 -*-
 
import MySQLdb
from MySQLdb.cursors import DictCursor 
 
def process_row(row):
  print row
 
con = MySQLdb.connect(host='localhost', db='testdb', user='testuser', passwd='testpass')
# SELECT
cur = con.cursor()                        # connectionから取得したcursorからsqlを発行する
print cur.execute('SELECT * FROM books')  # executeは行数を返却
res = cur.fetchall()                      # fetchone, fetchmany, fetchallで結果取得
for row in res:
  process_row(row)                        # 各行はtuple (10L, 'Book A', 1000L, None)
 
# INSERT
# executemanyでパラメータが違うだけの複数のSQLを一気に実行できる
print cur.executemany('INSERT INTO books(title, price) VALUES(%s, %s)',
                [('Book A', 1000),       # プレースホルダーは%s固定でかつクォーテーション不要('%s'とはしない)
                ('Book B', 2000),        # INSERTは即時反映 (commit不要)
                ('Book C', 3000)])
# UPDATE
print cur.execute('UPDATE books SET is_finish = true WHERE title = %s', ('Book A',))
con.commit()   # UPDATEのみcommitしないと反映されない
 
# DELETE
print cur.execute('DELETE FROM books WHERE id = %s', (1,))  # DELETEも即時反映
cur.close()
 
# カーソルはDictCursorも選べる
cur = con.cursor(DictCursor)
print cur.execute('SELECT * FROM books')
res = cur.fetchall()                    
for row in res:
  process_row(row)   # 各行は辞書 {'price': 1000L, 'is_finish': 1, 'id': 19L, 'title': 'Book A'}
 
# 後片付け
cur.close()
con.close()

 CREATE TABLE `books` (
  `id` INT(11) NOT NULL AUTO_INCREMENT,
  `title` text,
  `price` INT(11) DEFAULT NULL,
  `is_finish` tinyint(1) DEFAULT NULL,
  PRIMARY KEY (`id`)
)