summaryrefslogtreecommitdiff
path: root/Db/__init__.py
diff options
context:
space:
mode:
authoryo mama <pepper@scannerjammer.com>2015-09-22 00:51:40 -0700
committeryo mama <pepper@scannerjammer.com>2015-09-22 00:51:40 -0700
commitd3e7b5708deffbed864c916de22663f48333c58b (patch)
treeef76784a7827baff88c03670bf22832a3f146b17 /Db/__init__.py
parent86c79f4372d7b2e7640a26473c7a4d331cdf7d16 (diff)
finishing server
Diffstat (limited to 'Db/__init__.py')
-rw-r--r--Db/__init__.py82
1 files changed, 0 insertions, 82 deletions
diff --git a/Db/__init__.py b/Db/__init__.py
deleted file mode 100644
index f4ebc57..0000000
--- a/Db/__init__.py
+++ /dev/null
@@ -1,82 +0,0 @@
-# coding: utf-8
-import time, sys
-HOST = "lalalizard.com"
-USER = "asdfus"
-PASSWORD = "gTYgT&M6q"
-DATABASE = "asdfus"
-
-from sqlalchemy import Column, Integer, LargeBinary, String, create_engine, sql
-from sqlalchemy.ext.declarative import declarative_base
-from sqlalchemy.orm import sessionmaker
-_NULL = sql.null()
-
-Base = declarative_base()
-metadata = Base.metadata
-
-class ImCmd(Base):
- __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))
-
-class Db(object):
- def __init__(self):
- engine = create_engine('mysql://{}:{}@{}/{}'.format(
- USER,
- PASSWORD,
- HOST,
- DATABASE
- ))
- self.Session = sessionmaker(bind=engine)
-
- def insert_cmd (
- self,
- date=time.time(),
- remote_addr=_NULL,
- username=_NULL,
- url=_NULL,
- directory=_NULL,
- oldfile=_NULL,
- newfile=_NULL,
- cmd=_NULL,
- dataobj=_NULL,
- tag=_NULL):
-
-# sys.stderr.write("date={}".format(str(date)) + "\n")
-# sys.stderr.write("remote_addr={}".format(str(remote_addr)) + "\n")
-# sys.stderr.write("name={}".format(str(username)) + "\n")
-# sys.stderr.write("url={}".format(str(url)) + "\n")
-# sys.stderr.write("dir={}".format(str(directory)) + "\n")
-# sys.stderr.write("oldfile={}".format(str(oldfile)) + "\n")
-# sys.stderr.write("newfile={}".format(str(newfile)) + "\n")
-# sys.stderr.write("cmd={}".format(str(cmd)) + "\n")
-# sys.stderr.write("dataobj={}".format(str(dataobj)) + "\n")
-# sys.stderr.write("tag={}".format(str(tag)) + "\n")
- try:
- session = self.Session()
- entry = ImCmd(
- date=date,
- remote_addr=remote_addr,
- name=username,
- url=url,
- dir=directory,
- oldfile=oldfile,
- newfile=newfile,
- cmd=cmd,
- dataobj=dataobj,
- tag=tag
- )
- session.add(entry)
- session.commit()
- #FIXME session.close()....
- except Exception as e:
- sys.stderr.write("Unable to commit database entry\n");
- sys.stderr.write(str(e))