Skip to content

Commit b5de8a6

Browse files
DISTMYSQL-421: Remove master-slave terminologies in Orchestrator
Addressed review comments.
1 parent ffaec94 commit b5de8a6

File tree

3 files changed

+19
-23
lines changed

3 files changed

+19
-23
lines changed

go/db/tls.go

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -81,20 +81,22 @@ var query_whitelist = []string{
8181
}
8282

8383
func (logger SqlUtilsLogger) ValidateQuery(query string) {
84-
if !logger.backend_connection {
85-
// check if whitelisted
86-
for i := 0; i < len(query_whitelist); i++ {
87-
if strings.Contains(query, query_whitelist[i]) {
88-
return
89-
}
90-
}
84+
if logger.backend_connection {
85+
return
86+
}
9187

92-
lquery := strings.ToLower(query)
93-
if strings.Contains(lquery, "master") || strings.Contains(lquery, "slave") {
94-
log.Error("QUERY CONTAINS MASTER / SLAVE: ")
95-
// panic("Query contains master/slave: " + query)
88+
// check if whitelisted
89+
for i := 0; i < len(query_whitelist); i++ {
90+
if strings.Contains(query, query_whitelist[i]) {
91+
return
9692
}
9793
}
94+
95+
lquery := strings.ToLower(query)
96+
if strings.Contains(lquery, "master") || strings.Contains(lquery, "slave") {
97+
log.Error("QUERY CONTAINS MASTER / SLAVE: ")
98+
// panic("Query contains master/slave: " + query)
99+
}
98100
}
99101

100102
func requiresTLS(host string, port int, mysql_uri string) bool {

go/golib/sqlutils/sqlutils.go

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -175,9 +175,8 @@ func validateQuery(query string, db *sql.DB) {
175175
return
176176

177177
knownDBsMutex.RLock()
178-
defer func() {
179-
knownDBsMutex.RUnlock()
180-
}()
178+
defer knownDBsMutex.RUnlock()
179+
181180
if logger, exists := DB2logger[db]; exists && logger != nil {
182181
logger.ValidateQuery((query))
183182
}
@@ -283,9 +282,7 @@ func ScanRowsToMaps(rows *sql.Rows, on_row func(RowMap) error) error {
283282
func logErrorInternal(context string, db *sql.DB, query string, err error) error {
284283
// find logger registered by the client
285284
knownDBsMutex.RLock()
286-
defer func() {
287-
knownDBsMutex.RUnlock()
288-
}()
285+
defer knownDBsMutex.RUnlock()
289286

290287
if logger, exists := DB2logger[db]; exists && logger != nil {
291288
return logger.OnError(context, query, err)

vendor/github.com/openark/golib/sqlutils/sqlutils.go

Lines changed: 3 additions & 6 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)