diff options
| author | yo mama <pepper@scannerjammer.com> | 2015-09-22 00:51:40 -0700 |
|---|---|---|
| committer | yo mama <pepper@scannerjammer.com> | 2015-09-22 00:51:40 -0700 |
| commit | d3e7b5708deffbed864c916de22663f48333c58b (patch) | |
| tree | ef76784a7827baff88c03670bf22832a3f146b17 /Db/__init__.py | |
| parent | 86c79f4372d7b2e7640a26473c7a4d331cdf7d16 (diff) | |
finishing server
Diffstat (limited to 'Db/__init__.py')
| -rw-r--r-- | Db/__init__.py | 82 |
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)) |
