mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
SearchV2: explicit dashboard loading order and cleanups (#50210)
This commit is contained in:
@@ -120,14 +120,7 @@ func initIndex(dashboards []dashboard, logger log.Logger, extendDoc ExtendDashbo
|
||||
if err := flushIfRequired(true); err != nil {
|
||||
return nil, nil, err
|
||||
}
|
||||
logger.Info("Finish inserting docs into batch", "elapsed", time.Since(label))
|
||||
label = time.Now()
|
||||
|
||||
err = writer.Batch(batch)
|
||||
if err != nil {
|
||||
return nil, nil, err
|
||||
}
|
||||
logger.Info("Finish writing batch", "elapsed", time.Since(label))
|
||||
logger.Info("Finish inserting docs into index", "elapsed", time.Since(label))
|
||||
|
||||
reader, err := writer.Reader()
|
||||
if err != nil {
|
||||
@@ -470,9 +463,6 @@ func doSearchQuery(
|
||||
return response
|
||||
}
|
||||
|
||||
dvfieldNames := []string{"type"}
|
||||
sctx := search.NewSearchContext(0, 0)
|
||||
|
||||
fScore := data.NewFieldFromFieldType(data.FieldTypeFloat64, 0)
|
||||
fUID := data.NewFieldFromFieldType(data.FieldTypeString, 0)
|
||||
fKind := data.NewFieldFromFieldType(data.FieldTypeString, 0)
|
||||
@@ -517,11 +507,6 @@ func doSearchQuery(
|
||||
// iterate through the document matches
|
||||
match, err := documentMatchIterator.Next()
|
||||
for err == nil && match != nil {
|
||||
err = match.LoadDocumentValues(sctx, dvfieldNames)
|
||||
if err != nil {
|
||||
continue
|
||||
}
|
||||
|
||||
uid := ""
|
||||
kind := ""
|
||||
ptype := ""
|
||||
|
||||
@@ -567,6 +567,7 @@ func (l sqlDashboardLoader) LoadDashboards(ctx context.Context, orgID int64, das
|
||||
|
||||
sess.Cols("id", "uid", "is_folder", "folder_id", "data", "slug", "created", "updated")
|
||||
|
||||
sess.OrderBy("id ASC")
|
||||
sess.Limit(limit)
|
||||
|
||||
return sess.Find(&rows)
|
||||
@@ -607,10 +608,6 @@ func newFolderIDLookup(sql *sqlstore.SQLStore) folderUIDLookup {
|
||||
return func(ctx context.Context, folderID int64) (string, error) {
|
||||
uid := ""
|
||||
err := sql.WithDbSession(ctx, func(sess *sqlstore.DBSession) error {
|
||||
sess.Table("dashboard").
|
||||
Where("id = ?", folderID).
|
||||
Cols("uid")
|
||||
|
||||
res, err := sess.Query("SELECT uid FROM dashboard WHERE id=?", folderID)
|
||||
if err != nil {
|
||||
return err
|
||||
|
||||
Reference in New Issue
Block a user