From: Christian Heller Date: Wed, 20 Nov 2024 22:56:41 +0000 (+0100) Subject: Use UUID for queries table .id field, to reduce reliance on chronology. X-Git-Url: https://plomlompom.com/repos/templates?a=commitdiff_plain;h=d9cf2a3493d824297bd06e4b3e45ce1fbad723d7;p=ytplom Use UUID for queries table .id field, to reduce reliance on chronology. --- diff --git a/ytplom.py b/ytplom.py index 2ca5891..1d94ccc 100755 --- a/ytplom.py +++ b/ytplom.py @@ -32,7 +32,7 @@ DatetimeStr = NewType('DatetimeStr', str) QuotaCost = NewType('QuotaCost', int) YoutubeId = NewType('YoutubeId', str) PathStr = NewType('PathStr', str) -QueryId = NewType('QueryId', int) +QueryId = NewType('QueryId', str) QueryText = NewType('QueryText', str) ProseText = NewType('ProseText', str) SqlText = NewType('SqlText', str) @@ -84,7 +84,7 @@ LEGAL_EXTENSIONS = {'webm', 'mp4', 'mkv'} # tables to create database with SCRIPT_INIT_DB = ''' CREATE TABLE yt_queries ( - id INTEGER PRIMARY KEY, + id TEXT PRIMARY KEY, text TEXT NOT NULL, retrieved_at TEXT NOT NULL ); @@ -97,7 +97,7 @@ CREATE TABLE yt_videos ( definition TEXT NOT NULL ); CREATE TABLE yt_query_results ( - query_id INTEGER NOT NULL, + query_id TEXT NOT NULL, video_id TEXT NOT NULL, PRIMARY KEY (query_id, video_id), FOREIGN KEY (query_id) REFERENCES yt_queries(id), @@ -196,18 +196,10 @@ class YoutubeQuery(DbData): text: QueryText, retrieved_at: DatetimeStr ) -> None: - self.id_ = id_ + self.id_ = id_ if id_ else QueryId(str(uuid4())) self.text = QueryText(text) self.retrieved_at = retrieved_at - def save(self, conn: DatabaseConnection) -> Cursor: - """DbData.save but assign .id_ from Cursor's lastrowid if yet unset.""" - cursor = super().save(conn) - if self.id_ is None: - assert cursor.lastrowid is not None - self.id_ = QueryId(cursor.lastrowid) - return cursor - @classmethod def get_all_for_video(cls, conn: DatabaseConnection, @@ -628,7 +620,6 @@ class TaskHandler(BaseHTTPRequestHandler): query_data.save(conn) for result in collect_results(query_txt): result.save(conn) - assert query_data.id_ is not None result.save_to_query(conn, query_data.id_) conn.commit_close() self._send_http(headers=[('Location', f'/query/{query_data.id_}')], @@ -649,7 +640,7 @@ class TaskHandler(BaseHTTPRequestHandler): elif 'video_about' == page_name: self._send_video_about(YoutubeId(toks_url[2])) elif 'query' == page_name: - self._send_query_page(QueryId(int(toks_url[2]))) + self._send_query_page(QueryId(toks_url[2])) elif 'queries' == page_name: self._send_queries_index_and_search() elif '_last_playlist_update.json' == page_name: