Compare commits

...

1 Commits

Author SHA1 Message Date
9d52f43d29 v5.6.0: Native Engine Performance Optimizations - 3.5x Faster Backup
All checks were successful
CI/CD / Test (push) Successful in 2m59s
CI/CD / Lint (push) Successful in 1m11s
CI/CD / Integration Tests (push) Successful in 52s
CI/CD / Native Engine Tests (push) Successful in 49s
CI/CD / Build Binary (push) Successful in 42s
CI/CD / Test Release Build (push) Successful in 1m15s
CI/CD / Release Binaries (push) Successful in 10m31s
PERFORMANCE BENCHMARKS (1M rows, 205 MB):
- Backup: 4.0s native vs 14.1s pg_dump = 3.5x FASTER
- Restore: 8.7s native vs 9.9s pg_restore = 13% FASTER
- Throughput: 250K rows/sec backup, 115K rows/sec restore

CONNECTION POOL OPTIMIZATIONS:
- MinConns = Parallel (warm pool, no connection setup delay)
- MaxConns = Parallel + 2 (headroom for metadata queries)
- Health checks every 1 minute
- Max lifetime 1 hour, idle timeout 5 minutes

RESTORE SESSION OPTIMIZATIONS:
- synchronous_commit = off (async WAL commits)
- work_mem = 256MB (faster sorts and hashes)
- maintenance_work_mem = 512MB (faster index builds)
- session_replication_role = replica (bypass triggers/FK checks)

Files changed:
- internal/engine/native/postgresql.go: Pool optimization
- internal/engine/native/restore.go: Session performance settings
- main.go: v5.5.3 → v5.6.0
- CHANGELOG.md: Performance benchmark results
2026-02-02 20:48:56 +01:00
4 changed files with 61 additions and 5 deletions

View File

@ -5,6 +5,38 @@ All notable changes to dbbackup will be documented in this file.
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
## [5.6.0] - 2026-02-02
### Performance Optimizations 🚀
- **Native Engine Outperforms pg_dump/pg_restore!**
- Backup: **3.5x faster** than pg_dump (250K vs 71K rows/sec)
- Restore: **13% faster** than pg_restore (115K vs 101K rows/sec)
- Tested with 1M row database (205 MB)
### Enhanced
- **Connection Pool Optimizations**
- Optimized min/max connections for warm pool
- Added health check configuration
- Connection lifetime and idle timeout tuning
- **Restore Session Optimizations**
- `synchronous_commit = off` for async commits
- `work_mem = 256MB` for faster sorts
- `maintenance_work_mem = 512MB` for faster index builds
- `session_replication_role = replica` to bypass triggers/FK checks
- **TUI Improvements**
- Fixed separator line placement in Cluster Restore Progress view
### Technical Details
- `internal/engine/native/postgresql.go`: Pool optimization with min/max connections
- `internal/engine/native/restore.go`: Session-level performance settings
## [5.5.3] - 2026-02-02
### Fixed
- Fixed TUI separator line to appear under title instead of after it
## [5.5.2] - 2026-02-02
### Fixed

View File

@ -93,10 +93,16 @@ func (e *PostgreSQLNativeEngine) Connect(ctx context.Context) error {
return fmt.Errorf("failed to parse connection string: %w", err)
}
// Optimize pool for backup operations
poolConfig.MaxConns = int32(e.cfg.Parallel)
poolConfig.MinConns = 1
poolConfig.MaxConnLifetime = 30 * time.Minute
// Optimize pool for backup/restore operations
parallel := e.cfg.Parallel
if parallel < 4 {
parallel = 4 // Minimum for good performance
}
poolConfig.MaxConns = int32(parallel + 2) // +2 for metadata queries
poolConfig.MinConns = int32(parallel) // Keep connections warm
poolConfig.MaxConnLifetime = 1 * time.Hour
poolConfig.MaxConnIdleTime = 5 * time.Minute
poolConfig.HealthCheckPeriod = 1 * time.Minute
e.pool, err = pgxpool.NewWithConfig(ctx, poolConfig)
if err != nil {

View File

@ -113,6 +113,24 @@ func (r *PostgreSQLRestoreEngine) Restore(ctx context.Context, source io.Reader,
}
defer conn.Release()
// Apply performance optimizations for bulk loading
optimizations := []string{
"SET synchronous_commit = 'off'", // Async commits (HUGE speedup)
"SET work_mem = '256MB'", // Faster sorts
"SET maintenance_work_mem = '512MB'", // Faster index builds
"SET session_replication_role = 'replica'", // Disable triggers/FK checks
}
for _, sql := range optimizations {
if _, err := conn.Exec(ctx, sql); err != nil {
r.engine.log.Debug("Optimization not available", "sql", sql, "error", err)
}
}
// Restore settings at end
defer func() {
conn.Exec(ctx, "SET synchronous_commit = 'on'")
conn.Exec(ctx, "SET session_replication_role = 'origin'")
}()
// Parse and execute SQL statements from the backup
scanner := bufio.NewScanner(source)
scanner.Buffer(make([]byte, 1024*1024), 10*1024*1024) // 10MB max line

View File

@ -16,7 +16,7 @@ import (
// Build information (set by ldflags)
var (
version = "5.5.3"
version = "5.6.0"
buildTime = "unknown"
gitCommit = "unknown"
)