function Invoke-SQLRequest { 
  <#
  .SYNOPSIS
  Выполнение запроса к серверу SQL
  .DESCRIPTION
  Выполнение запроса к заданному серверу (инстансу) SQL.
  Возможен выбор метода авторизации "Integrated Security" или "Login/Password",
  параметров выполнения запроса - параллельно или последовательно, и т.п.
  .EXAMPLE
  Invoke-SQLRequest -SqlServer 'Server' -SqlDB 'DB'
  .EXAMPLE
  Invoke-SQLRequest -SqlServer 'Server' -SqlDB 'DB' -Login 'UserLogin' -Password 'P@ssVVord' -ParallelLimit 12
  .PARAMETER SqlServer
  Имя сервера SQL или именнованного инстанса SQL для подключения
  .PARAMETER SqlDB
  Имя базы данных на сервере, к которой выполняется подключение
  .PARAMETER SQLRequest
  Текст запроса для выполнения на сервере SQL. Может быть указан массив элементов типа "string"
  .PARAMETER Login
  Логин для подключения к серверу SQL. Если отсутствует - будет выполнено подключение под
  текущей учётной записью скрипта - режим "Integrated Security"
  .PARAMETER Password
  Пароль для подключения к серверу SQL. Если отсутствует - будет выполнено подключение под
  текущей учётной записью скрипта - режим "Integrated Security"
  .PARAMETER CommandTimeout
  Время ожидания в секундах результата выполнения запроса перед прерыванием и возвратом ошибки.
  Следует изменить для длительно выполняющихся запросов.
  .PARAMETER ParallelLimit
  Количество потоков, которое будет использовано при параллельном выполнении составного запроса.
  Если не указано - будет использован 1 поток, т.е. отсутствие параллельности.
  #>
  [CmdletBinding()]
  param (
    [Parameter(Mandatory=$True)][string]$SqlServer,
    [Parameter(Mandatory=$True)][string]$SqlDB,
    [Parameter(Mandatory=$True)][string[]]$SQLRequest,
    [string]$Login,
    [string]$Password,
    [int]$CommandTimeout = 15,
    [int]$ParallelLimit = 1
  )
  Process {
    # Создаём объект для размещения вывода параллельных запросов к серверу SQL
    $ParallelOut = [System.Collections.Concurrent.ConcurrentDictionary[int,System.Object]]::new()
    # Выполняем запросы параллельно в $ParallelLimit потоков
    $SQLRequest | ForEach-Object -Parallel {

      # Функция для получения информационных сообщений "InfoMessage" при выполнении запросов
      function Get-ConnectionEvents($EventID) {
        Get-Event | % {
          if ($_.SourceIdentifier -eq $EventID) {
            $CurrentEventIdentifier = $_.EventIdentifier;   
            $InfoMessage = $_.SourceEventArgs   
            Remove-Event -EventIdentifier $CurrentEventIdentifier
            $InfoMessage.Message
          }
        }
      }

      # Создаём объект подключения к инстансу на сервере SQL
      if (!$using:Login -or !$using:Password) {
        # Если не указан логин или пароль - используем Integrated Security
        $ConnectionString = "Server = $using:SqlServer; Database = $using:SqlDB; Integrated Security = true;"
      } else {
        $ConnectionString = "Server = $using:SqlServer; Database = $using:SqlDB; Integrated Security = false; User ID = $using:Login; Password = $using:Password"
      }
      $Connection = New-Object System.Data.SqlClient.SqlConnection
      $Connection.ConnectionString = $ConnectionString
      # Подписываемся на "InfoMessage"
      $EventID = "Connection.Messages."+(Get-Random)
      Register-ObjectEvent -InputObject $Connection -EventName InfoMessage -SourceIdentifier $EventID
      # Пробуем открыть подключение, при ошибке - никаких запросов не выполняется
      try {$Connection.Open()}
      catch {$DataSet = $null; $Connection = $null}
      # Выполняем запросы только если подключение открыто успешно
      try {
        if ($Connection) {
        # Создаём новый запрос к серверу SQL
        $SqlCmd = New-Object System.Data.SqlClient.SqlCommand
        # Задаём текст запроса, выполняем, результат помещаем в $ReqwDataSet
        $SqlCmd.CommandText = $_
        $SqlCmd.Connection = $Connection
        $SqlCmd.CommandTimeout = $using:CommandTimeout
        $SqlAdapter = New-Object System.Data.SqlClient.SqlDataAdapter
        $SqlAdapter.SelectCommand = $SqlCmd
        $DataSet = New-Object System.Data.DataSet
        $SqlAdapter.Fill($DataSet) > $null
        $Connection.Close()
        }
        # Создаём объект $Result из $DataSet.Tables[0] с дополнительным свойством InfoMessage
        $Result = $DataSet.Tables[0]
        try {
          $InfoMessage = Get-ConnectionEvents($EventID)
          $Result | Add-Member -NotePropertyName 'InfoMessage' -NotePropertyValue $InfoMessage -ErrorAction SilentlyContinue
        }
        catch {}
        # Размещаем вывод запроса $Result в объект $ParallelOut
        $Out = $using:ParallelOut
        $RndInt = Get-Random
        $Out.TryAdd($RndINT, $Result) > $null
      }
      catch {
        $DataSet = $null
      }
    } -ThrottleLimit $ParallelLimit
    $FunctionOutput = $null
    foreach ($item in $ParallelOut.Values) {$FunctionOutput += $item}
    return $FunctionOutput
  }
}

# Скрипт выполняет перестроение (rebuild) индексов в базах данных $SqlDBs на сервере SQL $SqlServer
# Операции могут выполняться параллельно в зависимости от параметра $ParallelLimit

# -----------------------------------------------------------------------------
# Задаём параметры и их дефолтные значения
[CmdletBinding()]
Param (
  # Параметры подключения к БД
  [Parameter(Mandatory=$True)][string]$SqlServer,  # Имя сервера (именованного инстанса) SQL
  [Parameter(Mandatory=$True)][string[]]$SqlDBs,   # Имя базы данных. Можно указать несколько значений (массив) имён баз данных
                                                   # на сервере SQL. В этом случае базы будут обработаны последовательно.
  [string]$Login,                                  # Логин для подключения к БД. Оставьте пустым для Integrated Security
  [string]$Password,                               # Пароль для подключения к БД. Оставьте пустым для Integrated Security
  [int]$RebuildIdxPercentThreshold = 15,           # Степерь фрагментации индекса, в %% для перестроения
  [int]$ParallelLimit = 4                          # Количество параллельно перестраиваемых индексов
)
# -----------------------------------------------------------------------------
# Подключаем внешнюю функцию Invoke-SQLRequest выполняющиую запрос к серверу SQL
# Предполагается что файл функции расположен в одной папке с этим скриптом
$ScriptFolder = $MyInvocation.MyCommand.Path | Split-Path -Parent
."$ScriptFolder\function_Invoke-SQLRequest.ps1"
# -----------------------------------------------------------------------------
# Обрабатываем последовательно все имена баз данных, указанные в $SqlDBs
$SqlDBs | ForEach-Object {
  $SqlDB = $_
  Write-Host "`n ┌───── База '$SqlDB' обработка начата ─────────────────┐"
  $ScriptStart = Get-Date
  # -----------------------------------------------------------------------------
  # Выполянем перестроение (rebuild) индексов в базе данных
  # -----------------------------------------------
  # Получаем текущую модель восстановления базы, если это Full - меняем на Bulk Logged
  $SQLRequest = "SELECT recovery_model_desc FROM sys.databases WHERE name = '$SqlDB'"
  $SQLOutput = Invoke-SQLRequest -SqlServer $SqlServer -SqlDB $SqlDB -SQLRequest $SQLRequest
  $SqlDBRecoveryModel = $SQLOutput.recovery_model_desc
  if ($SqlDBRecoveryModel -eq 'FULL') {
    $SQLRequest = "USE [master]; ALTER DATABASE [$SqlDB] SET RECOVERY BULK_LOGGED WITH NO_WAIT;"
    Invoke-SQLRequest -SqlServer $SqlServer -SqlDB $SqlDB -SQLRequest $SQLRequest
  }
  # -----------------------------------------------
  # Получаем список индексов для перестроения
  $StepStart = Get-Date; Write-Host " ├─┬── Получаем список индексов для перестроения, начало:" $StepStart.ToShortTimeString()
  $SQLRequest = "
    SET NOCOUNT ON
    SET QUOTED_IDENTIFIER ON
      IF OBJECT_ID('tempdb..#NotOnlineIndex') IS NOT NULL 
      DROP TABLE #NotOnlineIndex;
    CREATE TABLE #NotOnlineIndex (
       SchName nvarchar(64)
      ,TblName nvarchar(128)
      ,IdxName nvarchar(254)
      )
    CREATE CLUSTERED INDEX IXC_NotOnlineIndex ON #NotOnlineIndex
      (SchName, TblName, IdxName)
    INSERT INTO #NotOnlineIndex (SchName, TblName, IdxName)
    SELECT  SCHEMA_NAME(t.schema_id),
      t.name,
      i.name
      FROM sys.tables t WITH (nolock) 
      JOIN sys.indexes i WITH (nolock) 
        ON i.object_id = t.object_id
    WHERE t.is_ms_shipped = 0 
      AND i.name IS NOT NULL 
      AND (EXISTS (
        SELECT 1 
          FROM sys.index_columns ic
          JOIN sys.columns c
            ON ic.object_id = c.object_id
            AND ic.column_id = c.column_id
          JOIN sys.types ty
            ON c.user_type_id = ty.user_type_id
        WHERE ic.index_id = i.index_id
          AND ic.object_id = i.object_id
          AND (ty.name IN ('text','ntext','xml','image','geometry','geography')
          OR  (ty.name IN ('varchar','nvarchar','varbinary')
            AND c.max_length = -1)
        )
      )
  	OR EXISTS (
        SELECT 1 
        FROM sys.columns c
        JOIN sys.types ty
          ON c.user_type_id = ty.user_type_id
        WHERE i.index_id = 1 
  		AND c.object_id = t.object_id
  		AND ty.name IN ('text','ntext','image')
      )
    )
    SELECT QUOTENAME(idx.name) idxname, QUOTENAME(sc.name) + '.' + QUOTENAME(t.name) tblname, p.rows, st.avg_fragmentation_in_percent
    FROM sys.dm_db_index_physical_stats( DB_ID(),NULL,NULL,NULL,NULL) st
    JOIN sys.tables t ON (st.object_id=t.object_id)
    JOIN sys.schemas sc ON (sc.schema_id=t.schema_id)
    JOIN sys.indexes idx ON (st.object_id=idx.object_id and st.index_id=idx.index_id)
    JOIN sys.partitions p ON (p.index_id=idx.index_id and p.object_id=idx.object_id)
    WHERE st.page_count > 100
      AND st.alloc_unit_type_desc = 'IN_ROW_DATA'
      AND idx.type_desc IN ('CLUSTERED', 'NONCLUSTERED')
      AND st.avg_fragmentation_in_percent > $RebuildIdxPercentThreshold
      AND st.index_id > 0
      AND NOT EXISTS (SELECT 1 FROM #NotOnlineIndex
        WHERE SchName = sc.name
          AND TblName = t.name
          AND IdxName = idx.name
      )
    ORDER BY st.page_count ;
    DROP TABLE #NotOnlineIndex;   
  "
  $SQLOutput = Invoke-SQLRequest -SqlServer $SqlServer -SqlDB $SqlDB -SQLRequest $SQLRequest -CommandTimeout 10800
  $RebuildIndexReq = @()
  foreach ($item in $SQLOutput) {
    $RebuildIndexReq += 'ALTER INDEX ' + $item.idxname + ' ON ' + $item.tblname + ' REBUILD PARTITION = ALL WITH (SORT_IN_TEMPDB = ON, ONLINE = OFF, MAXDOP = 8);'
  }
  $StepEnd = Get-Date; Write-Host " │ └── Конец:" $StepEnd.ToShortTimeString() "Длительность:" ($StepEnd-$StepStart)
  # -----------------------------------------------
  # Выполняем перестроение (rebuild) индексов параллельно
  $StepStart = Get-Date; Write-Host " ├─┬── Выполняем перестроение (rebuild) индексов, начало:" $StepStart.ToShortTimeString()
  if ($RebuildIndexReq) {
    Invoke-SQLRequest -SqlServer $SqlServer -SqlDB $SqlDB -SQLRequest $RebuildIndexReq -CommandTimeout 345600 -ParallelLimit $ParallelLimit
  } else {Write-Host " │ ├───  " -NoNewline; Write-Host "Индексы не фрагментированы: rebuild  не требуется" -ForegroundColor DarkGreen}
  $StepEnd = Get-Date; Write-Host " │ └── Конец:" $StepEnd.ToShortTimeString() "Длительность:" ($StepEnd-$StepStart)
  # -----------------------------------------------
  # Если модель восстановления базы - FULL, то меняем её обратно с Bulk Logged на FULL
  if ($SqlDBRecoveryModel -eq 'FULL') {
    $SQLRequest = "USE [master]; ALTER DATABASE [$SqlDB] SET RECOVERY FULL WITH NO_WAIT;"
    Invoke-SQLRequest -SqlServer $SqlServer -SqlDB $SqlDB -SQLRequest $SQLRequest
  }
  # Конец перестроения (rebuild) индексов
  # -----------------------------------------------------------------------------
  $ScriptEnd = Get-Date; Write-Host " ├──── Полное время выполнения скрипта:" ($ScriptEnd-$ScriptStart)
  Write-Host " └───── База $SqlDB обработка завершена ──────────────────┘"
}
# Конец скрипта

$SQLOutput = Invoke-SQLRequest -SqlServer $SqlServer -SqlDB $SqlDB -SQLRequest $SQLRequest -CommandTimeout 345600 -ParallelLimit 12
Write-Host $SQLOutput.InfoMessage