avoid SELECT * in cluster discovery store (#30830)

Этот коммит содержится в:
Jesse Hallam
2025-04-22 18:08:43 -03:00
коммит произвёл GitHub
родитель b095ba22b8
Коммит 94bc32b50c

Просмотреть файл

@@ -13,10 +13,29 @@ import (
type sqlClusterDiscoveryStore struct { type sqlClusterDiscoveryStore struct {
*SqlStore *SqlStore
clusterDiscoveryQuery sq.SelectBuilder
} }
func newSqlClusterDiscoveryStore(sqlStore *SqlStore) store.ClusterDiscoveryStore { func newSqlClusterDiscoveryStore(sqlStore *SqlStore) store.ClusterDiscoveryStore {
return &sqlClusterDiscoveryStore{sqlStore} s := &sqlClusterDiscoveryStore{
SqlStore: sqlStore,
}
s.clusterDiscoveryQuery = s.getQueryBuilder().
Select(
"Id",
"Type",
"ClusterName",
"Hostname",
"GossipPort",
"Port",
"CreateAt",
"LastPingAt",
).
From("ClusterDiscovery")
return s
} }
func (s sqlClusterDiscoveryStore) Save(ClusterDiscovery *model.ClusterDiscovery) error { func (s sqlClusterDiscoveryStore) Save(ClusterDiscovery *model.ClusterDiscovery) error {
@@ -84,9 +103,7 @@ func (s sqlClusterDiscoveryStore) Exists(ClusterDiscovery *model.ClusterDiscover
} }
func (s sqlClusterDiscoveryStore) GetAll(ClusterDiscoveryType, clusterName string) ([]*model.ClusterDiscovery, error) { func (s sqlClusterDiscoveryStore) GetAll(ClusterDiscoveryType, clusterName string) ([]*model.ClusterDiscovery, error) {
query := s.getQueryBuilder(). query := s.clusterDiscoveryQuery.
Select("*").
From("ClusterDiscovery").
Where(sq.Eq{"Type": ClusterDiscoveryType}). Where(sq.Eq{"Type": ClusterDiscoveryType}).
Where(sq.Eq{"ClusterName": clusterName}). Where(sq.Eq{"ClusterName": clusterName}).
Where(sq.Gt{"LastPingAt": model.GetMillis() - model.CDSOfflineAfterMillis}) Where(sq.Gt{"LastPingAt": model.GetMillis() - model.CDSOfflineAfterMillis})