| 151 | return [CacheResponse(key, value) for key, value in self.cursor] |
| 152 | |
| 153 | def enable_zstd(self): |
| 154 | self.ensure_connection() |
| 155 | with self.connection: |
| 156 | try: |
| 157 | self.cursor.execute( |
| 158 | 'SELECT zstd_enable_transparent(\'{"table": "cache", "column": "value", "compression_level": 9, "dict_chooser": "\'\'a\'\'"}\')' |
| 159 | ) |
| 160 | except Exception as error: |
| 161 | logger.error(f"Error enabling ZSTD compression: {error}") |
| 162 | logger.exception(error) |
| 163 | |
| 164 | self.connection.execute("PRAGMA auto_vacuum=full") |
| 165 | |
| 166 | def init_db(self): |
| 167 | self.ensure_connection() |