fix: query request should be executed with slave db (#121)

dk-lockdown · web-flow · commit 3be1d592a4a1 · 2022-05-31T20:41:01.000+08:00
diff --git a/pkg/executor/executor.go b/pkg/executor/executor.go
@@ -36,7 +36,7 @@ func (ex *DBGroupExecutor) Begin(ctx context.Context) (proto.Tx, proto.Result, e
 
 func (ex *DBGroupExecutor) Query(ctx context.Context, query string) (proto.Result, uint16, error) {
 	db := ex.reads.Next(proto.WithSlave(ctx)).(*DataSourceBrief)
-	return db.DB.Query(proto.WithMaster(ctx), query)
+	return db.DB.Query(proto.WithSlave(ctx), query)
 }
 
 func (ex *DBGroupExecutor) Execute(ctx context.Context, query string) (proto.Result, uint16, error) {
@@ -46,7 +46,7 @@ func (ex *DBGroupExecutor) Execute(ctx context.Context, query string) (proto.Res
 
 func (ex *DBGroupExecutor) PrepareQuery(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error) {
 	db := ex.reads.Next(proto.WithSlave(ctx)).(*DataSourceBrief)
-	return db.DB.ExecuteSql(proto.WithMaster(ctx), query, args...)
+	return db.DB.ExecuteSql(proto.WithSlave(ctx), query, args...)
 }
 
 func (ex *DBGroupExecutor) PrepareExecute(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error) {

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ func (ex *DBGroupExecutor) Begin(ctx context.Context) (proto.Tx, proto.Result, e`
`36`	`36`
`37`	`37`	`func (ex *DBGroupExecutor) Query(ctx context.Context, query string) (proto.Result, uint16, error) {`
`38`	`38`	`db := ex.reads.Next(proto.WithSlave(ctx)).(*DataSourceBrief)`
`39`		`- return db.DB.Query(proto.WithMaster(ctx), query)`
	`39`	`+ return db.DB.Query(proto.WithSlave(ctx), query)`
`40`	`40`	`}`
`41`	`41`
`42`	`42`	`func (ex *DBGroupExecutor) Execute(ctx context.Context, query string) (proto.Result, uint16, error) {`
`@@ -46,7 +46,7 @@ func (ex *DBGroupExecutor) Execute(ctx context.Context, query string) (proto.Res`
`46`	`46`
`47`	`47`	`func (ex *DBGroupExecutor) PrepareQuery(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error) {`
`48`	`48`	`db := ex.reads.Next(proto.WithSlave(ctx)).(*DataSourceBrief)`
`49`		`- return db.DB.ExecuteSql(proto.WithMaster(ctx), query, args...)`
	`49`	`+ return db.DB.ExecuteSql(proto.WithSlave(ctx), query, args...)`
`50`	`50`	`}`
`51`	`51`
`52`	`52`	`func (ex *DBGroupExecutor) PrepareExecute(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error) {`