|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.dhtmlx.connector.DataWrapper
com.dhtmlx.connector.DBDataWrapper
public abstract class DBDataWrapper
The Class DBDataWrapper. Class implements DataWrapper for common DB type
Field Summary | |
---|---|
private java.lang.String |
sequence_name
The sequence name. |
private java.util.HashMap<OperationType,java.lang.String> |
sqls
The set of defined sql strings |
Fields inherited from class com.dhtmlx.connector.DataWrapper |
---|
config, connection |
Constructor Summary | |
---|---|
DBDataWrapper()
|
Method Summary | |
---|---|
void |
attach(OperationType name,
java.lang.String sql)
Attach. |
void |
begin_transaction()
Begin transaction. |
protected java.lang.String |
build_order(java.util.ArrayList<SortingRule> sorts)
Convert sorting rules to sql string |
protected java.lang.String |
build_where(java.util.ArrayList<FilteringRule> rules,
java.lang.String relation)
Convert filtering rules to sql string |
void |
commit_transaction()
Commit transaction. |
private java.lang.String |
delete_query(DataAction data,
DataRequest source)
Generate SQL for delete operation |
void |
delete(DataAction data,
DataRequest source)
Delete data from storage |
abstract java.lang.String |
escape(java.lang.String data)
Escape the data, befor using in SQL |
protected java.sql.Connection |
get_connection()
Gets the connection. |
abstract java.lang.String |
get_new_id(ConnectorResultSet result)
Gets the new id |
java.lang.String |
get_size(DataRequest source)
Gets the size of the data in storage. |
java.lang.String |
get_sql(OperationType name,
java.util.HashMap<java.lang.String,java.lang.String> data)
Gets the sql string for named operation |
ConnectorResultSet |
get_variants(DataRequest source)
Gets the all variations of defined field in the storage |
protected java.sql.Statement |
getStatement()
Gets the statement |
protected java.lang.String |
insert_query(DataAction data,
DataRequest source)
Generate sql for insert query. |
void |
insert(DataAction data,
DataRequest source)
Insert data in storage |
ConnectorResultSet |
query(java.lang.String data)
Executes DB query. |
void |
rollback_transaction()
Rollback transaction. |
protected java.lang.String |
select_query(java.lang.String select,
java.lang.String from,
java.lang.String where,
java.lang.String sort,
java.lang.String start,
java.lang.String count)
Generates sql for select query |
ConnectorResultSet |
select(DataRequest source)
Select data from storage |
void |
sequence(java.lang.String sequence_name)
Sets sequence Sequence used in Oracle to implement auto-id generation |
private java.lang.String |
update_query(DataAction data,
DataRequest source)
Builds the update sql query. |
void |
update(DataAction data,
DataRequest source)
Update data in storage |
Methods inherited from class com.dhtmlx.connector.DataWrapper |
---|
init, is_global_transaction, is_record_transaction, set_transaction_mode |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private java.lang.String sequence_name
private java.util.HashMap<OperationType,java.lang.String> sqls
Constructor Detail |
---|
public DBDataWrapper()
Method Detail |
---|
public abstract java.lang.String escape(java.lang.String data)
data
- the incoming data
public abstract java.lang.String get_new_id(ConnectorResultSet result) throws ConnectorOperationException
result
- the resultset, which contains the new ID
ConnectorOperationException
- the connector operation exceptionpublic void sequence(java.lang.String sequence_name)
sequence_name
- the name of sequenceprotected java.sql.Connection get_connection()
public void attach(OperationType name, java.lang.String sql)
name
- the namesql
- the sqlpublic java.lang.String get_sql(OperationType name, java.util.HashMap<java.lang.String,java.lang.String> data) throws ConnectorConfigException
DataWrapper
get_sql
in class DataWrapper
name
- the name of operationdata
- the hash of data, will be used to fill vars in sql
ConnectorConfigException
- the connector config exceptionpublic void delete(DataAction data, DataRequest source) throws ConnectorOperationException
DataWrapper
delete
in class DataWrapper
data
- the data wrapped in DataAction objectsource
- the source defined by DataRequest object
ConnectorOperationException
- the connector operation exceptionprivate java.lang.String delete_query(DataAction data, DataRequest source)
data
- the datasource
- the source
protected java.lang.String insert_query(DataAction data, DataRequest source)
data
- the datasource
- the source
public java.lang.String get_size(DataRequest source) throws ConnectorOperationException
DataWrapper
get_size
in class DataWrapper
source
- the source defined by DataRequest object
ConnectorOperationException
- the connector operation exceptionpublic ConnectorResultSet get_variants(DataRequest source) throws ConnectorOperationException
DataWrapper
get_variants
in class DataWrapper
source
- the source defined by DataRequest object
ConnectorOperationException
- the connector operation exceptionpublic void insert(DataAction data, DataRequest source) throws ConnectorOperationException
DataWrapper
insert
in class DataWrapper
data
- the data wrapped in DataAction objectsource
- the source defined by DataRequest object
ConnectorOperationException
- the connector operation exceptionpublic ConnectorResultSet select(DataRequest source) throws ConnectorOperationException
DataWrapper
select
in class DataWrapper
source
- the source defined by DataRequest object
ConnectorOperationException
- the connector operation exceptionprotected java.lang.String select_query(java.lang.String select, java.lang.String from, java.lang.String where, java.lang.String sort, java.lang.String start, java.lang.String count)
select
- the list of fieldsfrom
- the name of tablewhere
- the filtering rulessort
- the sorting rulesstart
- the start indexcount
- the count of records to fetch
protected java.lang.String build_where(java.util.ArrayList<FilteringRule> rules, java.lang.String relation)
rules
- the set of filtering rulesrelation
- the name of relation id field
protected java.lang.String build_order(java.util.ArrayList<SortingRule> sorts)
sorts
- the set of sorting rules
public void update(DataAction data, DataRequest source) throws ConnectorOperationException
DataWrapper
update
in class DataWrapper
data
- the data wrapped in DataAction objectsource
- the source defined by DataRequest object
ConnectorOperationException
- the connector operation exceptionprivate java.lang.String update_query(DataAction data, DataRequest source)
data
- the datasource
- the source
public void begin_transaction() throws ConnectorOperationException
DataWrapper
begin_transaction
in class DataWrapper
ConnectorOperationException
- the connector operation exceptionpublic void commit_transaction() throws ConnectorOperationException
DataWrapper
commit_transaction
in class DataWrapper
ConnectorOperationException
- the connector operation exceptionpublic void rollback_transaction() throws ConnectorOperationException
DataWrapper
rollback_transaction
in class DataWrapper
ConnectorOperationException
- the connector operation exceptionprotected java.sql.Statement getStatement() throws java.sql.SQLException
java.sql.SQLException
- the SQL exceptionpublic ConnectorResultSet query(java.lang.String data) throws ConnectorOperationException
data
- the data
ConnectorOperationException
- the connector operation exception
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |