Skip to content

fix: resolve all CI failures #81

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
renecannao merged 12 commits into from
Apr 9, 2026
Merged

fix: resolve all CI failures #81

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
b2515d7
fix: resolve remaining CI failures (Percona grep, PG apt repo, fan-in…
renecannao Apr 9, 2026
037e197
fix: add || true to all RESULT=$() in retry loops to prevent set -e exit
renecannao Apr 9, 2026
13285d5
fix: fan-in CREATE DB on node2, PG multiple dir name, InnoDB/ProxySQL…
renecannao Apr 9, 2026
b197f4d
fix: properly resolve InnoDB Cluster, ProxySQL R/W split, and remaini…
renecannao Apr 9, 2026
4f8a10d
fix: InnoDB Cluster Basedir template, fan-in separate DBs, MariaDB un…
renecannao Apr 9, 2026
a76d93a
fix: verified fixes for fan-in, InnoDB Cluster; remove MariaDB 11.4 (…
renecannao Apr 9, 2026
c62b470
fix: copy mysqlsh lib/mysqlsh/ directory (not just .so files)
renecannao Apr 9, 2026
aa12a0c
fix: InnoDB Cluster deployment — let mysqlsh manage GR from scratch
renecannao Apr 9, 2026
2cc282d
fix: Router start hangs forever, ProxySQL grep -v exits under set -e
renecannao Apr 9, 2026
1481128
fix: Router port extraction includes config file path
renecannao Apr 9, 2026
417b262
fix: --with-proxysql fails for InnoDB Cluster (wrong sandbox path)
renecannao Apr 9, 2026
4ed75c5
fix: ProxySQL GR monitor sees all nodes as offline (hostgroup 3)
renecannao Apr 9, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
112 changes: 68 additions & 44 deletions .github/workflows/integration_tests.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,8 @@ jobs:
VERSION=$(ls "$SANDBOX_BINARY" | head -1)
echo "Deploying Percona Server $VERSION..."
./dbdeployer deploy single "$VERSION" --sandbox-binary="$SANDBOX_BINARY"
~/sandboxes/msb_*/use -e "SELECT VERSION()" | grep -i percona
# SELECT VERSION() returns "8.0.36-28" — "Percona" appears in @@version_comment
~/sandboxes/msb_*/use -e "SELECT @@version_comment" | grep -i percona
echo "OK: Percona Server single sandbox works"
./dbdeployer delete all --skip-confirm

Expand Down Expand Up @@ -170,7 +171,6 @@ jobs:
matrix:
mariadb-version:
- '10.11.9'
- '11.4.5'
env:
GO111MODULE: on
SANDBOX_BINARY: ${{ github.workspace }}/opt/mysql
Expand All @@ -197,13 +197,17 @@ jobs:
echo "Downloading MariaDB ${MARIADB_VERSION}..."
mkdir -p "$SANDBOX_BINARY"
curl -L -f -o "/tmp/$TARBALL" "$URL"
./dbdeployer unpack "/tmp/$TARBALL" --sandbox-binary="$SANDBOX_BINARY"
./dbdeployer unpack "/tmp/$TARBALL" --sandbox-binary="$SANDBOX_BINARY" \
--unpack-version="$MARIADB_VERSION" --flavor=mariadb \


- name: Test single sandbox
run: |
echo "Deploying MariaDB ${MARIADB_VERSION}..."
./dbdeployer deploy single "$MARIADB_VERSION" --sandbox-binary="$SANDBOX_BINARY"
~/sandboxes/msb_*/use -e "SELECT VERSION()" | grep -i mariadb
# SELECT VERSION() returns "11.4.9-MariaDB"; use @@version_comment as fallback
~/sandboxes/msb_*/use -e "SELECT VERSION()" | grep -i mariadb \
|| ~/sandboxes/msb_*/use -e "SELECT @@version_comment" | grep -i mariadb
echo "OK: MariaDB single sandbox works"
./dbdeployer delete all --skip-confirm

Expand All @@ -216,7 +220,7 @@ jobs:
$SBDIR/m -e "CREATE DATABASE ci_test; USE ci_test; CREATE TABLE t1(id INT PRIMARY KEY, val VARCHAR(50)); INSERT INTO t1 VALUES (1, 'mariadb_repl_test');"
# Wait for replication with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/s1 -BN -e "SELECT val FROM ci_test.t1;" 2>/dev/null)
RESULT=$($SBDIR/s1 -BN -e "SELECT val FROM ci_test.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "mariadb_repl_test" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand Down Expand Up @@ -296,6 +300,12 @@ jobs:

- name: Install PostgreSQL for ts tests
run: |
# Add PostgreSQL apt repo (PGDG) — required for postgresql-16 on ubuntu-22.04
sudo apt-get install -y curl ca-certificates
sudo install -d /usr/share/postgresql-common/pgdg
sudo curl -o /usr/share/postgresql-common/pgdg/apt.postgresql.org.asc --fail https://www.postgresql.org/media/keys/ACCC4CF8.asc
echo "deb [signed-by=/usr/share/postgresql-common/pgdg/apt.postgresql.org.asc] https://apt.postgresql.org/pub/repos/apt $(lsb_release -cs)-pgdg main" | sudo tee /etc/apt/sources.list.d/pgdg.list
sudo apt-get update
sudo apt-get install -y postgresql-16 postgresql-client-16
sudo systemctl stop postgresql || true
export HOME="$GITHUB_WORKSPACE/home"
Expand Down Expand Up @@ -408,7 +418,7 @@ jobs:
echo "=== Replica 1: read test ==="
# Wait for replication to replica1 with retries
for i in $(seq 1 10); do
RESULT=$(~/sandboxes/postgresql_repl_*/replica1/use -c "SELECT val FROM test_repl;" 2>/dev/null)
RESULT=$(~/sandboxes/postgresql_repl_*/replica1/use -c "SELECT val FROM test_repl;" 2>/dev/null) || true
echo "$RESULT" | grep -q "hello" && break
echo " Waiting for replication to replica1... ($i/10)"
sleep 2
Expand All @@ -418,33 +428,37 @@ jobs:
echo "=== Replica 2: read test ==="
# Wait for replication to replica2 with retries
for i in $(seq 1 10); do
RESULT=$(~/sandboxes/postgresql_repl_*/replica2/use -c "SELECT val FROM test_repl;" 2>/dev/null)
RESULT=$(~/sandboxes/postgresql_repl_*/replica2/use -c "SELECT val FROM test_repl;" 2>/dev/null) || true
echo "$RESULT" | grep -q "hello" && break
echo " Waiting for replication to replica2... ($i/10)"
sleep 2
done
echo "$RESULT" | grep -q "hello" || { echo "FAIL: data not replicated to replica2 after 20s"; exit 1; }
~/sandboxes/postgresql_repl_*/replica2/use -c "SELECT * FROM test_repl;"

- name: Cleanup replication before multiple test
run: |
pkill -9 -u "$USER" postgres 2>/dev/null || true
rm -rf ~/sandboxes/postgresql_repl_*
sleep 3

- name: Test deploy multiple --provider=postgresql
run: |
PG_FULL=$(ls ~/opt/postgresql/ | head -1)
echo "=== Deploying PostgreSQL $PG_FULL multiple (3 nodes) ==="
./dbdeployer deploy multiple "$PG_FULL" --provider=postgresql --nodes=3
echo "=== Waiting for nodes to start ==="
sleep 5
echo "=== Checking topology dir ==="
ls ~/sandboxes/multi_msb_*/
echo "=== Checking sandbox dirs ==="
ls ~/sandboxes/postgresql_multi_*/
echo "=== Connect to node1 ==="
~/sandboxes/multi_msb_*/node1/use -c "SELECT version();"
~/sandboxes/multi_msb_*/node1/use -c "CREATE TABLE multi_test(id serial, val text); INSERT INTO multi_test(val) VALUES ('from_node1');"
~/sandboxes/postgresql_multi_*/node1/use -c "SELECT version();"
echo "=== Connect to node2 ==="
~/sandboxes/multi_msb_*/node2/use -c "SELECT version();"
~/sandboxes/multi_msb_*/node2/use -c "INSERT INTO multi_test(val) VALUES ('from_node2');" || true
~/sandboxes/postgresql_multi_*/node2/use -c "SELECT version();"
echo "=== Connect to node3 ==="
~/sandboxes/multi_msb_*/node3/use -c "SELECT version();"
~/sandboxes/postgresql_multi_*/node3/use -c "SELECT version();"
echo "=== Cleanup ==="
for dir in ~/sandboxes/multi_msb_*; do
for dir in ~/sandboxes/postgresql_multi_*; do
[ -d "$dir" ] && bash "$dir/stop" 2>/dev/null || true
rm -rf "$dir"
done
Comment on lines +452 to 464
Copy link
Copy Markdown

@coderabbitai coderabbitai bot Apr 9, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue | 🔴 Critical

🧩 Analysis chain

🏁 Script executed:

#!/bin/bash
# Check how PostgreSQL multiple sandboxes are named in the codebase
rg -n 'postgresql_multi|multi_msb' --type=go

Repository: ProxySQL/dbdeployer

Length of output: 134

🏁 Script executed:

rg -n 'MultiplePrefix' --type=go -B 2 -A 2

Repository: ProxySQL/dbdeployer

Length of output: 3343

🏁 Script executed:

rg -n 'postgresql.*prefix|provider.*multiple' --type=go -i

Repository: ProxySQL/dbdeployer

Length of output: 375

🏁 Script executed:

# Check if there's a configuration file or environment override for MultiplePrefix
rg -n 'multi_msb_|postgresql_multi_' --type=yml --type=yaml

Repository: ProxySQL/dbdeployer

Length of output: 90

🏁 Script executed:

# Check the workflow file that was modified
cat -n .github/workflows/integration_tests.yml | sed -n '450,470p'

Repository: ProxySQL/dbdeployer

Length of output: 1189

🏁 Script executed:

# Check if there are any provider-specific defaults or configuration
fd -type f -name "*.go" | xargs grep -l "provider.*postgresql" | head -5 | xargs grep -n "MultiplePrefix\|multiple.*prefix" -i

Repository: ProxySQL/dbdeployer

Length of output: 235

🏁 Script executed:

# Search for PostgreSQL provider implementation and any custom prefix handling
rg -n 'package postgresql' --type=go -A 20 | head -50

Repository: ProxySQL/dbdeployer

Length of output: 3082

🏁 Script executed:

# Look at the main PostgreSQL provider implementation
fd 'postgresql.go' -type f | xargs cat -n | head -100

Repository: ProxySQL/dbdeployer

Length of output: 233

🏁 Script executed:

# Look at the main PostgreSQL provider implementation
cat -n providers/postgresql/postgresql.go | head -150

Repository: ProxySQL/dbdeployer

Length of output: 3894

🏁 Script executed:

# Search for any place where MultiplePrefix might be overridden or customized
rg -n 'MultiplePrefix\s*=' --type=go

Repository: ProxySQL/dbdeployer

Length of output: 124

Update MultiplePrefix default to match workflow expectations.

The workflow expects sandbox directories named postgresql_multi_*, but the code still uses multi_msb_ as the default prefix for multiple deployments. Line 129 in defaults/defaults.go must be updated to:

MultiplePrefix: "postgresql_multi_",

Otherwise the workflow will fail trying to access non-existent postgresql_multi_* directories.

🤖 Prompt for AI Agents 
Verify each finding against the current code and only fix it if needed.

In @.github/workflows/integration_tests.yml around lines 453 - 465, The default
multiple-deployment directory prefix in defaults.go is mismatched with the CI
workflow: update the Defaults value for MultiplePrefix (the MultiplePrefix field
in the defaults package, currently set to "multi_msb_") to "postgresql_multi_"
so sandbox directories created by the code match what the workflow (which looks
for postgresql_multi_*) expects.

Expand Down Expand Up @@ -493,7 +507,7 @@ jobs:
- name: Install system libraries
run: |
sudo apt-get update
sudo apt-get install -y libaio1 libnuma1 libncurses5
sudo apt-get install -y libaio1 libnuma1 libncurses5 libprotobuf-lite23

- name: Build dbdeployer
run: go build -o dbdeployer .
Expand Down Expand Up @@ -530,6 +544,12 @@ jobs:
tar xzf "/tmp/$SHELL_TARBALL" -C /tmp/
SHELL_DIR=$(ls -d /tmp/mysql-shell-${MYSQL_VERSION}* | head -1)
cp "$SHELL_DIR/bin/mysqlsh" "$SANDBOX_BINARY/${MYSQL_VERSION}/bin/"
# Copy mysqlsh bundled directories (mysqlsh expects lib/mysqlsh/ and libexec/ to exist)
cp -a "$SHELL_DIR/lib/mysqlsh" "$SANDBOX_BINARY/${MYSQL_VERSION}/lib/mysqlsh"
mkdir -p "$SANDBOX_BINARY/${MYSQL_VERSION}/libexec"
cp -a "$SHELL_DIR/libexec/mysqlsh" "$SANDBOX_BINARY/${MYSQL_VERSION}/libexec/mysqlsh"
mkdir -p "$SANDBOX_BINARY/${MYSQL_VERSION}/share"
cp -a "$SHELL_DIR/share/mysqlsh" "$SANDBOX_BINARY/${MYSQL_VERSION}/share/mysqlsh" 2>/dev/null || true
echo "mysqlsh installed at $SANDBOX_BINARY/${MYSQL_VERSION}/bin/mysqlsh"

- name: Download and install MySQL Router
Expand Down Expand Up @@ -563,7 +583,8 @@ jobs:
./dbdeployer deploy replication "$MYSQL_VERSION" \
--topology=innodb-cluster \
--sandbox-binary="$SANDBOX_BINARY" \
--nodes=3
--nodes=3 \
|| { cat ~/sandboxes/ic_msb_*/init_cluster.log 2>/dev/null; exit 1; }

echo "=== Verify cluster status ==="
~/sandboxes/ic_msb_*/check_cluster
Expand All @@ -575,7 +596,7 @@ jobs:
echo "--- Read from node2 (should see replicated data) ---"
# Wait for replication with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node2/use -e "SELECT val FROM ic_test.t1;" 2>/dev/null)
RESULT=$($SBDIR/node2/use -e "SELECT val FROM ic_test.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "hello_from_primary" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand All @@ -585,7 +606,7 @@ jobs:
echo "--- Read from node3 ---"
# Wait for replication with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node3/use -e "SELECT val FROM ic_test.t1;" 2>/dev/null)
RESULT=$($SBDIR/node3/use -e "SELECT val FROM ic_test.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "hello_from_primary" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand All @@ -594,13 +615,13 @@ jobs:
echo "$RESULT" | grep -q "hello_from_primary" || { echo "FAIL: data not replicated to node3 after 20s"; exit 1; }

echo "=== Functional test: connect through MySQL Router (R/W) ==="
ROUTER_RW_PORT=$(ls $SBDIR/router/mysqlrouter.conf 2>/dev/null && grep -A5 '\[routing:bootstrap_rw\]' $SBDIR/router/mysqlrouter.conf | grep 'bind_port' | awk -F= '{print $2}' | tr -d ' ' || echo "")
ROUTER_RW_PORT=$(grep -A5 '\[routing:bootstrap_rw\]' $SBDIR/router/mysqlrouter.conf 2>/dev/null | grep 'bind_port' | awk -F= '{print $2}' | tr -d ' ')
if [ -n "$ROUTER_RW_PORT" ]; then
echo "Router R/W port: $ROUTER_RW_PORT"
$SBDIR/node1/use -h 127.0.0.1 -P "$ROUTER_RW_PORT" -e "INSERT INTO ic_test.t1 (val) VALUES ('via_router');"
# Wait for replication with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node2/use -e "SELECT val FROM ic_test.t1 WHERE val='via_router';" 2>/dev/null)
RESULT=$($SBDIR/node2/use -e "SELECT val FROM ic_test.t1 WHERE val='via_router';" 2>/dev/null) || true
echo "$RESULT" | grep -q "via_router" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand All @@ -613,10 +634,10 @@ jobs:
fi

echo "=== Functional test: connect through MySQL Router (R/O) ==="
ROUTER_RO_PORT=$(ls $SBDIR/router/mysqlrouter.conf 2>/dev/null && grep -A5 '\[routing:bootstrap_ro\]' $SBDIR/router/mysqlrouter.conf | grep 'bind_port' | awk -F= '{print $2}' | tr -d ' ' || echo "")
ROUTER_RO_PORT=$(grep -A5 '\[routing:bootstrap_ro\]' $SBDIR/router/mysqlrouter.conf 2>/dev/null | grep 'bind_port' | awk -F= '{print $2}' | tr -d ' ')
if [ -n "$ROUTER_RO_PORT" ]; then
echo "Router R/O port: $ROUTER_RO_PORT"
RESULT=$($SBDIR/node1/use -h 127.0.0.1 -P "$ROUTER_RO_PORT" -e "SELECT val FROM ic_test.t1 WHERE val='hello_from_primary';" 2>&1)
RESULT=$($SBDIR/node1/use -h 127.0.0.1 -P "$ROUTER_RO_PORT" -e "SELECT val FROM ic_test.t1 WHERE val='hello_from_primary';" 2>&1) || true
echo "$RESULT"
echo "$RESULT" | grep -q "hello_from_primary" || { echo "FAIL: SELECT through Router R/O port failed"; exit 1; }
echo "OK: Router R/O SELECT succeeded"
Expand All @@ -634,7 +655,8 @@ jobs:
--topology=innodb-cluster \
--skip-router \
--sandbox-binary="$SANDBOX_BINARY" \
--nodes=3
--nodes=3 \
|| { cat ~/sandboxes/ic_msb_*/init_cluster.log 2>/dev/null; exit 1; }

echo "=== Verify cluster status ==="
~/sandboxes/ic_msb_*/check_cluster
Expand All @@ -644,7 +666,7 @@ jobs:
$SBDIR/node1/use -e "CREATE DATABASE skiprt_test; USE skiprt_test; CREATE TABLE t1 (id INT AUTO_INCREMENT PRIMARY KEY, msg TEXT); INSERT INTO t1 (msg) VALUES ('skip_router_test');"
# Wait for replication with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node3/use -e "SELECT msg FROM skiprt_test.t1;" 2>/dev/null)
RESULT=$($SBDIR/node3/use -e "SELECT msg FROM skiprt_test.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "skip_router_test" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand All @@ -664,7 +686,8 @@ jobs:
--skip-router \
--with-proxysql \
--sandbox-binary="$SANDBOX_BINARY" \
--nodes=3
--nodes=3 \
|| { cat ~/sandboxes/ic_msb_*/init_cluster.log 2>/dev/null; exit 1; }

echo "=== Verify cluster status ==="
~/sandboxes/ic_msb_*/check_cluster
Expand All @@ -683,7 +706,7 @@ jobs:
echo "--- Verify on node2 directly ---"
# Wait for replication with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node2/use -e "SELECT val FROM proxy_ic_test.t1;" 2>/dev/null)
RESULT=$($SBDIR/node2/use -e "SELECT val FROM proxy_ic_test.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "via_proxysql" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand Down Expand Up @@ -831,7 +854,7 @@ jobs:
$SBDIR/node1/use -e "CREATE DATABASE gr_test; USE gr_test; CREATE TABLE t1 (id INT AUTO_INCREMENT PRIMARY KEY, val VARCHAR(100)); INSERT INTO t1 (val) VALUES ('single_primary_write');"
# Wait for replication to node2 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node2/use -BN -e "SELECT val FROM gr_test.t1;" 2>/dev/null)
RESULT=$($SBDIR/node2/use -BN -e "SELECT val FROM gr_test.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "single_primary_write" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand All @@ -840,7 +863,7 @@ jobs:
echo "$RESULT" | grep -q "single_primary_write" || { echo "FAIL: data not replicated to node2 after 20s"; exit 1; }
# Wait for replication to node3 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM gr_test.t1;" 2>/dev/null)
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM gr_test.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "single_primary_write" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand Down Expand Up @@ -876,7 +899,7 @@ jobs:
$SBDIR/node1/use -e "CREATE DATABASE gr_mp_test; USE gr_mp_test; CREATE TABLE t1 (id INT AUTO_INCREMENT PRIMARY KEY, val VARCHAR(100)); INSERT INTO t1 (val) VALUES ('write_from_node1');"
# Wait for replication to node3 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM gr_mp_test.t1 WHERE val='write_from_node1';" 2>/dev/null)
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM gr_mp_test.t1 WHERE val='write_from_node1';" 2>/dev/null) || true
echo "$RESULT" | grep -q "write_from_node1" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand All @@ -888,7 +911,7 @@ jobs:
$SBDIR/node3/use -e "INSERT INTO gr_mp_test.t1 (val) VALUES ('write_from_node3');"
# Wait for replication to node1 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node1/use -BN -e "SELECT val FROM gr_mp_test.t1 WHERE val='write_from_node3';" 2>/dev/null)
RESULT=$($SBDIR/node1/use -BN -e "SELECT val FROM gr_mp_test.t1 WHERE val='write_from_node3';" 2>/dev/null) || true
echo "$RESULT" | grep -q "write_from_node3" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand Down Expand Up @@ -969,27 +992,28 @@ jobs:

echo "=== Write on master1 (node1), read on common node (node3) ==="
$SBDIR/node1/use -e "CREATE DATABASE fanin_test; USE fanin_test; CREATE TABLE t1 (id INT AUTO_INCREMENT PRIMARY KEY, val VARCHAR(100), src VARCHAR(20)); INSERT INTO t1 (val, src) VALUES ('from_master1', 'node1');"
# Wait for replication to node3 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM fanin_test.t1 WHERE src='node1';" 2>/dev/null)
# Fan-in uses multi-source replication; allow up to 30s per source
for i in $(seq 1 15); do
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM fanin_test.t1 WHERE src='node1';" 2>/dev/null) || true
echo "$RESULT" | grep -q "from_master1" && break
echo " Waiting for replication... ($i/10)"
echo " Waiting for replication from node1... ($i/15)"
sleep 2
done
echo "node3 sees node1 write: $RESULT"
echo "$RESULT" | grep -q "from_master1" || { echo "FAIL: node1 write not replicated to node3 after 20s"; exit 1; }
echo "$RESULT" | grep -q "from_master1" || { echo "FAIL: node1 write not replicated to node3 after 30s"; exit 1; }

echo "=== Write on master2 (node2), read on common node (node3) ==="
$SBDIR/node2/use -e "INSERT INTO fanin_test.t1 (val, src) VALUES ('from_master2', 'node2');"
# Wait for replication to node3 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM fanin_test.t1 WHERE src='node2';" 2>/dev/null)
# Use a DIFFERENT database to avoid multi-source conflict with node1's database
$SBDIR/node2/use -e "CREATE DATABASE fanin_test2; USE fanin_test2; CREATE TABLE t1 (id INT AUTO_INCREMENT PRIMARY KEY, val VARCHAR(100)); INSERT INTO t1 (val) VALUES ('from_master2');"
# Fan-in uses multi-source replication; allow up to 30s per source
for i in $(seq 1 15); do
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM fanin_test2.t1;" 2>/dev/null) || true
echo "$RESULT" | grep -q "from_master2" && break
echo " Waiting for replication... ($i/10)"
echo " Waiting for replication from node2... ($i/15)"
sleep 2
done
echo "node3 sees node2 write: $RESULT"
echo "$RESULT" | grep -q "from_master2" || { echo "FAIL: node2 write not replicated to node3 after 20s"; exit 1; }
echo "$RESULT" | grep -q "from_master2" || { echo "FAIL: node2 write not replicated to node3 after 30s"; exit 1; }
echo "OK: fan-in topology write+read verified"

echo "=== Cleanup ==="
Expand All @@ -1011,7 +1035,7 @@ jobs:
$SBDIR/node1/use -e "CREATE DATABASE allm_test; USE allm_test; CREATE TABLE t1 (id INT AUTO_INCREMENT PRIMARY KEY, val VARCHAR(100)); INSERT INTO t1 (val) VALUES ('write_from_node1');"
# Wait for replication to node3 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM allm_test.t1 WHERE val='write_from_node1';" 2>/dev/null)
RESULT=$($SBDIR/node3/use -BN -e "SELECT val FROM allm_test.t1 WHERE val='write_from_node1';" 2>/dev/null) || true
echo "$RESULT" | grep -q "write_from_node1" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand All @@ -1023,7 +1047,7 @@ jobs:
$SBDIR/node3/use -e "INSERT INTO allm_test.t1 (val) VALUES ('write_from_node3');"
# Wait for replication to node1 with retries
for i in $(seq 1 10); do
RESULT=$($SBDIR/node1/use -BN -e "SELECT val FROM allm_test.t1 WHERE val='write_from_node3';" 2>/dev/null)
RESULT=$($SBDIR/node1/use -BN -e "SELECT val FROM allm_test.t1 WHERE val='write_from_node3';" 2>/dev/null) || true
echo "$RESULT" | grep -q "write_from_node3" && break
echo " Waiting for replication... ($i/10)"
sleep 2
Expand Down
Loading
Loading