if ($this->driverConnection->
getDatabasePlatform() instanceof MySQLPlatform
) { try { $this->driverConnection->
delete($this->configuration
['table_name'
],
['delivered_at' => '9999-12-31 23:59:59'
]);
} catch (DriverException
$e) { // Ignore the exception
} } get:
$this->driverConnection->
beginTransaction();
try { $query =
$this->
createAvailableMessagesQueryBuilder() ->
orderBy('available_at', 'ASC'
) ->
setMaxResults(1
);
if ($this->driverConnection->
getDatabasePlatform() instanceof OraclePlatform
) { $query->
select('m.id'
);
} // Append pessimistic write lock to FROM clause if db platform supports it
$sql =
$query->
getSQL();
if (($fromPart =
$query->
getQueryPart('from'
)) && ($table =
$fromPart[0
]['table'
] ?? null
)