Package org.bgerp.plugin.inventory.sync1c.dao

Class ExportQueueDAO

java.lang.Object

ru.bgcrm.dao.CommonDAO

org.bgerp.plugin.inventory.sync1c.dao.ExportQueueDAO

public class ExportQueueDAO
extends CommonDAO

DAO for ExportQueue (inventory_sync1c_export_queue table).

Nested Class Summary

Nested classes/interfaces inherited from class ru.bgcrm.dao.CommonDAO

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

Field Summary

Fields inherited from class ru.bgcrm.dao.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
ExportQueueDAO(Connection con)

Method Summary

Modifier and Type	Method	Description
void	add(int processId, int instanceId, String warehouseId)	Inserts or resets a pending queue entry for the given process/instance pair.
void	delete(int id)
static ExportQueue	fromRs(ResultSet rs)
List<ExportQueue>	getListByInstance(int instanceId)	Returns queue entries for a given instance (latest 100, newest first).
List<ExportQueue>	getPending(int maxAttempts)	Returns pending queue entries with attempts less than maxAttempts.
void	updateStatus(int id, String status, int attempts, String error)	Updates status, attempts count and error text for a queue entry.

Methods inherited from class ru.bgcrm.dao.CommonDAO

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

Methods inherited from class java.lang.Object

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

Constructor Details

ExportQueueDAO

public ExportQueueDAO(Connection con)

Method Details

add

public void add(int processId,
 int instanceId,
 String warehouseId)
         throws SQLException

Inserts or resets a pending queue entry for the given process/instance pair. If a record already exists (from a previous export), it is reset to pending so the process can be re-exported after status is reverted and re-applied.

Throws:

SQLException

getPending

public List<ExportQueue> getPending(int maxAttempts)
                             throws SQLException

Returns pending queue entries with attempts less than maxAttempts.

Throws:

SQLException

updateStatus

public void updateStatus(int id,
 String status,
 int attempts,
 String error)
                  throws SQLException

Updates status, attempts count and error text for a queue entry.

Throws:

SQLException

getListByInstance

public List<ExportQueue> getListByInstance(int instanceId)
                                    throws SQLException

Returns queue entries for a given instance (latest 100, newest first).

Throws:

SQLException

delete

public void delete(int id)
            throws SQLException

Throws:

SQLException

fromRs

public static ExportQueue fromRs(ResultSet rs)
                          throws SQLException

Throws:

SQLException