(self)
| 159 | self.delayed_queue_thread = None |
| 160 | |
| 161 | def close(self): |
| 162 | s = time.time() |
| 163 | if self.delayed_queue: |
| 164 | self.processDelayed() |
| 165 | if self in opened_dbs: |
| 166 | opened_dbs.remove(self) |
| 167 | self.need_commit = False |
| 168 | self.commit("Closing") |
| 169 | if self.cur: |
| 170 | self.cur.close() |
| 171 | if self.conn: |
| 172 | self.conn.close() |
| 173 | self.conn = None |
| 174 | self.cur = None |
| 175 | self.log.debug("%s closed in %.3fs, opened: %s" % (self.db_path, time.time() - s, len(opened_dbs))) |
| 176 | |
| 177 | # Gets a cursor object to database |
| 178 | # Return: Cursor class |