https://blog.liuts.com/index.php zh-cn https://blog.liuts.com/post// root <admin@yourname.com> Sat, 22 Sep 2007 07:47:14 +0000 https://blog.liuts.com/post// # -*- 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()))
模块代码
from sqlalchemy.orm import * from gumi.db import Session, metadata some_table = Table('some_table', metadata,                           Column('id', Integer, primary_key=True),                           Column('some_value', String(100), nullable=False,                           mysql_engine='InnoDB',                           ) class SomeObject(object):     pass mapper(SomeObject, some_table)
视图代码
import django.newforms as forms from gumi.db import Session class SomeForm(forms.Form):      # newform      pass def some_action(req):      if req.method != "POST":          form = SomeForm()      else:          form = SomeForm(req.POST)          if form.is_valid():                  data = form.clean()                  obj = SomeObject()                  obj.some_param = data['a']                  obj.another_param = data['b']                  Session.save(obj)                  Session.commit()                  return HttpResponseRedirect('/')      return render_to_response('some/template.html')
Tags - python , sqlalchemy ]]> https://blog.liuts.com/post//#blogcomment <user@domain.com> Thu, 01 Jan 1970 00:00:00 +0000 https://blog.liuts.com/post//#blogcomment