##############################################################################
from database import Database
+import dbutils
class Connection(object):
- def __init__(self, *args, **kwargs):
- self._db_con = None
+ Query = dbutils.Query
+ Field = dbutils.Field
+ Table = dbutils.Table
+ Constraint = dbutils.Constraint
+ Literal = dbutils.Literal
+
+ def __init__(self, serializer=None, *args, **kwargs):
+ if serializer is None:
+ import msgpack
+ self.serializer = msgpack
+ else:
+ self.serializer = serializer
def __getattr__(self, db_name):
return Database(self, db_name)
# [{'name': 'id', 'type': 'char', 'size': 20, 'primary': True}]
return None
- def _get_cursor(self, db_name, query):
- # {'select': [('t1$_id', 'id'), {'select': [('t1$c1', 'value')], 'from': ['t1$c1'], 'where': [(('t1$c1', 'id'), '=', ('t1$_id', 'id'))]}], 'from': ['t1$_id']}
+ def _get_cursor(self, query):
return None
- def _next(self, cursor):
+ def _next(self, db_name, cursor):
return None
def _insert(self, db_name, table_name, values):
def rollback(self):
pass
+
+ def savepoint(self, name):
+ pass
+
+ def commit_savepoint(self, name):
+ pass
+
+ def rollback_savepoint(self, name):
+ pass