return errors from newTxRouter
parent
3901c5d8c4
commit
804da8614b
|
@ -543,13 +543,15 @@ func (pg *PostGIS) EnableGeneralizeUpdates() {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (pg *PostGIS) Begin() error {
|
func (pg *PostGIS) Begin() error {
|
||||||
pg.txRouter = newTxRouter(pg, false)
|
var err error
|
||||||
return nil
|
pg.txRouter, err = newTxRouter(pg, false)
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (pg *PostGIS) BeginBulk() error {
|
func (pg *PostGIS) BeginBulk() error {
|
||||||
pg.txRouter = newTxRouter(pg, true)
|
var err error
|
||||||
return nil
|
pg.txRouter, err = newTxRouter(pg, true)
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (pg *PostGIS) Abort() error {
|
func (pg *PostGIS) Abort() error {
|
||||||
|
|
|
@ -10,7 +10,7 @@ type TxRouter struct {
|
||||||
tx *sql.Tx
|
tx *sql.Tx
|
||||||
}
|
}
|
||||||
|
|
||||||
func newTxRouter(pg *PostGIS, bulkImport bool) *TxRouter {
|
func newTxRouter(pg *PostGIS, bulkImport bool) (*TxRouter, error) {
|
||||||
txr := TxRouter{
|
txr := TxRouter{
|
||||||
Tables: make(map[string]TableTx),
|
Tables: make(map[string]TableTx),
|
||||||
}
|
}
|
||||||
|
@ -20,7 +20,7 @@ func newTxRouter(pg *PostGIS, bulkImport bool) *TxRouter {
|
||||||
tt := NewBulkTableTx(pg, table)
|
tt := NewBulkTableTx(pg, table)
|
||||||
err := tt.Begin(nil)
|
err := tt.Begin(nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err) // TODO
|
return nil, err
|
||||||
}
|
}
|
||||||
txr.Tables[tableName] = tt
|
txr.Tables[tableName] = tt
|
||||||
}
|
}
|
||||||
|
@ -34,7 +34,7 @@ func newTxRouter(pg *PostGIS, bulkImport bool) *TxRouter {
|
||||||
tt := NewSynchronousTableTx(pg, table.FullName, table)
|
tt := NewSynchronousTableTx(pg, table.FullName, table)
|
||||||
err := tt.Begin(tx)
|
err := tt.Begin(tx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err) // TODO
|
return nil, err
|
||||||
}
|
}
|
||||||
txr.Tables[tableName] = tt
|
txr.Tables[tableName] = tt
|
||||||
}
|
}
|
||||||
|
@ -42,13 +42,13 @@ func newTxRouter(pg *PostGIS, bulkImport bool) *TxRouter {
|
||||||
tt := NewSynchronousTableTx(pg, table.FullName, table)
|
tt := NewSynchronousTableTx(pg, table.FullName, table)
|
||||||
err := tt.Begin(tx)
|
err := tt.Begin(tx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err) // TODO
|
return nil, err
|
||||||
}
|
}
|
||||||
txr.Tables[tableName] = tt
|
txr.Tables[tableName] = tt
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return &txr
|
return &txr, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (txr *TxRouter) End() error {
|
func (txr *TxRouter) End() error {
|
||||||
|
|
Loading…
Reference in New Issue