1、互動型別

1、安裝引入模組

安裝mysql模組，在windows和ubuntu中

windows裡安裝mysql模組

Linux裡安裝mysql模組

在檔案中引入模組

import pymysql

connection物件

用於建立與資料庫的連線

建立物件：呼叫connect()方法 conn=connect(引數列表)

引數host：連線的mysql主機，如果本機是'localhost'

引數port：連線的mysql主機的埠，預設是3306

引數db：資料庫的名稱

引數user：連線的使用者名稱

引數password：連線的密碼

引數charset：通訊採用的編碼方式，預設是'gb2312'，要求與資料庫建立時指定的編碼一致，否則中文會亂碼

2、物件的方法

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，絕對的。

舉個例子便於理解

# 匯入python操作mysql的模組 import pymysql # 獲取連線物件 conn = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='python01', port=3306, charset='utf8') # 獲取執行工具 cur = conn.cursor() # sql語句,增刪改 #sql = 'select birthday from t_user' sql = 'select id,name,pwd,birthday from t_user' # 執行,返回值。如果是增刪改，返回受影響的行數，如果是查詢，返回查詢的行數 count = cur.execute(sql) print('查詢的結果有%s條資料'%count) #獲取第一行 dateOne = cur.fetchone() print(dateOne) #向上移動一行

cur.scroll(-1) #向下移動一行 cur.scroll(1) cur.scroll(1,mode='absolute') 絕對的，這裡指的是第一行 cur.scroll(1,mode='relative') 相對的 #獲取所有行的資料 dataAll = cur.fetchall() print(dataAll) for temp in dataAll:

print(temp) print(dataAll[-1][2]) #dataAll[-1]得到的是一個使用者所有的資訊，dataAll[-1][2]獲取最後一個人的密碼 for temp in cur: print(temp) s = 'id:%s,name:%s,pwd:%s,birthday:%s' for temp in dataAll: print(s%(temp[0],temp[1],temp[2],temp[3])) # 關閉 cur.close() conn.close()

3、物件的屬性

connection獲得當前連線物件

2、增刪改查（CRUD）

1、增

#encoding=utf-8 import pymysql try: conn=pymysql.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)

2、修改

3、刪除

建立testDelete.py檔案，刪除學生表的一條資料

#encoding=utf-8 import pymysql try: conn=pymysql.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 as e: print(e)

4、查

建立testSelectOne.py檔案，查詢一條學生資訊

import Pymysql try: conn=Pymysql.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 as e: print(e)

建立testSelectMany.py檔案，查詢全部學生資訊

#encoding=utf8 import Pymysql try:   conn=Pymysql.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 as e:   print(e)

例項一：引數

# 匯入python操作mysql的模組 
import pymysql 
import time 
# 獲取連線物件 
conn = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='python01', port=3306, charset='utf8') 
# 獲取執行工具 
cur = conn.cursor()
 # sql語句,增刪改，sql注入 
sql = 'insert into t_user(name,pwd,birthday) values(%s,%s,%s)' 
# 引數列表
 name = input('輸入姓名:') 
pwd = input('輸入密碼:') 
birthday = input('輸入生日:')     # 2017年10月01日-->日期struct_time(--->2017-10-01) 
birthday = time.strptime(birthday,'%Y年%m月%d日')      
#這裡我們就用到了時間與字串的相互轉換(詳情見MySQL高階) 
params = [name,pwd,birthday] 
# 執行,返回值。如果是增刪改，返回受影響的行數，如果是查詢，返回查詢的行數 
count = cur.execute(sql,params) 
#提交 
conn.commit() 
print('受影響的行數:%s'%count) 
# 關閉 
cur.close() 
conn.close()

例項二：丟擲異常

# 匯入python操作mysql的模組

 import pymysql 
try:   
 conn = None    
cur = None    
# 獲取連線物件    
conn = pymysql.connect(host='127.0.0.1',                           
user='root',                           
password='123456',                          
 database='python01',                           
port=3306,                           

charset='utf8')    
# 模擬異常    
# a = 1 / 0   
 # 獲取執行工具    
cur = conn.cursor()    
# sql語句,增刪改    

sql = 'insert into t_user(name,pwd,birthday) values("小伊","123456",str_to_date("2017年10月20日","%Y年%m月%d日"))'    
# 執行,返回值。如果是增刪改，返回受影響的行數，如果是查詢，返回查詢的行數    
count = cur.execute(sql)    
# 提交    
conn.commit()    
print('受影響的行數:%s' % count) 
except Exception as ex:    
# 列印異常資訊，測試時候使用，專案上線，去掉   
 print(str(ex))    
# 將異常繼續丟擲    
# raise
 finally:   
 if cur != None:        
cur.close()   
 if conn != None:        
conn.close()

例項三：

# 匯入python操作mysql的模組 
import pymysql 
# 獲取連線物件 
conn = pymysql.connect(host='127.0.0.1', user='root', password='123456', database='python01', port=3306, charset='utf8') 
# 獲取執行工具 
cur = conn.cursor() 
# sql語句,增刪改
#sql = 'select birthday from t_user' 
sql = 'select id,name,pwd,birthday from t_user' 
# 執行,返回值。如果是增刪改，返回受影響的行數，如果是查詢，返回查詢的行數 
count = cur.execute(sql) 
print('查詢的結果有%s條資料'%count) 
#獲取第一行 
# dateOne = cur.fetchone() 
# print(dateOne) 
# for temp in cur: 
#     print(temp) 
s = 'id:%s,name:%s,pwd:%s,birthday:%s' 
for temp in dataAll:   
 print(s%(temp[0],temp[1],temp[2],temp[3])) 
# 關閉 
cur.close() 
conn.close()

3、封裝

這個庫的名字：mySqlHelper

python操作mysql進行增刪改查的封裝 1、增刪改，程式碼類似 2、查詢 程式碼分析 1、獲取連線物件

 2、sql語句不同，引數不同    
3、獲取執行物件        
增刪改        
查詢            
1、fetchone            
2、fetchall    
4、處理結果    
5、關閉    
面向物件  建立類，封裝屬性和函式 ''' 
import pymysql 
class MysqlHelper:    
'''python操作mysql的增刪改查的封裝'''    
def __init__(self, host, user, password, database, port=3306, charset='utf8'):       
 '''        
初始化引數        
:param host:        主機       
 :param user:        使用者名稱        
:param password:    密碼        
:param database:    資料庫        
:param port:        埠號，預設是3306        
:param charset:     編碼，預設是utf8       
 '''        
self.host = host        
self.port = port        
self.database = database       
 self.user = user        
self.password = password        
self.charset = charset    
def connect(self):       
 '''        
獲取連線物件和執行物件        
:return:        
'''        
self.conn = pymysql.connect(host=self.host,                                    
user=self.user,                                    
password=self.password,                                    
database=self.database,                                   
 port=self.port,                                    
charset=self.charset)        
self.cur = self.conn.cursor()    
def fetchone(self, sql, params=None):       
 '''         
根據sql和引數獲取一行資料      
 :param sql:          sql語句       
:param params:       sql語句物件的引數元組，預設值為None       
:return:             查詢的一行資料      
 '''        
dataOne = None        
try:            
count = self.cur.execute(sql, params)            
if count != 0:                
dataOne = self.cur.fetchone()        
except Exception as ex:           
 print(ex)       
 finally:            
self.close()        
return dataOne    
def fetchall(self, sql, params=None):        
'''         
根據sql和引數獲取一行資料       
:param sql:          sql語句       
:param params:       sql語句物件的引數列表，預設值為None      
 :return:             查詢的一行資料      
 '''        
dataall = None        
try:            
count = self.cur.execute(sql, params)           
 if count != 0:                
dataall = self.cur.fetchall()       
 except Exception as ex:            
print(ex)        
finally:            
self.close()        
return dataall    
def __item(self, sql, params=None):       
 '''        
執行增刪改        :param sql:           
sql語句        :param params:        
sql語句物件的引數列表，預設值為None        
:return:              受影響的行數       
 '''       
 count = 0        
try:            
count = self.cur.execute(sql, params)           
 self.conn.commit()        
except Exception as ex:            
print(ex)        
finally:            
self.close()        
return count    
def update(self, sql, params=None):       
 '''        
執行修改        
:param sql:     sql語句       
 :param params:  sql語句物件的引數列表，預設值為None        
:return:        受影響的行數       
 '''       
 return self.__item(sql, params)    
def insert(self, sql, params=None):       
 '''        
執行新增        
:param sql:     sql語句       
 :param params:  sql語句物件的引數列表，預設值為None        
:return:        受影響的行數        
'''       
 return self.__item(sql, params)    

def delete(self, sql, params=None):        
'''        
執行刪除        
:param sql:     sql語句       
 :param params:  sql語句物件的引數列表，預設值為None        
:return:        受影響的行數        
'''        
return self.__item(sql, params)    
def close(self):        
'''        
關閉執行工具和連線物件        
'''        
if self.cur != None:            
self.cur.close()        
if self.conn != None:            
self.conn.close()

1、測試查詢多條資料

  import mysqlHelper 
# 初始化物件 
helper = mysqlHelper.MysqlHelper('127.0.0.1', 'root', '123456', 'python01') 
# 連線 
helper.connect() 
# sql 
sql = 'select * from t_user where name = %s and id > %s' # params params = ['小茗',1] 
# 執行 
data = helper.fetchall(sql, params) 
# 判斷 
if data:   
 for temp in data:        
print(temp) 
else:  # None,False,0   
 print('沒有資料.') 
helper.close()

2、測試查詢一條資料

import mysqlHelper 
# 初始化物件 
helper = mysqlHelper.MysqlHelper('127.0.0.1', 'root', '123456', 'python01') 
# 連線 
helper.connect() 
# sql 
sql = 'select * from t_user where id = %s' 
#sql = 'select * from t_user where id = 1' 
# params params = [2] 
# 執行 
data = helper.fetchone(sql, params) 
#data = helper.fetchone(sql) 
# 判斷
 if data:    
print(data)
 else:  # None,False,0    
print('沒有資料.')

3、測試增刪改

import mysqlHelper 
import time 
# 初始化物件 
helper = mysqlHelper.MysqlHelper('127.0.0.1', 'root', '123456', 'python01') 
# 連線 
helper.connect() 
# sql 
sql = 'update t_user set name =%s,pwd=%s,birthday=%s where id=%s' 
# params
 id = input('輸入編號:') 
name = input('輸入姓名:') 
pwd = input('輸入密碼:') 
birthday = time.strptime(input('輸入生日:'), '%Y年%m月%d日') 
params = [name, pwd, birthday,id] 
# 執行 
count = helper.update(sql, params) 
# 判斷 
if count:    
print('操作成功.') 
else:  # None,False,0    
print('操作失敗.')

4、登入和註冊

登入和註冊的時候需要對密碼進行加密

注意：

1、需要對密碼進行加密

2、如果使用md5加密，則密碼包含32個字元

3、如果使用sha1加密，則密碼包含40個字元，這裡使用這種方式

create table userinfos(    
id int primary key auto_increment,   
 uname varchar(20),    
upwd char(40),    
isdelete bit default 0 );
 /* 
ret = doPwd('123')
 print(ret) 
結果：40bd001563085fc35165329ea1ff5c5ecbdbbeef              
*/ -- 插入如下資料，使用者名稱為123,密碼為123,這是sha1加密後的值 
insert into userinfos 
values(1,'123','40bd001563085fc35165329ea1ff5c5ecbdbbeef',0);

登入與註冊

from mysqlHelper import MysqlHelper 
import hashlib 

def login():    
'''登入'''    
name = input('輸入使用者名稱:')    
pwd = input('輸入密碼:')    
#加密    

pwd = doPwd(pwd)    
helper = MysqlHelper('127.0.0.1', 'root', '123456', 'python01')    
helper.connect()   
 sql = 'select * from t_user where name=%s and pwd=%s'    
params = [name, pwd]    
data = helper.fetchone(sql, params)    
if data:        
print('登入成功.')    
else:  # None,False,0       
 print('登入失敗.') 
def doPwd(pwd):    
'''sha1編碼'''    
mysha1 = hashlib.sha1()    
mysha1.update(pwd.encode('utf-8'))    
pwd = mysha1.hexdigest()    
return pwd def register():    
'''註冊'''    
name = input('輸入使用者名稱:')    
pwd = input('輸入密碼:')    
# 加密   
 pwd = doPwd(pwd)    
 helper = MysqlHelper('127.0.0.1', 'root', '123456', 'python01')    
helper.connect()    
sql = 'insert into t_user(name,pwd) values(%s,%s)'    
params = [name, pwd]    
count = helper.insert(sql, params)    
if count:        
print('操作成功.')    
else:  # None,False,0        
print('操作失敗.') 
if __name__ == '__main__':   
 #register()   
 login()