2007/9/22 归档 - 运维进行时 - 互联网运维与架构

分页： 1/11

1 2 3 4 5 6 7 8 9 10

[ 显示模式：摘要 | 列表 ]

Django与SQLAlchemy结合例子

root , 2007/09/22 15:47 , Python , 评论(0) , 阅读(7769) , Via 本站原创

譬如，以下gumi/db.py代码，其中gumi制作Django项目名，项目中使用的唯一的数据库连接的包装，作为py调用。

# -*- coding: utf-8 -*-
from django.conf import settings
from django.core import signals
from django.dispatch import dispatcher
import sqlalchemy
from sqlalchemy.orm import scoped_session, sessionmaker
from sqlalchemy.engine.url import URL

__all__ = ['Session', 'metadata']

def create_engine():
    url = URL(drivername=settings.DATABASE_ENGINE,
              database=settings.DATABASE_NAME,
              username=settings.DATABASE_USER,
              password=settings.DATABASE_PASSWORD,
              host=settings.DATABASE_HOST,
              port=settings.DATABASE_PORT or None,
              query = getattr(settings, 'DATABASE_OPTIONS', {})
              )

options = getattr(settings, 'SQLALCHEMY_OPTIONS', {})
    engine = sqlalchemy.create_engine(url, **options)
    return engine

def end_request(signal, sender):
    Session.remove()

dispatcher.connect(receiver=end_request,
                   signal=signals.request_finished)

metadata = sqlalchemy.MetaData()

Session = scoped_session(sessionmaker(autoflush=True,
                                      transactional=True,
                                      bind=create_engine()))