314 lines
13 KiB
Go
314 lines
13 KiB
Go
|
package sqlserver
|
||
|
|
|
||
|
|
import (
|
||
|
|
"os"
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
"github.com/stretchr/testify/require"
|
||
|
|
|
||
|
|
"github.com/influxdata/telegraf/config"
|
||
|
|
"github.com/influxdata/telegraf/testutil"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestAzureSQLIntegration_ArcManaged_DatabaseIO_Query(t *testing.T) {
|
||
|
|
if testing.Short() {
|
||
|
|
t.Skip("Skipping integration test in short mode")
|
||
|
|
}
|
||
|
|
|
||
|
|
if os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING") == "" {
|
||
|
|
t.Skip("Missing environment variable AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
}
|
||
|
|
|
||
|
|
connectionString := os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
sl := config.NewSecret([]byte(connectionString))
|
||
|
|
|
||
|
|
server := &SQLServer{
|
||
|
|
Servers: []*config.Secret{&sl},
|
||
|
|
IncludeQuery: []string{"AzureArcSQLMIDatabaseIO"},
|
||
|
|
AuthMethod: "connection_string",
|
||
|
|
DatabaseType: "AzureArcSQLManagedInstance",
|
||
|
|
}
|
||
|
|
|
||
|
|
var acc testutil.Accumulator
|
||
|
|
|
||
|
|
require.NoError(t, server.Start(&acc))
|
||
|
|
require.NoError(t, server.Gather(&acc))
|
||
|
|
|
||
|
|
require.True(t, acc.HasMeasurement("sqlserver_database_io"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_database_io", "sql_instance"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_database_io", "database_name"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_database_io", "physical_filename"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_database_io", "logical_filename"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_database_io", "file_type"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "reads"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "read_bytes"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "read_latency_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "write_latency_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "writes"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "write_bytes"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "rg_read_stall_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_database_io", "rg_write_stall_ms"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_database_io", "replica_updateability"))
|
||
|
|
|
||
|
|
server.Stop()
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestAzureSQLIntegration_ArcManaged_ServerProperties_Query(t *testing.T) {
|
||
|
|
if testing.Short() {
|
||
|
|
t.Skip("Skipping integration test in short mode")
|
||
|
|
}
|
||
|
|
|
||
|
|
if os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING") == "" {
|
||
|
|
t.Skip("Missing environment variable AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
}
|
||
|
|
|
||
|
|
connectionString := os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
sl := config.NewSecret([]byte(connectionString))
|
||
|
|
|
||
|
|
server := &SQLServer{
|
||
|
|
Servers: []*config.Secret{&sl},
|
||
|
|
IncludeQuery: []string{"AzureArcSQLMIServerProperties"},
|
||
|
|
AuthMethod: "connection_string",
|
||
|
|
DatabaseType: "AzureArcSQLManagedInstance",
|
||
|
|
}
|
||
|
|
|
||
|
|
var acc testutil.Accumulator
|
||
|
|
|
||
|
|
require.NoError(t, server.Start(&acc))
|
||
|
|
require.NoError(t, server.Gather(&acc))
|
||
|
|
|
||
|
|
require.True(t, acc.HasMeasurement("sqlserver_server_properties"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_server_properties", "sql_instance"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "cpu_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "server_memory"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_server_properties", "sku"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "engine_edition"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_server_properties", "hardware_type"))
|
||
|
|
require.True(t, acc.HasField("sqlserver_server_properties", "uptime")) // Time field.
|
||
|
|
require.True(t, acc.HasTag("sqlserver_server_properties", "sql_version"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_server_properties", "sql_version_desc"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "db_online"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "db_restoring"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "db_recovering"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "db_recoveryPending"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_server_properties", "db_suspect"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_server_properties", "replica_updateability"))
|
||
|
|
|
||
|
|
// This query should only return one row
|
||
|
|
require.Len(t, acc.Metrics, 1)
|
||
|
|
server.Stop()
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestAzureSQLIntegration_ArcManaged_OsWaitStats_Query(t *testing.T) {
|
||
|
|
if testing.Short() {
|
||
|
|
t.Skip("Skipping integration test in short mode")
|
||
|
|
}
|
||
|
|
|
||
|
|
if os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING") == "" {
|
||
|
|
t.Skip("Missing environment variable AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
}
|
||
|
|
|
||
|
|
connectionString := os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
sl := config.NewSecret([]byte(connectionString))
|
||
|
|
|
||
|
|
server := &SQLServer{
|
||
|
|
Servers: []*config.Secret{&sl},
|
||
|
|
IncludeQuery: []string{"AzureArcSQLMIOsWaitstats"},
|
||
|
|
AuthMethod: "connection_string",
|
||
|
|
DatabaseType: "AzureArcSQLManagedInstance",
|
||
|
|
}
|
||
|
|
|
||
|
|
var acc testutil.Accumulator
|
||
|
|
|
||
|
|
require.NoError(t, server.Start(&acc))
|
||
|
|
require.NoError(t, server.Gather(&acc))
|
||
|
|
|
||
|
|
require.True(t, acc.HasMeasurement("sqlserver_waitstats"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_waitstats", "sql_instance"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_waitstats", "wait_type"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_waitstats", "waiting_tasks_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_waitstats", "wait_time_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_waitstats", "max_wait_time_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_waitstats", "signal_wait_time_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_waitstats", "resource_wait_ms"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_waitstats", "wait_category"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_waitstats", "replica_updateability"))
|
||
|
|
|
||
|
|
server.Stop()
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestAzureSQLIntegration_ArcManaged_MemoryClerks_Query(t *testing.T) {
|
||
|
|
if testing.Short() {
|
||
|
|
t.Skip("Skipping integration test in short mode")
|
||
|
|
}
|
||
|
|
|
||
|
|
if os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING") == "" {
|
||
|
|
t.Skip("Missing environment variable AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
}
|
||
|
|
|
||
|
|
connectionString := os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
sl := config.NewSecret([]byte(connectionString))
|
||
|
|
|
||
|
|
server := &SQLServer{
|
||
|
|
Servers: []*config.Secret{&sl},
|
||
|
|
IncludeQuery: []string{"AzureArcSQLMIMemoryClerks"},
|
||
|
|
AuthMethod: "connection_string",
|
||
|
|
DatabaseType: "AzureArcSQLManagedInstance",
|
||
|
|
}
|
||
|
|
|
||
|
|
var acc testutil.Accumulator
|
||
|
|
|
||
|
|
require.NoError(t, server.Start(&acc))
|
||
|
|
require.NoError(t, server.Gather(&acc))
|
||
|
|
|
||
|
|
require.True(t, acc.HasMeasurement("sqlserver_memory_clerks"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_memory_clerks", "sql_instance"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_memory_clerks", "clerk_type"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_memory_clerks", "size_kb"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_memory_clerks", "replica_updateability"))
|
||
|
|
|
||
|
|
server.Stop()
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestAzureSQLIntegration_ArcManaged_PerformanceCounters_Query(t *testing.T) {
|
||
|
|
if testing.Short() {
|
||
|
|
t.Skip("Skipping integration test in short mode")
|
||
|
|
}
|
||
|
|
|
||
|
|
if os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING") == "" {
|
||
|
|
t.Skip("Missing environment variable AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
}
|
||
|
|
|
||
|
|
connectionString := os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
sl := config.NewSecret([]byte(connectionString))
|
||
|
|
|
||
|
|
server := &SQLServer{
|
||
|
|
Servers: []*config.Secret{&sl},
|
||
|
|
IncludeQuery: []string{"AzureArcSQLMIPerformanceCounters"},
|
||
|
|
AuthMethod: "connection_string",
|
||
|
|
DatabaseType: "AzureArcSQLManagedInstance",
|
||
|
|
}
|
||
|
|
|
||
|
|
var acc testutil.Accumulator
|
||
|
|
|
||
|
|
require.NoError(t, server.Start(&acc))
|
||
|
|
require.NoError(t, server.Gather(&acc))
|
||
|
|
|
||
|
|
require.True(t, acc.HasMeasurement("sqlserver_performance"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_performance", "sql_instance"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_performance", "object"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_performance", "counter"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_performance", "instance"))
|
||
|
|
require.True(t, acc.HasFloatField("sqlserver_performance", "value"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_performance", "counter_type"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_performance", "replica_updateability"))
|
||
|
|
|
||
|
|
server.Stop()
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestAzureSQLIntegration_ArcManaged_Requests_Query(t *testing.T) {
|
||
|
|
if testing.Short() {
|
||
|
|
t.Skip("Skipping integration test in short mode")
|
||
|
|
}
|
||
|
|
|
||
|
|
if os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING") == "" {
|
||
|
|
t.Skip("Missing environment variable AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
}
|
||
|
|
|
||
|
|
connectionString := os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
sl := config.NewSecret([]byte(connectionString))
|
||
|
|
|
||
|
|
server := &SQLServer{
|
||
|
|
Servers: []*config.Secret{&sl},
|
||
|
|
IncludeQuery: []string{"AzureArcSQLMIRequests"},
|
||
|
|
AuthMethod: "connection_string",
|
||
|
|
DatabaseType: "AzureArcSQLManagedInstance",
|
||
|
|
}
|
||
|
|
|
||
|
|
var acc testutil.Accumulator
|
||
|
|
|
||
|
|
require.NoError(t, server.Start(&acc))
|
||
|
|
require.NoError(t, server.Gather(&acc))
|
||
|
|
|
||
|
|
require.True(t, acc.HasMeasurement("sqlserver_requests"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "sql_instance"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "database_name"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "session_id"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "request_id"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "status"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "cpu_time_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "total_elapsed_time_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "logical_reads"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "writes"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "command"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "wait_time_ms"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "wait_type"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "wait_resource"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "blocking_session_id"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "program_name"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "host_name"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "nt_user_name"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "login_name"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "open_transaction"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "transaction_isolation_level"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_requests", "granted_query_memory_pages"))
|
||
|
|
require.True(t, acc.HasFloatField("sqlserver_requests", "percent_complete"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "statement_text"))
|
||
|
|
require.True(t, acc.HasField("sqlserver_requests", "objectid")) // Can be null.
|
||
|
|
require.True(t, acc.HasField("sqlserver_requests", "stmt_object_name")) // Can be null.
|
||
|
|
require.True(t, acc.HasField("sqlserver_requests", "stmt_db_name")) // Can be null.
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "query_hash"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "query_plan_hash"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "session_db_name"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_requests", "replica_updateability"))
|
||
|
|
|
||
|
|
server.Stop()
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestAzureSQLIntegration_ArcManaged_Schedulers_Query(t *testing.T) {
|
||
|
|
if testing.Short() {
|
||
|
|
t.Skip("Skipping integration test in short mode")
|
||
|
|
}
|
||
|
|
|
||
|
|
if os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING") == "" {
|
||
|
|
t.Skip("Missing environment variable AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
}
|
||
|
|
|
||
|
|
connectionString := os.Getenv("AZURESQL_ARCMI_CONNECTION_STRING")
|
||
|
|
sl := config.NewSecret([]byte(connectionString))
|
||
|
|
|
||
|
|
server := &SQLServer{
|
||
|
|
Servers: []*config.Secret{&sl},
|
||
|
|
IncludeQuery: []string{"AzureArcSQLMISchedulers"},
|
||
|
|
AuthMethod: "connection_string",
|
||
|
|
DatabaseType: "AzureArcSQLManagedInstance",
|
||
|
|
}
|
||
|
|
|
||
|
|
var acc testutil.Accumulator
|
||
|
|
|
||
|
|
require.NoError(t, server.Start(&acc))
|
||
|
|
require.NoError(t, server.Gather(&acc))
|
||
|
|
|
||
|
|
require.True(t, acc.HasMeasurement("sqlserver_schedulers"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_schedulers", "sql_instance"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_schedulers", "scheduler_id"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_schedulers", "cpu_id"))
|
||
|
|
require.True(t, acc.HasField("sqlserver_schedulers", "is_online")) // Bool field.
|
||
|
|
require.True(t, acc.HasField("sqlserver_schedulers", "is_idle")) // Bool field.
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "preemptive_switches_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "context_switches_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "current_tasks_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "runnable_tasks_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "current_workers_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "active_workers_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "work_queue_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "pending_disk_io_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "load_factor"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "yield_count"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "total_cpu_usage_ms"))
|
||
|
|
require.True(t, acc.HasInt64Field("sqlserver_schedulers", "total_scheduler_delay_ms"))
|
||
|
|
require.True(t, acc.HasTag("sqlserver_schedulers", "replica_updateability"))
|
||
|
|
|
||
|
|
server.Stop()
|
||
|
|
}
|