upgrade: fix scripts
This commit is contained in:
rjshrjndrn
parent
e2469f577b
commit
9fe6bbdd5e
1 changed files with 82 additions and 70 deletions
|
|
@ -5,9 +5,9 @@ original_env_file="$1"
|
||||||
|
|
||||||
# Check if the original env file exists and is not empty
|
# Check if the original env file exists and is not empty
|
||||||
if [ ! -s "$original_env_file" ]; then
|
if [ ! -s "$original_env_file" ]; then
|
||||||
echo "Error: The original env file is empty or does not exist."
|
echo "Error: The original env file is empty or does not exist."
|
||||||
echo "Usage: $0 /path/to/original.env"
|
echo "Usage: $0 /path/to/original.env"
|
||||||
exit 1
|
exit 1
|
||||||
fi
|
fi
|
||||||
|
|
||||||
new_env_file="./common.env"
|
new_env_file="./common.env"
|
||||||
|
|
@ -15,99 +15,111 @@ temp_env_file=$(mktemp)
|
||||||
|
|
||||||
# Function to merge environment variables from original to new env file
|
# Function to merge environment variables from original to new env file
|
||||||
function merge_envs() {
|
function merge_envs() {
|
||||||
while IFS='=' read -r key value; do
|
while IFS='=' read -r key value; do
|
||||||
# Skip the line if the key is COMMON_VERSION
|
# Skip the line if the key is COMMON_VERSION
|
||||||
case "$key" in
|
case "$key" in
|
||||||
COMMON_VERSION)
|
COMMON_VERSION)
|
||||||
original_version=$(echo "$value" | xargs)
|
original_version=$(echo "$value" | xargs)
|
||||||
continue
|
continue
|
||||||
;;
|
;;
|
||||||
COMMON_PG_PASSWORD)
|
COMMON_PG_PASSWORD)
|
||||||
pgpassword=$value
|
pgpassword=$(echo $value | xargs)
|
||||||
;;
|
;;
|
||||||
POSTGRES_VERSION | REDIS_VERSION | MINIO_VERSION)
|
POSTGRES_VERSION | REDIS_VERSION | MINIO_VERSION)
|
||||||
# Don't update db versions automatically.
|
# Don't update db versions automatically.
|
||||||
continue
|
continue
|
||||||
;;
|
;;
|
||||||
esac
|
esac
|
||||||
|
|
||||||
# Remove any existing entry from the new env file and add the new value
|
# Remove any existing entry from the new env file and add the new value
|
||||||
grep -v "^$key=" "$new_env_file" >"$temp_env_file"
|
grep -v "^$key=" "$new_env_file" >"$temp_env_file"
|
||||||
mv "$temp_env_file" "$new_env_file"
|
mv "$temp_env_file" "$new_env_file"
|
||||||
echo "$key=$value" >>"$new_env_file"
|
echo "$key=$value" >>"$new_env_file"
|
||||||
done <"$original_env_file"
|
done <"$original_env_file"
|
||||||
}
|
}
|
||||||
|
|
||||||
# Function to normalize version numbers for comparison
|
# Function to normalize version numbers for comparison
|
||||||
function normalise_version {
|
function normalise_version {
|
||||||
echo "$1" | awk -F. '{ printf("%03d%03d%03d\n", $1, $2, $3); }'
|
echo "$1" | awk -F. '{ printf("%03d%03d%03d\n", $1, $2, $3); }'
|
||||||
}
|
}
|
||||||
|
|
||||||
# Function to log messages
|
# Function to log messages
|
||||||
function log_message() {
|
function log_message() {
|
||||||
echo "$@" >&2
|
echo "$@" >&2
|
||||||
}
|
}
|
||||||
|
|
||||||
# Function to create migration versions based on the current and previous application versions
|
# Function to create migration versions based on the current and previous application versions
|
||||||
function create_migration_versions() {
|
function create_migration_versions() {
|
||||||
cd "${SCHEMA_DIR:-/opt/openreplay/openreplay/scripts/schema}" || {
|
SCHEMA_DIR="../schema/"
|
||||||
log_message "not able to cd $SCHEMA_DIR"
|
cd $SCHEMA_DIR || {
|
||||||
exit 100
|
log_message "not able to cd $SCHEMA_DIR"
|
||||||
}
|
exit 100
|
||||||
|
}
|
||||||
|
|
||||||
db=postgresql
|
db=postgresql
|
||||||
# List all version directories excluding 'create' directory
|
# List all version directories excluding 'create' directory
|
||||||
all_versions=($(find db/init_dbs/$db -maxdepth 1 -type d -exec basename {} \; | grep -v create))
|
all_versions=($(find db/init_dbs/$db -maxdepth 1 -type d -exec basename {} \; | grep -v create))
|
||||||
|
|
||||||
# Normalize the previous application version for comparison
|
# Normalize the previous application version for comparison
|
||||||
PREVIOUS_APP_VERSION_NORMALIZED=$(normalise_version "${PREVIOUS_APP_VERSION}")
|
PREVIOUS_APP_VERSION_NORMALIZED=$(normalise_version "${PREVIOUS_APP_VERSION}")
|
||||||
|
|
||||||
migration_versions=()
|
migration_versions=()
|
||||||
for ver in "${all_versions[@]}"; do
|
for ver in "${all_versions[@]}"; do
|
||||||
if [[ $(normalise_version "$ver") > "$PREVIOUS_APP_VERSION_NORMALIZED" ]]; then
|
if [[ $(normalise_version "$ver") > "$PREVIOUS_APP_VERSION_NORMALIZED" ]]; then
|
||||||
migration_versions+=("$ver")
|
migration_versions+=("$ver")
|
||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
|
|
||||||
# Join migration versions into a single string separated by commas
|
# Join migration versions into a single string separated by commas
|
||||||
joined_migration_versions=$(
|
joined_migration_versions=$(
|
||||||
IFS=,
|
IFS=,
|
||||||
echo "${migration_versions[*]}"
|
echo "${migration_versions[*]}"
|
||||||
)
|
)
|
||||||
|
|
||||||
# Return to the previous directory
|
# Return to the previous directory
|
||||||
cd - >/dev/null || {
|
cd - >/dev/null || {
|
||||||
log_message "not able to cd back"
|
log_message "not able to cd back"
|
||||||
exit 100
|
exit 100
|
||||||
}
|
}
|
||||||
|
|
||||||
log_message "output: $joined_migration_versions"
|
log_message "output: $joined_migration_versions"
|
||||||
echo "$joined_migration_versions"
|
echo "$joined_migration_versions"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export SCHEMA_DIR="$(readlink -f ../schema/)"
|
||||||
|
echo $SCHEMA_DIR
|
||||||
# Function to perform migration
|
# Function to perform migration
|
||||||
function migrate() {
|
function migrate() {
|
||||||
# Set schema directory and previous application version
|
# Set schema directory and previous application version
|
||||||
export SCHEMA_DIR="../schema/"
|
export PREVIOUS_APP_VERSION=${original_version#v}
|
||||||
export PREVIOUS_APP_VERSION=${original_version#v}
|
|
||||||
|
|
||||||
# Create migration versions array
|
# Create migration versions array
|
||||||
IFS=',' read -ra joined_migration_versions <<<"$(create_migration_versions)"
|
IFS=',' read -ra joined_migration_versions <<<"$(create_migration_versions)"
|
||||||
# Check if there are versions to migrate
|
# Check if there are versions to migrate
|
||||||
[[ ${#joined_migration_versions[@]} -eq 0 ]] && {
|
[[ ${#joined_migration_versions[@]} -eq 0 ]] && {
|
||||||
echo "Nothing to migrate"
|
echo "Nothing to migrate"
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
# Loop through versions and prepare Docker run commands
|
# Loop through versions and prepare Docker run commands
|
||||||
for ver in "${joined_migration_versions[@]}"; do
|
for ver in "${joined_migration_versions[@]}"; do
|
||||||
echo "$ver"
|
echo "$ver"
|
||||||
"docker run --rm --network openreplay-net \
|
docker run --rm --network docker-compose_opereplay-net \
|
||||||
--name pgmigrate -e 'PGHOST=postgres' -e 'PGPORT=5432' \
|
--name pgmigrate -e PGHOST=postgres -e PGPORT=5432 \
|
||||||
-e 'PGDATABASE=postgres' -e 'PGUSER=postgres' -e 'PGPASSWORD=$pgpassword' \
|
-e PGDATABASE=postgres -e PGUSER=postgres -e PGPASSWORD=$pgpassword \
|
||||||
-v /opt/data/:$SCHEMA_DIR postgres psql -f /opt/data/schema/db/init_dbs/postgresql/$ver/$ver.sql"
|
-v $SCHEMA_DIR:/opt/data/ postgres psql -f /opt/data/db/init_dbs/postgresql/$ver/$ver.sql
|
||||||
done
|
done
|
||||||
}
|
}
|
||||||
|
|
||||||
# Merge environment variables and perform migration
|
# Merge environment variables and perform migration
|
||||||
merge_envs
|
merge_envs
|
||||||
migrate
|
migrate
|
||||||
|
|
||||||
|
# Load variables from common.env into the current shell's environment
|
||||||
|
set -a # automatically export all variables
|
||||||
|
source common.env
|
||||||
|
set +a
|
||||||
|
|
||||||
|
# Use the `envsubst` command to substitute the shell environment variables into reference_var.env and output to a combined .env
|
||||||
|
find ./ -type f \( -iname "*.env" -o -iname "docker-compose.yaml" \) ! -name "common.env" -exec /bin/bash -c 'file="{}";cp "$file" "$file.bak"; envsubst < "$file.bak" > "$file"; rm "$file.bak"' \;
|
||||||
|
|
||||||
|
sudo -E docker-compose up -d
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue