const std::string& connect,

const std::string& source,

const std::string& destination):

_connector(connector),

_connect(connect),

_source(source),

_destination(destination)

{

open();

{

if (_connector.empty() || _connect.empty())

throw IllegalStateException("Connector and connect string must be non-empty.");

_pSession = new Session(_connector, _connect);

const std::string& connect,

const std::string& sourceTable,

const std::string& destinationTable):

ArchiveStrategy(connector, connect, sourceTable, destinationTable)

{

initStatements();

{

if (!session().isConnected()) open();

DateTime now;

_archiveDateTime = now - _maxAge;

getCountStatement().execute();

if (_archiveCount > 0)

{

getCopyStatement().execute();

getDeleteStatement().execute();

}

{

std::string src = getSource();

std::string dest = getDestination();

setCountStatement();

_archiveCount = 0;

std::string sql;

Poco::format(sql, "SELECT COUNT(*) FROM %s WHERE DateTime < ?", src);

getCountStatement() << sql, into(_archiveCount), use(_archiveDateTime);

setCopyStatement();

sql.clear();

Poco::format(sql, "INSERT INTO %s SELECT * FROM %s WHERE DateTime < ?", dest, src);

getCopyStatement() << sql, use(_archiveDateTime);

setDeleteStatement();

sql.clear();

Poco::format(sql, "DELETE FROM %s WHERE DateTime < ?", src);

getDeleteStatement() << sql, use(_archiveDateTime);

{

std::string::const_iterator it = age.begin();

std::string::const_iterator end = age.end();

int n = 0;

while (it != end && Ascii::isSpace(*it)) ++it;

while (it != end && Ascii::isDigit(*it)) { n *= 10; n += *it++ - '0'; }

while (it != end && Ascii::isSpace(*it)) ++it;

std::string unit;

while (it != end && Ascii::isAlpha(*it)) unit += *it++;

Timespan::TimeDiff factor = Timespan::SECONDS;

if (unit == "minutes")

factor = Timespan::MINUTES;

else if (unit == "hours")

factor = Timespan::HOURS;

else if (unit == "days")

factor = Timespan::DAYS;

else if (unit == "weeks")

factor = 7*Timespan::DAYS;

else if (unit == "months")

factor = 30*Timespan::DAYS;

else if (unit != "seconds")

throw InvalidArgumentException("setMaxAge", age);

_maxAge = factor * n;