與python交互

安裝引入模塊

• 安裝mysql模塊

sudo apt-get install python-mysql

• 在文件中引入模塊

import Mysqldb

Connection對象

• 用於建立與資料庫的連接
• 創建對象：調用connect()方法

conn=connect(參數列表)

• 參數host：連接的mysql主機，如果本機是'localhost'
• 參數port：連接的mysql主機的埠，預設是3306
• 參數db：資料庫的名稱
• 參數user：連接的用戶名
• 參數password：連接的密碼
• 參數charset：通信採用的編碼方式，預設是'gb2312'，要求與資料庫創建時指定的編碼一致，否則中文會亂碼

對象的方法

• close()關閉連接
• commit()事務，所以需要提交才會生效
• rollback()事務，放棄之前的操作
• cursor()返回Cursor對象，用於執行sql語句並獲得結果

Cursor對象

• 執行sql語句
• 創建對象：調用Connection對象的cursor()方法

cursor1=conn.cursor()

對象的方法

• close()關閉
• execute(operation [, parameters ])執行語句，返回受影響的行數
• fetchone()執行查詢語句時，獲取查詢結果集的第一個行數據，返回一個元組
• next()執行查詢語句時，獲取當前行的下一行
• fetchall()執行查詢時，獲取結果集的所有行，一行構成一個元組，再將這些元組裝入一個元組返回
• scroll(value[,mode])將行指針移動到某個位置
  • mode表示移動的方式
  • mode的預設值為relative，表示基於當前行移動到value，value為正則向下移動，value為負則向上移動
  • mode的值為absolute，表示基於第一條數據的位置，第一條數據的位置為0

對象的屬性

• rowcount只讀屬性，表示最近一次execute()執行後受影響的行數
• connection獲得當前連接對象

增加

• 創建testInsert.py文件，向學生表中插入一條數據

#encoding=utf-8
import MySQLdb
try:
    conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')
    cs1=conn.cursor()
    count=cs1.execute("insert into students(sname) values('張良')")
    print count
    conn.commit()
    cs1.close()
    conn.close()
except Exception,e:
    print e.message

修改

• 創建testUpdate.py文件，修改學生表的一條數據

  #encoding=utf-8
  import MySQLdb
  try:
      conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')
      cs1=conn.cursor()
      count=cs1.execute("update students set sname='劉邦' where id=6")
      print count
      conn.commit()
      cs1.close()
      conn.close()
  except Exception,e:
      print e.message

刪除

• 創建testDelete.py文件，刪除學生表的一條數據

#encoding=utf-8
import MySQLdb
try:
    conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')
    cs1=conn.cursor()
    count=cs1.execute("delete from students where id=6")
    print count
    conn.commit()
    cs1.close()
    conn.close()
except Exception,e:
    print e.message

sql語句參數化

• 創建testInsertParam.py文件，向學生表中插入一條數據

#encoding=utf-8
import MySQLdb
try:
    conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')
    cs1=conn.cursor()
    sname=raw_input("請輸入學生姓名：")
    params=[sname]
    count=cs1.execute('insert into students(sname) values(%s)',params)
    print count
    conn.commit()
    cs1.close()
    conn.close()
except Exception,e:
    print e.message

其它語句

• cursor對象的execute()方法，也可以用於執行create table等語句
• 建議在開發之初，就創建好資料庫表結構，不要在這裡執行

查詢一行數據

• 創建testSelectOne.py文件，查詢一條學生信息

  #encoding=utf8
  import MySQLdb
  try:
      conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')
      cur=conn.cursor()
      cur.execute('select * from students where id=7')
      result=cur.fetchone()
      print result
      cur.close()
      conn.close()
  except Exception,e:
      print e.message

查詢多行數據

• 創建testSelectMany.py文件，查詢一條學生信息

#encoding=utf8
import MySQLdb
try:
    conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')
    cur=conn.cursor()
    cur.execute('select * from students')
    result=cur.fetchall()
    print result
    cur.close()
    conn.close()
except Exception,e:
    print e.message