安裝引入模塊
安裝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
xxxxxxxxxx12 1#encoding=utf-82import MySQLdb3try:4 conn=MySQLdb.connect(host=‘localhost’,port=3306,db=‘test1’,user=‘root’,passwd=‘mysql’,charset=‘utf8’)5 cs1=conn.cursor()6 count=cs1.execute(“insert into students(sname) values(‘張良’)”)7 print count8 conn.commit()9 cs1.close()10 conn.close()11except Exception,e:12 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
xxxxxxxxxx12 1#encoding=utf-82import MySQLdb3try:4 conn=MySQLdb.connect(host=‘localhost’,port=3306,db=‘test1’,user=‘root’,passwd=‘mysql’,charset=‘utf8’)5 cs1=conn.cursor()6 count=cs1.execute(“update students set sname=‘劉邦’ where id=6”)7 print count8 conn.commit()9 cs1.close()10 conn.close()11except Exception,e:12 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
xxxxxxxxxx12 1#encoding=utf-82import MySQLdb3try:4 conn=MySQLdb.connect(host=‘localhost’,port=3306,db=‘test1’,user=‘root’,passwd=‘mysql’,charset=‘utf8’)5 cs1=conn.cursor()6 count=cs1.execute(“delete from students where id=6”)7 print count8 conn.commit()9 cs1.close()10 conn.close()11except Exception,e:12 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
xxxxxxxxxx14 1#encoding=utf-82import MySQLdb3try:4 conn=MySQLdb.connect(host=‘localhost’,port=3306,db=‘test1’,user=‘root’,passwd=‘mysql’,charset=‘utf8’)5 cs1=conn.cursor()6 sname=raw_input(“請輸入學生姓名：”)7 params=[sname]8 count=cs1.execute(‘insert into students(sname) values(%s)’,params)9 print count10 conn.commit()11 cs1.close()12 conn.close()13except Exception,e:14 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
xxxxxxxxxx12 1#encoding=utf82import MySQLdb3try:4 conn=MySQLdb.connect(host=‘localhost’,port=3306,db=‘test1’,user=‘root’,passwd=‘mysql’,charset=‘utf8’)5 cur=conn.cursor()6 cur.execute(‘select * from students where id=7’)7 result=cur.fetchone()8 print result9 cur.close()10 conn.close()11except Exception,e:12 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
xxxxxxxxxx12 1#encoding=utf82import MySQLdb3try:4 conn=MySQLdb.connect(host=‘localhost’,port=3306,db=‘test1’,user=‘root’,passwd=‘mysql’,charset=‘utf8’)5 cur=conn.cursor()6 cur.execute(‘select * from students’)7 result=cur.fetchall()8 print result9 cur.close()10 conn.close()11except Exception,e:12 print e.message

封裝
觀察前面的文件發現，除了sql語句及參數不同，其它語句都是一樣的
創建MysqlHelper.py文件，定義類

#encoding=utf8
import MySQLdb

class MysqlHelper():
def init(self,host,port,db,user,passwd,charset=‘utf8’):
self.host=host
self.port=port
self.db=db
self.user=user
self.passwd=passwd
self.charset=charset

def connect(self):self.conn=MySQLdb.connect(host=self.host,port=self.port,db=self.db,user=self.user,passwd=self.passwd,charset=self.charset)self.cursor=self.conn.cursor()def close(self):self.cursor.close()self.conn.close()def get_one(self,sql,params=()):result=Nonetry:self.connect()self.cursor.execute(sql, params)result = self.cursor.fetchone()self.close()except Exception, e:print e.messagereturn resultdef get_all(self,sql,params=()):list=()try:self.connect()self.cursor.execute(sql,params)list=self.cursor.fetchall()self.close()except Exception,e:print e.messagereturn listdef insert(self,sql,params=()):return self.__edit(sql,params)def update(self, sql, params=()):return self.__edit(sql, params)def delete(self, sql, params=()):return self.__edit(sql, params)def __edit(self,sql,params):count=0try:self.connect()count=self.cursor.execute(sql,params)self.conn.commit()self.close()except Exception,e:print e.messagereturn count

xxxxxxxxxx61 1#encoding=utf82import MySQLdb3?4class MysqlHelper():5 def init(self,host,port,db,user,passwd,charset=‘utf8’):6 self.host=host7 self.port=port8 self.db=db9 self.user=user10 self.passwd=passwd11 self.charset=charset12?13 def connect(self):14 self.conn=MySQLdb.connect(host=self.host,port=self.port,db=self.db,user=self.user,passwd=self.passwd,charset=self.charset)15 self.cursor=self.conn.cursor()16?17 def close(self):18 self.cursor.close()19 self.conn.close()20?21 def get_one(self,sql,params=()):22 result=None23 try:24 self.connect()25 self.cursor.execute(sql, params)26 result = self.cursor.fetchone()27 self.close()28 except Exception, e:29 print e.message30 return result31?32 def get_all(self,sql,params=()):33 list=()34 try:35 self.connect()36 self.cursor.execute(sql,params)37 list=self.cursor.fetchall()38 self.close()39 except Exception,e:40 print e.message41 return list42?43 def insert(self,sql,params=()):44 return self.__edit(sql,params)45?46 def update(self, sql, params=()):47 return self.__edit(sql, params)48?49 def delete(self, sql, params=()):50 return self.__edit(sql, params)51?52 def __edit(self,sql,params):53 count=054 try:55 self.connect()56 count=self.cursor.execute(sql,params)57 self.conn.commit()58 self.close()59 except Exception,e:60 print e.message61 return count

添加
創建testInsertWrap.py文件，使用封裝好的幫助類完成插入操作

#encoding=utf8
from MysqlHelper import *

sql=‘insert into students(sname,gender) values(%s,%s)’
sname=raw_input(“請輸入用戶名：”)
gender=raw_input(“請輸入性別，1為男，0為女”)
params=[sname,bool(gender)]

mysqlHelper=MysqlHelper(‘localhost’,3306,‘test1’,‘root’,‘mysql’)
count=mysqlHelper.insert(sql,params)
if count1:
print ‘ok’
else:
print ‘error’
xxxxxxxxxx14 1#encoding=utf82from MysqlHelper import *3?4sql='insert into students(sname,gender) values(%s,%s)'5sname=raw_input(“請輸入用戶名：”)6gender=raw_input(“請輸入性別，1為男，0為女”)7params=[sname,bool(gender)]8?9mysqlHelper=MysqlHelper(‘localhost’,3306,‘test1’,‘root’,‘mysql’)10count=mysqlHelper.insert(sql,params)11if count1:12 print 'ok’13else:14 print ‘error’

查詢一個
創建testGetOneWrap.py文件，使用封裝好的幫助類完成查詢最新一行數據操作

#encoding=utf8
from MysqlHelper import *

sql=‘select sname,gender from students order by id desc’

helper=MysqlHelper(‘localhost’,3306,‘test1’,‘root’,‘mysql’)
one=helper.get_one(sql)
print one
xxxxxxxxxx8 1#encoding=utf82from MysqlHelper import *3?4sql='select sname,gender from students order by id desc’5?6helper=MysqlHelper(‘localhost’,3306,‘test1’,‘root’,‘mysql’)7one=helper.get_one(sql)8print one

實例：用戶登錄
創建用戶表userinfos
表結構如下
id
uname
upwd
isdelete
注意：需要對密碼進行加密
如果使用md5加密，則密碼包含32個字符
如果使用sha1加密，則密碼包含40個字符，推薦使用這種方式

create table userinfos(
id int primary key auto_increment,
uname varchar(20),
upwd char(40),
isdelete bit default 0
);
xxxxxxxxxx6 1create table userinfos(2id int primary key auto_increment,3uname varchar(20),4upwd char(40),5isdelete bit default 06);

加入測試數據
插入如下數據，用戶名為123,密碼為123,這是sha1加密后的值
insert into userinfos values(0,‘123’,‘40bd001563085fc35165329ea1ff5c5ecbdbbeef’,0);
接收輸入并驗證
創建testLogin.py文件，引入hashlib模塊、MysqlHelper模塊
接收輸入
根據用戶名查詢，如果未查到則提示用戶名不存在
如果查到則匹配密碼是否相等，如果相等則提示登錄成功
如果不相等則提示密碼錯誤

#encoding=utf-8
from MysqlHelper import MysqlHelper
from hashlib import sha1

sname=raw_input(“請輸入用戶名：”)
spwd=raw_input(“請輸入密碼:”)

s1=sha1()
s1.update(spwd)
spwdSha1=s1.hexdigest()

sql=“select upwd from userinfos where uname=%s”
params=[sname]

sqlhelper=MysqlHelper(‘localhost’,3306,‘test1’,‘root’,‘mysql’)
userinfo=sqlhelper.get_one(sql,params)
if userinfo==None:
print ‘用戶名錯誤’
elif userinfo[0]spwdSha1:
print ‘登錄成功’
else:
print ‘密碼錯誤’
?x 1#encoding=utf-82from MysqlHelper import MysqlHelper3from hashlib import sha14?5sname=raw_input(“請輸入用戶名：”)6spwd=raw_input(“請輸入密碼:”)7?8s1=sha1()9s1.update(spwd)10spwdSha1=s1.hexdigest()11?12sql="select upwd from userinfos where uname=%s"13params=[sname]14?15sqlhelper=MysqlHelper(‘localhost’,3306,‘test1’,‘root’,‘mysql’)16userinfo=sqlhelper.get_one(sql,params)17if userinfoNone:18 print '用戶名錯誤’19elif userinfo[0]==spwdSha1:20 print '登錄成功’21else:22 print ‘密碼錯誤’
想學習交流，視頻資源等，推薦群：C++大學技術協會：145655849

總結

以上是生活随笔為你收集整理的如何使用Python操作MySQL数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。