jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(migration): migrate all versions

Browse source 
Signed-off-by: Rajesh Rajendran <rjshrjndrn@gmail.com>
This commit is contained in:
Rajesh Rajendran 2022-02-11 17:17:03 +01:00
parent fb30fc3225
commit d22d0299fd
3 changed files with 13 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
scripts/helmcharts/openreplay/files/clickhouse.sh
View file

@ -1,13 +1,13 @@
#!/bin/bash #!/bin/bash
set -e set -ex
clickhousedir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/clickhouse clickhousedir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/clickhouse
function migrate() { function migrate() {
echo "Starting clickhouse migration" echo "Starting clickhouse migration"
migration_versions=$1 IFS=',' read -r -a migration_versions <<< "$1"
for version in $migration_versions; do for version in ${migration_versions[*]}; do
echo "Migrating clickhouse version $version" echo "Migrating clickhouse version $version"
# For now, we can ignore the clickhouse db inject errors. # For now, we can ignore the clickhouse db inject errors.
# TODO: Better error handling in script # TODO: Better error handling in script

12
scripts/helmcharts/openreplay/files/dbops.sh
View file

@ -27,22 +27,24 @@ function migration() {
# Checking migration versions # Checking migration versions
cd /opt/openreplay/openreplay/scripts/helm cd /opt/openreplay/openreplay/scripts/helm
migration_versions=(`ls -l db/init_dbs/$db | grep -E ^d | awk -v number=${PREVIOUS_APP_VERSION} '$NF > number {print $NF}' | grep -v create`) migration_versions=(`ls -l db/init_dbs/$db | grep -E ^d | awk -v number=${PREVIOUS_APP_VERSION} '$NF > number {print $NF}' | grep -v create`)
echo "Migration version: $migration_versions" echo "Migration version: ${migration_versions[*]}"
# Can't pass the space seperated array to ansible for migration. So joining them with ,
joined_migration_versions=$(IFS=, ; echo "${migration_versions[*]}")
cd - cd -
case "$1" in case "$1" in
postgresql) postgresql)
/bin/bash postgresql.sh migrate $migration_versions /bin/bash postgresql.sh migrate $joined_migration_versions
;; ;;
minio) minio)
/bin/bash minio.sh migrate $migration_versions /bin/bash minio.sh migrate $joined_migration_versions
;; ;;
clickhouse) clickhouse)
/bin/bash clickhouse.sh migrate $migration_versions /bin/bash clickhouse.sh migrate $joined_migration_versions
;; ;;
kafka) kafka)
/bin/bash kafka.sh migrate $migration_versions /bin/bash kafka.sh migrate $joined_migration_versions
;; ;;
*) *)
echo "Unknown operation for db migration; exiting." echo "Unknown operation for db migration; exiting."

6
scripts/helmcharts/openreplay/files/postgresql.sh
View file

@ -1,6 +1,6 @@
#!/bin/bash #!/bin/bash
set -e set -ex
pgdir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/postgresql pgdir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/postgresql
@ -14,8 +14,8 @@ pgdir=/opt/openreplay/openreplay/scripts/helm/db/init_dbs/postgresql
function migrate() { function migrate() {
echo "Starting postgresql migration" echo "Starting postgresql migration"
migration_versions=$1 IFS=',' read -r -a migration_versions <<< "$1"
for version in $migration_versions; do for version in ${migration_versions[*]}; do
echo "Migrating postgresql version $version" echo "Migrating postgresql version $version"
psql -f ${pgdir}/${version}/${version}.sql psql -f ${pgdir}/${version}/${version}.sql
done done