SqlEngine (root 0.2-SNAPSHOT API)

java.lang.Object
- xyz.cofe.cxconsole.script.sql.SqlEngine

All Implemented Interfaces:

MapStore, Engine, EngineOutput, GetScriptDocument, SetScriptDocument, ScnChanged<SqlEngine,Long>
```
public class SqlEngine
extends Object
implements Engine, MapStore, ScnChanged<SqlEngine,Long>, EngineOutput, SetScriptDocument, GetScriptDocument
```
Author:

Kamnev Georgiy (nt.gocha@gmail.com)

Field Summary

Fields
Modifier and Type	Field and Description
`protected Connection`	`connection`
`protected ConnectPool`	`connectPool`
`protected String`	`dataSourceName`
`protected long`	`scn`
`protected ScnChangedSupport<SqlEngine,Long>`	`scnChangedSupport`
`protected WeakReference<TextDocument>`	`scriptDocument`
`protected Long`	`scriptDocumentId`

Constructor Summary

Constructors
Constructor and Description

SqlEngine()

SqlEngine(SqlEngineFactory factory)

Constructors
Constructor and Description
`SqlEngine()`
`SqlEngine(SqlEngineFactory factory)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addScnChangedEvent(ScnChangedEvent<SqlEngine,Long> ev)`
`Closeable`	`addScnChangedListener(ScnChanedListener<SqlEngine,Long> listener)` Добавляет подписчика на изменения
`Closeable`	`addScnChangedListener(ScnChanedListener<SqlEngine,Long> listener, boolean weakLink)` Добавляет подписчика на изменения
`SqlEngineFactory`	`compareAndSetFactory(SqlEngineFactory cmpVal, SqlEngineFactory setVal)`
`protected Func0<Pair<Object,Throwable>>`	`createExecutor(String query)`
`protected Pair<Object,Throwable>`	`executeQuery(String query, Long scriptDocumentID, WeakReference<TextDocument> scriptDocument)`
`void`	`fireScnChanged(Long old, Long cur)`
`void`	`fireScnChangedEvent(ScnChangedEvent<SqlEngine,Long> event)`
`void`	`fireScnChangedEvents()`
`Connection`	`getConnection()`
`Connection`	`getConnection(boolean autoConnect)`
`ConnectPool`	`getConnectPool()`
`String`	`getDataSourceName()`
`Writer`	`getErrorWriter()`
`SqlEngineFactory`	`getFactory()` Возвращает фабрику для создания движка
`ConcurrentLinkedQueue<ScnChangedEvent<SqlEngine,Long>>`	`getScnChangedEventQueue()`
`Set<ScnChanedListener<SqlEngine,Long>>`	`getScnChangedListeners()` Возвращает активных подписчиков
`protected ScnChangedSupport<SqlEngine,Long>`	`getScnChangedSupport()`
`TextDocument`	`getScriptDocument()`
`long`	`getScriptDocumentId()`
`SqlService`	`getSqlService()`
`Writer`	`getWriter()`
`boolean`	`hasScnChangedListener(ScnChanedListener<SqlEngine,Long> listener)` Проверяет что указанный подписчик имеется в списках рассылки
`boolean`	`isPrintResultCounters()`
`protected void`	`nextscn()`
`protected void`	`onDataTableCreated(QueryExecutor.DataTableCreated ev, WeakReference<TextDocument> scriptDocument, Long scriptDocumentId, Integer dataTableNum)`
`void`	`removeAllScnChangedListeners()` Удаляет всех подписчиков
`void`	`removeScnChangedListener(ScnChanedListener<SqlEngine,Long> listener)` Удаляет подписчика от уведомлений
`void`	`restore(Map map)` Восстановление состояния объекта
`Long`	`scn()` Возвращает текущий номер изменений
`void`	`setConnection(Connection conn)`
`void`	`setConnectPool(ConnectPool cp)`
`void`	`setDataSourceName(String dataSourceName)`
`void`	`setErrorWriter(Writer writer)`
`void`	`setFactory(SqlEngineFactory ef)`
`void`	`setPrintResultCounters(boolean printResultCounters)`
`void`	`setScriptDocument(TextDocument textDocument)`
`void`	`setScriptDocumentId(Long scriptDocumentId)`
`void`	`setWriter(Writer writer)`
`void`	`store(Map map)` Сохранение состояния объекта
`ExecuteMonitor<String>`	`submit(String script)` Отправляет скрипт на выполнение

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - scn
```
protected long scn
```
  - scnChangedSupport
```
protected transient ScnChangedSupport<SqlEngine,Long> scnChangedSupport
```
  - dataSourceName
```
protected String dataSourceName
```
  - connectPool
```
protected transient volatile ConnectPool connectPool
```
  - connection
```
protected transient Connection connection
```
  - scriptDocumentId
```
protected volatile Long scriptDocumentId
```
  - scriptDocument
```
protected volatile WeakReference<TextDocument> scriptDocument
```
- Constructor Detail
  - SqlEngine
```
public SqlEngine()
```
  - SqlEngine
```
public SqlEngine(SqlEngineFactory factory)
```
- Method Detail
  - getSqlService
```
public SqlService getSqlService()
```
  - scn
```
public Long scn()
```
    Description copied from interface: ScnChanged
    
    Возвращает текущий номер изменений
    
    Specified by:
    
    scn in interface ScnChanged<SqlEngine,Long>
    
    Returns:
    
    текущий номер изменения
  - nextscn
```
protected void nextscn()
```
  - getScnChangedSupport
```
protected ScnChangedSupport<SqlEngine,Long> getScnChangedSupport()
```
  - hasScnChangedListener
```
public boolean hasScnChangedListener(ScnChanedListener<SqlEngine,Long> listener)
```
    Description copied from interface: ScnChanged
    
    Проверяет что указанный подписчик имеется в списках рассылки
    
    Specified by:
    
    hasScnChangedListener in interface ScnChanged<SqlEngine,Long>
    
    Parameters:
    
    listener - подписчик
    
    Returns:
    
    true - подписчик имеется в списках рассылки
  - getScnChangedListeners
```
public Set<ScnChanedListener<SqlEngine,Long>> getScnChangedListeners()
```
    Description copied from interface: ScnChanged
    
    Возвращает активных подписчиков
    
    Specified by:
    
    getScnChangedListeners in interface ScnChanged<SqlEngine,Long>
    
    Returns:
    
    подписчики
  - addScnChangedListener
```
public Closeable addScnChangedListener(ScnChanedListener<SqlEngine,Long> listener)
```
    Description copied from interface: ScnChanged
    
    Добавляет подписчика на изменения
    
    Specified by:
    
    addScnChangedListener in interface ScnChanged<SqlEngine,Long>
    
    Parameters:
    
    listener - подписчик
    
    Returns:
    
    Интерфейс отписки от уведомлений
  - addScnChangedListener
```
public Closeable addScnChangedListener(ScnChanedListener<SqlEngine,Long> listener,
                                       boolean weakLink)
```
    Description copied from interface: ScnChanged
    
    Добавляет подписчика на изменения
    
    Specified by:
    
    addScnChangedListener in interface ScnChanged<SqlEngine,Long>
    
    Parameters:
    
    listener - подписчик
    
    weakLink - true - добавить подписчика на weak ссылку / false - как hard ссылку
    
    Returns:
    
    Интерфейс отписки от уведомлений
  - removeScnChangedListener
```
public void removeScnChangedListener(ScnChanedListener<SqlEngine,Long> listener)
```
    Description copied from interface: ScnChanged
    
    Удаляет подписчика от уведомлений
    
    Specified by:
    
    removeScnChangedListener in interface ScnChanged<SqlEngine,Long>
    
    Parameters:
    
    listener - подписчик
  - removeAllScnChangedListeners
```
public void removeAllScnChangedListeners()
```
    Description copied from interface: ScnChanged
    
    Удаляет всех подписчиков
    
    Specified by:
    
    removeAllScnChangedListeners in interface ScnChanged<SqlEngine,Long>
  - fireScnChangedEvent
```
public void fireScnChangedEvent(ScnChangedEvent<SqlEngine,Long> event)
```
  - getScnChangedEventQueue
```
public ConcurrentLinkedQueue<ScnChangedEvent<SqlEngine,Long>> getScnChangedEventQueue()
```
  - addScnChangedEvent
```
public void addScnChangedEvent(ScnChangedEvent<SqlEngine,Long> ev)
```
  - fireScnChangedEvents
```
public void fireScnChangedEvents()
```
  - fireScnChanged
```
public void fireScnChanged(Long old,
                           Long cur)
```
  - getDataSourceName
```
public String getDataSourceName()
```
  - setDataSourceName
```
public void setDataSourceName(String dataSourceName)
```
  - getConnectPool
```
public ConnectPool getConnectPool()
```
  - setConnectPool
```
public void setConnectPool(ConnectPool cp)
```
  - getFactory
```
public SqlEngineFactory getFactory()
```
    Description copied from interface: Engine
    
    Возвращает фабрику для создания движка
    
    Specified by:
    
    getFactory in interface Engine
    
    Returns:
    
    фабрика движков
  - setFactory
```
public void setFactory(SqlEngineFactory ef)
```
  - compareAndSetFactory
```
public SqlEngineFactory compareAndSetFactory(SqlEngineFactory cmpVal,
                                             SqlEngineFactory setVal)
```
  - submit
```
public ExecuteMonitor<String> submit(String script)
```
    Description copied from interface: Engine
    
    Отправляет скрипт на выполнение
    
    Specified by:
    
    submit in interface Engine
    
    Parameters:
    
    script - скрипт
    
    Returns:
    
    монитор выполнения
  - createExecutor
```
protected Func0<Pair<Object,Throwable>> createExecutor(String query)
```
  - getConnection
```
public Connection getConnection()
                         throws SQLException
```
    Throws:
    
    SQLException
  - getConnection
```
public Connection getConnection(boolean autoConnect)
                         throws SQLException
```
    Throws:
    
    SQLException
  - setConnection
```
public void setConnection(Connection conn)
```
  - setWriter
```
public void setWriter(Writer writer)
```
    Specified by:
    
    setWriter in interface EngineOutput
  - getWriter
```
public Writer getWriter()
```
    Specified by:
    
    getWriter in interface EngineOutput
  - setErrorWriter
```
public void setErrorWriter(Writer writer)
```
    Specified by:
    
    setErrorWriter in interface EngineOutput
  - getErrorWriter
```
public Writer getErrorWriter()
```
    Specified by:
    
    getErrorWriter in interface EngineOutput
  - executeQuery
```
protected Pair<Object,Throwable> executeQuery(String query,
                                              Long scriptDocumentID,
                                              WeakReference<TextDocument> scriptDocument)
```
  - isPrintResultCounters
```
public boolean isPrintResultCounters()
```
  - setPrintResultCounters
```
public void setPrintResultCounters(boolean printResultCounters)
```
  - getScriptDocumentId
```
public long getScriptDocumentId()
```
  - setScriptDocumentId
```
public void setScriptDocumentId(Long scriptDocumentId)
```
  - setScriptDocument
```
public void setScriptDocument(TextDocument textDocument)
```
    Specified by:
    
    setScriptDocument in interface SetScriptDocument
  - getScriptDocument
```
public TextDocument getScriptDocument()
```
    Specified by:
    
    getScriptDocument in interface GetScriptDocument
  - onDataTableCreated
```
protected void onDataTableCreated(QueryExecutor.DataTableCreated ev,
                                  WeakReference<TextDocument> scriptDocument,
                                  Long scriptDocumentId,
                                  Integer dataTableNum)
```
  - store
```
public void store(Map map)
```
    Description copied from interface: MapStore
    
    Сохранение состояния объекта
    
    Specified by:
    
    store in interface MapStore
    
    Parameters:
    
    map - хранилище
  - restore
```
public void restore(Map map)
```
    Description copied from interface: MapStore
    
    Восстановление состояния объекта
    
    Specified by:
    
    restore in interface MapStore
    
    Parameters:
    
    map - хранилище

Class SqlEngine

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

scn

scnChangedSupport

dataSourceName

connectPool

connection

scriptDocumentId

scriptDocument

Constructor Detail

SqlEngine

SqlEngine

Method Detail

getSqlService

scn

nextscn

getScnChangedSupport

hasScnChangedListener

getScnChangedListeners

addScnChangedListener

addScnChangedListener

removeScnChangedListener

removeAllScnChangedListeners

fireScnChangedEvent

getScnChangedEventQueue

addScnChangedEvent

fireScnChangedEvents

fireScnChanged

getDataSourceName

setDataSourceName

getConnectPool

setConnectPool

getFactory

setFactory

compareAndSetFactory

submit

createExecutor

getConnection

getConnection

setConnection

setWriter

getWriter

setErrorWriter

getErrorWriter

executeQuery

isPrintResultCounters

setPrintResultCounters

getScriptDocumentId

setScriptDocumentId

setScriptDocument

getScriptDocument

onDataTableCreated

store

restore