Class SyncLogDAO

java.lang.Object

ru.bgcrm.dao.CommonDAO

org.bgerp.plugin.inventoru.sync1c.dao.SyncLogDAO

public class SyncLogDAO
extends CommonDAO

DAO for inventoru_sync1c_import_log.

Nested Class Summary

Nested classes/interfaces inherited from class CommonDAO

CommonDAO.ObjectExtractor<T>, CommonDAO.RecordUpdater<T>

Field Summary

Fields inherited from class CommonDAO

con, log, SQL_AND, SQL_DELETE, SQL_DELETE_FROM, SQL_DESC, SQL_DISTINCT, SQL_FROM, SQL_GROUP_BY, SQL_INNER_JOIN, SQL_INSERT_IGNORE_INTO, SQL_INSERT_INTO, SQL_LEFT_JOIN, SQL_LIMIT, SQL_ON_DUP_KEY_UPDATE, SQL_ORDER_BY, SQL_REPLACE, SQL_SELECT, SQL_SELECT_ALL_FROM, SQL_SELECT_COUNT_ROWS, SQL_SET, SQL_UNION_ALL, SQL_UPDATE, SQL_VALUES, SQL_VALUES_1, SQL_VALUES_2, SQL_VALUES_3, SQL_VALUES_4, SQL_VALUES_5, SQL_WHERE

Constructor Summary

Constructors

Constructor	Description
SyncLogDAO(Connection con)

Method Summary

Modifier and Type	Method	Description
int	countRecentConsecutiveImportErrors(int instanceId, int limit)	Counts the streak of most recent finished import log records of the instance that ended in 'error' — the streak breaks on the first non-error record.
void	finishImportLog(ImportLog log)	Updates finished_at, items_synced, status, error_text on an existing log record.
List<ImportLog>	getImportLog(int instanceId, int limit)
void	insertImportLog(ImportLog log)	Creates a new import log record with status=running; sets id on the object.

Methods inherited from class CommonDAO

deleteById, foundRows, getById, getGroupedIds, getGroupedIds, getIds, getIds, getPageLimit, getPeriodSql, lastInsertId, setPeriodParamValue, setRecordCount, update, updateColumn, updateIds, updateIds, updateOrInsert

Methods inherited from class Object

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

Constructor Details

SyncLogDAO

public SyncLogDAO(Connection con)

Method Details

insertImportLog

public void insertImportLog(ImportLog log)
                     throws SQLException

Creates a new import log record with status=running; sets id on the object.

Throws:

SQLException

finishImportLog

public void finishImportLog(ImportLog log)
                     throws SQLException

Updates finished_at, items_synced, status, error_text on an existing log record.

Throws:

SQLException

countRecentConsecutiveImportErrors

public int countRecentConsecutiveImportErrors(int instanceId,
 int limit)
                                       throws SQLException

Counts the streak of most recent finished import log records of the instance that ended in 'error' — the streak breaks on the first non-error record. Note: the unit is a log RECORD (one per engineer-warehouse mapping per poller run), not a poller cycle — with several mappings a single cycle against a dead 1C produces several error records at once. Used by ImportPoller to alarm on a persistently unreachable/broken instance, mirroring ExportPoller.alarmIfExhausted.

Throws:

SQLException

getImportLog

public List<ImportLog> getImportLog(int instanceId,
 int limit)
                             throws SQLException

Throws:

SQLException