Skip to content

Commit 2a66d51

Browse files
authored
Support static increment value (#38)
* Support static increment value * Pass Increment on beginning transaction
1 parent 93e7ae9 commit 2a66d51

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

sql.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ type SQL struct {
2424
DeleteBuilder DeleteBuilder
2525
TableBuilder TableBuilder
2626
IndexBuilder IndexBuilder
27+
Increment int
2728
IncrementFunc IncrementFunc
2829
ErrorMapper ErrorMapper
2930
DB *sql.DB
@@ -101,6 +102,7 @@ func (s SQL) Begin(ctx context.Context) (rel.Adapter, error) {
101102
DeleteBuilder: s.DeleteBuilder,
102103
TableBuilder: s.TableBuilder,
103104
IndexBuilder: s.IndexBuilder,
105+
Increment: s.Increment,
104106
IncrementFunc: s.IncrementFunc,
105107
ErrorMapper: s.ErrorMapper,
106108
Tx: tx,
@@ -226,7 +228,7 @@ func (s SQL) InsertAll(ctx context.Context, query rel.Query, primaryField string
226228

227229
var (
228230
ids = make([]interface{}, len(bulkMutates))
229-
inc = 1
231+
inc = s.Increment
230232
)
231233

232234
if s.IncrementFunc != nil {

0 commit comments

Comments
 (0)