xyz.cofe.cxconsole.script.sql

Class SqlService

java.lang.Object

xyz.cofe.cxconsole.srvc.AbstractService

xyz.cofe.cxconsole.srvc.StartableService

xyz.cofe.cxconsole.srvc.BaseService

xyz.cofe.cxconsole.script.sql.SqlService

All Implemented Interfaces:

ConsoleService, ServiceEventPublisher, StartService

public class SqlService
extends BaseService

Сервис по работе с SQL

Author:

georgiy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SqlService.ConnectionNodeCreated Событие создания узла для Connection
static class	SqlService.ScriptGeneric

Nested classes/interfaces inherited from class xyz.cofe.cxconsole.srvc.BaseService

BaseService.OnStart, BaseService.OnStop, BaseService.UiAction, BaseService.UiActionBase, BaseService.UiActionField, BaseService.UiActionMethod, BaseService.UiMenu

Field Summary

Fields

Modifier and Type	Field and Description
protected xyz.cofe.sql.ConnectPool	connectPool
protected xyz.cofe.gui.swing.tree.TreeTableNodeBasic	connectPoolNode
protected DataTableFactory	dataTableFactory
protected DockingService	dockingService
protected FileDialogService	fileDialogService
protected MapDB2Service	mapDB2Service
protected NotifyService	notifyService
protected ObjectBrowserService	objectBrowserService
protected PropertiesService	propertiesService
protected ScriptDocExecService	scriptDocExecService
protected ScriptService	scriptService
protected SqlEngineFactory	sqlEngineFactory
protected StatusBarService	statusBarService
protected TextService	textService

Fields inherited from class xyz.cofe.cxconsole.srvc.BaseService

actionFieldSet, actionMethodSet, initUiActionsSuccess, MENU_FIELD_NAME, running

Fields inherited from class xyz.cofe.cxconsole.srvc.StartableService

startCallLevel, startStopSync, stopCallLevel

Fields inherited from class xyz.cofe.cxconsole.srvc.AbstractService

serviceEventQueue

Constructor Summary

Constructors

Constructor and Description
SqlService()

Method Summary

Modifier and Type	Method and Description
void	addSqlServiceEvent(SqlServiceEvent ev)
Closeable	addSqlServiceListener(SqlServiceListener listener)
Closeable	addSqlServiceListener(SqlServiceListener listener, boolean weakLink)
void	applySqlPerspective()
void	bindDataTable() Объявление активной таблицы (DataTable) для скриптов
void	commit(Connection conn, xyz.cofe.common.Reciver<SQLException> onfinish)
boolean	commitable(Connection conn)
ConnectionNode	createConnectionNode(Connection conn, DataSource ds, String dsName) Создание узла для открытого соединения с БД
DataTableDock	createDataTableDock() Создание DataTableDock
void	exportDataTableXml() Экспорт данных из таблицы в XML
void	exportDataTableXml(DataTableDock dtd) Экспорт данных из таблицы в XML
void	exportDataTableXml(xyz.cofe.io.File file) Экспорт XML из активной таблицы
void	exportDataTableXml(xyz.cofe.io.File file, DataTableDock dtd) Экспорт XML в файл из таблицы
DataTableDock	findDataTableDock(Long scriptDocumentId, Integer dataTableNumber) Возвращает DataTableDock для указанного документа
void	fireSqlServiceEvent(SqlServiceEvent event)
void	fireSqlServiceEvents()
DataTableDock	getActiveDataTableDock() Возвращает текущий (последий который имеел фокус) документ
xyz.cofe.sql.ConnectPool	getConnectPool() Указывает пул соединений
xyz.cofe.gui.swing.tree.TreeTableNodeBasic	getConnectPoolNode() Узел в дереве (ObjectBrowser) содержащий ConnectPool
Map<String,String>	getDataSourceStorage() Коллекция описания DataSource в XML формате
DockingService.DockableList<DataTableDock>	getDataTableDockHistory() Возвращает историю переключения фокуса документов
DockingService.DockableList<DataTableDock>	getDataTableDocks() Возвращает список документов, отсортированный в обратном порядке переключения фокуса
DataTableFactory	getDataTableFactory() Возвращает фабрику DataTableDock
DockingService	getDockingService() Ссылка на сервис DockingService
FileDialogService	getFileDialogService() Ссылка на сервис FileDialogService
WeakHashMap<xyz.cofe.sql.BasicDataSource,Long>	getLoadedDataSources() Карта/коллекция загруженных DataSource
MapDB2Service	getMapDB2Service() Ссылка на сервис MapDB2Service
NotifyService	getNotifyService() Ссылка на сервис NotifyService
ObjectBrowserService	getObjectBrowserService() Ссылка на сервис ObjectBrowserService
PropertiesService	getPropertiesService() Ссылка на сервис PropertiesService
ScriptDocExecService	getScriptDocExecService() Ссылка на сервис ScriptDocExecService
ScriptService	getScriptService() Ссылка на сервис ScriptService
xyz.cofe.common.CloseableSet	getShutdownList() Список объект которые будут закрыты при завершении работы
SqlEngineFactory	getSqlEngineFactory() Возвращает фабрику SqlEngine
ConcurrentLinkedQueue<SqlServiceEvent>	getSqlServiceEventQueue()
Set<SqlServiceListener>	getSqlServiceListeners()
StatusBarService	getStatusBarService() Ссылка на сервис StatusBarService
TextService	getTextService() Ссылка на сервис TextService
boolean	hasSqlServiceListener(SqlServiceListener listener)
void	importDataTableXml() Импорт данных из XML в таблицу
void	importDataTableXml(DataTableDock dtd) Импорт XML данных в таблицу
void	importDataTableXml(xyz.cofe.io.File file) Импорт таблицы XML из файла
void	importDataTableXml(xyz.cofe.io.File file, DataTableDock dtd) Импорт таблицы XML из файла
protected void	initConnectPoolNode(ObjectBrowserService obs) Инициализация узла ConnectPool
protected void	initIcons(ObjectBrowserService obs) Инициализация иконок
protected void	initObjectBrowser(xyz.cofe.gui.swing.tree.ob.ObjectBrowser ob) Инициализация ObjectBrowser
protected void	initSqlEngineStatusBar()
protected void	loadDataSources() Загржает DataSource из XML
void	onDataTableDockFocused(DataTableDock dtDock)
protected void	registerDataTableFactory(DockingService ds) Регистрация фабрики DataTableDock
protected void	registerInScriptService(ScriptService ss) Регистрация фабрики SqlEngine
void	reinitObjectBrowser() Повторная реинициализация ObjectBrowserService Закрытие объектов shutdownList.closeAll() Инициализация ObjectBrowser
void	removeAllSqlServiceListeners()
void	removeSqlServiceListener(SqlServiceListener listener)
SqlService.ScriptGeneric	script()
protected void	shutdown() Завершение работы
protected JComponent	sqlEngineStatBar(TextDocument tdoc)
protected void	starting() Инициализация

Methods inherited from class xyz.cofe.cxconsole.srvc.BaseService

buttonGroup, getActionFieldSet, getActionMethodSet, getActionsService, getButtonGroup, getMenuService, getStartableMethodsList, getStartableMethodsMap, getStoppableMethodsList, getStoppableMethodsMap, initUiActionError, initUiActions, isRunning, onStart, onStop

Methods inherited from class xyz.cofe.cxconsole.srvc.StartableService

fireStarted, fireStarting, fireStopped, fireStopping, getServiceByStopper, getServiceDependencies, isDetectCycleStart, isDetectCycleStop, onResolvedDependencies, start, stop, stopByDependency

Methods inherited from class xyz.cofe.cxconsole.srvc.AbstractService

addServiceEvent, addServiceListener, addServiceListener, findFirstService, findFirstService, findServices, findServices, findServices, fireServiceEvent, fireServiceEvents, getConsole, getFieldDependencies, getInitDependenciesCallCount, getServiceListeners, getUnresolvedDependencies, hasServiceListener, init, initDependencies, instances, isResolvedDependencies, listeners, onInitServicesEnd, removeServiceListener, resolveDependecy

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface xyz.cofe.cxconsole.ConsoleService

init

Methods inherited from interface xyz.cofe.cxconsole.srvc.ServiceEventPublisher

addServiceEvent, addServiceListener, addServiceListener, fireServiceEvents, getServiceListeners, hasServiceListener, removeServiceListener

Field Detail

connectPool

protected volatile xyz.cofe.sql.ConnectPool connectPool

mapDB2Service

protected MapDB2Service mapDB2Service

objectBrowserService

protected ObjectBrowserService objectBrowserService

propertiesService

protected PropertiesService propertiesService

notifyService

protected NotifyService notifyService

scriptService

protected ScriptService scriptService

scriptDocExecService

protected ScriptDocExecService scriptDocExecService

dockingService

protected DockingService dockingService

fileDialogService

protected FileDialogService fileDialogService

textService

protected TextService textService

statusBarService

protected StatusBarService statusBarService

sqlEngineFactory

protected volatile SqlEngineFactory sqlEngineFactory

dataTableFactory

protected volatile DataTableFactory dataTableFactory

connectPoolNode

protected volatile xyz.cofe.gui.swing.tree.TreeTableNodeBasic connectPoolNode

Constructor Detail

SqlService

public SqlService()

Method Detail

hasSqlServiceListener

public boolean hasSqlServiceListener(SqlServiceListener listener)

getSqlServiceListeners

public Set<SqlServiceListener> getSqlServiceListeners()

addSqlServiceListener

public Closeable addSqlServiceListener(SqlServiceListener listener)

addSqlServiceListener

public Closeable addSqlServiceListener(SqlServiceListener listener,
                                       boolean weakLink)

removeSqlServiceListener

public void removeSqlServiceListener(SqlServiceListener listener)

removeAllSqlServiceListeners

public void removeAllSqlServiceListeners()

fireSqlServiceEvent

public void fireSqlServiceEvent(SqlServiceEvent event)

getSqlServiceEventQueue

public ConcurrentLinkedQueue<SqlServiceEvent> getSqlServiceEventQueue()

addSqlServiceEvent

public void addSqlServiceEvent(SqlServiceEvent ev)

fireSqlServiceEvents

public void fireSqlServiceEvents()

getConnectPool

public xyz.cofe.sql.ConnectPool getConnectPool()

Указывает пул соединений

Returns:

пул соединений

getMapDB2Service

public MapDB2Service getMapDB2Service()

Ссылка на сервис MapDB2Service

Returns:

сервис MapDB2Service

getLoadedDataSources

public WeakHashMap<xyz.cofe.sql.BasicDataSource,Long> getLoadedDataSources()

Карта/коллекция загруженных DataSource

Returns:

Карта/коллекция загруженных DataSource

loadDataSources

protected void loadDataSources()

Загржает DataSource из XML

See Also:

getDataSourceStorage()

getDataSourceStorage

public Map<String,String> getDataSourceStorage()

Коллекция описания DataSource в XML формате

Returns:

карта: имя DataSource / XML

getObjectBrowserService

public ObjectBrowserService getObjectBrowserService()

Ссылка на сервис ObjectBrowserService

Returns:

сервис ObjectBrowserService

getPropertiesService

public PropertiesService getPropertiesService()

Ссылка на сервис PropertiesService

Returns:

сервис PropertiesService

getNotifyService

public NotifyService getNotifyService()

Ссылка на сервис NotifyService

Returns:

сервис NotifyService

getScriptService

public ScriptService getScriptService()

Ссылка на сервис ScriptService

Returns:

сервис ScriptService

getScriptDocExecService

public ScriptDocExecService getScriptDocExecService()

Ссылка на сервис ScriptDocExecService

Returns:

сервис ScriptDocExecService

getDockingService

public DockingService getDockingService()

Ссылка на сервис DockingService

Returns:

сервис DockingService

getFileDialogService

public FileDialogService getFileDialogService()

Ссылка на сервис FileDialogService

Returns:

сервис FileDialogService

getTextService

public TextService getTextService()

Ссылка на сервис TextService

Returns:

сервис TextService

getStatusBarService

public StatusBarService getStatusBarService()

Ссылка на сервис StatusBarService

Returns:

сервис StatusBarService

getShutdownList

public xyz.cofe.common.CloseableSet getShutdownList()

Список объект которые будут закрыты при завершении работы

Returns:

интф для завершения работы

getSqlEngineFactory

public SqlEngineFactory getSqlEngineFactory()

Возвращает фабрику SqlEngine

Returns:

фабрика SqlEngine

registerInScriptService

protected void registerInScriptService(ScriptService ss)

Регистрация фабрики SqlEngine

Parameters:

ss - Сервис ScriptService

getDataTableFactory

public DataTableFactory getDataTableFactory()

Возвращает фабрику DataTableDock

Returns:

фабрика DataTableDock

registerDataTableFactory

protected void registerDataTableFactory(DockingService ds)

Регистрация фабрики DataTableDock

Parameters:

ds - Сервис DockingService

starting

protected void starting()

Инициализация

shutdown

protected void shutdown()

Завершение работы

getConnectPoolNode

public xyz.cofe.gui.swing.tree.TreeTableNodeBasic getConnectPoolNode()

Узел в дереве (ObjectBrowser) содержащий ConnectPool

Returns:

узел в дереве ObjectBrowser

initConnectPoolNode

protected void initConnectPoolNode(ObjectBrowserService obs)

Инициализация узла ConnectPool

Parameters:

obs - Служба ObjectBrowserService

initIcons

protected void initIcons(ObjectBrowserService obs)

Инициализация иконок

Parameters:

obs - Служба ObjectBrowserService

createConnectionNode

public ConnectionNode createConnectionNode(Connection conn,
                                           DataSource ds,
                                           String dsName)

Создание узла для открытого соединения с БД

Parameters:

conn - Соединение с БД

ds - Источник БД

dsName - Имя источника

Returns:

Узел в ObjectBrowser

reinitObjectBrowser

public void reinitObjectBrowser()

Повторная реинициализация ObjectBrowserService

• Закрытие объектов shutdownList.closeAll()
• Инициализация ObjectBrowser

See Also:

getShutdownList(), #initObjectBrowser(xyz.cofe.cxconsole.ob.ObjectBrowser)

initObjectBrowser

protected void initObjectBrowser(xyz.cofe.gui.swing.tree.ob.ObjectBrowser ob)

Инициализация ObjectBrowser

Parameters:

ob - Браузер объектов

createDataTableDock

public DataTableDock createDataTableDock()

Создание DataTableDock

Returns:

DataTableDock

getDataTableDockHistory

public DockingService.DockableList<DataTableDock> getDataTableDockHistory()

Возвращает историю переключения фокуса документов

Returns:

история

getDataTableDocks

public DockingService.DockableList<DataTableDock> getDataTableDocks()

Возвращает список документов, отсортированный в обратном порядке переключения фокуса

Returns:

список документов

getActiveDataTableDock

public DataTableDock getActiveDataTableDock()

Возвращает текущий (последий который имеел фокус) документ

Returns:

текущий документ или null

findDataTableDock

public DataTableDock findDataTableDock(Long scriptDocumentId,
                                       Integer dataTableNumber)

Возвращает DataTableDock для указанного документа

Parameters:

scriptDocumentId - Ид документа

dataTableNumber - Номер таблицы в выборке

Returns:

DataTableDock или null

onDataTableDockFocused

public void onDataTableDockFocused(DataTableDock dtDock)

exportDataTableXml

public void exportDataTableXml()

Экспорт данных из таблицы в XML

exportDataTableXml

public void exportDataTableXml(DataTableDock dtd)

Экспорт данных из таблицы в XML

Parameters:

dtd - Таблица

importDataTableXml

public void importDataTableXml()

Импорт данных из XML в таблицу

importDataTableXml

public void importDataTableXml(DataTableDock dtd)

Импорт XML данных в таблицу

Parameters:

dtd - целевая таблица

exportDataTableXml

public void exportDataTableXml(xyz.cofe.io.File file)

Экспорт XML из активной таблицы

Parameters:

file - файл XML

See Also:

getActiveDataTableDock()

exportDataTableXml

public void exportDataTableXml(xyz.cofe.io.File file,
                               DataTableDock dtd)

Экспорт XML в файл из таблицы

Parameters:

file - файл

dtd - таблица

importDataTableXml

public void importDataTableXml(xyz.cofe.io.File file)

Импорт таблицы XML из файла

Parameters:

file - файл XML

importDataTableXml

public void importDataTableXml(xyz.cofe.io.File file,
                               DataTableDock dtd)

Импорт таблицы XML из файла

Parameters:

file - файл XML

dtd - таблица

bindDataTable

public void bindDataTable()

Объявление активной таблицы (DataTable) для скриптов

See Also:

getActiveDataTableDock(), DataTableDock.bindDataTable(java.lang.String)

applySqlPerspective

public void applySqlPerspective()

script

public SqlService.ScriptGeneric script()

initSqlEngineStatusBar

protected void initSqlEngineStatusBar()

sqlEngineStatBar

protected JComponent sqlEngineStatBar(TextDocument tdoc)

commitable

public boolean commitable(Connection conn)

commit

public void commit(Connection conn,
                   xyz.cofe.common.Reciver<SQLException> onfinish)