CFX sync

Tigo9527 · web-flow · commit bdaa3383489f · 2026-01-09T15:18:53.000+08:00
CFX sync
diff --git a/sync/evm/evm_sync.go b/sync/evm/evm_sync.go
@@ -93,7 +93,8 @@ func (o *TraceOperation) Exec(tx *gorm.DB) error {
 		for _, log := range o.logArr {
 			log.TxId = o.txArr[log.TxIndex].ID
 		}
-		if err := tx.Create(&o.logArr).Error; err != nil {
+		batchSize := 1000
+		if err := tx.CreateInBatches(&o.logArr, batchSize).Error; err != nil {
 			return errors.Wrap(err, "create logs")
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,8 @@ func (o TraceOperation) Exec(tx gorm.DB) error {`
`93`	`93`	`for _, log := range o.logArr {`
`94`	`94`	`log.TxId = o.txArr[log.TxIndex].ID`
`95`	`95`	`}`
`96`		`- if err := tx.Create(&o.logArr).Error; err != nil {`
	`96`	`+ batchSize := 1000`
	`97`	`+ if err := tx.CreateInBatches(&o.logArr, batchSize).Error; err != nil {`
`97`	`98`	`return errors.Wrap(err, "create logs")`
`98`	`99`	`}`
`99`	`100`	`}`