Diff for "ObpLovelyPython/AbtWebModules"

   1 # -*- coding: utf-8 -*-
   2 from wsgiref import simple_server
   3 
   4 # 定义一个输出 hello world 和环境变量的简单web应用程序
   5 def hello_app(environ, start_response):
   6     # 输出 http 头
   7     start_response('200 OK', [('Content-type','text/plain')])
   8     # 准备输出的内容
   9     content = []
  10     content.append('Hello world')
  11     for key, value in environ.items():
  12         content.append('%s : %s' % (key, value))
  13     # 输出，根据 wsgi 协议，返回的需要是一个迭代器，返回一个 list 就可以
  14     return ['\n'.join(content)]
  15 
  16 # 构造开发服务器对象，设置绑定的地址和端口，并把 hello world 应用程序传给他
  17 server = simple_server.make_server('localhost', 8080, hello_app)
  18 # 启动开发服务器
  19 server.serve_forever()

   1 >>> # 导入 Request 对象
   2 >>> from webob import Request
   3 >>> environ = {}
   4 >>> # 使用 Request 来包装 environ 字典
   5 >>> req = Request(environ)

   1 >>> from webob import Request
   2 >>> req = Request.blank('http://localhost:8080/hello?name=python')
   3 >>> from pprint import pprint
   4 >>> # 自动构建的简易 web 环境
   5 >>> pprint(req.environ)
   6 {'HTTP_HOST': 'localhost:8080',
   7  'PATH_INFO': '/hello',
   8  'QUERY_STRING': 'name=python',
   9  'REQUEST_METHOD': 'GET',
  10  'SCRIPT_NAME': '',
  11  'SERVER_NAME': 'localhost',
  12  'SERVER_PORT': '8080',
  13  'SERVER_PROTOCOL': 'HTTP/1.0',
  14  'webob._parsed_query_vars': (MultiDict([('name', 'python')]), 'name=python'),
  15  'wsgi.errors': <open file '<stderr>', mode 'w' at 0x00B6F0B0>,
  16  'wsgi.input': <cStringIO.StringI object at 0x00B6A2F0>,
  17  'wsgi.multiprocess': False,
  18  'wsgi.multithread': False,
  19  'wsgi.run_once': False,
  20  'wsgi.url_scheme': 'http',
  21  'wsgi.version': (1, 0),
  22  'wsgiorg.routing_args': ((), {})}
  23 >>> # 通过 Request 的属性可以更方便地进行访问
  24 >>> req.method
  25 'GET'
  26 >>> req.host
  27 'localhost:8080'
  28 >>> req.path
  29 '/hello'
  30 >>> req.query_string
  31 'name=python'
  32 >>> # 可以通过字典的方式直接访问 get 参数
  33 >>> req.GET['name']
  34 'python'
  35 >>> # 和 post 数据，显然，这不是一个 post 请求
  36 >>> req.POST
  37 <NoVars: Not a form request>
  38 >>> # 不过我们仍然可以模拟一个 post 请求
  39 >>> req.method = 'POST'
  40 >>> # 手动设置模拟 post 的数据
  41 >>> req.body = 'name=python'
  42 >>> # 这下就可以了
  43 >>> req.POST['name']
  44 'python'
  45 >>> # 还可以很方便获取 cookie 数据
  46 >>> # 先模拟一段客户端请求带来的cookie
  47 >>> req.headers['Cookie'] = 'name=python'
  48 >>> # 同样，通过字典的方式对 cookie 进行访问
  49 >>> req.cookies
  50 {'name': 'python'}

   1 >>> from webob import Response
   2 >>> # 构造一个 Response对象
   3 >>> res = Response(status=200, body='hello world')
   4 >>> # 设置响应头
   5 >>> res.headers['content-type'] = 'text/plain'
   6 >>> # 设置 cookie
   7 >>> res.set_cookie('name', 'python', max_age=360, path='/',
   8 ...                domain='example.org', secure=True)
   9 >>> print res
  10 200 OK
  11 Content-Length: 11
  12 content-type: text/plain
  13 Set-Cookie: name=python; Domain=example.org; expires="Thu, 25-Sep-2008 14:28:07
  14 GMT"; Max-Age=360; Path=/; secure
  15 
  16 hello world

   1 # -*- coding: utf-8 -*-
   2 from wsgiref import simple_server
   3 from webob import Request, Response
   4 
   5 # 专门实现业务的函数，现在简洁多了
   6 def hello_app(request):
   7     content = []
   8     # 获取 get 请求的参数
   9     content.append('Hello %s'%request.GET['name'])
  10     # 输出所有 environ 变量
  11     for key, value in request.environ.items():
  12         content.append('%s : %s' % (key, value))
  13 
  14     response = Response(body='\n'.join(content))
  15     response.headers['content-type'] = 'text/plain'
  16     return response
  17 
  18 # 对请求和响应进行包装
  19 def wrapper(environ, start_response):
  20     request = Request(environ)
  21     response = hello_app(request)
  22     # response 对象本身也实现了与 wsgi 服务器之间通讯的协议，
  23     # 所以可以帮我们处理与web服务器之间的交互。
  24     return response(environ, start_response)
  25 
  26 server = simple_server.make_server('localhost', 8080, wrapper)
  27 server.serve_forever()

   1 # -*- coding: utf-8 -*-
   2 # 导入模板对象
   3 from mako import Template
   4 # 使用模板文件名构造模板对象
   5 tmpl = Template('./simple.html')
   6 # 构造一个简单的字典填充模板，并print出来
   7 print tmpl.render(name='python', data = {'a':1, 'b':2})

   1 # -*- coding: utf-8 -*-
   2 from wsgiref import simple_server
   3 from webob import Request
   4 from controller import hello_app
   5 
   6 def wrapper(environ, start_response):
   7     request = Request(environ)
   8     response = hello_app(request)
   9     return response(environ, start_response)
  10 
  11 server = simple_server.make_server('localhost', 8080, wrapper)
  12 server.serve_forever()

   1 # -*- coding: utf-8 -*-
   2 from webob import Response
   3 from mako import Template
   4 
   5 def hello_app(request):
   6     tmpl = Template('./simple.html.html')
   7     content = tmpl.render(name=request.GET['name'], data=request.environ)
   8     return Response(body=content)

   1 # -*- coding: utf-8 -*-
   2 from sqlalchemy.ext.declarative import declarative_base
   3 
   4 # 创建数据库引擎，这里我们直接使用 python2.5 自带的数据库引擎：sqlite，
   5 # 直接在当前目录下建立名为 data.db 的数据库
   6 engine = create_engine('sqlite:///data.db')
   7 # sqlalchemy 中所有数据库操作都要由某个session来进行管理
   8 # 关于 session 的详细信息请参考：http://www.sqlalchemy.org/docs/05/session.html
   9 Session = scoped_session(sessionmaker(autocommit=False, autoflush=False, bind=engine))
  10 Base = declarative_base()
  11 
  12 class Dictionay(Base):
  13     # python 对象对应关系数据库的表名
  14     __tablename__ = 't_dictionay'
  15     # 两个字段：
  16     key = Column('key', String(255), primary_key=True)
  17     value =  Column('value', String(255))
  18 
  19 # 创建数据库
  20 Base.metadata.create_all(engine)
  21 
  22 session = Session()
  23 for item in ['python','ruby','java']:
  24     dictionay = Dictionay(key=item, value=item.upper())
  25     session.add(dictionay)
  26 
  27 # 提交session，在这里才真正执行数据库的操作，添加三条记录到数据库
  28 session.commit()
  29 
  30 # 查询Dictionary类对应的数据
  31 for dictionay in session.query(Dictionary):
  32     print dictionay.name, dictionay.value

   1 # -*- coding: utf-8 -*-
   2 from sqlalchemy.ext.declarative import declarative_base
   3 
   4 engine = create_engine('sqlite:///data.db')
   5 Session = scoped_session(sessionmaker(autocommit=False, autoflush=False, bind=engine))
   6 Base = declarative_base()
   7 
   8 class Dictionay(Base):
   9     __tablename__ = 't_dictionay'
  10     key = Column('key', String(255), primary_key=True)
  11     value =  Column('value', String(255))

   1 # -*- coding: utf-8 -*-
   2 # 导入公用的 model 模块
   3 from model import Base, Session, Dictionary
   4 
   5 # 创建数据库
   6 Base.metadata.create_all(engine)
   7 
   8 # 插入初始数据
   9 session = Session()
  10 for item in ['python','ruby','java']:
  11     dictionay = Dictionay(key=item, value=item.upper())
  12     session.add(dictionay)
  13 
  14 session.commit()

   1 # -*- coding: utf-8 -*-
   2 from webob import Response
   3 from mako import Template
   4 # 导入公用的 model 模块
   5 from model import Session, Dictionary
   6 
   7 def hello_app(request):
   8     session = Session()
   9     # 查询到所有 Dictionary 对象
  10     dictionaries = session.Query(Dictionary)
  11     # 然后根据 Dictionary 对象的 name、value 属性把列表转换成一个字典
  12     data = dict([(dictionary.name, dictionary.value) for dictionary in dictionaries])
  13 
  14     tmpl = Template('./simple.html.html')
  15     content = tmpl.render(name=request.GET['name'], data=data)
  16     return Response(body=content)