Project

General

Profile

1
##### Configuration
2

    
3
# Command line
4
log ?= $(if $(test),,1)
5
profile ?=
6
quiet ?=
7
reverify ?= 1
8
use_staged ?= $(by_col)
9

    
10
# Makefile
11
tablesSort ?= plots organisms stems specimens
12
exts ?= csv tsv txt xml
13
test_n ?= 2
14

    
15
##### Vars/functions
16

    
17
selfDir_uZPPqC := $(dir $(lastword $(MAKEFILE_LIST)))
18

    
19
# Paths
20
datasrc := $(notdir $(realpath .))
21
root := $(selfDir_uZPPqC)..
22
bin := $(root)/bin
23
mappings := $(root)/mappings
24

    
25
# Make
26
SHELL := /bin/bash
27
selfMake = $(MAKE) --makefile=../input.Makefile
28
subMake = $(MAKE) $(@:$(root)/%=%) --directory=$(root)
29
+_ = $(+:_%=)
30
addBeforeExt = $(basename $(2))$(1)$(suffix $(2))
31

    
32
# OS
33
os := $(shell uname)
34
forOs = $(patsubst %,%-$(filter Linux Darwin,$(os)),$(1))
35

    
36
# Formatting
37
SED = sed -$(if $(filter Darwin,$(os)),E,r)
38

    
39
# System
40
date = $(shell date +"%Y-%m-%d-%H-%M-%S")
41

    
42
# Terminal
43
termCols := $(shell tput cols)
44
esc := '['
45
reset := $(esc)'0m'
46
emph := $(esc)'7m '
47
endEmph := ' '$(reset)
48

    
49
# Commands
50
MKDIR = mkdir -p
51
mkdir = $(MKDIR) $(@D)
52
CP = cp -p
53
diff = diff --unified=2
54
diffVerbose = $(if $(verbose),diff --side-by-side --left-column\
55
--width=$(termCols),$(diff))
56

    
57
# BIEN commands
58
selfMap = $(bin)/cols 0 0
59
psqlOpts := --set ON_ERROR_STOP=1 --quiet
60
psqlAsBien := $(bin)/psql_vegbien $(psqlOpts)
61

    
62
# SVN
63
addDir = $(if $(wildcard $(1)/),svn add --depth=empty $(1),svn mkdir $(1))
64
setSvnIgnore = svn propset svn:ignore $(2) $(1)
65
define addDirWithIgnore
66
$(addDir)
67
$(setSvnIgnore)
68
endef
69

    
70
##### General targets
71

    
72
all: _always maps ;
73

    
74
.SUFFIXES: # turn off built-in suffix rules
75
.SECONDARY: # don't automatically delete intermediate files
76
.DELETE_ON_ERROR: # delete target if recipe fails
77

    
78
_always:
79
.PHONY: _always
80

    
81
clean: _always
82
	$(RM) $(all)
83

    
84
remake: _always clean
85
	+$(selfMake)
86
# re-run make so that cache of existing files is reset
87

    
88
make_script = ./$< >$@
89

    
90
%/: % _always ;
91

    
92
# Must come before `%: %.make` to override it
93
src/%: src/%.make _always
94
	(set -x; $(make_script)) 2>>$<.log.sql
95
.PRECIOUS: src/% # save partial outputs of aborted src make scripts
96

    
97
%: %.make _always
98
	$(make_script)
99

    
100
##### SVN
101

    
102
add: _always
103
	$(call setSvnIgnore,.,$$'')
104
	$(call addDirWithIgnore,src,$$'*')
105
	$(call addDirWithIgnore,maps,$$'.~*')
106
	$(call addDirWithIgnore,import,$$'*')
107
	$(call addDirWithIgnore,test,$$'*.out\n*.xml')
108
	$(call addDirWithIgnore,verify,$$'*.out')
109

    
110
##### Existing maps discovery
111

    
112
inputFiles := $(wildcard $(exts:%=src/*.%))
113
ifeq ($(inputFiles),)
114
dbExport := $(firstword $(wildcard src/db.*.sql))
115
endif
116

    
117
srcMap := maps/src.%.csv
118
fullViaMap := maps/%.full.csv
119
directMap := maps/VegBIEN.%.csv
120
allViaMaps := $(filter-out $(srcMap) $(fullViaMap) $(directMap),\
121
$(wildcard maps/*.csv))
122
via := $(firstword $(sort $(basename $(basename $(notdir $(allViaMaps))))))
123

    
124
coreMap := $(mappings)/$(via)-VegBIEN.%.csv
125
coreSelfMap := $(mappings)/$(via).self.%.csv
126

    
127
viaMaps := $(wildcard $(tablesSort:%=maps/$(via).%.csv))
128
viaMaps += $(filter-out $(viaMaps) $(fullViaMap),$(wildcard maps/$(via).*.csv))
129

    
130
autogenMaps := $(subst $(via).,VegBIEN.,$(viaMaps))
131
directMaps := $(autogenMaps) $(filter-out $(autogenMaps),\
132
$(wildcard maps/VegBIEN.*.csv))
133
tables := $(directMaps:maps/VegBIEN.%.csv=%)
134

    
135
##### Sources
136

    
137
srcs = $(shell $(bin)/sort_filenames $(wildcard $(exts:%=src/*.$*.%)))
138
isCsv = $(if $(srcs),$(if $(filter %.xml,$(srcs)),,1))
139
    # true if $(srcs) non-empty and contains no *.xml
140
catSrcs = $(bin)/cat$(if $(isCsv),_csv) $(srcs)
141
withCatSrcs = $(catSrcs:$(bin)/%=$(bin)/with_%) --
142

    
143
# Usage: `make {--silent|-s} inputs/<datasrc>/cat` (don't echo make commands)
144
cat: $(addprefix cat-,$(tables)) _always ;
145

    
146
cat-%: _always
147
	$(catSrcs)
148

    
149
##### Installation
150

    
151
install: _always src/install import/install ;
152

    
153
uninstall: _always import/uninstall src/uninstall ;
154

    
155
reinstall: _always uninstall install ;
156

    
157
##### Staging tables
158

    
159
import/install: _always import/schema $(addprefix import/install-,$(tables)) ;
160

    
161
import/uninstall: _always import/rm_schema ;
162
# rm_schema will also drop all staging tables
163

    
164
import/schema: _always
165
	-echo 'CREATE SCHEMA "$(datasrc)";'|$(psqlAsBien)
166
# ignore errors if schema exists
167

    
168
import/rm_schema: _always
169
	echo 'DROP SCHEMA IF EXISTS "$(datasrc)" CASCADE;'|$(psqlAsBien)
170

    
171
import/install-%: _always
172
	$(if $(isCsv),$(import_install_))
173
import_install_ = (prefix=; . $(bin)/vegbien_dest; "time" nice -n +5\
174
env schema=$(datasrc) table=$* $(bin)/csv2db $(catSrcs)\
175
$(if $(log),$(if $(quiet),&>,2>&1|tee )import/install-$*.log.sql))
176

    
177
##### Maps building
178

    
179
# Maps to (try to) build are added to one of these
180
maps :=
181
createOnlyMaps :=
182

    
183
srcMaps := $(wildcard maps/src.*.csv)
184

    
185
srcRoot = $(mappings)/roots/$*.sh
186
mkSrcMap = $(catSrcs)|(. $(srcRoot); env datasrc=$(datasrc) $(bin)/src_map >$@)
187

    
188
# Src maps cleanup
189
ifneq ($(filter maps/.%.last_cleanup,$(MAKECMDGOALS)),)
190
maps/.src.%.csv.last_cleanup: maps/src.%.csv
191
	$(bin)/in_place $< $(bin)/cols '*'
192
	touch $@
193
else
194
# Autogen src maps with known table names
195
maps/src.%.csv: _always
196
	$(if $(wildcard $@),,$(if $(isCsv),$(mkSrcMap)))
197
	+$(if $(isCsv),$(selfMake) $(@:maps/%=maps/.%.last_cleanup))
198
# only build if doesn't exist
199
# only build if CSV srcs exist for that table name
200
endif
201

    
202
# Try all table names
203
createOnlyMaps += $(tablesSort:%=maps/src.%.csv)
204

    
205
# Must come before $(root)/% to override it
206
$(coreSelfMap): _always
207
	-+$(subMake)
208
# ignore errors if $(coreSelfMap) does not exist
209

    
210
joinSrcMap = $(if $(hasSrc),$(bin)/in_place $@ $(bin)/intersect $(word 3,$+) 0)
211
hasSrc = $(shell test -s $(word 3,$+) && echo t)
212

    
213
makeFullCsv = $(if $(shell test -e $(word 2,$+) && echo t),\
214
env ignore=1 $(bin)/union <$(wordlist 1,2,$+)|,<$< )$(bin)/sort_map >$@
215
# can't use $(wildcard) because it won't recheck file after $(coreSelfMap) runs
216

    
217
# Must come before maps/$(via).%.csv to override it
218
maps/$(via).%.full.csv: maps/$(via).%.csv $(coreSelfMap) $(srcMap)
219
	$(makeFullCsv)
220
	$(joinSrcMap)
221
maps += $(patsubst maps/%.csv,maps/%.full.csv,$(viaMaps))
222

    
223
# Via maps cleanup
224
ifneq ($(filter maps/.%.last_cleanup,$(MAKECMDGOALS)),)
225
maps/.$(via).%.csv.last_cleanup: maps/$(via).%.csv $(coreMap)
226
	$(bin)/in_place $< env ignore=1 $(bin)/subtract $(word 2,$+) 0 1 2
227
	touch $@
228
# Include comment column so commented mappings are never removed
229
else
230
maps/$(via).%.csv: _always
231
	+$(selfMake) $(@:maps/%=maps/.%.last_cleanup)
232
endif
233

    
234
maps/VegBIEN.%.csv: maps/$(via).%.full.csv $(coreMap)
235
	$(bin)/join <$+|$(bin)/sort_map >$@
236
maps += $(autogenMaps)
237

    
238
maps: $(createOnlyMaps) $(maps) _always ;
239

    
240
all += $(maps)
241

    
242
##### Maps validation
243

    
244
missing_mappings: _always missing_join_mappings missing_input_mappings ;
245

    
246
missing_%_mappings: _always # stem is one of join|input
247
	@echo $(emph)"Missing $* mappings:"$(endEmph)
248
	@+$(selfMake) remake 2>&1\
249
|$(SED) -n 's/^.*No.* $* mapping for ([0-9A-Za-z_-]+).*$$/\1/p'\
250
$(if $(filter join,$*),|$(bin)/ucase_first 0)|sort|uniq
251

    
252
##### External dependencies
253

    
254
$(root)/%: _always
255
	+$(subMake)
256
.PRECIOUS: $(root)/% # let ext. dir's Makefile decide whether to delete on error
257

    
258
##### Mapping
259

    
260
+maps = $(filter maps/% $(mappings)/%,$(+_))
261
<in = $(firstword $(filter-out $(+maps),$(+_)))
262
map = $(if $(<in),<$(<in),\
263
$(if $(srcs),$(withCatSrcs),\
264
$(if $(mapEnv),env $(mapEnv),\
265
$(error No input file src/*.$*.{$(exts)}))))\
266
$(root)/map $(+maps)
267
map2db = $(if $(use_staged),env in_database=vegbien in_schema=$(datasrc)\
268
in_table=$*) env out_database=vegbien $(map)
269

    
270
##### Import to VegBIEN
271

    
272
ifneq ($(dbExport)$(inputFiles),)
273

    
274
profileTest = $(if $(profile),$(if $(test),1))
275
profileOnly = -env profile_to=/dev/fd/3 $(map2db) 3>&1 1>&2|\
276
$(bin)/profile_stats /dev/fd/0
277

    
278
log_ = import/$*$(if $(n),.n=$(n),).$(date).log.sql
279
trace = $(log_:.log.sql=.trace)
280
import = -$(if $(profileTest),$(profileOnly),(set -x; "time" env commit=1\
281
$(if $(profile),profile_to=$(trace)) $(map2db)) $(if $(log),\
282
$(if $(n),,&>>$(log_)))$(if $(log),$(if $(n), 2>&1|tee -a $(log_))))
283
# don't abort on import errors, which often relate to invalid input data
284

    
285
import: $(addprefix import-,$(tables)) _always ;
286

    
287
import-%: maps/VegBIEN.%.csv _always
288
	$(import)
289
# default:
290
import-%: _always ;
291

    
292
else
293
import: _always ;
294
endif
295

    
296
##### Log files from import
297

    
298
logs := $(wildcard import/*.log.sql import/*.trace)
299

    
300
rm_logs: _always
301
	$(RM) $(logs)
302

    
303
##### Verification of import
304

    
305
verify: $(addprefix verify-,$(tables)) _always ;
306

    
307
verify-%: verify/%.ref verify/%.out _always
308
	-$(diffVerbose) $(+_)
309
# don't abort on verification errors, which are expected during development
310
# default:
311
verify-%: verify/%.out _always
312
	$(if $(shell test -e $< && echo t),cat $<)
313
# don't run if verify/%.out's default do-nothing action was used
314
# can't use $(wildcard) because it won't recheck file after verify/%.out is run
315

    
316
verify = $(if $(reverify),"time" $(psqlAsBien) --set=datasource="'$(datasrc)'"\
317
--no-align --field-separator=$$'\t' --pset=footer=off --pset=null=NULL <$< >$@)
318

    
319
verify/%.out: $(mappings)/verify.%.sql _always
320
	$(verify)
321
# default:
322
verify/%.out: _always ;
323

    
324
all += $(wildcard verify/*.out)
325

    
326
ifneq ($(dbExport),)
327
%.ref: %.ref.sql
328
	$(dbAsBien) $(db) <$< >$@
329
endif
330

    
331
##### Editing import
332

    
333
import/rotate: _always
334
	echo "UPDATE party SET organizationname = organizationname||'.$(date)'\
335
WHERE organizationname = '$(datasrc)';"|$(psqlAsBien)
336

    
337
import/rm: _always
338
	echo "DELETE FROM party WHERE organizationname = '$(datasrc)';"|\
339
$(psqlAsBien)
340

    
341
##### Testing
342

    
343
testRefOutput = $(subst .2-step,,$(subst .staging,,$(1)))
344
testRef = $(testRefOutput).ref
345
hasOwnRef = $(filter $@,$(call testRefOutput,$@))
346
# filter returns non-empty if they are equal
347

    
348
define runTest
349
@echo "Testing $(abspath $@)..."
350
>$@ env test=1 n=$(test_n) $(1)
351
@(set -x; $(diff) $(call testRef,$@) $@) 2>&1 || { e=$$?;\
352
$(if $(wildcard $(call testRef,$@)),,cat $@;)\
353
$(if $(hasOwnRef),\
354
{\
355
read -p $(emph)'Accept new test output? (y/n)'$(endEmph) REPLY;\
356
if test "$$REPLY" = y; then\
357
(set -x; $(MAKE) $@-ok --directory=$(realpath .) --makefile=../input.Makefile);\
358
exit 0;\
359
fi;\
360
};,\
361
echo $(emph)"Note: The preceding failed test is compared to another test's\
362
output"$(endEmph);\
363
echo $(emph)"When it fails, this always indicates a bug"$(endEmph);\
364
)\
365
exit $$e;}
366
endef
367

    
368
test2File = $(call runTest,$(map))
369
test2Db = $(call runTest,$(map2db))
370

    
371
tests :=
372

    
373
test/$(via).%.xml: maps/$(via).%.full.csv _always
374
	$(test2File)
375
tests += test/$(via).%.xml
376

    
377
test/VegBIEN.%.xml: maps/VegBIEN.%.csv _always
378
	$(test2File)
379
tests += test/VegBIEN.%.xml
380

    
381
test/VegBIEN.%.2-step.xml: test/$(via).%.xml $(coreMap) _always
382
	-$(test2File)
383
# Don't abort tester if only 2-step test fails, as it's often finicky
384
tests += test/VegBIEN.%.2-step.xml
385

    
386
test/import.%.out: maps/VegBIEN.%.csv _always
387
	$(test2Db)
388
tests += test/import.%.out
389

    
390
testStaged2Db = $(foreach use_staged,1,$(test2Db))
391
    # run with use_staged=1
392

    
393
# Requires staging tables. To create them, run `make inputs/<datasrc>/install`.
394
test/import.%.staging.out: maps/VegBIEN.%.csv _always
395
	-$(if $(isCsv),$(testStaged2Db),cp -p $(@:.staging.out=.out) $@)
396
# Don't abort tester if only staging test fails, in case staging table missing
397
# Non-flat-file inputs fall back to mimicking a successful test
398
tests += test/import.%.staging.out
399

    
400
testOutputs := $(foreach test,$(tests),$(tables:%=$(test)))
401

    
402
.PRECIOUS: $(testOutputs) # save outputs of failed tests so they can be accepted
403

    
404
test: _always $(testOutputs) ;
405

    
406
all += $(filter-out %.ref,$(wildcard test/*))
407

    
408
# Accepts a test output: make <test_output_path>-ok
409
%-ok: _always
410
	$(CP) $* $(call testRef,$*)
411

    
412
##### Documentation
413

    
414
steps = $(selfMake) import test=1 by_col=1 verbosity=2 n=100\
415
2>&1|$(bin)/debug2redmine >$@
416

    
417
import/steps.by_col.sql: _always
418
	+$(steps)
419

    
420
##### Input-type-specific
421

    
422
# Each input type needs var $(mapEnv) and targets src/install, src/uninstall
423

    
424
#### DB export
425

    
426
ifneq ($(dbExport),)
427

    
428
dbEngineExt := $(subst .,,$(suffix $(basename $(notdir $(dbExport)))))
429
db := $(datasrc)
430

    
431
### Installation
432

    
433
src/install: _always db ;
434

    
435
src/uninstall: _always rm_db ;
436

    
437
### DB-engine-specific
438

    
439
# Each DB engine needs vars $(dbEngine), $(dbAsBien) and targets db, rm_db
440

    
441
ifeq ($(dbEngineExt),my)
442

    
443
dbEngine := MySQL
444

    
445
bienPassword := $(shell cat $(root)/config/bien_password)
446
mysqlAs = mysql --user=$(1) --password='$(bienPassword)'
447
mysqlAsRoot := $(call mysqlAs,root)
448
dbAsBien := $(call mysqlAs,bien)
449

    
450
dbExists = $(shell echo "SHOW DATABASES LIKE '$(db)';"|$(mysqlAsRoot))
451

    
452
define createDb
453
echo "CREATE DATABASE $(db) DEFAULT CHARACTER SET latin1;"|$(mysqlAsRoot)
454
-$(mysqlAsRoot) --database=$(db) <$<
455
endef
456
# ignore errors in db import so that GRANT will still be run
457

    
458
db: $(dbExport) _always
459
	$(if $(dbExists),,$(createDb))
460
	echo "GRANT SELECT ON $(db).* TO 'bien'@'localhost';"|$(mysqlAsRoot)
461

    
462
rm_db: _always
463
	-echo "REVOKE ALL ON $(db).* FROM 'bien'@'localhost';"|$(mysqlAsRoot)
464
	echo "DROP DATABASE IF EXISTS $(db);"|$(mysqlAsRoot)
465
# ignore errors if grant not defined
466

    
467
## Unrecognized DB engine
468

    
469
else
470
$(error The DB filename $(dbExport) must be db.my.sql)
471
endif
472

    
473
### Other input types
474

    
475
else
476

    
477
src/install: _always ;
478
src/uninstall: _always ;
479

    
480
endif
481

    
482
#### DB connection info
483

    
484
ifneq ($(dbEngine),)
485
# Must come after dbEngine is set
486
mapEnv := in_engine=$(dbEngine) in_database=$(db)
487
endif
(3-3/3)