- self.conn.execute(self.create_table(ctxcols, self.ctxtab, 'text', 'unique'))
- self.conn.execute(self.create_table(evcols, self.evtab, 'double', ''))
+ self.cursor = self.conn.cursor()
+
+ self.types["data"] = "double"
+ self.types["text"] = "text"
+ self.types["bool"] = "int"
+ self.ctxtab = options.prefix + "ctx"
+ self.evtab = options.prefix + "ev"
+
+ self.create_table(ctxcols, self.ctxtab, "text", "integer primary key")
+ self.create_table(evcols, self.evtab, "data", "int")
+ self.execute("CREATE INDEX IF NOT EXISTS `%sindex` ON `%s`(id)"
+ % (self.evtab, self.evtab))
+
+ keys = "id, " + ", ".join(evcols)
+ marks = ",".join(["?"] * (len(evcols)+1))
+ self.evinsert = "insert into `%s` values (%s)" % (self.evtab, marks)
+
+ keys = ", ".join(ctxcols)
+ marks = ",".join(["?"] * len(ctxcols))
+ self.ctxinsert = "insert into `%s` (%s) values (%s)" % (self.ctxtab, keys, marks)