Raise exception on unsupported dbschema version
This commit is contained in:
parent
de550d7cae
commit
551aa3ef67
1 changed files with 2 additions and 0 deletions
|
@ -144,6 +144,8 @@ class DbCursor:
|
||||||
self.execute("INSERT INTO json ?", {"site": site_address, "directory": directory, "file_name": file_name})
|
self.execute("INSERT INTO json ?", {"site": site_address, "directory": directory, "file_name": file_name})
|
||||||
res = self.execute("SELECT * FROM json WHERE ? LIMIT 1", {"site": site_address, "directory": directory, "file_name": file_name})
|
res = self.execute("SELECT * FROM json WHERE ? LIMIT 1", {"site": site_address, "directory": directory, "file_name": file_name})
|
||||||
row = res.fetchone()
|
row = res.fetchone()
|
||||||
|
else:
|
||||||
|
raise Exception("Dbschema version %s not supported" % self.db.schema.get("version"))
|
||||||
return row
|
return row
|
||||||
|
|
||||||
def close(self):
|
def close(self):
|
||||||
|
|
Loading…
Reference in a new issue