diff --git a/sources/mysql/snapshot.go b/sources/mysql/snapshot.go
index 01116911..57d66f69 100644
--- a/sources/mysql/snapshot.go
+++ b/sources/mysql/snapshot.go
@@ -47,7 +47,7 @@ func (s *Source) Run(ctx context.Context, writer kafkalib.BatchWriter) error {
 }
 
 func (s Source) snapshotTable(ctx context.Context, writer kafkalib.BatchWriter, tableCfg config.MySQLTable) error {
-	logger := slog.With(slog.String("table", tableCfg.Name))
+	logger := slog.With(slog.String("table", tableCfg.Name), slog.String("database", s.cfg.Database))
 	snapshotStartTime := time.Now()
 
 	adapter, err := adapter.NewMySQLAdapter(s.db, s.cfg.Database, tableCfg)