Python操作MySQL
- MySQL之查詢操作
- MySQL之插入數(shù)據(jù)
- MySQL之批量插入數(shù)據(jù)
- MySQL之刪除數(shù)據(jù)
- MySQL之更新數(shù)據(jù)庫
- MySQL之事務(wù)
- MySQL之批量獲取字典類型數(shù)據(jù)
- MySQL之fetchone
- MySQL之獲取自增ID
三層架構(gòu)（程序分成三種架構(gòu)）
- 三層架構(gòu)之公共層
- 三層架構(gòu)之model層
- 三層架構(gòu)之配置文件
Socket網(wǎng)絡(luò)編程
【Python操作MySQL】
準(zhǔn)備工作：
Windows下載鏈接，Python操作MySQL模塊：
http://pan.baidu.com/s/1o7JuMgU
提示：Windows安裝了mysql模塊后，因為我用的是Eclipse，所以我還要在Eclipse下做一下設(shè)置，如下：
在Eclipse菜單欄上點擊Windows->Preferences->PyDev-Interpreter-Python->Forced Builtins->New->MySQLdb->ok->Apply，必要時重啟Eclipse
Linux直接安裝Python操作MySQL模塊 yum -y install python-mysqldb
建表語句
create table students ( id int not null auto_increment primary key, name char(8) not null, sex char(4) not null, age tinyint unsigned not null, tel char(13) null default "-" );插入數(shù)據(jù)：
insert into students(name,sex,age,tel) values('wsyht','man',20,'1319')數(shù)據(jù)庫和表
mysql> select database(); +------------+ | database() | +------------+ | wsyht | +------------+ 1 row in set (0.00 sec) mysql> select *from students; +----+---------+-----+-----+---------+ | id | name | sex | age | tel | +----+---------+-----+-----+---------+ | 2 | wsyht | man | 22 | 1231313 | | 3 | jack | man | 23 | 12313 | | 4 | jenkins | man | 25 | 123 | | 5 | peter | man | 23 | 123 | | 6 | wsyht90 | man | 23 | 123 | | 8 | wsyht11 | man | 26 | 12345 | | 9 | wsyht12 | man | 26 | 12345 | | 10 | wsyht1 | man | 26 | 12345 | | 11 | wsyht2 | man | 26 | 12345 | +----+---------+-----+-----+---------+ 9 rows in set (0.00 sec)1）MySQL之查詢操作
import MySQLdb #必須在導(dǎo)入MySQLdb模塊之前，要先裝python操作mysql模塊#創(chuàng)建連接
conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手，這里可以理解為伸出手，獲取表數(shù)據(jù)#數(shù)據(jù)查詢操作
reCount = cur.execute('select * from students') #然后執(zhí)行動作，只是查詢影響了多少行，并不是查詢相關(guān)表的數(shù)據(jù) data = cur.fetchall() #把select查詢影響到的行的數(shù)據(jù)全拿出來#關(guān)閉連接
cur.close() #收回手 conn.close() #關(guān)門#輸出信息
print reCount #輸出查詢影響到的行數(shù) print data #輸出查詢影響到的行的數(shù)據(jù)2）MySQL之插入數(shù)據(jù)
import MySQLdb#創(chuàng)建連接
conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手，這里可以理解為伸出手，獲取表數(shù)據(jù)#數(shù)據(jù)插入操作
sql = "insert into students(id,name,sex,age,tel) values(%s,%s,%s,%s,%s)" #不管什么類型，占位符都是給%s，五個占位符，就給五個%s params = ('6','peter','man','23','123') #如果這里id設(shè)了自增，那么這排第一位和上面一排第一位id可以不用寫 reCount = cur.execute(sql,params) #插入數(shù)據(jù) conn.commit() #提交數(shù)據(jù)，insert,update,delete都要加commit，而select則不用#關(guān)閉連接
cur.close() #收回手 conn.close() #關(guān)門 print reCount #輸出影響到的行數(shù)3）MySQL之批量插入數(shù)據(jù)
import MySQLdb #必入MySQLdb模塊之前，要先裝python操作mysql模塊#創(chuàng)建連接
conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手，這里可以理解為伸出手，獲取表數(shù)據(jù)#批量插入數(shù)據(jù)操作
li = [ ('wsyht11','man','26','12345'), ('wsyht12','man','26','12345'), ] #sql = 'insert into students(name,sex,age,tel) values(%s,%s,%s,%s)' #reCount = cur.executemany(sql,li) reCount = cur.executemany('insert into students(name,sex,age,tel) values(%s,%s,%s,%s)',li) #刪除數(shù)據(jù) conn.commit() #提交數(shù)據(jù)，insert,update,delete都要加commit，而select則不用#關(guān)閉連接
cur.close() #收回手 conn.close() #關(guān)門 print reCount #輸出影響到的行數(shù)4）MySQL之刪除數(shù)據(jù)庫
import MySQLdb #必入MySQLdb模塊之前，要先裝python操作mysql模塊#創(chuàng)建連接
conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手，這里可以理解為伸出手，獲取表數(shù)據(jù)#數(shù)據(jù)刪除操作
sql = "delete from students where id=%s" #不管什么類型，占位符都是給%s， params = (7,) #把%s需要刪除的數(shù)據(jù)內(nèi)容添加到params變量就可以了，如果是字符，則需要用單引號引起來如：('n1',) reCount = cur.execute(sql,params) #刪除數(shù)據(jù) conn.commit() #提交數(shù)據(jù)，insert,update,delete都要加commit，而select則不用#關(guān)閉連接
cur.close() #收回手 conn.close() #關(guān)門 print reCount #輸出影響到的行數(shù)5）MySQL之更新數(shù)據(jù)庫
import MySQLdb #必入MySQLdb模塊之前，要先裝python操作mysql模塊#創(chuàng)建連接
conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手，這里可以理解為伸出手，獲取表數(shù)據(jù)#數(shù)據(jù)更新操作
sql = "update students set name=%s where id=6" #不管什么類型，占位符都是給%s， params = ('wsyht90') #把id為6那一行數(shù)據(jù)中的name內(nèi)容改為wsyht90 reCount = cur.execute(sql,params) #更新數(shù)據(jù) conn.commit() #提交數(shù)據(jù)，insert,update,delete都要加commit，而select則不用#關(guān)閉連接
cur.close() #收回手 conn.close() #關(guān)門 print reCount #輸出影響到的行數(shù)6）事務(wù)，要所有提交成功才會執(zhí)行成功
mysql> select *from students; +----+---------+-----+-----+---------+ | id | name | sex | age | tel | +----+---------+-----+-----+---------+ | 2 | wsyht | man | 22 | 1231313 | | 3 | jack | man | 23 | 12313 |import MySQLdb #必入MySQLdb模塊之前，要先裝python操作mysql模塊 conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手 sql = "update students set age=%s where id=2" params = (0) reCount = cur.execute(sql,params) sql = "update students set age=%s where id=3" params = (46) reCount = cur.execute(sql,params) conn.commit() cur.close() #收回手 conn.close() #關(guān)門 print reCount #輸出影響到的行數(shù)mysql> select *from students; +----+---------+-----+-----+---------+ | id | name | sex | age | tel | +----+---------+-----+-----+---------+ | 2 | wsyht | man | 0 | 1231313 | | 3 | jack | man | 46 | 12313 |7）MySQL之批量獲取字典類型數(shù)據(jù)
import MySQLdb #必入MySQLdb模塊之前，要先裝python操作mysql模塊#創(chuàng)建鏈接
conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 #cur = conn.cursor() #這里可以理解為伸出手，這里可以理解為伸出手，獲取表數(shù)據(jù) cur = conn.cursor(cursorclass = MySQLdb.cursors.DictCursor) #以字典類型獲取數(shù)據(jù)，也就是獲取表的列名和列的數(shù)據(jù)#數(shù)據(jù)操作
reCount = cur.execute('select * from students') #然后執(zhí)行動作，只是查詢影響了多少行，并不是查詢相關(guān)表的數(shù)據(jù) data = cur.fetchall() #把select查詢影響到的行的數(shù)據(jù)全拿出來#關(guān)閉連接
cur.close() #收回手 conn.close() #關(guān)門 print reCount #輸出查詢影響到的行數(shù) print data #輸出查詢影響到的行的數(shù)據(jù)8）MySQL之fetchone
import MySQLdb conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手，獲取表數(shù)據(jù) #cur = conn.cursor(cursorclass = MySQLdb.cursors.DictCursor)#數(shù)據(jù)操作
reCount = cur.execute('select * from students') #然后執(zhí)行動作，只是查詢影響了多少行，并不是查詢相關(guān)表的數(shù)據(jù) data = cur.fetchone() #只輸出取到數(shù)據(jù)的第一行 print data #輸出查詢影響到的行的數(shù)據(jù) #cur.scroll(0,mode='absolute') #覺對模式，往上走一層，從重輸出 data = cur.fetchone() #輸出取到數(shù)據(jù)的第二行 print data #輸出查詢影響到的行的數(shù)據(jù) cur.scroll(-1,mode='relative') #相對模式，往上走一層，從重新輸出 data = cur.fetchone() #輸出取到數(shù)據(jù)的第三行 cur.close() conn.close() print data #輸出查詢影響到的行的數(shù)據(jù)9）MySQL之獲取自增ID
#可看到下表ID是12，然后我插入三次數(shù)據(jù)就會變成十五，代碼如下所示
mysql> select *from students; +----+-------+-----+-----+-------+ | id | name | sex | age | tel | +----+-------+-----+-----+-------+ | 3 | jack | man | 22 | 12313 | | 12 | peter | man | 23 | 123 | +----+-------+-----+-----+-------+import MySQLdb conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #這里可以理解為打開門的鑰匙 cur = conn.cursor() #這里可以理解為伸出手，獲取表數(shù)據(jù)#數(shù)據(jù)操作
sql = "insert into students(name,sex,age,tel) values(%s,%s,%s,%s)" #不管什么類型，占位符都是給%s，四個占位符，就給四個%s params = ('peter','man','23','123') reCount = cur.execute(sql,params) #插入數(shù)據(jù) conn.commit() #提交數(shù)據(jù)，insert,update,delete都要加commit，而select則不用 new_id = cur.lastrowid #自動自增ID print new_id #輸出新的ID #關(guān)閉連接 cur.close() #收回手 conn.close() #關(guān)門#再次查看數(shù)據(jù)表
mysql> select *from students; +----+-------+-----+-----+-------+ | id | name | sex | age | tel | +----+-------+-----+-----+-------+ | 3 | jack | man | 22 | 12313 | | 12 | peter | man | 23 | 123 | | 13 | peter | man | 23 | 123 | | 14 | peter | man | 23 | 123 | | 15 | peter | man | 23 | 123 | +----+-------+-----+-----+-------+【三層架構(gòu)】 （程序分成三種架構(gòu)）
數(shù)據(jù)訪問層
業(yè)務(wù)處理層
表示層，UI層
08day10 #工程（項目） - model #（包）數(shù)據(jù)庫里有幾張表，這里就建幾個文件，并且跟數(shù)據(jù)庫的名要一一對應(yīng)，也就是要對什么表操作就建什么名字的模塊文件 - __init__.py - students.py #有一個表叫students，可以調(diào)用sql_helper模塊文件對students表做增刪改查操作，公共配置配寫在sql_helper，增刪改查寫在students，最后由admin去做執(zhí)行 - utility #（包）公共層，這里寫公共的一些功能，比如說對數(shù)據(jù)庫的操作,又比如說你要用網(wǎng)絡(luò)服務(wù)的時候，你需要請求哪個地址，那你可以再為他建一個單獨文件，統(tǒng)一操作，所有一類的都通過我去執(zhí)行，如下 - __init__.py - sql_helper.py #數(shù)據(jù)庫的公共配置操作 - conf.py #（模塊）這里面放配置文件，比如：要連接的數(shù)據(jù)庫或者要連接的接口把他的URL放在這里 - index.py #（模塊）主文件，程序進來首先執(zhí)行的文件，index再起觸發(fā)其他模塊的其他類，或其它類里的方法1)三層架構(gòu)之公共層
cat sql_helper.py #!/usr/bin/env python #coding:utf-8 import MySQLdb import conf class MySQLHelper(object): def __init__(self): self.__conn_dict = conf.conf_dict def Get_Dict(self,sql,params): conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') cur = conn.cursor() reCount = cur.execute(sql,params) data = cur.fetchall() cur.close() conn.close() return data #返回值給調(diào)用方 def Get_One(self,sql,params): conn = MySQLdb.connect(**self.__conn_dict) #兩個*以字典方式傳多個值，一個*以列表方式傳值，傳多個值 cur = conn.cursor() reCounts = cur.execute(sql,params) data = cur.fetchone() cur.close() conn.close() return data #返回值給調(diào)用方 ''' #注意：調(diào)用的話不是直接寫在這個文件調(diào)用，這不過是為了演示 helper = MySQLHelper() sql = "select *from students where id > %s" params = (15) one_data = helper.Get_one(sql, params) dict_data = helper.Get_Dict(sql, params) print one_data print dict_data '''2）三層架構(gòu)之model層
cat students.py #!/usr/bin/env python #coding:utf-8 from utility.sql_helper import MySQLHelper #把類導(dǎo)入進來 class Students(object): def __init__(self): self.__helper = MySQLHelper() #面向?qū)ο褓x值給私有字段 def Get_One(self,id): sql = "select *from students where id = %s" params = (id) return self.__helper.Get_One(sql,params) def CheckValidate(self,username,password): sql = "select * from students where name = %s and password = %s" params = (username,password) return self.__helper.Get_One(sql,params) 3）三層架構(gòu)之配置文件 conf一般與utility這一層進行相應(yīng)的設(shè)置 #!/usr/bin/env python #coding:utf-8 #以字典方式傳值,第一排和第二排勻是用字典方式傳值，任選其一即可，以后要改IP啥的來這里改即可 conf_dict = dict(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #conf_dict = {'host':'192.168.1.113','user':'root','passwd':'123456','db':'wsyht'}#主程序執(zhí)行文件
cat index.py #!/usr/bin/env python #coding:utf-8 from model.students import Students def main(): user = raw_input('username:') pwd = raw_input('password:') students = Students() result = students.CheckValidate(user,pwd) if not result: print '你輸入的用戶名或密碼有誤' else: print '歡迎登陸后臺管理頁面' if __name__ == '__main__': main()#wsyht庫下的students表
mysql> select *from students; +----+---------+-----+-----+----------+ | id | name | sex | age | password | +----+---------+-----+-----+----------+ | 1 | wsyht | man | 18 | 123456 | | 2 | jenkins | man | 20 | 13579 | +----+---------+-----+-----+----------+執(zhí)行順序總結(jié)： -->1、調(diào)用配置文件
主程序（index文件）--> model層（students表文件）--> 公共層（sql_helper數(shù)據(jù)庫公共操作文件）
-->2、調(diào)用數(shù)據(jù)庫
寫法總結(jié)： 寫法則是按執(zhí)行順序從后往上
1、先寫公共層
2、寫model層
3、寫主程序文件
4、寫配置文件
【Socket網(wǎng)絡(luò)編程】
- main 包 - client.py - server.py 示例1： #!/usr/bin/env Python #coding:utf-8 import socket def handle_request(client): buf = client.recv(1024) #客戶端接收服務(wù)端數(shù)據(jù)，緩存區(qū)1024字節(jié)，最多只能拿1024字節(jié) client.send("HTTP/1.1 200 OK\r\n\r\n") #服務(wù)端發(fā)送信息 client.send("Hello,World!123") #服務(wù)端發(fā)送信息 print buf def main(): sock = socket.socket() #建立socket對像 sock.bind(('localhost',5821)) #監(jiān)聽本地8080端口 sock.listen(5) #允許建立的大連接數(shù) while True: connection, address = sock.accept() #阻塞直接有客戶端請求，connectin就是客戶端的socket對像，address代表客戶端的地址 handle_request(connection) connection.close() if __name__ == '__main__': main() #瀏覽器訪問測試 http://localhost:5821示例2：
main #包 - init.py - server.py - client.py 服務(wù)端腳本 cat server.py #!/usr/bin/env python #coding:utf-8 import socket sk = socket.socket() #調(diào)用socket的這個類對像，創(chuàng)建對像 ip_port = ('127.0.0.1',873) sk.bind(ip_port) #監(jiān)聽服務(wù)器的IP和端口 sk.listen(5) #允許的大接數(shù)為5 while True: #創(chuàng)建一個死循環(huán)，讓他不停的接收用戶發(fā)過來的請求 conn,address = sk.accept() #阻塞等待直到有客戶端連接，conn就是客戶端的socket對像，address代表客戶端的地址 conn.send('Hello,Wo2ld!') #向客戶端發(fā)送數(shù)據(jù) conn.close() #對客戶端關(guān)閉連接客戶端腳本
cat client.py #!/usr/bin/env python #coding:utf-8 import socket client = socket.socket() #創(chuàng)建客戶端socket ip_port = ('127.0.0.1',873) client.connect(ip_port) #連接服務(wù)端 data = client.recv(1024) #接收服務(wù)端數(shù)據(jù) print data執(zhí)行腳本：先執(zhí)行服務(wù)端腳本，再執(zhí)行客戶端腳本
socket服務(wù)端執(zhí)行步驟：
1、創(chuàng)建socket對像
2、監(jiān)聽服務(wù)器IP和端口
3、設(shè)置大連接數(shù)
4、阻塞等待直到有客戶端連接
5、發(fā)送數(shù)據(jù)
6、關(guān)閉連接
socket客戶端執(zhí)行步驟
1、創(chuàng)建socket對像
2、與服務(wù)器端建立連接
3、請求數(shù)據(jù)
Socket客戶端與服務(wù)端的交互示例：
-
main 包 - client.py - server.py 服務(wù)器端演示： #!/usr/bin/env Python #coding:utf-8 import socket sk = socket.socket() ip_port = ('127.0.0.1',995) sk.bind(ip_port) sk.listen(5) #阻塞數(shù)量 while True: conn,address = sk.accept() conn.send('hello') print '新用戶進入系統(tǒng)' print 'server：hello' flag = True while flag: data = conn.recv(1024) #接收客戶端數(shù)據(jù) if data == 'exit': flag = False print '對方已退出系統(tǒng)' break print 'client:',data inp = raw_input('server：') conn.send(inp) conn.close()客戶端演示：
#!/usr/bin/env Python #coding:utf-8 import socket client = socket.socket() ip_port = ('127.0.0.1',995) client.connect(ip_port) while True: data = client.recv(1024) #接收服務(wù)端數(shù)據(jù) print 'server:',data inp = raw_input('client：') client.send(inp) if inp == 'exit': break#異步多線程服務(wù)端
cat server.py #!/usr/bin/env Python #coding:utf-8 import SocketServer class MyServer(SocketServer.BaseRequestHandler): def setup(self): pass def handle(self): conn = self.request conn.send('hello') print '新用戶進入系統(tǒng)' print 'server：hello' flag = True while flag: data = conn.recv(1024) if data == 'exit': flag = False print '對方已退出系統(tǒng)' break print 'client:',data inp = raw_input('server：') conn.send(inp) conn.close() def finish(self): pass if __name__ == '__main__': server = SocketServer.ThreadingTCPServer(('127.0.0.1',995),MyServer) server.serve_forever()#客戶端
cat client.py #!/usr/bin/env Python #coding:utf-8 import socket client = socket.socket() ip_port = ('127.0.0.1',995) client.connect(ip_port) while True: data = client.recv(1024) print 'server：',data inp = raw_input('client：') client.send(inp) if inp == 'exit': break#可以拷貝多一個client.py文件出來，然后，先執(zhí)行服務(wù)端程序，再執(zhí)行兩個客戶端文件，就可以實現(xiàn)異步處理兩個對話，也就是異步多線程處理
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
重慶分公司
重慶分公司
