python使用MySQLdb模塊連接MySQL

1.安裝驅動

目前有兩個MySQL的驅動，我們可以選擇其中一個進行安裝：

MySQL-python：是封裝了MySQL C驅動的Python驅動；mysql-connector-python：是MySQL官方的純Python驅動。

MySQL-python：

安裝教程：http://www.cnblogs.com/jfl-xx/p/7299221.html

mysql-connector-python：

安裝教程：http://www.cnblogs.com/Bgod/p/6995601.html

2.測試連接

這里使用MySQL-python驅動，即MySQLdb模塊。

test_connect.py

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

import MySQLdb

# 打開數據庫連接
db = MySQLdb.connect("localhost", "root", "123456", "test")

# 使用cursor()方法獲取操作游標
cursor = db.cursor()

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

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

print "Database version : %s " % data

# 關閉數據庫連接
db.close()

測試結果如下，連接成功：

3.創建數據庫表

測試成功后，我們可以在python中直接為MySQL創建表：

create_table.py

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

import MySQLdb

# 打開數據庫連接
db = MySQLdb.connect("localhost", "root", "123456", "test")

# 使用cursor()方法獲取操作游標
cursor = db.cursor()

# 如果數據表已經存在使用 execute() 方法刪除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 創建數據表SQL語句
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# 關閉數據庫連接
db.close()

建表結果 如下：

4.操作數據庫表

注意點：MySQL中的占位符為%s

operate_table.js

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

import MySQLdb

# 打開數據庫連接
db = MySQLdb.connect("localhost", "root", "123456", "test")

# 使用cursor()方法獲取操作游標
cursor = db.cursor()

# SQL插入語句
ins_sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('yu', 'jie', 20, 'M', 8000)"""

ins_sql1 = 'insert into employee(first_name, last_name, age, sex, income) values (%s, %s, %s, %s, %s)'

# SQL查詢語句
sel_sql = 'select * from employee where first_name = %s'

# SQL更新語句
upd_sql = 'update employee set age = %s where sex = %s'

# SQL刪除語句
del_sql = 'delete from employee where first_name = %s'

try:
    # 執行sql語句
    # insert
    cursor.execute(ins_sql)
    cursor.execute(ins_sql1, ('xu', 'f', 20, 'M', 8000))
    # select
    cursor.execute(sel_sql, ('yu',))
    values = cursor.fetchall()
    print values
    # update
    cursor.execute(upd_sql, (24, 'M',))
    # delete
    cursor.execute(del_sql, ('xu',))

    # 提交到數據庫執行
    db.commit()
except:
    # 發生錯誤時回滾
    db.rollback()

# 關閉數據庫連接
db.close()

 執行插入操作

執行查詢操作

執行更新操作

執行刪除操作

 

查詢語句的知識點：

Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

fetchone(): 該方法獲取下一個查詢結果集。結果集是一個對象

fetchall():接收全部的返回結果行.

例如該例子：

sel_sql = 'select * from employee where first_name = %s'
cursor.execute(sel_sql, ('yu',))
    results = cursor.fetchall()
    for row in results:
        fname = row[0]
        lname = row[1]
        age = row[2]
        sex = row[3]
        income = row[4]
        print "fname=%s, lname=%s,age=%d,sex=%s,income=%d" % (fname, lname, age, sex, income)

結果如下: