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

#!/bin/bash -e

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

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

if self_not_included; then

### is_pkey_imported()

is_pkey_imported__int() # usage: pkey_name=... pkey=# is_pkey_imported__int

{

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

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

	mk_table_esc

	use_local_remote

	data_only=1 mysql_ANSI \

<<<"SELECT COUNT(*) FROM $table_esc WHERE $pkey_name = $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_name 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

}

resume_import() # usage: [pos=#] resume_import

{

	echo_func; kw_params pos

	if ! isset pos; then local pos; pos="$(import_resume_pos)"; fi

	use_local_remote

	echo_run tail -c +"$pos" "$top_file"|mysql

}

fi