summaryrefslogtreecommitdiff
path: root/lib/db.py
diff options
context:
space:
mode:
authorpepperpepperpepper <pepper@scannerjammer.com>2015-10-06 20:06:15 -0700
committerpepperpepperpepper <pepper@scannerjammer.com>2015-10-06 20:06:15 -0700
commit14b6ac27f1b4e910886389f5d5980ac6c586825d (patch)
treedd3bccc88e33f0481b4cab0c39a821a6c2f468bd /lib/db.py
parent55636242fb42009fac80656ad5106ad2717bcd75 (diff)
parent24cbbdbf904403f79c07bb4d358fa4293e3e6709 (diff)
merging
Merge branch 'master' of ghghgh.us:photoblaster/photoblaster
Diffstat (limited to 'lib/db.py')
-rw-r--r--lib/db.py6
1 files changed, 6 insertions, 0 deletions
diff --git a/lib/db.py b/lib/db.py
index a236344..6a7e424 100644
--- a/lib/db.py
+++ b/lib/db.py
@@ -2,6 +2,7 @@
"""all database connections and logic goes here"""
from config import DB_HOST, DB_USER, DB_PASSWORD, DB_NAME
import time, sys
+import simplejson as json
from sqlalchemy import Column, Integer, LargeBinary, String, create_engine, sql
from sqlalchemy.ext.declarative import declarative_base
@@ -37,6 +38,11 @@ class Db(object):
))
self.Session = sessionmaker(bind=engine)
+ def search(self, **kwargs):
+ session = self.Session()
+ results = session.query(ImCmd).filter_by(**kwargs).all()
+ return map(lambda n: { "tag": n.tag, "data": json.loads(n.dataobj) }, results)
+
def insert_cmd(self, **kwargs):
try:
session = self.Session()