From 6445ffc7d44d460a7ba3965a9558ad554128361a Mon Sep 17 00:00:00 2001
From: varac <varacanero@zeromail.org>
Date: Wed, 21 Aug 2013 22:29:34 +0200
Subject: initial commit

---
 README.md                     |   9 +++
 couchdb-scripts-defaults.conf |  12 ++++
 couchdb_dumpall.sh            |  20 ++++++
 couchdb_functions             | 152 ++++++++++++++++++++++++++++++++++++++++++
 couchdb_listall.sh            |  13 ++++
 couchdb_recreate_dbs.sh       |  57 ++++++++++++++++
 couchdb_restoreall.sh         |  16 +++++
 7 files changed, 279 insertions(+)
 create mode 100644 README.md
 create mode 100644 couchdb-scripts-defaults.conf
 create mode 100755 couchdb_dumpall.sh
 create mode 100644 couchdb_functions
 create mode 100755 couchdb_listall.sh
 create mode 100755 couchdb_recreate_dbs.sh
 create mode 100755 couchdb_restoreall.sh

diff --git a/README.md b/README.md
new file mode 100644
index 0000000..35c19cb
--- /dev/null
+++ b/README.md
@@ -0,0 +1,9 @@
+Leap Couchdb/Bigcouch scripts
+=============================
+
+Use couchdb functions on command line
+
+    . couchdb-scripts-defaults.conf
+    . couchdb_functions
+    get_dbs $URL 
+
diff --git a/couchdb-scripts-defaults.conf b/couchdb-scripts-defaults.conf
new file mode 100644
index 0000000..c0dfd2d
--- /dev/null
+++ b/couchdb-scripts-defaults.conf
@@ -0,0 +1,12 @@
+NETRC_FILE='/etc/couchdb/couchdb.netrc'
+OPTS="--netrc-file $NETRC_FILE -HContent-Type:application/json -s"
+CURL="curl $OPTS "
+URL='http://127.0.0.1:5984'
+BACKEND_URL='http://127.0.0.1:5986'
+DUMPDIR='/var/backups/couchdb'
+TMPPREFIX='tmp'
+
+user=`cat /etc/couchdb/couchdb.netrc | cut -d ' ' -f 4`
+pw=`cat /etc/couchdb/couchdb.netrc | cut -d ' ' -f 6`
+auth_url="http://${user}:${pw}@127.0.0.1:5984"
+
diff --git a/couchdb_dumpall.sh b/couchdb_dumpall.sh
new file mode 100755
index 0000000..53cfae4
--- /dev/null
+++ b/couchdb_dumpall.sh
@@ -0,0 +1,20 @@
+#!/bin/bash
+
+# dump_db() and restore_db() rely on python-couchdb package, 
+# python-couchdb =< 0.8-1 needs to be patched, see
+# http://code.google.com/p/couchdb-python/issues/detail?id=194 
+
+. couchdb-scripts-defaults.conf
+. couchdb_functions
+
+# create backupdir
+[ -d $DUMPDIR ] || mkdir $DUMPDIR
+
+dbs="`get_dbs $URL`"
+#dbs='tickets'  # for debugging
+
+for db in $dbs
+do
+  dump_db ${URL} $db $user $pw
+
+done
diff --git a/couchdb_functions b/couchdb_functions
new file mode 100644
index 0000000..cf6cb2b
--- /dev/null
+++ b/couchdb_functions
@@ -0,0 +1,152 @@
+# dump_db() and restore_db() rely on python-couchdb package, 
+# python-couchdb =< 0.8-1 needs to be patched, see
+# http://code.google.com/p/couchdb-python/issues/detail?id=194 
+
+
+create_db () {
+  local url=$1
+  local db=$2
+  $CURL -X PUT "${url}/${db}"
+}
+
+db_exists () {
+  local url=$1
+  local db=$2
+  $CURL -X GET "${url}/${db}" | grep -q -v '{"error":"not_found"'
+  return $?
+}
+
+delete_db () {
+  local url=$1
+  local db=$2
+  $CURL -X DELETE "${url}/${db}"
+}
+
+delete_doc () {
+  local url=$1
+  local db=$2
+  local doc=$3
+  local latest_rev=`get_latest_rev $url $db $doc`
+  $CURL -X DELETE "${url}/${db}/${doc}?rev=$latest_rev"
+}
+
+doc_exists () {
+  local url=$1
+  local db=$2
+  local doc=$3
+  $CURL -X GET "${url}/${db}/${doc}" | grep -q -v '{"error":"not_found"'
+  return $?
+}
+
+
+dump_db () {
+  local url=$1
+  local db=$2
+  local user=$3
+  local pw=$4
+  local dumpdir=$5
+
+  [ -z $dumpdir ] && dumpdir='/var/backups/couchdb'
+  
+  echo "Dumping db \"$db\" to ${dumpdir}/$db"
+  # couchdb-dump cmd is VERY slow, simply dumping _all_docs?include_docs=true 
+  # to a file is faster with the factor ~60 (!)
+  couchdb-dump -u $user -p $pw ${url}/$db > ${dumpdir}/$db #2>/dev/null
+
+  # restoring from this will not include _design/User right
+  #$CURL -X GET "${URL}/${db}/_all_docs?include_docs=true" > ${DUMPDIR}/$db
+
+  echo "Dumping _security to ${DUMPDIR}/${db}_security"
+  $CURL -X GET "${URL}/${db}/_security" > ${DUMPDIR}/${db}_security
+
+  chmod 600 ${dumpdir}/${db}*
+}
+
+get_dbs () { 
+  local url=$1
+  local dbs="`$CURL -X GET "${url}/_all_dbs" | sed 's/[\[",]/ /g' | sed 's/]//'`"
+  echo "$dbs"
+}
+
+get_security () {
+  local url=$1
+  local db=$2
+  local security=`$CURL -X GET "${url}/${db}/_security"`
+  echo $security
+}
+
+get_latest_rev () {
+  local url=$1
+  local db=$2
+  local doc=$3
+  local latest_rev=''
+  latest_rev=`$CURL -X GET "${url}/${db}/${doc}" | sed 's/^.*"_rev":"//'|cut -d'"' -f 1`
+  echo $latest_rev
+}
+
+replicate_db () {
+  local url=$1
+  local backend_url=$2
+  local source_db=$3
+  local target_db=$4
+  local additional_opts=$5
+  local task=''
+  # old style replication, no status can be queried
+  # -X POST http://localhost:5984/_replicate -d ' {"source": "http://admin:zyMM7LZMjGE2aUvJ5sH_8SraPuxB2H5L@localhost:5984/users", "target": "http://admin:zyMM7LZMjGE2aUvJ5sH_8SraPuxB2H5L@localhost:5984/users_replicated", "create_target": true }
+  # netrcfile doesn't work with replicate, we need to use username + pw here
+  #echo "Getting _security from $db"
+  local security=`get_security $url $source_db` 
+
+  create_db $url $target_db
+
+  #echo "Set security for $tmpdb"
+  set_security $url $target_db $security
+
+  #echo "Replicating $db to $tmpdb"
+  #$CURL -X POST ${BACKEND_URL}/_replicator -d " { \"_id\":  \"${source_db}_${target_db}\", \"source\": \"$auth_url/${source_db}\", \"target\": \"$auth_url/${target_db}\", \"create_target\": true $additional_opts }"
+  task="${source_db}_${target_db}"
+  $CURL -X POST ${BACKEND_URL}/_replicator -d " { \"_id\":  \"${task}\", \"source\": \"$auth_url/${source_db}\", \"target\": \"$auth_url/${target_db}\" $additional_opts }"
+  
+  #echo -e "\nGetting replication status of task \"$task\":"
+  #$CURL -X GET ${BACKEND_URL}/_replicator/$task
+
+  wait_for_complete_replication $backend_url
+}
+
+restore_db () {
+  local url=$1
+  local db=$2
+  local user=$3
+  local pw=$4
+  local dumpdir=$5
+  [ -z $dumpdir ] && dumpdir='/var/backups/couchdb'
+
+  # restore with couchdb-load only works with an empty db
+  db_exists $url $db && delete_db $url $db
+  create_db $url $db
+  
+  $CURL -X PUT "${url}/${db}/_security" -d  @${dumpdir}/${db}_security
+  
+  couchdb-load -u $user -p $pw ${url}/$db <  ${dumpdir}/$db 
+
+  # old style
+  # $CURL -d @${dumpdir}/$db -X POST "${url}/${db}/_bulk_docs"
+}
+
+set_security () {
+  local url=$1
+  local db=$2
+  local security=$3
+  $CURL -X PUT "${url}/${db}/_security" -d $security
+}
+
+wait_for_complete_replication () {
+  local backend_url=$1
+  local uncomplete_tasks=1
+  echo -e "\nWaiting for uncompleted replication tasks"
+  while [ $uncomplete_tasks -gt 0 ]
+  do
+    uncomplete_tasks=`$CURL -X GET "${backend_url}/_replicator/_all_docs/?include_docs=true" | egrep -v '("_replication_state":"completed"|"id":"_design/_replicator"|{"total_rows":|^]}$)'|wc -l`
+    sleep 1
+  done
+}
diff --git a/couchdb_listall.sh b/couchdb_listall.sh
new file mode 100755
index 0000000..5bd7115
--- /dev/null
+++ b/couchdb_listall.sh
@@ -0,0 +1,13 @@
+#!/bin/bash
+
+. couchdb-scripts-defaults.conf
+. couchdb_functions
+
+
+dbs="`get_dbs $URL`"
+#dbs='tickets'  # for debugging
+
+for db in $dbs
+do
+  $CURL -X GET "${URL}/${db}"
+done
diff --git a/couchdb_recreate_dbs.sh b/couchdb_recreate_dbs.sh
new file mode 100755
index 0000000..3892720
--- /dev/null
+++ b/couchdb_recreate_dbs.sh
@@ -0,0 +1,57 @@
+#!/bin/bash
+
+# script for recreating all dbs
+# useful after a node gets added or removed from the cluster
+# because there's no automatic rebalancing of bigcouch atm (2013/08)
+# One workaround is to recreate all dbs and restore from a backup, 
+# then all current cluster nodes get recognized
+#
+# For each db the following main steps are processed:
+# 1. replicate db to tmp_db
+# 2. delete db, create db
+# 3. replicate tmp_db to db
+
+# concurrent replication might cause stalled tasks, see #https://leap.se/code/issues/3506,
+# so we use slower, sequential replication here
+
+. couchdb-scripts-defaults.conf
+. couchdb_functions
+
+
+dbs="`get_dbs $URL`"
+dbs='users_replicated'  # for debugging
+
+# concurrent replication might cause stalled tasks, see #https://leap.se/code/issues/3506
+for db in $dbs
+do
+  tmpdb="${TMPPREFIX}_${db}"
+
+  echo -e "\n\n\nRecreating db $db\n------------------------------\n"
+
+  # cleaning potential leftovers from past replications
+  task="${db}_${tmpdb}"
+  doc_exists $URL $db $task && ( echo -e "\nDeleting old backup replication task \"$task\" "; delete_doc ${BACKEND_URL} "_replicator" ${task} )
+  doc_exists $URL $db ${tmpdb}_${db} && ( echo -e "\nDeleting old restore replication task \"${tmpdb}_${db}\" "; delete_doc ${BACKEND_URL} "_replicator" ${tmpdb}_${db} )   
+  db_exists $URL $tmpdb && ( echo -e "\nDeleting old backup db $tmpdb"; delete_db $URL $tmpdb )
+
+  # backup, delete, restore
+  echo -e "\nReplicating $db to $tmpdb"
+  replicate_db ${auth_url} ${BACKEND_URL} $db $tmpdb
+
+  echo -e "\nDeleting $db"
+  delete_db $URL $db
+
+  echo -e "\nRestoring $db"
+  replicate_db $auth_url ${BACKEND_URL} $tmpdb $db
+
+
+  # clean up
+  echo -e "\nDeleting backup db $tmpdb"
+  delete_db $URL $tmpdb
+
+  echo -e "\nDeleting backup replication task \"$task\" "
+  delete_doc ${BACKEND_URL} "_replicator" ${task}
+
+  echo -e "\nDeleting restore replication task \"${tmpdb}_${db}\" "
+  delete_doc ${BACKEND_URL} "_replicator" ${tmpdb}_${db}
+done
diff --git a/couchdb_restoreall.sh b/couchdb_restoreall.sh
new file mode 100755
index 0000000..20cd6b0
--- /dev/null
+++ b/couchdb_restoreall.sh
@@ -0,0 +1,16 @@
+#!/bin/bash
+
+# dump_db() and restore_db() rely on python-couchdb package, 
+# python-couchdb =< 0.8-1 needs to be patched, see
+# http://code.google.com/p/couchdb-python/issues/detail?id=194 
+
+. couchdb-scripts-defaults.conf
+. couchdb_functions
+
+dbs="`get_dbs $URL`"
+#dbs='users_replicated'  # for debugging
+
+for db in $dbs
+do
+  restore_db ${URL} $db $user $pw
+done
-- 
cgit v1.2.3