Port importer to new transaction api

This commit is contained in:
2025-11-20 07:39:16 +01:00
parent 20838b6882
commit 0b38a980d2

View File

@@ -55,7 +55,18 @@ func InitDB() error {
// Bundle 100 inserts into one transaction for better performance // Bundle 100 inserts into one transaction for better performance
if i%100 == 0 { if i%100 == 0 {
r.TransactionCommit(t) if i > 0 {
if err := t.Commit(); err != nil {
cclog.Errorf("transaction commit error: %v", err)
return err
}
// Start a new transaction for the next batch
t, err = r.TransactionInit()
if err != nil {
cclog.Errorf("transaction init error: %v", err)
return err
}
}
fmt.Printf("%d jobs inserted...\r", i) fmt.Printf("%d jobs inserted...\r", i)
} }