arguments
"""
operators={'eq':'=', 'neq':'<>', 'gt':'>', 'gte':'>=', 'lt':'<', 'lte':'<=', 'lk':'LIKE'}
-
+
def __init__ (self, dbname):
self.dbname = dbname
def connect(self):
- if not os.path.isfile(self.dbname):
- return False
+ if not os.path.isfile(self.dbname):
+ return False
self.conn = sqlite3.connect(self.dbname)
self.cursor = self.conn.cursor()
- return True
+ return True
def disconnect(self):
self.cursor.close()
if cs_id == -1:
self.cursor.execute("select * from status_messages")
else:
- values = (cs_id, )
- query = "select * from status_messages where cs_id=? and "
-
- if restrictArray:
- for (key, value, op) in restrictArray:
- query += "%s %s ? and " % (key, self.operators[op])
- values += (value, )
-
- query = query.strip('and ')
- print query, values
- self.cursor.execute(query, values)
-
- if show == True:
+ values = (cs_id, )
+ query = "select * from status_messages where cs_id=? and "
+
+ if restrictArray:
+ for (key, value, op) in restrictArray:
+ query += "%s %s ? and " % (key, self.operators[op])
+ values += (value, )
+
+ query = query.strip('and ')
+ print query, values
+ self.cursor.execute(query, values)
+
+ if show == True:
for row in self.cursor:
print row
else:
def insert_verbose_messages(self, cs_id, timestamp, direction, peer_ip, peer_port, message_type, _index, begin, length, listen_port):
self.insert_verbose_messages_row([cs_id, timestamp, direction, peer_ip, peer_port, message_type, _index, begin, length, listen_port])
-
+
def select_verbose_messages(self, show = True, cs_id = -1, restrictArray=None):
try:
if cs_id == -1:
self.cursor.execute("select * from verbose_messages")
else:
- values = (cs_id, )
- query = "select * from verbose_messages where cs_id=? and "
- if restrictArray:
- for (key, value, op) in restrictArray:
- query += "%s %s ? and " % (key, self.operators[op])
- values += (value, )
-
- query = query.strip('and ')
- #print query, values
- self.cursor.execute(query, values)
-
- if show == True:
+ values = (cs_id, )
+ query = "select * from verbose_messages where cs_id=? and "
+ if restrictArray:
+ for (key, value, op) in restrictArray:
+ query += "%s %s ? and " % (key, self.operators[op])
+ values += (value, )
+
+ query = query.strip('and ')
+ #print query, values
+ self.cursor.execute(query, values)
+
+ if show == True:
for row in self.cursor:
print row
else:
line = sys.stdin.readline().strip()
if line:
message_array = line.split(sep)
-
+
swarm_name = message_array[0].strip()
filesize = int(message_array[1].strip())
purpose = message_array[2].strip()
line = sys.stdin.readline().strip()
if line:
message_array = line.split(sep)
-
+
swarm_id = int(message_array[0].strip())
client_name = message_array[1].strip()
system_os = message_array[2].strip()