Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
  • Loading branch information
tharun0064 committed Jan 2, 2025
1 parent f9b9b59 commit 4fd69ae
Show file tree
Hide file tree
Showing 4 changed files with 16 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -43,11 +43,11 @@ func processExecutionPlanOfQueries(individualQueriesList []datamodels.Individual
query := "EXPLAIN (FORMAT JSON) " + *individualQuery.RealQueryText
rows, err := dbConn.Queryx(query)
if err != nil {
log.Info("Error executing query: %v", err)
log.Debug("Error executing query: %v", err)
continue
}
if !rows.Next() {
log.Info("Execution plan not found for queryId", *individualQuery.QueryID)
log.Debug("Execution plan not found for queryId", *individualQuery.QueryID)
continue
}
var execPlanJSON string
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ func PopulateIndividualQueryMetrics(conn *performancedbconnection.PGSQLConnectio
log.Debug("Extension 'pg_stat_monitor' is not enabled.")
return nil
}
log.Info("Extension 'pg_stat_monitor' enabled.")
log.Debug("Extension 'pg_stat_monitor' enabled.")
individualQueryMetricsInterface, individualQueriesForExecPlan := GetIndividualQueryMetrics(conn, slowRunningQueries, args, databaseNames)
if len(individualQueryMetricsInterface) == 0 {
log.Debug("No individual queries found.")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ func PopulateSlowRunningMetrics(conn *performancedbconnection.PGSQLConnection, p
return nil
}
if !isExtensionEnabled {
log.Info("Extension 'pg_stat_statements' is not enabled.")
log.Debug("Extension 'pg_stat_statements' is not enabled.")
return nil
}

Expand Down
24 changes: 12 additions & 12 deletions src/query-performance-monitoring/query_performance_main.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,34 +20,34 @@ func QueryPerformanceMain(args args.ArgumentList, pgIntegration *integration.Int
databaseStringList := commonutils.GetDatabaseListInString(databaseList)
newConnection, err := connectionInfo.NewConnection(connectionInfo.DatabaseName())
if err != nil {
log.Info("Error creating connection: ", err)
log.Debug("Error creating connection: ", err)
return
}

start := time.Now()
log.Info("Starting PopulateSlowRunningMetrics at ", start)
log.Debug("Starting PopulateSlowRunningMetrics at ", start)
slowRunningQueries := performancemetrics.PopulateSlowRunningMetrics(newConnection, pgIntegration, args, databaseStringList)
log.Info("PopulateSlowRunningMetrics completed in ", time.Since(start))
log.Debug("PopulateSlowRunningMetrics completed in ", time.Since(start))

start = time.Now()
log.Info("Starting PopulateWaitEventMetrics at ", start)
log.Debug("Starting PopulateWaitEventMetrics at ", start)
performancemetrics.PopulateWaitEventMetrics(newConnection, pgIntegration, args, databaseStringList)
log.Info("PopulateWaitEventMetrics completed in ", time.Since(start))
log.Debug("PopulateWaitEventMetrics completed in ", time.Since(start))

start = time.Now()
log.Info("Starting PopulateBlockingMetrics at ", start)
log.Debug("Starting PopulateBlockingMetrics at ", start)
performancemetrics.PopulateBlockingMetrics(newConnection, pgIntegration, args, databaseStringList)
log.Info("PopulateBlockingMetrics completed in ", time.Since(start))
log.Debug("PopulateBlockingMetrics completed in ", time.Since(start))

start = time.Now()
log.Info("Starting PopulateIndividualQueryMetrics at ", start)
log.Debug("Starting PopulateIndividualQueryMetrics at ", start)
individualQueries := performancemetrics.PopulateIndividualQueryMetrics(newConnection, slowRunningQueries, pgIntegration, args, databaseStringList)
log.Info("PopulateIndividualQueryMetrics completed in ", time.Since(start))
log.Debug("PopulateIndividualQueryMetrics completed in ", time.Since(start))

start = time.Now()
log.Info("Starting PopulateExecutionPlanMetrics at ", start)
log.Debug("Starting PopulateExecutionPlanMetrics at ", start)
performancemetrics.PopulateExecutionPlanMetrics(individualQueries, pgIntegration, args)
log.Info("PopulateExecutionPlanMetrics completed in ", time.Since(start))
log.Debug("PopulateExecutionPlanMetrics completed in ", time.Since(start))

log.Info("Query analysis completed.")
log.Debug("Query analysis completed.")
}

0 comments on commit 4fd69ae

Please sign in to comment.