5.Python操作MySQL,三层架构,Socket网络编程-创新互联

Python操作MySQL

创新互联建站于2013年创立，先为海北州等服务建站，海北州等地企业，进行企业商务咨询服务。为海北州企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。

- MySQL之查询操作

- MySQL之插入数据

- MySQL之批量插入数据

- MySQL之删除数据

- MySQL之更新数据库

- MySQL之事务

- MySQL之批量获取字典类型数据

- MySQL之fetchone

- MySQL之获取自增ID

三层架构（程序分成三种架构）

- 三层架构之公共层

- 三层架构之model层

- 三层架构之配置文件

Socket网络编程

【Python操作MySQL】

准备工作：

Windows下载链接，Python操作MySQL模块：

http://pan.baidu.com/s/1o7JuMgU

提示：Windows安装了mysql模块后，因为我用的是Eclipse，所以我还要在Eclipse下做一下设置，如下：

在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 "-" );

插入数据：

insert into students(name,sex,age,tel) values('wsyht','man',20,'1319')

数据库和表

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 #必须在导入MySQLdb模块之前，要先装python操作mysql模块

#创建连接

conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #这里可以理解为打开门的钥匙 cur = conn.cursor() #这里可以理解为伸出手，这里可以理解为伸出手，获取表数据

#数据查询操作

reCount = cur.execute('select * from students') #然后执行动作，只是查询影响了多少行，并不是查询相关表的数据 data = cur.fetchall() #把select查询影响到的行的数据全拿出来

#关闭连接

cur.close() #收回手 conn.close() #关门

#输出信息

print reCount #输出查询影响到的行数 print data #输出查询影响到的行的数据

2）MySQL之插入数据

import MySQLdb

#创建连接

#数据插入操作

sql = "insert into students(id,name,sex,age,tel) values(%s,%s,%s,%s,%s)" #不管什么类型，占位符都是给%s，五个占位符，就给五个%s params = ('6','peter','man','23','123') #如果这里id设了自增，那么这排第一位和上面一排第一位id可以不用写 reCount = cur.execute(sql,params) #插入数据 conn.commit() #提交数据，insert,update,delete都要加commit，而select则不用

#关闭连接

cur.close() #收回手 conn.close() #关门 print reCount #输出影响到的行数

3）MySQL之批量插入数据

import MySQLdb #必入MySQLdb模块之前，要先装python操作mysql模块

#创建连接

#批量插入数据操作

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) #删除数据 conn.commit() #提交数据，insert,update,delete都要加commit，而select则不用

#关闭连接

cur.close() #收回手 conn.close() #关门 print reCount #输出影响到的行数

4）MySQL之删除数据库

import MySQLdb #必入MySQLdb模块之前，要先装python操作mysql模块

#创建连接

#数据删除操作

sql = "delete from students where id=%s" #不管什么类型，占位符都是给%s， params = (7,) #把%s需要删除的数据内容添加到params变量就可以了，如果是字符，则需要用单引号引起来如：('n1',) reCount = cur.execute(sql,params) #删除数据 conn.commit() #提交数据，insert,update,delete都要加commit，而select则不用

#关闭连接

cur.close() #收回手 conn.close() #关门 print reCount #输出影响到的行数

5）MySQL之更新数据库

import MySQLdb #必入MySQLdb模块之前，要先装python操作mysql模块

#创建连接

#数据更新操作

sql = "update students set name=%s where id=6" #不管什么类型，占位符都是给%s， params = ('wsyht90') #把id为6那一行数据中的name内容改为wsyht90 reCount = cur.execute(sql,params) #更新数据 conn.commit() #提交数据，insert,update,delete都要加commit，而select则不用

#关闭连接

cur.close() #收回手 conn.close() #关门 print reCount #输出影响到的行数

6）事务，要所有提交成功才会执行成功

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() #关门 print reCount #输出影响到的行数

mysql> select *from students; +----+---------+-----+-----+---------+ | id | name | sex | age | tel | +----+---------+-----+-----+---------+ | 2 | wsyht | man | 0 | 1231313 | | 3 | jack | man | 46 | 12313 |

7）MySQL之批量获取字典类型数据

import MySQLdb #必入MySQLdb模块之前，要先装python操作mysql模块

#创建链接

conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #这里可以理解为打开门的钥匙 #cur = conn.cursor() #这里可以理解为伸出手，这里可以理解为伸出手，获取表数据 cur = conn.cursor(cursorclass = MySQLdb.cursors.DictCursor) #以字典类型获取数据，也就是获取表的列名和列的数据

#数据操作

#关闭连接

cur.close() #收回手 conn.close() #关门 print reCount #输出查询影响到的行数 print data #输出查询影响到的行的数据

8）MySQL之fetchone

import MySQLdb conn = MySQLdb.connect(host='192.168.1.113',user='root',passwd='123456',db='wsyht') #这里可以理解为打开门的钥匙 cur = conn.cursor() #这里可以理解为伸出手，获取表数据 #cur = conn.cursor(cursorclass = MySQLdb.cursors.DictCursor)

#数据操作

reCount = cur.execute('select * from students') #然后执行动作，只是查询影响了多少行，并不是查询相关表的数据 data = cur.fetchone() #只输出取到数据的第一行 print data #输出查询影响到的行的数据 #cur.scroll(0,mode='absolute') #觉对模式，往上走一层，从重输出 data = cur.fetchone() #输出取到数据的第二行 print data #输出查询影响到的行的数据 cur.scroll(-1,mode='relative') #相对模式，往上走一层，从重新输出 data = cur.fetchone() #输出取到数据的第三行 cur.close() conn.close() print data #输出查询影响到的行的数据

9）MySQL之获取自增ID

#可看到下表ID是12，然后我插入三次数据就会变成十五，代码如下所示

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() #这里可以理解为伸出手，获取表数据

#数据操作

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) #插入数据 conn.commit() #提交数据，insert,update,delete都要加commit，而select则不用 new_id = cur.lastrowid #自动自增ID print new_id #输出新的ID #关闭连接 cur.close() #收回手 conn.close() #关门

#再次查看数据表

【三层架构】（程序分成三种架构）

数据访问层

业务处理层

表示层，UI层

08day10 #工程（项目） - model #（包）数据库里有几张表，这里就建几个文件，并且跟数据库的名要一一对应，也就是要对什么表操作就建什么名字的模块文件 - __init__.py - students.py #有一个表叫students，可以调用sql_helper模块文件对students表做增删改查操作，公共配置配写在sql_helper，增删改查写在students，最后由admin去做执行 - utility #（包）公共层，这里写公共的一些功能，比如说对数据库的操作,又比如说你要用网络服务的时候，你需要请求哪个地址，那你可以再为他建一个单独文件，统一操作，所有一类的都通过我去执行，如下 - __init__.py - sql_helper.py #数据库的公共配置操作 - conf.py #（模块）这里面放配置文件，比如：要连接的数据库或者要连接的接口把他的URL放在这里 - index.py #（模块）主文件，程序进来首先执行的文件，index再起触发其他模块的其他类，或其它类里的方法

1)三层架构之公共层

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 #返回值给调用方 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 #返回值给调用方 ''' #注意：调用的话不是直接写在这个文件调用，这不过是为了演示 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）三层架构之model层

cat students.py #!/usr/bin/env python #coding:utf-8 from utility.sql_helper import MySQLHelper #把类导入进来 class Students(object): def __init__(self): self.__helper = MySQLHelper() #面向对像赋值给私有字段 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）三层架构之配置文件 conf一般与utility这一层进行相应的设置 #!/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'}

#主程序执行文件

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 | +----+---------+-----+-----+----------+

执行顺序总结： -->1、调用配置文件

主程序（index文件）--> model层（students表文件）--> 公共层（sql_helper数据库公共操作文件）

-->2、调用数据库

写法总结：写法则是按执行顺序从后往上

1、先写公共层

2、写model层

3、写主程序文件

4、写配置文件

【Socket网络编程】

- main 包 - client.py - server.py 示例1： #!/usr/bin/env Python #coding:utf-8 import socket def handle_request(client): buf = client.recv(1024) #客户端接收服务端数据，缓存区1024字节，最多只能拿1024字节 client.send("HTTP/1.1 200 OK\r\n\r\n") #服务端发送信息 client.send("Hello,World!123") #服务端发送信息 print buf def main(): sock = socket.socket() #建立socket对像 sock.bind(('localhost',5821)) #监听本地8080端口 sock.listen(5) #允许建立的大连接数 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 服务端脚本 cat server.py #!/usr/bin/env python #coding:utf-8 import socket sk = socket.socket() #调用socket的这个类对像，创建对像 ip_port = ('127.0.0.1',873) sk.bind(ip_port) #监听服务器的IP和端口 sk.listen(5) #允许的大接数为5 while True: #创建一个死循环，让他不停的接收用户发过来的请求 conn,address = sk.accept() #阻塞等待直到有客户端连接，conn就是客户端的socket对像，address代表客户端的地址 conn.send('Hello,Wo2ld!') #向客户端发送数据 conn.close() #对客户端关闭连接

客户端脚本

cat client.py #!/usr/bin/env python #coding:utf-8 import socket client = socket.socket() #创建客户端socket ip_port = ('127.0.0.1',873) client.connect(ip_port) #连接服务端 data = client.recv(1024) #接收服务端数据 print data

执行脚本：先执行服务端脚本，再执行客户端脚本

socket服务端执行步骤：

1、创建socket对像

2、监听服务器IP和端口

3、设置大连接数

4、阻塞等待直到有客户端连接

5、发送数据

6、关闭连接

socket客户端执行步骤

1、创建socket对像

2、与服务器端建立连接

3、请求数据

Socket客户端与服务端的交互示例：

main 包 - client.py - server.py 服务器端演示： #!/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) #阻塞数量 while True: conn,address = sk.accept() conn.send('hello') print '新用户进入系统' print 'server：hello' flag = True while flag: data = conn.recv(1024) #接收客户端数据 if data == 'exit': flag = False print '对方已退出系统' 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) #接收服务端数据 print 'server:',data inp = raw_input('client：') client.send(inp) if inp == 'exit': break

#异步多线程服务端

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 '新用户进入系统' print 'server：hello' flag = True while flag: data = conn.recv(1024) if data == 'exit': flag = False print '对方已退出系统' 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文件出来，然后，先执行服务端程序，再执行两个客户端文件，就可以实现异步处理两个对话，也就是异步多线程处理

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

分享名称：5.Python操作MySQL,三层架构,Socket网络编程-创新互联
网页地址：http://6mz.cn/article/cdjico.html

网站建设知识

5.Python操作MySQL,三层架构,Socket网络编程-创新互联

其他资讯