Skip to content

Commit 9358bb7

Browse files
authored
fix: correct CHANGE REPLICATION FILTER' statement (#343)
1 parent 24726b2 commit 9358bb7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

devtools/replica-setup-mysql/start_replication.sh

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -26,16 +26,16 @@ fi
2626
# Prepare replication filters
2727
REPLICATION_FILTERS=""
2828
if [ -n "$INCLUDE_SCHEMAS" ]; then
29-
REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_DO_DB=(${INCLUDE_SCHEMAS})"
29+
REPLICATION_FILTERS="REPLICATE_DO_DB=(${INCLUDE_SCHEMAS})"
3030
fi
3131
if [ -n "$EXCLUDE_SCHEMAS" ]; then
32-
REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_IGNORE_DB=(${EXCLUDE_SCHEMAS})"
32+
REPLICATION_FILTERS="${REPLICATION_FILTERS}${REPLICATION_FILTERS:+, }REPLICATE_IGNORE_DB=(${EXCLUDE_SCHEMAS})"
3333
fi
3434
if [ -n "$INCLUDE_TABLES" ]; then
35-
REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_DO_TABLE=(${INCLUDE_TABLES})"
35+
REPLICATION_FILTERS="${REPLICATION_FILTERS}${REPLICATION_FILTERS:+, }REPLICATE_DO_TABLE=(${INCLUDE_TABLES})"
3636
fi
3737
if [ -n "$EXCLUDE_TABLES" ]; then
38-
REPLICATION_FILTERS="$REPLICATION_FILTERS REPLICATE_IGNORE_TABLE=(${EXCLUDE_TABLES})"
38+
REPLICATION_FILTERS="${REPLICATION_FILTERS}${REPLICATION_FILTERS:+, }REPLICATE_IGNORE_TABLE=(${EXCLUDE_TABLES})"
3939
fi
4040

4141
# Add filter command if any filters are set

0 commit comments

Comments
 (0)