MBroker
 Указатель Классы Пространства имен Файлы Функции Переменные Определения типов Перечисления Элементы перечислений Свойства
Открытые члены | Защищенные члены | Защищенные данные | Статические защищенные данные | Свойства | Полный список членов класса
Класс MBroker.DbLevel.Base.ServiceBaseabstract

Базовый класс для работы с бд Подробнее...

Граф наследования:MBroker.DbLevel.Base.ServiceBase:
MBroker.DbLevel.Interface.IServiceBase

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

virtual void ContextAdded (Context context)
 Добавление контекста Подробнее...
 
virtual void ContextRemoved (Context context)
 Удаление контекста Подробнее...
 
virtual List< List< Dictionary
< string, object > > > 
ExecProc (Context context, ExecProcContext execContext, bool parseResult, out int intres)
 Выполнение хранимой процедуры Подробнее...
 
virtual string GetView (Context context, IDictionary< string, object > qDesc, ExecQueryContext execContext)
 Получение представления Подробнее...
 
virtual List< T > GetView< T > (Context context, IDictionary< string, object > qDesc, ExecQueryContext execContext)
 
virtual string GetViewData (Context context, string query)
 Получение данных представления Подробнее...
 
virtual void Close ()
 Закрытие кастомного пула Подробнее...
 
virtual void IsCancellationRequested (CancellationToken ct)
 Проверка на завершение команды Подробнее...
 
abstract List< ViewColumnGetViewColumns (Context context, string classCode, string viewName, string classRecipient, string viewRecipient, string locale=null)
 Возвращает поля для представления Подробнее...
 
abstract bool HasField (Context context, string viewName, string fieldName)
 Определение, существует ли колонка в указанном представлении Подробнее...
 
abstract void LoadWorkerProperties (Context context)
 Подготовка параметров сотрудника Подробнее...
 
abstract int GetWorkerGroup (string login)
 Возвращает группу пользователя Подробнее...
 
abstract int GetWorkerId (string login)
 Возвращает идентификатор пользователя Подробнее...
 
abstract IEnumerable< MirrorGetMirrors ()
 
abstract IEnumerable< ShardBaseGetShardBases ()
 
abstract ParamSys GetSystemParameter (string section, string paramName, string locale, int?idBase=null)
 Получение системного параметра Подробнее...
 
abstract Dictionary< string,
string > 
GetViewColumnTypes (string idsql, string locale, bool forceRefresh=false)
 Возвращает типы колонок для представления Подробнее...
 
abstract string ExecProcO (Context context, ExecProcContext execContext)
 Выполнение процедуры Подробнее...
 
abstract List< T > ExecuteQuery< T > (string query)
 
abstract void ChangePassword (string user, string oldPassword, string newPassword)
 Смена пароля пользователя Подробнее...
 
abstract string CheckFilter (Context context, string filter, IServiceBase primaryBroker)
 Метод служит для теста разбора параметра - фильтра, при построении SQL - запроса в GetView. Подробнее...
 
abstract ISqlProcessor GetSqlProcessor (Context context, int priority, int ttl)
 Возвращает SQL процессор Подробнее...
 
abstract ISqlProcessor GetSqlServiceProcessor (int priority, int ttl)
 Возвращает сервисный SQL процессор Подробнее...
 
abstract IList< ShardGetShards ()
 

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

abstract string ExecuteQuery (Context context, string query, ICollection< string > fields, List< QueryParam > parameters, bool hasUserParams, ExecQueryContext execContext)
 
abstract List< T > ExecuteQuery< T > (Context context, string query, ICollection< string > fields, IList< QueryParam > parameters, bool hasUserParams, ExecQueryContext execContext)
 
DateTime ConvertTzToUtc (string date, string field, int?baseCoumn, string tz)
 Конвертируем из таймзоны в UTC Подробнее...
 

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

readonly Random Rand
 
readonly ConcurrentDictionary
< string, bool > 
ConFields = new ConcurrentDictionary<string, bool>()
 Кэш полей Подробнее...
 
ISqlBuilder SqlBuilder
 Сборщик SQL запросов Подробнее...
 
SqlProcessor Processor
 SQL процессор из кастомного пула соединений Подробнее...
 
readonly ConnectionElement ConnectionElement
 Элемент строки подключения к БД Подробнее...
 
readonly bool IsPrimaryEndPoint
 Флаг указывающий на тип конечной точки Подробнее...
 
readonly string BrokerId
 Идентификатор брокера Подробнее...
 
ConcurrentDictionary< Tuple
< string, string, int >, Tuple
< ParamSys, DateTime > > 
ParamSysCache
 Кэш системных параметров Подробнее...
 
readonly CacheManager CacheManager
 
readonly IQueryExporterProvider QueryExporterProvider
 

Статические защищенные данные

static readonly ResourceManager Rm
 Манагер ресурсов Подробнее...
 
static readonly string ProgramName
 Имя сервиса Подробнее...
 

Свойства

bool IsShardingMirror [get]
 
Policy ConnectionPolicy [get, set]
 
bool UseCustomPool [get]
 
- Свойства inherited from MBroker.DbLevel.Interface.IServiceBase
bool IsShardingMirror [get]
 

Подробное описание

Базовый класс для работы с бд

Методы

abstract void MBroker.DbLevel.Base.ServiceBase.ChangePassword ( string  user,
string  oldPassword,
string  newPassword 
)
pure virtual

Смена пароля пользователя

Аргументы
userИмя пользователя
oldPasswordСтарый пароль
newPasswordНовый пароль

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract string MBroker.DbLevel.Base.ServiceBase.CheckFilter ( Context  context,
string  filter,
IServiceBase  primaryBroker 
)
pure virtual

Метод служит для теста разбора параметра - фильтра, при построении SQL - запроса в GetView.

Аргументы
contextконтекст
filterобъект-фильтр
primaryBroker
Возвращает
сгенерированный SQL-запрос

Замещает MBroker.DbLevel.Interface.IServiceBase.

virtual void MBroker.DbLevel.Base.ServiceBase.Close ( )
virtual

Закрытие кастомного пула

Замещает MBroker.DbLevel.Interface.IServiceBase.

virtual void MBroker.DbLevel.Base.ServiceBase.ContextAdded ( Context  context)
virtual

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

Аргументы
contextКонтекст

Замещает MBroker.DbLevel.Interface.IServiceBase.

virtual void MBroker.DbLevel.Base.ServiceBase.ContextRemoved ( Context  context)
virtual

Удаление контекста

Аргументы
contextКонтекст

Замещает MBroker.DbLevel.Interface.IServiceBase.

DateTime MBroker.DbLevel.Base.ServiceBase.ConvertTzToUtc ( string  date,
string  field,
int?  baseCoumn,
string  tz 
)
protected

Конвертируем из таймзоны в UTC

Аргументы
date
field
baseCoumn
tz
Возвращает
virtual List<List<Dictionary<string, object> > > MBroker.DbLevel.Base.ServiceBase.ExecProc ( Context  context,
ExecProcContext  execContext,
bool  parseResult,
out int  intres 
)
virtual

Выполнение хранимой процедуры

Аргументы
contextКонтекст
execContext
parseResultЕсли установлено в true, то параметры Output и Input/Output сохраняются в JSON.
intres
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract string MBroker.DbLevel.Base.ServiceBase.ExecProcO ( Context  context,
ExecProcContext  execContext 
)
pure virtual

Выполнение процедуры

Аргументы
contextКонтекст пользователя
execContextПапаметры выполнения
Возвращает
JSON с результатами выполнения. Возвращаются параметры с типом Output или Input/Output

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract string MBroker.DbLevel.Base.ServiceBase.ExecuteQuery ( Context  context,
string  query,
ICollection< string >  fields,
List< QueryParam parameters,
bool  hasUserParams,
ExecQueryContext  execContext 
)
protectedpure virtual
abstract List<T> MBroker.DbLevel.Base.ServiceBase.ExecuteQuery< T > ( Context  context,
string  query,
ICollection< string >  fields,
IList< QueryParam parameters,
bool  hasUserParams,
ExecQueryContext  execContext 
)
protectedpure virtual
Согласование типов
T :new() 
abstract List<T> MBroker.DbLevel.Base.ServiceBase.ExecuteQuery< T > ( string  query)
pure virtual

Замещает MBroker.DbLevel.Interface.IServiceBase.

Согласование типов
T :new() 
abstract IEnumerable<Mirror> MBroker.DbLevel.Base.ServiceBase.GetMirrors ( )
pure virtual
abstract IEnumerable<ShardBase> MBroker.DbLevel.Base.ServiceBase.GetShardBases ( )
pure virtual
abstract IList<Shard> MBroker.DbLevel.Base.ServiceBase.GetShards ( )
pure virtual
abstract ISqlProcessor MBroker.DbLevel.Base.ServiceBase.GetSqlProcessor ( Context  context,
int  priority,
int  ttl 
)
pure virtual

Возвращает SQL процессор

Аргументы
contextКонтекст
priorityПриоритет
ttlВремя жизни
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract ISqlProcessor MBroker.DbLevel.Base.ServiceBase.GetSqlServiceProcessor ( int  priority,
int  ttl 
)
pure virtual

Возвращает сервисный SQL процессор

Аргументы
priorityПриоритет для запросов
ttlВремя жизни для запросов
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract ParamSys MBroker.DbLevel.Base.ServiceBase.GetSystemParameter ( string  section,
string  paramName,
string  locale,
int?  idBase = null 
)
pure virtual

Получение системного параметра

Аргументы
sectionСекция
paramNameНазвание параметра
idBaseИдентификатор филиала
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

virtual string MBroker.DbLevel.Base.ServiceBase.GetView ( Context  context,
IDictionary< string, object >  qDesc,
ExecQueryContext  execcContext 
)
virtual

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

Аргументы
contextКонтекст пользователя
qDescОписание запроса
execcContext
Возвращает
JSON с представлением

Замещает MBroker.DbLevel.Interface.IServiceBase.

virtual List<T> MBroker.DbLevel.Base.ServiceBase.GetView< T > ( Context  context,
IDictionary< string, object >  qDesc,
ExecQueryContext  execContext 
)
virtual

Замещает MBroker.DbLevel.Interface.IServiceBase.

Согласование типов
T :new() 
abstract List<ViewColumn> MBroker.DbLevel.Base.ServiceBase.GetViewColumns ( Context  context,
string  classCode,
string  viewName,
string  classRecipient,
string  viewRecipient,
string  locale = null 
)
pure virtual

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

Аргументы
contextКонтекст пользователя (для локализованной выборки)
classCodeКод класса
viewNameНаименование представления
classRecipient
viewRecipient
localeЯзык
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract Dictionary<string, string> MBroker.DbLevel.Base.ServiceBase.GetViewColumnTypes ( string  idsql,
string  locale,
bool  forceRefresh = false 
)
pure virtual

Возвращает типы колонок для представления

Аргументы
idsql
forceRefresh
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

virtual string MBroker.DbLevel.Base.ServiceBase.GetViewData ( Context  context,
string  query 
)
virtual

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

Аргументы
contextКонтекст
querySQL запрос
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract int MBroker.DbLevel.Base.ServiceBase.GetWorkerGroup ( string  login)
pure virtual

Возвращает группу пользователя

Аргументы
loginЛогин
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract int MBroker.DbLevel.Base.ServiceBase.GetWorkerId ( string  login)
pure virtual

Возвращает идентификатор пользователя

Аргументы
login
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

abstract bool MBroker.DbLevel.Base.ServiceBase.HasField ( Context  context,
string  viewName,
string  fieldName 
)
pure virtual

Определение, существует ли колонка в указанном представлении

Аргументы
context
viewName
fieldName
Возвращает

Замещает MBroker.DbLevel.Interface.IServiceBase.

virtual void MBroker.DbLevel.Base.ServiceBase.IsCancellationRequested ( CancellationToken  ct)
virtual

Проверка на завершение команды

Аргументы
ct
abstract void MBroker.DbLevel.Base.ServiceBase.LoadWorkerProperties ( Context  context)
pure virtual

Подготовка параметров сотрудника

Аргументы
contextКонтекст пользователя.

Замещает MBroker.DbLevel.Interface.IServiceBase.

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

readonly string MBroker.DbLevel.Base.ServiceBase.BrokerId
protected

Идентификатор брокера

readonly CacheManager MBroker.DbLevel.Base.ServiceBase.CacheManager
protected
readonly ConcurrentDictionary<string, bool> MBroker.DbLevel.Base.ServiceBase.ConFields = new ConcurrentDictionary<string, bool>()
protected

Кэш полей

readonly ConnectionElement MBroker.DbLevel.Base.ServiceBase.ConnectionElement
protected

Элемент строки подключения к БД

readonly bool MBroker.DbLevel.Base.ServiceBase.IsPrimaryEndPoint
protected

Флаг указывающий на тип конечной точки

ConcurrentDictionary<Tuple<string, string, int>, Tuple<ParamSys, DateTime> > MBroker.DbLevel.Base.ServiceBase.ParamSysCache
protected

Кэш системных параметров

SqlProcessor MBroker.DbLevel.Base.ServiceBase.Processor
protected

SQL процессор из кастомного пула соединений

readonly string MBroker.DbLevel.Base.ServiceBase.ProgramName
staticprotected
Инициализатор
= "MBroker " + Assembly.GetExecutingAssembly().GetName().Version +
" [" + ConfigurationManager.AppSettings.Get("brokerId") + "]"

Имя сервиса

readonly IQueryExporterProvider MBroker.DbLevel.Base.ServiceBase.QueryExporterProvider
protected
readonly Random MBroker.DbLevel.Base.ServiceBase.Rand
protected
readonly ResourceManager MBroker.DbLevel.Base.ServiceBase.Rm
staticprotected
Инициализатор
= new ResourceManager("MBroker.Localization.locale",
typeof (WorkerBroker).Assembly)

Манагер ресурсов

ISqlBuilder MBroker.DbLevel.Base.ServiceBase.SqlBuilder
protected

Сборщик SQL запросов

Полный список свойств

Policy MBroker.DbLevel.Base.ServiceBase.ConnectionPolicy
getset
bool MBroker.DbLevel.Base.ServiceBase.IsShardingMirror
get
bool MBroker.DbLevel.Base.ServiceBase.UseCustomPool
get

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