Skip to content

Latest commit

 

History

History
45 lines (33 loc) · 882 Bytes

README.md

File metadata and controls

45 lines (33 loc) · 882 Bytes

bufinsert

An enhancement for gorm bulk insert. This can help you save the data to the buffer first, and then insert the all data in buffer into database when the buffer is full.

Install

go get -u github.com/wux1an/bufinsert

Usage

package bufinsert

import (
	"gorm.io/gorm"
)

func ExampleNewInserter() {
	var db = &gorm.DB{} // fake database
	var inserter = NewInserter(db, 2)

	for i := 0; i < 11; i++ {
		go inserter.Insert(i)
	}

	inserter.Flush() // flush and empty
}

func ExampleBufferedInserter_Insert() {
	var db = &gorm.DB{} // fake database
	var inserter = NewInserter(db, 2)

	// way 1
	inserter.Insert("1") // not flush
	inserter.Insert("2") // flush and empty
	inserter.Insert("3") // not flush
	// way 2
	inserter.Insert([]interface{}{"4", "5", "6", "7"})

	inserter.Flush() // flush and empty
}