您的位置：首页 > 数据库

tornado开发输入输出，数据库操作，内置模板，综合示例

2013-04-01 18:33 351 查看

tornado开发学习之2.输入输出，数据库操作，内置模板，综合示例

使用python环境中的tornado进行web开发上篇已经解决了urlmap和基本运行机制的问题。接下来进行web编程就是一下几个问题

1.输入数据的获取和输出运算结果

2.数据库操作

3.自带模板的使用

当然还有cookies和session等，这些杂项，不在本篇进行学习。

1.输入数据的获取和输入运算结果

WEB作为一种UI表达方式，最重要的是获取数据和表达运算结果，所以如何在一个web开发框架中获取url或post传递过来的参数十分重要，我建议学习所有的Web开发语言或框架都从此开始比较好。在tornado中从我自己的理解来看有两种获取参数的方式

a.通过urlmap做正则表达式，通过抓取组来直接获取参数
这就需要我们在做URL配置时就想好要传递的参数如，我们需要给ArticleDetail类传递一个文章编号，我们知道这个编号只能是数字类型的。那么可以在配置时写成如下样子

?

其中的(d+)就是一个正则的抓取组，用于获取多位的数字。那么在ArticleDetail类的get或post函数实现时就要写成

?

入口时多了一个id参数，当然你也可以用别的变量名，都会将URL匹配的结果放进这个参数传入的。

b.通过在get或post中使用tornado的RequestHandler的get_argument函数来获取参数
为了同样获取到文章id这个参数，如果我们不在URL配置时做正则（一般我都不做，因为我对正则不很熟练），也可以在具体处理某个地址的类方法中使用get_argument来获得参数值，还是以获取文章编号为例，我们需要如下方式来编写Url配置

?

在地址定义中我们取消了正则匹配组，让地址直接交给ArticleDetail类全权负责。接下来在ArticleDetail中get或post函数的入口就不能在有除self意外的参数了,当使用/detail?id=1访问系统时

?

对于输出,一般在任何WEB开发框架中都比较简单，tornado中就是简单的self.write(htmlsrc),其中htmlsrc就是即将交给浏览器显示的html文件的源码。一般是由模板引擎将数据与模板结合后字符串结果。

2.数据操作

WEB开发与其他开发一致，也需要涉及数据的持久化和数据的读取。WEB的UI是HTML解决软件的界面，参数的收集，事件的触发，结果的显示；开发语言负责解决运算逻辑，数据读取和保存；数据库和数据文件或其他方式的持久化解决对象持久化和数据源问题（当然还有一种叫oracle的数据库！！！！它太NB了，自己都能写WEB，也能写程序，与我理解上数据库应该干的活区别较大，请观众随意吐槽）；所以解决参数获取和数据库操作，基本上就解决了WEB开发的最大问题了（jquery?html?这也是很大的问题，但属于前端开发的主要学习方向）。

tornado内置了一个简单封装了Mysql的操作，pypminstallpython-mysql需要事先安装好驱动哦。公布出来的函数比较少，与直接使用python的数据接口基本一致，稍稍简单写。

a.数据连接

?

创建数据库连接后就可以使用db来进行后边介绍的基本操作了。

b.查询常用的查询方法如下

1).query()，用于执行select语句，返回的是行集list,例如

　　

2).get(),返回的是符合条件的结果集的第一行

3).execute(),用于执行select以外的语句，返回值基本无视

基本上如果你的语句没写错，得到的都是0

c.数据结果

知道如何查询后续就是如何利用查询得到的结果了。

对于query()操作返回的是[]数组(命名位items)，

数组中每一个元素均是{}字典(每一个都是item)。

如果确切知道字段名（属性名）如确切知道查询结果中至少有一行数据，包含名为title的字段，可以直接使用items[0].title得到数据。

如果不确切知道字段名，或字段值可能为None，可使用items[0].get('title','')来获取值。最常用的方法是循环

foriteminitems:printitem.get('title','')

d.其他操作

execute_rowcount(sql)用于获取查询或更新得到的记录行集的行数，特别有意思的是如果你要更新的内容本来已经是那个样子，如

printdb.execute_rowcount("updatecustomersetsex='女'whereid=10128")printdb.execute_rowcount("updatecustomersetsex='女'whereid=10128")

执行两遍得到的结果是1,0。我原来一直以为数据库很弱智的，看来是我那时候不懂事，很天真。

close()用于手动关闭数据连接，在小型应用中我们基本不会看到他的出现

3.自带的模板的使用

web编程其实可以不用模板的，但是那样不仅写的时候痛苦，写出来以后更痛苦

写的时候，html代码与python代码混合，连接字符串非常费力

改的时候很容易出现错误，python又不是编译执行的，上线了执行到某错误时，多恼火，低级愚蠢的错误容易犯

换web的UI时这种写法根本没办法操作，那就是重写一次程序啊，杀人的心都有的

所以如果你开发了一个Web系统，但是没有用模板技术，这个系统就只能给钱多人傻的单位做了。

mako是我最喜欢的模板，但是学习tornado么，而且不是那种排版敏感的，先来学习用用它自带的。

web使用开发使用模板引擎我么要主要解决一下几个主要的问题，在tornado中我们一个个破解

-1.路径和模板存放方式

善用os.path.dirname(file)来解决路径问题，例如我们的模板准备放在工程的根目录下的/T/目录中，对于模板存放的目录我们可以这样定义

?

当然我更倾向直接定义绝对路径的方法来解决这个问题，因为使用上也特别简单，而且可以把模板放在与源代码无关的目录中，上线使用时也更加安全

?

模板一般就是普通的文本文件，方便起见一般以html扩展名存放比较好。比如index.html，这样我们把index.html放入我们定义的模板加载路径后使用以下代码加载模板引擎

?

其中t就是我们直接可以使用的模板了。

2.数据与模板如何结合

模板主要功能之一就是解决数据的显示方式，如何把我们的数据交给模板使用？首先我们来获取数据

?

代码第三行的datas1和data2是在tornado模板文件中将要引用的变量名我们的模板编写如下

?

可以高兴地讲：

1.tornado的模板不需要严格按照python的缩进来书写

2.tornado的模板使用{{变量或对象}}来获取具体的变量值或对象属性值

3.tornado的模板中使用{%forvarinvars%}....{%end%}来实现循环

4.tornado的模板中使用{%if条件%}...{%elif条件%}...{%else%}...{%end%}方式实现模板内的判断

5.tornado的模板使用{%include文件名%}来包含子模板，同时也会运算子模板的运算逻辑

制作的目标做一个对一个数据表进行增加、删除、修改和简单查询的程序数据表我们假定为通讯录数据为了简化程序的运行逻辑，尽可能不用ajax或其他需要一些javascript基础的写法数据库当然使用mysql啦

1#-*-coding:utf-8-*- 2importjson 3__author__='jy@cjlu.edu.cn' 4fromtornado.webimportRequestHandler 5fromStorageimportstorage 6classbasehandler(RequestHandler): 7"""所有Handler基类""" 8definput(self): 9"""获取到所有的输入数据，将其转换成storage方便调用""" 10i=storage()#初始化一个容器 11#得到所有的输入参数和参数值 12args=self.request.arguments 13#将参数写入i的属性 14forainargs: 15i[a]=self.get_argument(a) 16#获取file类型的参数 17i["files"]=storage(self.request.files) 18#获取path 19i["path"]=self.request.path 20#获取headers 21i["headers"]=storage(self.request.headers) 22returni

#-*-coding:utf-8-*-
__author__='jy@cjlu.edu.cn'
fromconfigimportsdb
fromStorageimportstorage
defGC_set(obj):
return""
classd_contacts:
fields=["id","truename","sex","phoneno","email"]#定义好数据表有的数据

defgetAll(self):
"""获取全部记录集合"""
items=sdb.query("select*fromd_contacts")
ifitems:
foriinitems:
i=storage(i)
returnitems
defdelEntityById(self,id):
"""根据id来删除数据"""
returnsdb.execute("deletefromd_contactswhereid=%s",id)
defgetEntityById(self,id):
"""根据id来或取对象实例"""
ifid:
id=int(id)
item=sdb.get("select*fromd_contactswhereid=%s",id)
returnstorage(item)
else:
returnNone
defgetRowsBySqlwhere(self,sqlwhere):
"""根据sqlwhere来查询数据集合"""
items=sdb.query("select*fromd_contactswhereid>0"+sqlwhere)
ifitems:
foriinitems:
i=storage(i)
returnitems
defupdate(self,obj):
"""更新数据行集"""
obj=storage(obj)
returnsdb.execute("updated_contactssettruename=%s,sex=%s,phoneno=%s,email=%swhereid=%s",obj.truename,obj.sex,obj.phoneno,obj.email,obj.id)
definsert(self,obj):
"""写入数据"""
obj=storage(obj)
returnsdb.execute("insertintod_contacts(truename,sex,phoneno,email)values(%s,%s,%s,%s)",obj.truename,obj.sex,obj.phoneno,obj.email)
defgetRowBySqlwhere(self,sqlwhere):
"""根据sqlwhere来获取一个数据实例"""
item=sdb.get("select*fromd_contactswhereid>0"+sqlwhere)
ifitem:
item=storage(item)
returnitem

#-*-coding:utf-8-*-
__author__='jy@cjlu.edu.cn'
importos
fromtornadoimporttemplate
fromStorageimportstorage
#导入工具函数
fromutilsimport*
#导入基础类
frombasehandlerimportbasehandler
#导出持久类
frommodels.d_contactsimportd_contacts
#导入模板
fromconfigimportTP
#创建持久对象
optobj=d_contacts()
#建立模板，指定模板路径
tl=template.Loader(os.path.join(TP,"f10/T"))

classList(basehandler):
"""用于处理显示列表"""
defget(self):
#获取全部输入参数
i=self.input()
#获取全部数据，继续改下去一定要考虑分页
i.recs=optobj.getAll()
#调用模板
t=tl.load("f1001_list.html")
#把数据推给模板进行运算
htmlsrc=t.generate(i=i)
#显示运算结果
self.write(htmlsrc)
defpost(self):
"""由于不需要处理POST，所以不实现"""
pass

classUpdate(basehandler):
"""用于处理显示修改界面，处理ajax修改、新增、删除的请求"""
defget(self):

i=self.input()
#初始化i的rec属性，让Rec具有与数据表字段名的全部属性
i.rec=InitStorage(i,["id","truename","phoneno","email"])
#从数据库中获取数据
i.rec=optobj.getEntityById(i.id)
#调用模板
t=tl.load("f1001_update.html")
#把数据推给模板进行运算
htmlsrc=t.generate(i=i)
#显示运算结果
self.write(htmlsrc)

defpost(self):
"""
处理写入数据删除数据和保存数据等操作
"""
defvalid(v):
"""验证邮件是否正确
"""
ifIsEmail(v.email):
returnTrue
else:
returnFalse
#特别要注意，因为是响应的ajax的请求，返回数据类型需指定为json
self.set_header("Content-Type","application/json")
#做一个容器变量
v=storage()
#获取到全部的输入值
i=self.input()
#将输入参数中与数据表字段名一致的值赋值给v对象的属性
v=CopyData_INC(v,i,optobj.fields)
#根据操作类型来进行处理
ifi.act=="add":
vv=valid(i)
ifvv==True:
optobj.insert(v)
#返回处理结果JSON值
self.write(JsonResult("OK"))
else:
self.write(JsonResult("NOOK"))
ifi.act=="update":
vv=valid(i)
ifvv==True:
optobj.update(v)
self.write(JsonResult("OK"))
else:
self.write(JsonResult("NOOK"))
ifi.act=="del":
optobj.delEntityById(i.id)
self.write(JsonResult("OK"))

tornado开发输入输出，数据库操作，内置模板，综合示例

tornado开发学习之2.输入输出，数据库操作，内置模板，综合示例

1.输入数据的获取和输入运算结果

2.数据操作

3.自带的模板的使用

4.综合示例

5.结论与其他