summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorpepperpepperpepper <pepper@scannerjammer.com>2015-11-16 15:45:42 -0800
committerpepperpepperpepper <pepper@scannerjammer.com>2015-11-16 15:45:42 -0800
commit2fd9e32c4afc4f116d95cc397ecad660f85c6bc6 (patch)
treec3d1d347e6b77240af6ec4edcbd09ec0b4c815b3
parentf65284969e4cffb88914de49ace8850a7f41c836 (diff)
ok installing new code on server
-rw-r--r--photoblaster/db/imcmd.py3
-rw-r--r--to_merge/TODO7
-rw-r--r--to_merge/__init__.py0
-rw-r--r--to_merge/db.py90
-rw-r--r--to_merge/imcmd.py43
5 files changed, 1 insertions, 142 deletions
diff --git a/photoblaster/db/imcmd.py b/photoblaster/db/imcmd.py
index 397d30a..91b4460 100644
--- a/photoblaster/db/imcmd.py
+++ b/photoblaster/db/imcmd.py
@@ -1,8 +1,7 @@
-<<<<<<< HEAD
"""describes the ImCmd class"""
import sys
from sqlalchemy import Column, Integer, LargeBinary, String
-from simplejson import json
+import simplejson as json
from sqlalchemy.orm import class_mapper
from sqlalchemy.ext.declarative import declarative_base
diff --git a/to_merge/TODO b/to_merge/TODO
deleted file mode 100644
index 04f0396..0000000
--- a/to_merge/TODO
+++ /dev/null
@@ -1,7 +0,0 @@
-GET RUNNING LOCALLY
-run_module_examples_test (doesn't use server)
-merge these files
-the gallery
-email cuthbert
-laundry
-
diff --git a/to_merge/__init__.py b/to_merge/__init__.py
deleted file mode 100644
index e69de29..0000000
--- a/to_merge/__init__.py
+++ /dev/null
diff --git a/to_merge/db.py b/to_merge/db.py
deleted file mode 100644
index d4dbec8..0000000
--- a/to_merge/db.py
+++ /dev/null
@@ -1,90 +0,0 @@
-"""Db bass class for updating the photoblaster database"""
-import time
-import sys
-from photoblaster.db.imcmd import ImCmd
-from photoblaster.config import DB_USER, DB_PASSWORD, DB_HOST,\
- DB_NAME
-from sqlalchemy import Column, Integer, LargeBinary, String, \
- create_engine, sql, func, desc
-from sqlalchemy.ext.declarative import declarative_base
-from sqlalchemy.orm import sessionmaker
-
-_NULL = sql.null()
-
-Base = declarative_base()
-metadata = Base.metadata
-
-
-class Db(object):
- """wrapper for all db methods"""
- def __init__(self):
- engine = create_engine('mysql://{}:{}@{}/{}'.format(
- DB_USER,
- DB_PASSWORD,
- DB_HOST,
- DB_NAME
- ))
- self.Session = sessionmaker(bind=engine)
-
- def _get(
- self,
- columns=None,
- filter_by={},
- order_by=None,
- offset=0,
- limit=20,
- not_deleted=False
- ):
- session = self.Session()
- results = session.query(ImCmd)
- if not_deleted:
- filter_by['deleted'] = 0
- if filter_by:
- results = results.filter_by(filter_by)
- if order_by is not None:
- results = results.order_by(order_by)
- results = results.offset(offset).limit(limit)
- session.close()
- return [result.serialize(columns=columns) for result in results]
-
- def get_random(
- self, filter_by={},
- offset=0, limit=20, columns=None
- ):
- return self._get(
- columns=columns, order_by=func.random(),
- offset=offset, limit=limit)
-
- def get_by_date(
- self,
- filter_by={},
- offset=0, limit=20, columns=None
- ):
- return self._get(
- columns=columns, offset=offset, limit=limit,
- order_by=desc(
- ImCmd.date
- )
- )
-
- def insert_cmd(self, **kwargs):
- try:
- session = self.Session()
- _entry_data = {
- 'date': kwargs.get("date", int(time.time())),
- 'remote_addr': kwargs['remote_addr'] or _NULL,
- 'name': kwargs['username'] or _NULL,
- 'url': kwargs['username'] or _NULL,
- 'dir': kwargs['directory'] or _NULL,
- 'oldfile': kwargs['oldfile'] or _NULL,
- 'newfile': kwargs['newfile'] or _NULL,
- 'cmd': kwargs['cmd'] or _NULL,
- 'dataobj': kwargs['dataobj'] or _NULL,
- 'tag': kwargs['tag'] or _NULL
- }
- session.add(ImCmd(**_entry_data))
- session.commit()
- session.close()
- except Exception as e:
- sys.stderr.write("Unable to commit database entry\n")
- sys.stderr.write(str(e))
diff --git a/to_merge/imcmd.py b/to_merge/imcmd.py
deleted file mode 100644
index 5206f99..0000000
--- a/to_merge/imcmd.py
+++ /dev/null
@@ -1,43 +0,0 @@
-"""describes the ImCmd class"""
-import sys
-from sqlalchemy import Column, Integer, LargeBinary, String
-from simplejson import json
-from sqlalchemy.orm import class_mapper
-
-
-class ImCmd(Base):
- """defines the table class"""
- __tablename__ = 'im_cmd'
- id = Column(Integer, primary_key=True)
- date = Column(Integer)
- remote_addr = Column(String(16))
- name = Column(String(16))
- url = Column(String(256))
- dir = Column(String(2))
- oldfile = Column(String(256))
- newfile = Column(String(256))
- cmd = Column(LargeBinary)
- dataobj = Column(LargeBinary)
- tag = Column(String(50))
-
- def serialize(self, columns=None):
- """returns the class as a dictionary"""
- if not columns:
- columns = [c.key for c in class_mapper(self.__class__).columns]
- col_val = []
- for c in columns:
- if c == "dataobj":
- val = getattr(self, c)
- if val is not None:
- try:
- val = json.loads(val)
- except json.JSONDecodeError:
- sys.stderr.write("Could not decode json: %s\n" % val)
- sys.stderr.write(
- "bad value in db, id = %s\n" % getattr(self, "id")
- )
- pass
- col_val.append((c, val))
- else:
- col_val.append((c, getattr(self, c)))
- return dict(col_val)