fix: fix db switch error in transaction (#209)

weloe · web-flow · commit d7df6d8086df · 2023-04-14T20:37:36.000+08:00
diff --git a/adapter.go b/adapter.go
@@ -234,9 +234,9 @@ func InitDbResolver(dbArr []gorm.Dialector, dbNames []string) (DbPool, error) {
 
 func NewAdapterByMulDb(dbPool DbPool, dbName string, prefix string, tableName string) (*Adapter, error) {
 	//change DB
-	dbPool.switchDb(dbName)
+	db := dbPool.switchDb(dbName)
 
-	return NewAdapterByDBUseTableName(dbPool.source, prefix, tableName)
+	return NewAdapterByDBUseTableName(db, prefix, tableName)
 }
 
 // NewFilteredAdapter is the constructor for FilteredAdapter.

Original file line number	Diff line number	Diff line change
`@@ -234,9 +234,9 @@ func InitDbResolver(dbArr []gorm.Dialector, dbNames []string) (DbPool, error) {`
`234`	`234`
`235`	`235`	`func NewAdapterByMulDb(dbPool DbPool, dbName string, prefix string, tableName string) (*Adapter, error) {`
`236`	`236`	`//change DB`
`237`		`- dbPool.switchDb(dbName)`
	`237`	`+ db := dbPool.switchDb(dbName)`
`238`	`238`
`239`		`- return NewAdapterByDBUseTableName(dbPool.source, prefix, tableName)`
	`239`	`+ return NewAdapterByDBUseTableName(db, prefix, tableName)`
`240`	`240`	`}`
`241`	`241`
`242`	`242`	`// NewFilteredAdapter is the constructor for FilteredAdapter.`