Project

General

Profile

1 9014 aaronmk
#!/bin/bash -e
2
. "$(dirname "${BASH_SOURCE[0]}")"/util.sh
3
4
if self_not_included; then
5
6
# using prefixed connection vars
7
alias use_local='declare prefix=local_; import_vars'
8
alias use_remote='declare prefix=remote_; import_vars'
9
alias use_local_remote='use_local; use_remote'
10
11
quote='"'
12
13
esc_name () { echo "$quote${1//$quote/$quote$quote}$quote"; }
14
15
mk_esc_name () { set_var "$1"_esc "$(esc_name "${!1}")"; }
16
17
alias mk_schema_esc='declare schema_esc; mk_esc_name schema'
18
alias mk_table_esc='declare table_esc; mk_esc_name table'
19
20
fi # load new aliases
21
if self_being_included; then
22
23
log_sql () { test "$verbosity" -ge 2; }
24
25 9017 aaronmk
26 9014 aaronmk
### MySQL
27
28
# auto-adds connection/login opts when specified
29
mysql_cmd () # usage: mysql* () { ...; mysql_cmd "$@"; }
30
{
31
	echo_func
32
	local ssh_server="$(localize_url "$ssh_server")"
33
	local server="$(localize_url "$server")"
34 9050 aaronmk
	if test "$ssh_server"; then
35 9014 aaronmk
		local ssh_dest="${ssh_dest-${ssh_user:+$ssh_user@}$ssh_server}"
36
	fi
37 9050 aaronmk
	if test "$schema"; then local database="${database-$schema}"; fi
38 9014 aaronmk
39
	local var=ssh_dest; local_inv
40
	extern ${ssh_dest:+ssh "$ssh_dest" }"${FUNCNAME[1]}" \
41
${server:+ --host="$server" }${user:+--user="$user" } --password\
42
${password+="$password"} ${database:+--databases "$database" --tables } "$@"
43
}
44
45
mysql () { echo_func; mysql_cmd --verbose "$@"; }
46
47
mysql_ANSI ()
48
{
49
	echo_func
50
	(echo "SET sql_mode = 'ANSI';"; cat)|mysql "$@"
51
}
52
53
mysqldump () # usage: [schema=1 | data=1] mysqldump db [table...]
54
{
55
	echo_func
56
	mysql_cmd --quick --lock-tables=false --set-charset \
57
${postgres_compat:+--compatible=postgresql --add-locks=false }\
58
${schema:+--no-data }${data:+--no-create-info }"$@"
59
}
60
61
mysqldump_diffable ()
62
{
63
	echo_func
64
	mysqldump "$@"|sed 's/^(-- Dump completed).*$/\1/'
65
}
66
67 9017 aaronmk
68 9014 aaronmk
### PostgreSQL
69
70
pg_copy_to ()
71
{
72
	echo_func
73 9050 aaronmk
	if test ! "$source"; then
74 9014 aaronmk
		: "${table:?}"; mk_table_esc
75 9050 aaronmk
		if test ! "$limit"; then local source="$table_esc"
76 9014 aaronmk
		else local source="(SELECT * FROM $table_esc LIMIT $limit)"
77
		fi
78
	fi
79
	local pg_copy_format="${pg_copy_format-CSV HEADER}"
80
81
	psql "$@" <<<"COPY $source TO STDOUT $pg_copy_format;"
82
}
83
84
pg_header ()
85
{
86
	echo_func
87
	local pg_copy_format="CSV HEADER" limit=0
88 9045 aaronmk
	pg_copy_to "$@"|echo_stdout
89 9014 aaronmk
}
90
91
pg_export_table_no_header ()
92
{
93
	echo_func
94
	local pg_copy_format="CSV"
95
	pg_copy_to "$@"
96
}
97
98
pg_export_table_to_dir_no_header ()
99
{
100
	echo_func
101
	local table="$1"; shift; mk_table_esc
102
	local cols="$(pg_header)"
103 9042 aaronmk
	stdout="$exports_dir/$table.no_header.cols=$cols.csv" to_file \
104
pg_export_table_no_header "$@"
105 9014 aaronmk
}
106
107
fi