MBroker
 Указатель Классы Пространства имен Файлы Функции Переменные Определения типов Перечисления Элементы перечислений Свойства
Открытые члены | Открытые атрибуты | Защищенные члены | Защищенные данные | Полный список членов класса
Класс DbConnectionPool.SQLProcessor.SqlProcessor
Граф наследования:DbConnectionPool.SQLProcessor.SqlProcessor:
DbConnectionPool.SQLProcessor.MSSQL.MsSqlProcessor DbConnectionPool.SQLProcessor.PGSQL.PgSqlProcessor

Открытые члены

string Execute (DCommand.Command command, string queryGuid, int priority, int ttl, ManualResetEvent resetThread, LogParam logParam, bool isPersistent=false)
 Выполнение запроса Подробнее...
 
IPool GetPool ()
 Возвращает пуул соединений Подробнее...
 
QQueueNode GetResultQuery (string queryGuid)
 Получение результата запроса Подробнее...
 
void CloseProcessor ()
 Закрытие SQL процессора Подробнее...
 
void Dispose ()
 Удаление ресурсов Подробнее...
 

Открытые атрибуты

readonly IQQueue< QQueueNodeQQueue = new QQueue<QQueueNode>()
 Очередь запросов в пул Подробнее...
 
readonly PoolTaskSheduler SqlTaskSheduler
 Планировщик задач Подробнее...
 
readonly AutoResetEvent WaitElementQueue
 Прерывание ожидания поступления запроса в очередь Подробнее...
 

Защищенные члены

 SqlProcessor (int correctQueueCount)
 Конструктор Подробнее...
 
void WorkQueue ()
 Обработка очереди Подробнее...
 
void UpdateStatistic_Callback (object timer)
 Обновление статистики Подробнее...
 

Защищенные данные

Logger Log
 Логирование Подробнее...
 
IPool SqlConnectionPool
 Пул соединений для MSSQL процессора Подробнее...
 
Timer UpdateStatisticTimer
 Таймер для обновления статистики Подробнее...
 
Thread WorkThread
 Поток для мониторинга очереди Подробнее...
 

Конструктор(ы)

DbConnectionPool.SQLProcessor.SqlProcessor.SqlProcessor ( int  correctQueueCount)
protected

Конструктор

Методы

void DbConnectionPool.SQLProcessor.SqlProcessor.CloseProcessor ( )

Закрытие SQL процессора

void DbConnectionPool.SQLProcessor.SqlProcessor.Dispose ( )

Удаление ресурсов

string DbConnectionPool.SQLProcessor.SqlProcessor.Execute ( DCommand.Command  command,
string  queryGuid,
int  priority,
int  ttl,
ManualResetEvent  resetThread,
LogParam  logParam,
bool  isPersistent = false 
)

Выполнение запроса

Аргументы
commandАнонимный метод
queryGuid
priorityПриоритет
ttlВремя жизни запроса
resetThreadСсылка на переменную, возобновляющую родительский поток
isPersistentФлаг, указывающий будет ли сохранено соединение в специальное хранилище
Возвращает
Уникальный идентификатор результата выполнения запроса
IPool DbConnectionPool.SQLProcessor.SqlProcessor.GetPool ( )

Возвращает пуул соединений

Возвращает
Интерфейс пула подключений
QQueueNode DbConnectionPool.SQLProcessor.SqlProcessor.GetResultQuery ( string  queryGuid)

Получение результата запроса

Аргументы
queryGuidУникальный идентификатор запроса
Возвращает
Элемент очереди запросов
void DbConnectionPool.SQLProcessor.SqlProcessor.UpdateStatistic_Callback ( object  timer)
protected

Обновление статистики

Аргументы
timer
void DbConnectionPool.SQLProcessor.SqlProcessor.WorkQueue ( )
protected

Обработка очереди

Данные класса

Logger DbConnectionPool.SQLProcessor.SqlProcessor.Log
protected

Логирование

readonly IQQueue<QQueueNode> DbConnectionPool.SQLProcessor.SqlProcessor.QQueue = new QQueue<QQueueNode>()

Очередь запросов в пул

IPool DbConnectionPool.SQLProcessor.SqlProcessor.SqlConnectionPool
protected

Пул соединений для MSSQL процессора

readonly PoolTaskSheduler DbConnectionPool.SQLProcessor.SqlProcessor.SqlTaskSheduler

Планировщик задач

Timer DbConnectionPool.SQLProcessor.SqlProcessor.UpdateStatisticTimer
protected

Таймер для обновления статистики

readonly AutoResetEvent DbConnectionPool.SQLProcessor.SqlProcessor.WaitElementQueue

Прерывание ожидания поступления запроса в очередь

Thread DbConnectionPool.SQLProcessor.SqlProcessor.WorkThread
protected

Поток для мониторинга очереди


Объявления и описания членов класса находятся в файле: