-
Notifications
You must be signed in to change notification settings - Fork 58
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
1 changed file
with
241 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1 +1,241 @@ | ||
test | ||
tornado内部化包含了一个很简陋的database.py,最近在这个简单封装了MysqlDb的模块基础上增加增强的功能。 | ||
对于Python这种动态语言来说我觉得ORM有点过度封装了,很多时候简单的数据操作不好用,太复杂的操作又不如直接写Sql,所以我放弃了Orm的方式,而是直接抽象了Sql的构建,现在的版本支持单表的sql查询,支持子查询,当然还有一些操作有所遗漏,我会继续向项目里追加。 | ||
下载地址:http://files.cnblogs.com/Alexander-Lee/database.py.zip | ||
文档: | ||
Quick start | ||
假设建立表User | ||
create table `user`( | ||
`id` bigint(20) AUTO_INCREMENT, | ||
`name` varchar(20), | ||
`age` int(10), | ||
`birth` datetime, | ||
) | ||
创建连接: | ||
db=Connection(host=’127.0.0.1′,database=’testdb’,user=’root’,password=’xxxxx’) | ||
基本sql操作 | ||
————————————————————————– | ||
查询多行 | ||
(打印年龄大于18的用户名) | ||
for row in db.query(‘select * from user where age>%s’,18) | ||
print row.name | ||
查询单行 | ||
(获取id=5的用户) | ||
user=db.query(‘select * from user where id=%s’,5) | ||
执行sql | ||
(更新生日大于等于8月23日的用户年龄+1) | ||
db.query(‘update user set age=age+1 where DATE_FORMAT(birth,’%%Y-%%m-%%d’)>=%s’,’2010-08-23′) | ||
插入记录 | ||
db.insert(‘user’,name=’alex’,age=28,birth=’1981-08-31′) | ||
————————————————————————– | ||
无sql操作 | ||
step 1 获取表对象 | ||
t = db.user | ||
step 2 创建一个查询 | ||
q=t(t.age>18) #用户年龄大于18岁的查询 | ||
在这个查询的基础上可以进行下一步的操作,在这个筛选数据条件基础上对筛选出来的数据进行查询、更新、删除的操作 | ||
查询条件可以多个组合,比如 | ||
(t.age>18)&(t.age<30)|(t.id<500) | ||
组合出来的条件就是 age>18 and age<30 or id<500 | ||
1,查询: | ||
for user in q.select.sort(birth="DESC")(): | ||
print user.name | ||
根据birth字段取倒序,查询出所有的age>18的用户,打印出用户名 | ||
查询分页 q.select.sort(birth=”DESC”)[2:10]() #按页大小20,取第二页的数据 | ||
2,更新: | ||
(更新生日大于等于8月23日的用户年龄+1) | ||
t=db.user | ||
q=t(t.birth.DL(‘%%Y-%%m-%%d’,’2010-08-23′)) | ||
q.update(t.age==t.age+1) | ||
3.删除 | ||
在查询的基础上还可以对查询出的结果直接删除掉,比如 | ||
q.delete() | ||
API reference | ||
Connection 对象 | ||
构造器参数: | ||
host=’服务器ip/域名’,database=’Schame名’,user=’登录用户’,password=’密码’ | ||
例子:db=Connection(host=’127.0.0.1′,database=’testdb’,user=’root’,password=’xxxxx’) | ||
方法(名称后带*的是tornado原有database.py中原有的方法,不带*的是扩展的方法): | ||
名称:execute * | ||
参数:(sql,[params]) | ||
返回值:执行sql影响的数据行数 | ||
用途:执行不返回结果集的sql | ||
例子:db.execute(‘update testtable set col1=%s where id=%s’,'haha’,1) | ||
名称:executemany * | ||
参数:(sql,[params]) | ||
返回值:执行sql影响的数据行数 | ||
用途:同时执行多条不返回结果集的sql | ||
例子:db.execute(‘update testtable set col1=%s where id=%s;update user set age=1 where,id=1′,’haha’,1) | ||
名称:get * | ||
参数:(sql,[params]) | ||
返回值:Row对象(见Row对象部分) | ||
用途:返回单行结果 | ||
例子:user=db.get(‘select * from user where id=%s’,1) | ||
名称:query * | ||
参数:(sql,[params]) | ||
返回值:Row对象列表 | ||
用途:返回多行结果 | ||
例子:users=db.query(‘select * from user where id<%s',5) | ||
名称:count | ||
参数:(sql,[params]) | ||
返回值:count函数返回的结果 | ||
用途:通过sql取记录数 | ||
例子:c=db.count('select count(1) from user where age>%s’,18) | ||
名称:insert | ||
参数:(tablename,**dict(字段名=值)) | ||
用途:插入记录 | ||
例子:db.insert(‘user’,name=’alex’,age=28,) | ||
名称:commit * | ||
参数:无 | ||
返回值:无 | ||
用途:提交事务,由于不是auto commit的连接,所以对数据库的更新都需要手动commit才能生效 | ||
例子:db.commit() | ||
名称:rollback * | ||
参数:无 | ||
返回值:无 | ||
用途:回滚事务 | ||
例子:db.rollback() | ||
名称:fromQuery | ||
参数:Select对象 | ||
返回值:TableQueryer对象 | ||
用途:得到一个基于已有查询的TableQueryer对象 | ||
例子:t2=db.fromQuery(q1) | ||
Row对象 | ||
查询的结果集都由Row对象进行封装,Row对象是一个字典,Key是数据库字段名,Value是字段的值,可以通过属性访问字典的Key | ||
TableQueryer对象 | ||
通过Connection对象创建 | ||
有两种方式: | ||
1: db.tablename #获取tablename这个表的TableQueryer对象 | ||
2: db.fromQuery(q) #通过已经存在的查询获取一个TableQueryer对象,实现子查询 | ||
用途: | ||
1:获取字段条件对象 (conds对象) | ||
例子:t=db.tablename | ||
t.col1 | ||
2:获取查询的执行对象 (Operater对象) | ||
例子:t=db.tablename | ||
q=t(t.col1>5) #需要加入查询条件来创建 | ||
方法: | ||
名称:get_one | ||
参数:conds对象 | ||
返回值:Row对象 | ||
用途:获取表中单条记录 | ||
例子:user=db.user.get_one(db.user.id==5) | ||
名称:insert | ||
参数:**dict(字段名=值) | ||
返回值:是否成功 | ||
用途:插入记录到该表 | ||
例子:db.tablename.insert(col1=123,col2=’abc’) | ||
Operater对象 | ||
通过调用TableQueryer对象创建 | ||
属性: | ||
select:返回Select对象 | ||
update:返回Update对象 | ||
delete:返回Delete对象 | ||
insert:返回Insert对象 | ||
Select对象 | ||
生成select的sql,收集参数,并执行返回多行结果集 | ||
方法: | ||
名称:group_by | ||
参数:*conds对象 | ||
返回值:Select对象 | ||
用途:加入group by操作的设定 | ||
例子:q=db.tablename(db.tablename.col1>5) | ||
q.select.group_by(db.tablename.age) | ||
sql:select * from tablename where col1>5 group by age | ||
名称:having | ||
参数:conds对象 | ||
返回值:Select对象 | ||
用途:加入having设定 | ||
例子:q=db.tablename(db.tablename.col1>5) | ||
q.select.group_by(db.tablename.age).having(db.tablename.col2.count>6) | ||
sql:select * from tablename where col1>5 group by age having count(col2)>6 | ||
备注:必须在调用了group_by的前提下才能调用having,否则having条件不生效 | ||
名称:collect | ||
参数:*conds | ||
返回值:Select对象 | ||
用途:设定要筛选出的字段 | ||
例子:q=db.tablename(db.tablename.col1>5) | ||
q.select.collect(db.tablename.col1,db.tablename.col12) | ||
sql:select col1,col2 from tablename where col1>5 | ||
名称:limit | ||
参数:start,count | ||
返回值:Select对象 | ||
用途:设定limit参数 | ||
例子:q=db.tablename(db.tablename.col1>5) | ||
q.select.collect(db.tablename.col1,db.tablename.col12).limit(10,10) | ||
sql:select col1,col2 from tablename where col1>5 limit 10,10 | ||
名称:get_sql | ||
参数:无 | ||
返回值:生成的sql语句 | ||
用途:返回生成的sql语句 | ||
分页: | ||
对Select对象切片操作即可设定分页参数 | ||
比如:q=db.tablename(db.tablename.col1>5) | ||
q.select.collect(db.tablename.col1,db.tablename.col12)[2:10] | ||
则是设定,页大小是10条记录,取地2页 | ||
执行sql: | ||
直接执行Select对象 | ||
比如:q=db.tablename(db.tablename.col1>5) | ||
s=q.select.collect(db.tablename.col1,db.tablename.col12)[2:10] | ||
rs=s() | ||
Update对象: | ||
用于生成Update语句更新记录 | ||
例子: | ||
q=db.tablename(db.tablename.col1>5) | ||
q.update(db.tablename.col3==db.tablename.col3+5) | ||
sql:update tablename set col3=col3+5 where col1>5 | ||
Delete对象 | ||
用于生成Delete语句 | ||
例子: | ||
q=db.tablename(db.tablename.col1>5) | ||
q.delete() | ||
sql:delete from tablename where col1>5 | ||
Insert对象 | ||
用于生成insert语句 | ||
例子: | ||
q=db.tablename(db.tablename.col1>5) | ||
q.insert(col1=1,col2=’abc’) | ||
conds对象 | ||
字段定义以及字段关系条件的定义对象 | ||
通过TableQueryer对象的属性获取新的对象 | ||
比如: t=db.tablename | ||
t.col1 | ||
操作符: | ||
==:赋值或者相等比较,比如 t.col1==5 生成sql col=%s 且在参数列表中加入值5 | ||
>:生成sql col>%s | ||
<:生成sql col<%s | ||
>=:生成sql col>=%s | ||
<=:生成sql col<=%s | ||
!=:生成sql col<>%s | ||
&:将两个条件取and关系,比如 (t.col1==5)&(t.col2<20) 生成sql col1=%s and col2<%s | ||
|:将两个条件取or关系 | ||
方法: | ||
名称:like | ||
参数:任意对象 | ||
返回值:conds对象 | ||
用途:生成sql col like %s | ||
名称:In | ||
参数:列表或者Select对象 | ||
返回值:conds对象 | ||
用途:生成IN 语句 | ||
名称:Not_In | ||
参数:列表或者Select对象 | ||
返回值:conds对象 | ||
用途:生成IN 语句 | ||
名称:DL | ||
参数:格式化字符串,时间值 | ||
返回值:conds对象 | ||
用途:时间字段大于等于给定值 | ||
例子:t.col1.DL('%%Y-%%m-%%d','2010-10-20') | ||
SQL: DATE_FORMAT(col1,'%%Y-%%m-%%d')>=%s | ||
名称:DG | ||
参数:格式化字符串,时间值 | ||
返回值:conds对象 | ||
用途:时间字段小于等于给定值 | ||
例子:t.col1.DG(‘%%Y-%%m-%%d’,’2010-10-20′) | ||
SQL: DATE_FORMAT(col1,’%%Y-%%m-%%d’)<=%s | ||
名称:DE | ||
参数:格式化字符串,时间值 | ||
返回值:conds对象 | ||
用途:时间字段等于给定值 | ||
例子:t.col1.DE('%%Y-%%m-%%d','2010-10-20') | ||
SQL: DATE_FORMAT(col1,'%%Y-%%m-%%d')=%s |