(self, table, cols, indexes=None, version=1)
| 161 | # Create table if not exist |
| 162 | # Return: True if updated |
| 163 | def needTable(self, table, cols, indexes=None, version=1): |
| 164 | current_version = self.db.getTableVersion(table) |
| 165 | if int(current_version) < int(version): # Table need update or not extis |
| 166 | self.db.log.info("Table %s outdated...version: %s need: %s, rebuilding..." % (table, current_version, version)) |
| 167 | self.createTable(table, cols) |
| 168 | if indexes: |
| 169 | self.createIndexes(table, indexes) |
| 170 | self.execute( |
| 171 | "INSERT OR REPLACE INTO keyvalue ?", |
| 172 | {"json_id": 0, "key": "table.%s.version" % table, "value": version} |
| 173 | ) |
| 174 | return True |
| 175 | else: # Not changed |
| 176 | return False |
| 177 | |
| 178 | # Get or create a row for json file |
| 179 | # Return: The database row |
no test coverage detected