summaryrefslogtreecommitdiff
path: root/lib/Db/sqlalchemy_example_code.py
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Db/sqlalchemy_example_code.py')
-rw-r--r--lib/Db/sqlalchemy_example_code.py105
1 files changed, 0 insertions, 105 deletions
diff --git a/lib/Db/sqlalchemy_example_code.py b/lib/Db/sqlalchemy_example_code.py
deleted file mode 100644
index fc38b38..0000000
--- a/lib/Db/sqlalchemy_example_code.py
+++ /dev/null
@@ -1,105 +0,0 @@
-# coding: utf-8
-import MySQLdb
-import time, sys
-USER = "asdfus"
-PASSWORD = "gTYgT&M6q"
-DATABASE = "asdfus"
-
-
-from sqlalchemy import Column, Integer, LargeBinary, String, create_engine
-from sqlalchemy.ext.declarative import declarative_base
-from sqlalchemy.orm import sessionmaker
-engine = create_engine('mysql://{}:{}@localhost/{}'.format(USER, PASSWORD, DATABASE))
-Session = sessionmaker(bind=engine)
-session = Session()
-connection = engine.connect()
-#result = connection.execute("select username from users")
-#for row in result:
-# print "username:", row['username']
-#connection.close()
-
-
-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))
-#def __repr__(self):
-#... return "<User(name='%s', fullname='%s', password='%s')>" % (
-#... self.name, self.fullname, self.password)
-
-
-for instance in session.query(ImCmd).order_by(ImCmd.id):
- print instance.name, instance.date
-
-
-ed_user = User(name='ed', fullname='Ed Jones', password='edspassword')
-session.add(ed_user)
-#session.add_all([
-#... User(name='wendy', fullname='Wendy Williams', password='foobar'),
-#... User(name='mary', fullname='Mary Contrary', password='xxg527'),
-#... User(name='fred', fullname='Fred Flinstone', password='blah')])
-
-#session.commit()
-
-class Db(object):
- def __init__ (self):
- self.conn = None
- self.cursor = None
- self.connect()
-
- def connect (self):
- self.conn = MySQLdb.connect (host = "lalalizard.com",
- user = USER,
- passwd = PASSWORD,
- db = DATABASE
- )
- self.cursor = self.conn.cursor ()
-
- def execute (self,sql,args=()):
- try:
- self.cursor.execute(sql,args)
- except MySQLdb.Error, e:
- print "Error %d: %s" % (e.args[0], e.args[1])
- # sys.exit (1)
- self.connect()
- self.cursor.execute(sql,args)
-
- def lastinsertid (self):
- return self.conn.insert_id()
-
- 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"):
- try:
- sql = "INSERT INTO im_cmd "
- sql += "(date, remote_addr, name, url, dir, oldfile, newfile, cmd, dataobj, tag) "
- sql += "VALUES(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"
- #or "NULL"
- args = (date, remote_addr, username, url, directory, oldfile, newfile, cmd, dataobj, tag)
- #args = (now(), os.environ['REMOTE_ADDR'], name, url, dir, oldfile, newfile, " ".join(cmd),dataobj)
- self.execute(sql, args)
- except Exception as e:
- sys.stderr.write(str(e))
- return