--- /dev/null
+from manifold.gateways import Gateway
+from manifold.util.callback import Callback
+
+#URL='sqlite:///:memory:?check_same_thread=False'
+URL='sqlite:////var/myslice/db.sqlite?check_same_thread=False'
+
+class Storage(object):
+ pass
+ # We can read information from files, database, commandline, etc
+ # Let's focus on the database
+
+ @classmethod
+ def register(self, object):
+ """
+ Registers a new object that will be stored locally by manifold.
+ This will live in the
+ """
+ pass
+
+class DBStorage(Storage):
+ @classmethod
+ def execute(self, query, user=None, format='dict'):
+ # XXX Need to pass local parameters
+ gw = Gateway.get('sqlalchemy')(config={'url': URL}, user=user, format=format)
+ gw.set_query(query)
+ cb = Callback()
+ gw.set_callback(cb)
+ gw.start()
+ return cb.get_results()