{

// skip leading spaces

while ((aFromStringCItr != aToStringCItr) && isspace(*aFromStringCItr)) aFromStringCItr++;

// skip trailing spaces

while ((aFromStringCItr != aToStringCItr) && isspace(*(aToStringCItr - 1))) aToStringCItr--;

return std::string(aFromStringCItr, aToStringCItr);

{

std::string connectionString;

for (std::map<std::string, std::string>::const_iterator citr = anOptionsMap.begin(); citr != anOptionsMap.end(); ++citr)

{

connectionString.append(citr->first);

connectionString.append("=");

connectionString.append(citr->second);

connectionString.append(" ");

}

return connectionString;

Poco::SQL::AbstractSessionImpl<SessionImpl>(aConnectionString, aLoginTimeout)

{

setProperty("handle", static_cast<SessionHandle*>(&_sessionHandle));

setConnectionTimeout(CONNECTION_TIMEOUT_DEFAULT);

open();

{

if (connectionString() != aConnectionString)

{

if (isConnected())

{

throw ConnectionException("Session already connected");

}

if (! aConnectionString.empty())

{

setConnectionString(aConnectionString);

}

}

poco_assert_dbg (! connectionString().empty());

unsigned int timeout = static_cast<unsigned int>(getLoginTimeout());

// PostgreSQL connections can use environment variables for connection parameters.

// As such it is not an error if they are not part of the connection string

std::map <std::string, std::string> optionsMap;

// Default values

optionsMap["connect_timeout"] = Poco::NumberFormatter::format(timeout);

const std::string& connString = connectionString();

for (std::string::const_iterator start = connString.begin();;)

{

std::string::const_iterator finish = std::find(start, connString.end(), ' '); // space is the separator between keyword=value pairs

std::string::const_iterator middle = std::find(start, finish, '=');

if (middle == finish)

{

throw PostgreSQLException("create session: bad connection string format, cannot find '='");

}

optionsMap[ copyStripped(start, middle) ] = copyStripped(middle + 1, finish);

if ((finish == connString.end()) || (finish + 1 == connString.end())) break;

start = finish + 1;

}

// Real connect

_sessionHandle.connect(createConnectionStringFromOptionsMap(optionsMap));

addFeature("autoCommit",

&SessionImpl::setAutoCommit,

&SessionImpl::isAutoCommit);

addFeature("asynchronousCommit",

&SessionImpl::setAutoCommit,

&SessionImpl::isAutoCommit);

{

if (isConnected())

{

_sessionHandle.disconnect();

}

{

if (isTransaction())

{

throw Poco::InvalidAccessException("Already in transaction.");

}

_sessionHandle.startTransaction();

{

// Not an error to issue a COMMIT without a preceding BEGIN

_sessionHandle.commit();

{

// Not an error to issue a ROLLBACK without a preceding BEGIN

_sessionHandle.rollback();