| author | Sandro Knauß <knauss@netzguerilla.net> |
| Thu, 29 Mar 2012 17:28:13 +0200 | |
| branch | devel |
| changeset 261 | 6b28b135a919 |
| parent 259 | 5d9c24c2cb8d |
| parent 260 | 4a03119a98c1 |
| child 262 | 212a69cc4d44 |
| permissions | -rw-r--r-- |
| 92 | 1 |
from sqlalchemy.orm import sessionmaker |
|
96
883b25b0b760
using nonblocking api for sqlalchemy
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
2 |
|
|
107
f11520354165
controller.database -> model.utils
Sandro Knauß <knauss@netzguerilla.net>
parents:
106
diff
changeset
|
3 |
class WithSession(object): |
|
259
5d9c24c2cb8d
iro.model.utils: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
4 |
'''a with statement for a database session connection.''' |
|
107
f11520354165
controller.database -> model.utils
Sandro Knauß <knauss@netzguerilla.net>
parents:
106
diff
changeset
|
5 |
def __init__(self, engine, autocommit=False): |
|
259
5d9c24c2cb8d
iro.model.utils: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
6 |
""" |
|
5d9c24c2cb8d
iro.model.utils: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
7 |
:param `sqlalchemy.engine.base.Engine` engine: a valid sqlalchemy engine object (normally created via :func:`sqlalchemy.create_engine`). |
|
5d9c24c2cb8d
iro.model.utils: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
8 |
:param boolean autocommit: autocommit after running the function. |
|
122
b55754aa4f96
nun typs query into session object
Sandro Knauß <knauss@netzguerilla.net>
parents:
117
diff
changeset
|
9 |
|
|
259
5d9c24c2cb8d
iro.model.utils: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
10 |
.. automethod:: __enter__ |
|
5d9c24c2cb8d
iro.model.utils: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
11 |
""" |
|
107
f11520354165
controller.database -> model.utils
Sandro Knauß <knauss@netzguerilla.net>
parents:
106
diff
changeset
|
12 |
self.engine = engine |
| 92 | 13 |
self.autocommit=autocommit |
|
96
883b25b0b760
using nonblocking api for sqlalchemy
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
14 |
|
| 92 | 15 |
def __enter__(self): |
|
259
5d9c24c2cb8d
iro.model.utils: adding docstrings
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
16 |
"""returns a vaild session object""" |
|
260
4a03119a98c1
deleting iro.model.session.
Sandro Knauß <knauss@netzguerilla.net>
parents:
122
diff
changeset
|
17 |
self.session = sessionmaker(bind=self.engine)() |
| 92 | 18 |
return self.session |
19 |
||
20 |
def __exit__(self,exc_type, exc_value, traceback): |
|
21 |
if exc_type is None: |
|
22 |
if self.autocommit: |
|
23 |
self.session.commit() |
|
24 |
else: |
|
25 |
self.session.rollback() |
|
26 |
self.session.close() |
|
27 |
||
|
96
883b25b0b760
using nonblocking api for sqlalchemy
Sandro Knauß <knauss@netzguerilla.net>
parents:
93
diff
changeset
|
28 |
|
|
115
323d06431100
restructering validate
Sandro Knauß <knauss@netzguerilla.net>
parents:
114
diff
changeset
|
29 |