#!/bin/bash -e

. "$(dirname "${BASH_SOURCE[0]}")"/../../../lib/runscripts/table_dir.run

. "$(dirname "${BASH_SOURCE[0]}")"/../../../lib/sh/binsearch.sh

if self_not_included; then

#### import resuming

### is_pkey_imported()

table=raw_occurrence_record

is_pkey_imported__int() # usage: pkey=# is_pkey_imported__int

{

	echo_func; kw_params pkey; : "${pkey?}"; mk_table_esc

	test "$pkey" || { log++ echo_run echo 0; return; }

	use_local_remote

	data_only=1 mysql_ANSI <<<"SELECT COUNT(*) FROM $table_esc WHERE id = $pkey"

}

func_override is_pkey_imported__int__no_cache

is_pkey_imported__int() # caches the last result for efficiency

{

	local cache_key="$(declare -p pkey) $*"; load_cache

	if ! cached; then save_cache "$(${FUNCNAME}__no_cache "$@")" || return; fi

	echo_cached_value

}

is_pkey_imported()

{ echo_func; local int; int="$(is_pkey_imported__int)"; int2bool "$int"; }

get_pkey_at_pos() # usage: i=# get_pkey_at_pos

{

	echo_func; log++; kw_params i; : "${i?}"; mk_table_esc

	piped_cmd echo_run tail -c +"$i" "$top_file"\

	|echo_run sed -n '/^INSERT INTO '"$table_esc"' VALUES \(([0-9]+),.*$/{

s//\1/p

q # stop after first match

}'

}

is_pkey_at_pos_imported()

{ echo_func; local pkey; pkey="$(get_pkey_at_pos)"; is_pkey_imported; }

import_resume_pos() # usage: [min=#] [max=#] import_resume_pos

{

	echo_func; kw_params min max; local min="${min-0}"

	if ! isset max; then local max; max="$(file_size "$top_file")"; fi

	binsearch is_pkey_at_pos_imported

}

fi