Differential D2566 Diff 9258 swh/storage/cassandra/schema.py

Changeset View

Standalone View

swh/storage/cassandra/schema.py

This file was added.

				# Copyright (C) 2019-2020 The Software Heritage developers
				# See the AUTHORS file at the top-level directory of this distribution
				# License: GNU General Public License version 3, or any later version
				# See top-level LICENSE file for more information


				CREATE_TABLES_QUERIES = '''
				CREATE OR REPLACE FUNCTION ascii_bins_count_sfunc (
				state tuple<int, map<ascii, int>>, -- (nb_none, map<target_type, nb>)
				bin_name ascii
				)
				CALLED ON NULL INPUT
				RETURNS tuple<int, map<ascii, int>>
				LANGUAGE java AS
				$$
				if (bin_name == null) {
				state.setInt(0, state.getInt(0) + 1);
				}
				else {
				Map<String, Integer> counters = state.getMap(
				1, String.class, Integer.class);
				Integer nb = counters.get(bin_name);
				if (nb == null) {
				nb = 0;
				}
				counters.put(bin_name, nb + 1);
				state.setMap(1, counters, String.class, Integer.class);
				}
				return state;
				$$
				;

				CREATE OR REPLACE AGGREGATE ascii_bins_count ( ascii )
				SFUNC ascii_bins_count_sfunc
				STYPE tuple<int, map<ascii, int>>
				INITCOND (0, {})
				;

				CREATE TYPE IF NOT EXISTS microtimestamp (
				seconds bigint,
				microseconds int
				);

				CREATE TYPE IF NOT EXISTS microtimestamp_with_timezone (
				timestamp frozen<microtimestamp>,
				offset smallint,
				negative_utc boolean
				);

				CREATE TYPE IF NOT EXISTS person (
				fullname blob,
				name blob,
				email blob
				);

				CREATE TABLE IF NOT EXISTS content (
				sha1 blob,
				sha1_git blob,
				sha256 blob,
				blake2s256 blob,
				length bigint,
				ctime timestamp,
				-- creation time, i.e. time of (first) injection into the storage
				status ascii,
				PRIMARY KEY ((sha1, sha1_git, sha256, blake2s256))
				);

				CREATE TABLE IF NOT EXISTS revision (
				id blob PRIMARY KEY,
				date microtimestamp_with_timezone,
				committer_date microtimestamp_with_timezone,
				type ascii,
				directory blob, -- source code "root" directory
				message blob,
				author person,
				committer person,
				synthetic boolean,
				-- true iff revision has been created by Software Heritage
				metadata text
				-- extra metadata as JSON(tarball checksums,
				-- extra commit information, etc...)
				);

				CREATE TABLE IF NOT EXISTS revision_parent (
				id blob,
				parent_rank int,
				-- parent position in merge commits, 0-based
				parent_id blob,
				PRIMARY KEY ((id), parent_rank)
				);

				CREATE TABLE IF NOT EXISTS release
				(
				id blob PRIMARY KEY,
				target_type ascii,
				target blob,
				date microtimestamp_with_timezone,
				name blob,
				message blob,
				author person,
				synthetic boolean,
				-- true iff release has been created by Software Heritage
				);

				CREATE TABLE IF NOT EXISTS directory (
				id blob PRIMARY KEY,
				);

				CREATE TABLE IF NOT EXISTS directory_entry (
				directory_id blob,
				name blob, -- path name, relative to containing dir
				target blob,
				perms int, -- unix-like permissions
				type ascii, -- target type
				PRIMARY KEY ((directory_id), name)
				);

				CREATE TABLE IF NOT EXISTS snapshot (
				id blob PRIMARY KEY,
				);

				-- For a given snapshot_id, branches are sorted by their name,
				-- allowing easy pagination.
				CREATE TABLE IF NOT EXISTS snapshot_branch (
				snapshot_id blob,
				name blob,
				target_type ascii,
				target blob,
				PRIMARY KEY ((snapshot_id), name)
				);

				CREATE TABLE IF NOT EXISTS origin_visit (
				origin text,
				visit bigint,
				date timestamp,
				type text,
				status ascii,
				metadata text,
				snapshot blob,
				PRIMARY KEY ((origin), visit)
				);


				CREATE TABLE IF NOT EXISTS origin (
				sha1 blob PRIMARY KEY,
				url text,
				type text,
				next_visit_id int,
				-- We need integer visit ids for compatibility with the pgsql
				-- storage, so we're using lightweight transactions with this trick:
				-- https://stackoverflow.com/a/29391877/539465
				);


				CREATE TABLE IF NOT EXISTS tool_by_uuid (
				id timeuuid PRIMARY KEY,
				name ascii,
				version ascii,
				configuration blob,
				);


				CREATE TABLE IF NOT EXISTS tool (
				id timeuuid,
				name ascii,
				version ascii,
				configuration blob,
				PRIMARY KEY ((name, version, configuration))
				)


				CREATE TABLE IF NOT EXISTS object_count (
				partition_key smallint, -- Constant, must always be 0
				object_type ascii,
				count counter,
				PRIMARY KEY ((partition_key), object_type)
				);
				'''.split('\n\n')

				CONTENT_INDEX_TEMPLATE = '''
				CREATE TABLE IF NOT EXISTS content_by_{main_algo} (
				sha1 blob,
				sha1_git blob,
				sha256 blob,
				blake2s256 blob,
				PRIMARY KEY (({main_algo}), {other_algos})
				);'''

				HASH_ALGORITHMS = ['sha1', 'sha1_git', 'sha256', 'blake2s256']

				for main_algo in HASH_ALGORITHMS:
				CREATE_TABLES_QUERIES.append(CONTENT_INDEX_TEMPLATE.format(
				main_algo=main_algo,
				other_algos=', '.join(
				[algo for algo in HASH_ALGORITHMS if algo != main_algo])
				))