|
1
|
#!/bin/bash -e
|
|
2
|
|
|
3
|
if false; then #### run script template:
|
|
4
|
#!/bin/bash -e
|
|
5
|
. "$(dirname "${BASH_SOURCE[0]}")"/path/to/table.run
|
|
6
|
|
|
7
|
func_override import__table_run
|
|
8
|
import()
|
|
9
|
{
|
|
10
|
echo_func
|
|
11
|
before_import_cmds
|
|
12
|
self_make import__table_run "$@"
|
|
13
|
after_import_cmds
|
|
14
|
}
|
|
15
|
fi ####
|
|
16
|
|
|
17
|
. "$(dirname "${BASH_SOURCE[0]}")"/import.run
|
|
18
|
.rel subdir.run
|
|
19
|
.rel ../sh/db_make.sh
|
|
20
|
|
|
21
|
if self_not_included; then
|
|
22
|
|
|
23
|
: "${table=$subdir}"; export table
|
|
24
|
|
|
25
|
table_make() { subdir_make "$@"; }
|
|
26
|
|
|
27
|
install_log_rel=logs/install.log.sql
|
|
28
|
|
|
29
|
table_make_install()
|
|
30
|
{
|
|
31
|
echo_func; local install_log="${install_log-$top_dir/$install_log_rel}"
|
|
32
|
local verbosity_min= # install logs require default verbosity
|
|
33
|
set -- table_make "$@"
|
|
34
|
if remaking || test ! -e "$install_log"; then "$@" # OK to clobber log
|
|
35
|
else benign_error=1 noclobber=1 "$@" || true
|
|
36
|
fi
|
|
37
|
}
|
|
38
|
|
|
39
|
datasrc_make_install()
|
|
40
|
{
|
|
41
|
echo_func
|
|
42
|
subdir=. install_log="$top_dir/../$install_log_rel" table_make_install "$@"
|
|
43
|
}
|
|
44
|
|
|
45
|
postprocess_sql="$top_dir"/postprocess.sql
|
|
46
|
|
|
47
|
map_table()
|
|
48
|
# note that collisions may prevent all renames from being made at once.
|
|
49
|
# if this is the case, run map_table repeatedly until no more renames are made:
|
|
50
|
# $ while true; do .../run map_table; done
|
|
51
|
# collisions may result if the staging table gets messed up (e.g. due to missing
|
|
52
|
# input columns in map.csv).
|
|
53
|
{
|
|
54
|
echo_func; set_make_vars
|
|
55
|
table_make map.csv
|
|
56
|
local map_table="\"~$table.map\"" # sort after other tables to avoid clutter
|
|
57
|
psql <<EOF
|
|
58
|
SELECT util.reset_map_table('$map_table');
|
|
59
|
ALTER TABLE $map_table DISABLE TRIGGER map_filter_insert;
|
|
60
|
\copy $map_table FROM 'map.csv' CSV HEADER;
|
|
61
|
SELECT util.set_col_names_with_metadata('"$table"', '$map_table'::regclass);
|
|
62
|
EOF
|
|
63
|
}
|
|
64
|
|
|
65
|
mk_derived()
|
|
66
|
{ echo_func; set_make_vars; "$root_dir"/schemas/VegCore/mk_derived; }
|
|
67
|
|
|
68
|
remake_VegBIEN_mappings()
|
|
69
|
{
|
|
70
|
echo_func; set_make_vars
|
|
71
|
public_schema_exists || return 0
|
|
72
|
if remaking; then in_top_dir rm header.csv map.csv; fi # remake them
|
|
73
|
piped_cmd yes|table_make test
|
|
74
|
}
|
|
75
|
|
|
76
|
postprocess() # overridable
|
|
77
|
{
|
|
78
|
echo_func; set_make_vars
|
|
79
|
local file="$postprocess_sql"
|
|
80
|
if test -e "$file"; then psql "$@"; fi
|
|
81
|
}
|
|
82
|
|
|
83
|
load_data()
|
|
84
|
{
|
|
85
|
echo_func; set_make_vars
|
|
86
|
datasrc_make_install schema
|
|
87
|
table_make_install ${_remake:+re}install # just the table
|
|
88
|
}
|
|
89
|
|
|
90
|
import()
|
|
91
|
{
|
|
92
|
echo_func; set_make_vars
|
|
93
|
kw_params can_test; local can_test="${can_test-1}"
|
|
94
|
self_make load_data
|
|
95
|
map_table
|
|
96
|
postprocess
|
|
97
|
mk_derived
|
|
98
|
if test "$can_test"; then remake_VegBIEN_mappings; fi
|
|
99
|
}
|
|
100
|
|
|
101
|
fi
|
