12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394 |
- <?php
- namespace OC\DB;
- use Doctrine\DBAL\Exception\UniqueConstraintViolationException;
- class AdapterSqlite extends Adapter {
-
- public function lockTable($tableName) {
- $this->conn->executeUpdate('BEGIN EXCLUSIVE TRANSACTION');
- }
- public function unlockTable() {
- $this->conn->executeUpdate('COMMIT TRANSACTION');
- }
- public function fixupStatement($statement) {
- $statement = preg_replace('/`(\w+)` ILIKE \?/', 'LOWER($1) LIKE LOWER(?)', $statement);
- $statement = str_replace('`', '"', $statement);
- $statement = str_ireplace('NOW()', 'datetime(\'now\')', $statement);
- $statement = str_ireplace('GREATEST(', 'MAX(', $statement);
- $statement = str_ireplace('UNIX_TIMESTAMP()', 'strftime(\'%s\',\'now\')', $statement);
- return $statement;
- }
-
- public function insertIfNotExist($table, $input, ?array $compare = null) {
- if (empty($compare)) {
- $compare = array_keys($input);
- }
- $fieldList = '`' . implode('`,`', array_keys($input)) . '`';
- $query = "INSERT INTO `$table` ($fieldList) SELECT "
- . str_repeat('?,', count($input) - 1) . '? '
- . " WHERE NOT EXISTS (SELECT 1 FROM `$table` WHERE ";
- $inserts = array_values($input);
- foreach ($compare as $key) {
- $query .= '`' . $key . '`';
- if (is_null($input[$key])) {
- $query .= ' IS NULL AND ';
- } else {
- $inserts[] = $input[$key];
- $query .= ' = ? AND ';
- }
- }
- $query = substr($query, 0, -5);
- $query .= ')';
- try {
- return $this->conn->executeUpdate($query, $inserts);
- } catch (UniqueConstraintViolationException $e) {
-
-
-
-
- return 0;
- }
- }
- public function insertIgnoreConflict(string $table, array $values): int {
- $builder = $this->conn->getQueryBuilder();
- $builder->insert($table);
- $updates = [];
- foreach ($values as $key => $value) {
- $builder->setValue($key, $builder->createNamedParameter($value));
- }
- return $this->conn->executeStatement(
- $builder->getSQL() . ' ON CONFLICT DO NOTHING',
- $builder->getParameters(),
- $builder->getParameterTypes()
- );
- }
- }
|