python鏈接操做mysql數據庫

用python來實現對mysql增刪改查的操做，具體代碼以下：

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb
#打開數據庫鏈接
db = MySQLdb.connect("localhost","root","1181ff69","test_demo",charset='utf8' )



# 使用cursor()方法獲取操做遊標
cursor = db.cursor()

# 使用execute方法執行SQL語句
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法獲取一條數據
data = cursor.fetchone()

print "Database version : %s " % data
cursor.execute("drop table if exists test_demo.employee")
sql="""CREATE TABLE test_demo.EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""
cursor.execute(sql)
print '建表語句爲：'+sql
print '建表完畢'
insertsql1="""insert into test_demo.employee values ("12","wen",27,'m',112222.001);"""
insertsql2="""insert into test_demo.employee values ("11","wen",27,'m',112222.001);"""
insertsql3="""insert into test_demo.employee values ("13","wen",27,'m',112222.001);"""

try:
  cursor.execute(insertsql1)
  cursor.execute(insertsql2)
  cursor.execute(insertsql3)
  db.commit()
except:
  db.rollback()
  print 'error'
print '插入語句爲：'+insertsql1
print '插入成功'
# 數據庫查詢操做
querysql="""select * from  employee """
cursor.execute(querysql)
# 獲取全部記錄列表
print '查詢語句爲：'+querysql
results = cursor.fetchall()
print type(results)
for i in results:
  # print i[0]
  # print i[1]
  # print i[2]
  # print i[3]
  print i
  # print type(i)
print 'query成功'
# 關閉數據庫鏈接
db.close()