ru.bgcrm.dao

Class CommonDAO

java.lang.Object

ru.bgcrm.dao.CommonDAO

Direct Known Subclasses:

AbstractDAO, AddressDAO, AddressDistributionDAO, AppointmentDAO, BGBillingDAO, CannedMessageDAO, CommonContractDAO, CommonLinkDAO, ConfigDAO, ConfigHistoryDAO, ContractCustomerDAO, ContractLinkDAO, CounterDAO, CustomerDAO, CustomerGroupDAO, DetourDAO, DirectionDAO, DispatchDAO, DocumentDAO, EntityLogDAO, FileDataDAO, GsmDao, MessageDAO, MovementDAO, NewsDAO, NomenclatureDAO, NomenclatureLinkDao, ParamDAO, ParamGroupDAO, ParamLogDAO, ParamValueDAO, PatternDAO, PaymentDAO, PeriodicDAO, ProcessDAO, ProcessTypeDAO, QueueDAO, RealizationDAO, SavedFilterDAO, SegmentDAO, ShiftDAO, SimDAO, SphinxDAO, StatusChangeDAO, StatusDAO, StorageDAO, TabelDAO, TaskDAO, TmcDAO, TopicDAO, UserDAO, UserGroupDAO, VacancyDAO, WizardDAO, WorkTaskDAO, WorkTypeDAO

public class CommonDAO
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	CommonDAO.ObjectExtractor<T>
protected static class	CommonDAO.RecordUpdater<T extends Id>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.sql.Connection	con
protected java.text.DateFormat	dateFormat_DDMMYYYY
protected java.text.DateFormat	dateFormat_DDMMYYYY_HHMM
protected Logger	log
protected static java.lang.String	SQL_AND
protected static java.lang.String	SQL_DELETE
protected static java.lang.String	SQL_DESC
protected static java.lang.String	SQL_FROM
protected static java.lang.String	SQL_GROUP_BY
protected static java.lang.String	SQL_INNER_JOIN
protected static java.lang.String	SQL_INSERT
protected static java.lang.String	SQL_INSERT_IGNORE
protected static java.lang.String	SQL_LEFT_JOIN
protected static java.lang.String	SQL_LEFT_OUTER_JOIN
protected static java.lang.String	SQL_LIMIT
protected static java.lang.String	SQL_ON_DUP_KEY_UPDATE
protected static java.lang.String	SQL_OR
protected static java.lang.String	SQL_ORDER_BY
protected static java.lang.String	SQL_REPLACE
protected static java.lang.String	SQL_SELECT
protected static java.lang.String	SQL_SELECT_ALL_FROM
protected static java.lang.String	SQL_SELECT_COUNT_ROWS
protected static java.lang.String	SQL_SET
protected static java.lang.String	SQL_UPDATE
protected static java.lang.String	SQL_WHERE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CommonDAO(java.sql.Connection con)

Method Summary

Modifier and Type	Method and Description
protected void	deleteById(java.lang.String tableName, int id)
protected <T> SearchResult<T>	execute(SearchResult<T> result, java.lang.String query, ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare, ThrowableFunction<java.sql.ResultSet,java.util.Collection<T>,java.sql.SQLException> builder)
protected <T> T	execute(java.lang.String query, ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare, ThrowableFunction<java.sql.ResultSet,T,java.sql.SQLException> builder)
protected <T> T	execute(java.lang.String query, ThrowableFunction<java.sql.ResultSet,T,java.sql.SQLException> builder)
protected int	executeInsert(java.lang.String query, ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare)
protected int	executeUpdate(java.lang.String query, ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare)
protected <T> T	getById(java.lang.String tableName, int id, CommonDAO.ObjectExtractor<T> extractor)
protected int	getFoundRows(java.sql.Connection con)
protected int	getFoundRows(java.sql.PreparedStatement ps)
protected java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>	getGroupedIds(java.lang.String tableName, java.lang.String linkColumn, java.lang.String selectColumn)
protected java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>>	getGroupedIds(java.lang.String tableName, java.lang.String linkColumn, java.lang.String selectColumn, java.lang.String posColumn)
protected java.util.Set<java.lang.Integer>	getIds(java.lang.String tableName, java.lang.String linkColumn, java.lang.String selectColumn, int id)
protected java.util.List<java.lang.Integer>	getIds(java.lang.String tableName, java.lang.String linkColumn, java.lang.String selectColumn, java.lang.String posColumn, int id)
static java.lang.String	getLikePattern(java.lang.String substring, java.lang.String mode)
static java.lang.String	getLikePatternEnd(java.lang.String substring)
static java.lang.String	getLikePatternStart(java.lang.String substring)
static java.lang.String	getLikePatternSub(java.lang.String substring)
protected java.lang.String	getMySQLLimit(Page page)
protected java.lang.String	getPeriodSql(Period period, java.lang.String fieldName)
protected int	lastInsertId(java.sql.PreparedStatement ps)
protected int	setPeriodParamValue(Period period, java.sql.PreparedStatement ps, int index)
protected void	setRecordCount(Page page, java.sql.PreparedStatement ps)
protected void	sqlToBgException(java.sql.SQLException e)
protected <T extends Id> void	update(T record, CommonDAO.RecordUpdater<T> updater)
void	updateColumn(java.lang.String tableName, int id, java.lang.String columnName, java.lang.String value)
protected void	updateIds(java.lang.String tableName, java.lang.String linkColumn, java.lang.String valueColumn, java.lang.Object id, java.util.Set<java.lang.Integer> values)
protected void	updateIds(java.lang.String tableName, java.lang.String linkColumn, java.lang.String valueColumn, java.lang.String posColumn, int id, java.util.List<java.lang.Integer> values)

Methods inherited from class java.lang.Object

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

Field Detail

SQL_SELECT

protected static final java.lang.String SQL_SELECT

See Also:

Constant Field Values

SQL_SELECT_ALL_FROM

protected static final java.lang.String SQL_SELECT_ALL_FROM

See Also:

Constant Field Values

SQL_SELECT_COUNT_ROWS

protected static final java.lang.String SQL_SELECT_COUNT_ROWS

See Also:

Constant Field Values

SQL_INSERT_IGNORE

protected static final java.lang.String SQL_INSERT_IGNORE

See Also:

Constant Field Values

SQL_INSERT

protected static final java.lang.String SQL_INSERT

See Also:

Constant Field Values

SQL_SET

protected static final java.lang.String SQL_SET

See Also:

Constant Field Values

SQL_UPDATE

protected static final java.lang.String SQL_UPDATE

See Also:

Constant Field Values

SQL_DELETE

protected static final java.lang.String SQL_DELETE

See Also:

Constant Field Values

SQL_FROM

protected static final java.lang.String SQL_FROM

See Also:

Constant Field Values

SQL_LEFT_JOIN

protected static final java.lang.String SQL_LEFT_JOIN

See Also:

Constant Field Values

SQL_LEFT_OUTER_JOIN

protected static final java.lang.String SQL_LEFT_OUTER_JOIN

See Also:

Constant Field Values

SQL_INNER_JOIN

protected static final java.lang.String SQL_INNER_JOIN

See Also:

Constant Field Values

SQL_WHERE

protected static final java.lang.String SQL_WHERE

See Also:

Constant Field Values

SQL_ORDER_BY

protected static final java.lang.String SQL_ORDER_BY

See Also:

Constant Field Values

SQL_GROUP_BY

protected static final java.lang.String SQL_GROUP_BY

See Also:

Constant Field Values

SQL_AND

protected static final java.lang.String SQL_AND

See Also:

Constant Field Values

SQL_OR

protected static final java.lang.String SQL_OR

See Also:

Constant Field Values

SQL_LIMIT

protected static final java.lang.String SQL_LIMIT

See Also:

Constant Field Values

SQL_DESC

protected static final java.lang.String SQL_DESC

See Also:

Constant Field Values

SQL_REPLACE

protected static final java.lang.String SQL_REPLACE

See Also:

Constant Field Values

SQL_ON_DUP_KEY_UPDATE

protected static final java.lang.String SQL_ON_DUP_KEY_UPDATE

See Also:

Constant Field Values

dateFormat_DDMMYYYY

protected java.text.DateFormat dateFormat_DDMMYYYY

dateFormat_DDMMYYYY_HHMM

protected java.text.DateFormat dateFormat_DDMMYYYY_HHMM

log

protected Logger log

con

protected java.sql.Connection con

Constructor Detail

CommonDAO

protected CommonDAO(java.sql.Connection con)

Method Detail

lastInsertId

protected int lastInsertId(java.sql.PreparedStatement ps)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

getFoundRows

protected int getFoundRows(java.sql.PreparedStatement ps)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

getFoundRows

protected int getFoundRows(java.sql.Connection con)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

getLikePattern

public static java.lang.String getLikePattern(java.lang.String substring,
                                              java.lang.String mode)

getLikePatternSub

public static java.lang.String getLikePatternSub(java.lang.String substring)

getLikePatternStart

public static java.lang.String getLikePatternStart(java.lang.String substring)

getLikePatternEnd

public static java.lang.String getLikePatternEnd(java.lang.String substring)

getMySQLLimit

protected java.lang.String getMySQLLimit(Page page)

setRecordCount

protected void setRecordCount(Page page,
                              java.sql.PreparedStatement ps)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

getPeriodSql

protected java.lang.String getPeriodSql(Period period,
                                        java.lang.String fieldName)

setPeriodParamValue

protected int setPeriodParamValue(Period period,
                                  java.sql.PreparedStatement ps,
                                  int index)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

getIds

protected java.util.Set<java.lang.Integer> getIds(java.lang.String tableName,
                                                  java.lang.String linkColumn,
                                                  java.lang.String selectColumn,
                                                  int id)
                                           throws BGException

Throws:

BGException

getIds

protected java.util.List<java.lang.Integer> getIds(java.lang.String tableName,
                                                   java.lang.String linkColumn,
                                                   java.lang.String selectColumn,
                                                   java.lang.String posColumn,
                                                   int id)
                                            throws BGException

Throws:

BGException

getGroupedIds

protected java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> getGroupedIds(java.lang.String tableName,
                                                                                          java.lang.String linkColumn,
                                                                                          java.lang.String selectColumn)
                                                                                   throws BGException

Throws:

BGException

getGroupedIds

protected java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> getGroupedIds(java.lang.String tableName,
                                                                                           java.lang.String linkColumn,
                                                                                           java.lang.String selectColumn,
                                                                                           java.lang.String posColumn)
                                                                                    throws BGException

Throws:

BGException

getById

protected <T> T getById(java.lang.String tableName,
                        int id,
                        CommonDAO.ObjectExtractor<T> extractor)
                 throws BGException

Throws:

BGException

deleteById

protected void deleteById(java.lang.String tableName,
                          int id)
                   throws BGException

Throws:

BGException

update

protected <T extends Id> void update(T record,
                                     CommonDAO.RecordUpdater<T> updater)
                              throws BGException

Throws:

BGException

updateIds

protected void updateIds(java.lang.String tableName,
                         java.lang.String linkColumn,
                         java.lang.String valueColumn,
                         java.lang.Object id,
                         java.util.Set<java.lang.Integer> values)
                  throws BGException

Throws:

BGException

updateIds

protected void updateIds(java.lang.String tableName,
                         java.lang.String linkColumn,
                         java.lang.String valueColumn,
                         java.lang.String posColumn,
                         int id,
                         java.util.List<java.lang.Integer> values)
                  throws BGException

Throws:

BGException

updateColumn

public void updateColumn(java.lang.String tableName,
                         int id,
                         java.lang.String columnName,
                         java.lang.String value)
                  throws BGException

Throws:

BGException

sqlToBgException

protected void sqlToBgException(java.sql.SQLException e)
                         throws BGException

Throws:

BGException

execute

protected <T> SearchResult<T> execute(SearchResult<T> result,
                                      java.lang.String query,
                                      ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare,
                                      ThrowableFunction<java.sql.ResultSet,java.util.Collection<T>,java.sql.SQLException> builder)
                               throws BGException

Throws:

BGException

execute

protected <T> T execute(java.lang.String query,
                        ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare,
                        ThrowableFunction<java.sql.ResultSet,T,java.sql.SQLException> builder)
                 throws BGException

Throws:

BGException

execute

protected <T> T execute(java.lang.String query,
                        ThrowableFunction<java.sql.ResultSet,T,java.sql.SQLException> builder)
                 throws BGException

Throws:

BGException

executeUpdate

protected int executeUpdate(java.lang.String query,
                            ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare)
                     throws BGException

Throws:

BGException

executeInsert

protected int executeInsert(java.lang.String query,
                            ThrowableConsumer<java.sql.PreparedStatement,java.sql.SQLException> prepare)
                     throws BGException

Throws:

BGException