kubernetes/common/cassandra/resources/restore.sh

#!/bin/sh

# Initialize variables
ss_dir=""
base_db_dir=""
ss_name=""
ss="snapshots"
me=`basename $0`

function find_target_table_name()
{
    dest_path=$1
    keyspace_name=$2
    src_table_name=$3
    find_in_dir=$dest_path/$keyspace_name
    tname_without_uuid=$(echo $src_table_name | cut -d '-' -f 1)
    dest_table_name=$(ls -td -- $find_in_dir/$tname_without_uuid-* | head -n 1 | rev | cut -d'/' -f1 | rev)
    printf $dest_table_name
}

function print_usage()
{
	echo "NAME"
	echo "	Script to restore Cassandra database from Nuvo/Cain snapshot"
	echo "SYNOPSIS"
	echo "	$me [--help|-h] [--base_db_dir|-b] [--snapshot_dir|-s] [--keyspace|-k] [--tag|-t]"
	echo "	MUST OPTIONS: base_db_dir, snapshot_dir, keyspace_name"
	echo "DESCRIPTION"
	echo "	--base_db_dir, -b"
	echo "		Location of running Cassandra database"
	echo "	--snapshot_dir, -s"
	echo "		Snapshot location of Cassandra database taken by Nuvo/Cain"
	echo "	--keyspace, -k"
	echo "		Name of the keyspace to restore"
	echo "EXAMPLE"
	echo "	$me -b /var/lib/cassandra/data -s /root/data.ss -k DISCOVERY_SERVER -t 1234567"
	exit
}
if [ $# -eq  0 ]
then
	print_usage
fi

while [[ $# -gt 0 ]]
do
key="$1"
shift

case $key in
	-h|--help)
	print_usage
	;;
	-b|--base_db_dir)
	base_db_dir="$1"
	shift
	;;
	-s|--snapshot_dir)
	ss_dir="$1"
	shift
	;;
	-k|--keyspace)
	keyspace_name="$1"
	;;
	-t|--tag)
	tag_name="$1"
	;;
	--default)
	DEFAULT=YES
	shift
	;;
	*)
	# unknown option
	;;
esac
done

# Validate inputs
if [ "$base_db_dir" == "" ] || [ "$ss_dir" == "" ] || [ "$keyspace_name" == "" ]
then
	echo ""
	echo ">>>>>>>>>>Not all inputs provided, please check usage >>>>>>>>>>"
	echo ""
	print_usage
fi

# Remove commit logs from current data dir
#/var/lib/cassandra/commitlog/CommitLog*.log
find $base_db_dir/../  -name "CommitLog*.log"  -delete

# Remove *.db from current data dir excluding skipped keyspaces
find $base_db_dir/$keyspace_name  -name "*.db"  -delete

# Copy snapshots to data dir
echo "----------db files in snapshots--------------"
dirs_to_be_restored=`ls $ss_dir`
for i in ${dirs_to_be_restored}
do
    src_path=$ss_dir/$i/snapshots/$tag_name
    # Find the destination
    table_name=$i
    dest_table=$(find_target_table_name $base_db_dir $keyspace_name $table_name)
    dest_path=$base_db_dir/$keyspace_name/$dest_table
    # Create keyspace/table directory if not exists
    #if [ ! -d "$dest_path" ]; then
    #    mkdir -p $dest_path
    #fi
    db_files=$(ls $src_path/*.db 2> /dev/null | wc -l)
    if [ $db_files -ne 0 ]
    then
        cp $src_path/*.db $dest_path
        if [ $? -ne 0 ]
        then
            echo "=====ERROR: Unable to restore $src_path/*.db to $dest_path====="
            exit 1
        fi
        echo "=======check $dest_path ==============="
        ls $dest_path
   fi
done