#!/bin/bash -e

if false; then #### run script template:

#!/bin/bash -e

. "$(dirname "${BASH_SOURCE[0]}")"/path/to/table.run

func_override import__table_run

import()

{

	begin_target

	before_import_cmds

	with_rm import__table_run "$@"

	after_import_cmds

}

fi ####

. "$(dirname "${BASH_SOURCE[0]}")"/import.run

.rel subdir.run

.rel ../sh/db_make.sh

if self_not_included; then

##### utils

: "${table=$subdir}"; export table

table_make() { subdir_make "$@"; }

install_log_rel=logs/install.log.sql

table_make_install()

{

	echo_func

	if ! remaking && pg_table_exists; then skip_table; return 0; fi

	local install_log="${install_log-$top_dir/$install_log_rel}"

	local verbosity_min= # install logs require default verbosity

	if ! remaking && test -e "$install_log"; then local_export noclobber=1; fi

	table_make "$@"

}

postprocess_sql="$top_dir"/postprocess.sql

is_view="$(test -e "$postprocess_sql" \

&& grep -F force_update_view "$postprocess_sql" >/dev/null; exit2bool)"

map_table="\"~$table.map\"" # sort after other tables to avoid clutter

srcs=($(output_data=1 table_make list_srcs))

srcs=("${srcs[@]/#/$datasrc_dir/}") # empty str at start (/#) -> $datasrc_dir/

_1st_src="$(echo1 "${srcs[@]}")"

header() { echo_func; : "${1:?}"; head -1 "$1"; }

##### targets

header.txt() { begin_target; to_target header "$_1st_src"; }

load_data()

{

	begin_target

	if remaking; then in_top_dir rm -f header.csv; fi # remake it

	make --directory="$top_dir/.." schema # works w/ old-style srcs w/o ../run

	#"$top_dir/../run" schema/make # uncomment once everything is new-style

	is_view="$is_view" table_make_install ${_remake:+re}install # just the table

}

trim_table()

{

	begin_target

	if test "$is_view"; then return 0; fi # do not modify view columns

	psql <<EOF

SELECT util.trim('"$table"', '$map_table');

EOF

}

reset_col_names()

{

	begin_target

	if test "$is_view"; then return 0; fi # do not rename view columns

	psql <<EOF

SELECT util.reset_col_names('"$table"', '$map_table');

EOF

}

map_table()

# note that collisions may prevent all renames from being made at once.

# if this is the case, run map_table repeatedly until no more renames are made:

# $ while true; do .../run map_table; done

# collisions may result if the staging table gets messed up (e.g. due to missing

# input columns in map.csv).

{

	begin_target

	if test "$is_view"; then return 0; fi # do not rename view columns

	if remaking; then reset_col_names; fi

	table_make map.csv

	psql <<EOF

SELECT util.reset_map_table('$map_table');

ALTER TABLE $map_table DISABLE TRIGGER map_filter_insert;

\copy $map_table FROM 'map.csv' CSV HEADER;

SELECT util.set_col_names_with_metadata('"$table"', '$map_table');

EOF

}

test_() { begin_target; piped_cmd yes|table_make test; }

mappings()

{

	begin_target

	benign_error=1 public_schema_exists || return 0

	if remaking; then in_top_dir rm -f map.csv; fi # remake it

	test_

}

custom_postprocess() # overridable

{

	begin_target

	local file="$postprocess_sql"

	if test -e "$file"; then

		table_make "$(basename "$file")" # apply renames to SQL statements

		psql "$@"

	fi

}

mk_derived()

{ begin_target; "$root_dir"/schemas/VegCore/mk_derived; }

postprocess()

{

	begin_target

	kw_params can_test; local can_test="${can_test-1}"

	if remaking; then trim_table; fi

	map_table

	custom_postprocess

	mk_derived

	if test "$can_test"; then mappings; fi

}

import()

{

	begin_target

	with_rm load_data

	postprocess

}

fi