| Index: Source/modules/webdatabase/SQLTransactionBackendSync.cpp
|
| diff --git a/Source/modules/webdatabase/SQLTransactionBackendSync.cpp b/Source/modules/webdatabase/SQLTransactionBackendSync.cpp
|
| deleted file mode 100644
|
| index 1f0d0008d28cbda98f41f167f2757b2486ef8beb..0000000000000000000000000000000000000000
|
| --- a/Source/modules/webdatabase/SQLTransactionBackendSync.cpp
|
| +++ /dev/null
|
| @@ -1,261 +0,0 @@
|
| -/*
|
| - * Copyright (C) 2010 Google Inc. All rights reserved.
|
| - * Copyright (C) 2013 Apple Inc. All rights reserved.
|
| - *
|
| - * Redistribution and use in source and binary forms, with or without
|
| - * modification, are permitted provided that the following conditions are
|
| - * met:
|
| - *
|
| - * * Redistributions of source code must retain the above copyright
|
| - * notice, this list of conditions and the following disclaimer.
|
| - * * Redistributions in binary form must reproduce the above
|
| - * copyright notice, this list of conditions and the following disclaimer
|
| - * in the documentation and/or other materials provided with the
|
| - * distribution.
|
| - * * Neither the name of Google Inc. nor the names of its
|
| - * contributors may be used to endorse or promote products derived from
|
| - * this software without specific prior written permission.
|
| - *
|
| - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
| - * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
| - * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
| - * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
| - * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
| - * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
| - * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
| - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
| - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
| - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
| - * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
| - */
|
| -
|
| -#include "config.h"
|
| -#include "modules/webdatabase/SQLTransactionBackendSync.h"
|
| -
|
| -#include "bindings/core/v8/ExceptionState.h"
|
| -#include "core/dom/ExceptionCode.h"
|
| -#include "core/dom/ExecutionContext.h"
|
| -#include "modules/webdatabase/sqlite/SQLValue.h"
|
| -#include "modules/webdatabase/sqlite/SQLiteTransaction.h"
|
| -#include "modules/webdatabase/DatabaseAuthorizer.h"
|
| -#include "modules/webdatabase/DatabaseContext.h"
|
| -#include "modules/webdatabase/DatabaseSync.h"
|
| -#include "modules/webdatabase/SQLError.h"
|
| -#include "modules/webdatabase/SQLResultSet.h"
|
| -#include "modules/webdatabase/SQLStatementSync.h"
|
| -#include "modules/webdatabase/SQLTransactionClient.h"
|
| -#include "modules/webdatabase/SQLTransactionSync.h"
|
| -#include "modules/webdatabase/SQLTransactionSyncCallback.h"
|
| -#include "wtf/PassRefPtr.h"
|
| -#include "wtf/RefPtr.h"
|
| -
|
| -namespace blink {
|
| -
|
| -SQLTransactionBackendSync::SQLTransactionBackendSync(DatabaseSync* db, PassOwnPtrWillBeRawPtr<SQLTransactionSyncCallback> callback, bool readOnly)
|
| - : m_database(db)
|
| - , m_callback(callback)
|
| - , m_readOnly(readOnly)
|
| - , m_hasVersionMismatch(false)
|
| - , m_modifiedDatabase(false)
|
| - , m_transactionClient(adoptPtr(new SQLTransactionClient()))
|
| -{
|
| - ASSERT(m_database->executionContext()->isContextThread());
|
| -}
|
| -
|
| -void SQLTransactionBackendSync::rollbackIfInProgress()
|
| -{
|
| - ASSERT(!m_database->executionContext() || m_database->executionContext()->isContextThread());
|
| - if (m_sqliteTransaction && m_sqliteTransaction->inProgress())
|
| - rollback();
|
| -}
|
| -
|
| -SQLTransactionBackendSync::~SQLTransactionBackendSync()
|
| -{
|
| -#if ENABLE(OILPAN)
|
| - ASSERT(!m_sqliteTransaction || !m_sqliteTransaction->inProgress());
|
| -#else
|
| - rollbackIfInProgress();
|
| -#endif
|
| -}
|
| -
|
| -void SQLTransactionBackendSync::trace(Visitor* visitor)
|
| -{
|
| - visitor->trace(m_database);
|
| - visitor->trace(m_callback);
|
| -}
|
| -
|
| -PassRefPtrWillBeRawPtr<SQLResultSet> SQLTransactionBackendSync::executeSQL(const String& sqlStatement, const Vector<SQLValue>& arguments, ExceptionState& exceptionState)
|
| -{
|
| - ASSERT(m_database->executionContext()->isContextThread());
|
| -
|
| - m_database->setLastErrorMessage("");
|
| -
|
| - if (!m_database->opened()) {
|
| - m_database->setLastErrorMessage("cannot executeSQL because the database is not open");
|
| - exceptionState.throwDOMException(UnknownError, SQLError::unknownErrorMessage);
|
| - return nullptr;
|
| - }
|
| -
|
| - if (m_hasVersionMismatch) {
|
| - m_database->setLastErrorMessage("cannot executeSQL because there is a version mismatch");
|
| - exceptionState.throwDOMException(VersionError, SQLError::versionErrorMessage);
|
| - return nullptr;
|
| - }
|
| -
|
| - if (sqlStatement.isEmpty())
|
| - return nullptr;
|
| -
|
| - int permissions = DatabaseAuthorizer::ReadWriteMask;
|
| - if (!m_database->databaseContext()->allowDatabaseAccess())
|
| - permissions |= DatabaseAuthorizer::NoAccessMask;
|
| - else if (m_readOnly)
|
| - permissions |= DatabaseAuthorizer::ReadOnlyMask;
|
| -
|
| - SQLStatementSync statement(sqlStatement, arguments, permissions);
|
| -
|
| - m_database->resetAuthorizer();
|
| - bool retryStatement = true;
|
| - RefPtrWillBeRawPtr<SQLResultSet> resultSet;
|
| - while (retryStatement) {
|
| - retryStatement = false;
|
| - resultSet = statement.execute(m_database.get(), exceptionState);
|
| - if (!resultSet) {
|
| - if (m_sqliteTransaction->wasRolledBackBySqlite())
|
| - return nullptr;
|
| -
|
| - if (exceptionState.code() == QuotaExceededError) {
|
| - if (m_transactionClient->didExceedQuota(database())) {
|
| - exceptionState.clearException();
|
| - retryStatement = true;
|
| - } else {
|
| - m_database->setLastErrorMessage("there was not enough remaining storage space");
|
| - return nullptr;
|
| - }
|
| - }
|
| - }
|
| - }
|
| -
|
| - if (m_database->lastActionChangedDatabase())
|
| - m_modifiedDatabase = true;
|
| -
|
| - return resultSet.release();
|
| -}
|
| -
|
| -void SQLTransactionBackendSync::begin(ExceptionState& exceptionState)
|
| -{
|
| - ASSERT(m_database->executionContext()->isContextThread());
|
| - if (!m_database->opened()) {
|
| - m_database->reportStartTransactionResult(1, SQLError::UNKNOWN_ERR, 0);
|
| - m_database->setLastErrorMessage("cannot begin transaction because the database is not open");
|
| - exceptionState.throwDOMException(UnknownError, SQLError::unknownErrorMessage);
|
| - return;
|
| - }
|
| -
|
| - ASSERT(!m_database->sqliteDatabase().transactionInProgress());
|
| -
|
| - // Set the maximum usage for this transaction if this transactions is not read-only.
|
| - if (!m_readOnly)
|
| - m_database->sqliteDatabase().setMaximumSize(m_database->maximumSize());
|
| -
|
| - ASSERT(!m_sqliteTransaction);
|
| - m_sqliteTransaction = adoptPtr(new SQLiteTransaction(m_database->sqliteDatabase(), m_readOnly));
|
| -
|
| - m_database->resetDeletes();
|
| - m_database->disableAuthorizer();
|
| - m_sqliteTransaction->begin();
|
| - m_database->enableAuthorizer();
|
| -
|
| - // Check if begin() succeeded.
|
| - if (!m_sqliteTransaction->inProgress()) {
|
| - ASSERT(!m_database->sqliteDatabase().transactionInProgress());
|
| - m_database->reportStartTransactionResult(2, SQLError::DATABASE_ERR, m_database->sqliteDatabase().lastError());
|
| - m_database->setLastErrorMessage("unable to begin transaction",
|
| - m_database->sqliteDatabase().lastError(), m_database->sqliteDatabase().lastErrorMsg());
|
| - m_sqliteTransaction.clear();
|
| - exceptionState.throwDOMException(SQLDatabaseError, "Unable to begin transaction.");
|
| - return;
|
| - }
|
| -
|
| - // Note: We intentionally retrieve the actual version even with an empty expected version.
|
| - // In multi-process browsers, we take this opportinutiy to update the cached value for
|
| - // the actual version. In single-process browsers, this is just a map lookup.
|
| - String actualVersion;
|
| - if (!m_database->getActualVersionForTransaction(actualVersion)) {
|
| - m_database->reportStartTransactionResult(3, SQLError::DATABASE_ERR, m_database->sqliteDatabase().lastError());
|
| - m_database->setLastErrorMessage("unable to read version",
|
| - m_database->sqliteDatabase().lastError(), m_database->sqliteDatabase().lastErrorMsg());
|
| - rollback();
|
| - exceptionState.throwDOMException(SQLDatabaseError, "Unable to read version.");
|
| - return;
|
| - }
|
| - m_hasVersionMismatch = !m_database->expectedVersion().isEmpty() && (m_database->expectedVersion() != actualVersion);
|
| - m_database->reportStartTransactionResult(0, -1, 0); // OK
|
| -}
|
| -
|
| -void SQLTransactionBackendSync::execute(ExceptionState& exceptionState)
|
| -{
|
| - ASSERT(m_database->executionContext()->isContextThread());
|
| - if (!m_database->opened() || (m_callback && !m_callback->handleEvent(SQLTransactionSync::from(this)))) {
|
| - if (m_database->lastErrorMessage().isEmpty())
|
| - m_database->setLastErrorMessage("failed to execute transaction callback");
|
| - m_callback.clear();
|
| - exceptionState.throwDOMException(UnknownError, SQLError::unknownErrorMessage);
|
| - return;
|
| - }
|
| -
|
| - m_callback.clear();
|
| -}
|
| -
|
| -void SQLTransactionBackendSync::commit(ExceptionState& exceptionState)
|
| -{
|
| - ASSERT(m_database->executionContext()->isContextThread());
|
| - if (!m_database->opened()) {
|
| - m_database->reportCommitTransactionResult(1, SQLError::UNKNOWN_ERR, 0);
|
| - m_database->setLastErrorMessage("unable to commit transaction because the database is not open.");
|
| - exceptionState.throwDOMException(UnknownError, SQLError::unknownErrorMessage);
|
| - return;
|
| - }
|
| -
|
| - ASSERT(m_sqliteTransaction);
|
| -
|
| - m_database->disableAuthorizer();
|
| - m_sqliteTransaction->commit();
|
| - m_database->enableAuthorizer();
|
| -
|
| - // If the commit failed, the transaction will still be marked as "in progress"
|
| - if (m_sqliteTransaction->inProgress()) {
|
| - m_database->reportCommitTransactionResult(2, SQLError::DATABASE_ERR, m_database->sqliteDatabase().lastError());
|
| - m_database->setLastErrorMessage("unable to commit transaction",
|
| - m_database->sqliteDatabase().lastError(), m_database->sqliteDatabase().lastErrorMsg());
|
| - exceptionState.throwDOMException(SQLDatabaseError, "Unable to commit transaction.");
|
| - return;
|
| - }
|
| -
|
| - m_sqliteTransaction.clear();
|
| -
|
| - // Vacuum the database if anything was deleted.
|
| - if (m_database->hadDeletes())
|
| - m_database->incrementalVacuumIfNeeded();
|
| -
|
| - // The commit was successful. If the transaction modified this database, notify the delegates.
|
| - if (m_modifiedDatabase)
|
| - m_transactionClient->didCommitWriteTransaction(database());
|
| -
|
| - m_database->reportCommitTransactionResult(0, -1, 0); // OK
|
| -}
|
| -
|
| -// This can be called during GC. Do not allocate new on-heap objects.
|
| -void SQLTransactionBackendSync::rollback()
|
| -{
|
| - ASSERT(!m_database->executionContext() || m_database->executionContext()->isContextThread());
|
| - m_database->disableAuthorizer();
|
| - if (m_sqliteTransaction) {
|
| - m_sqliteTransaction->rollback();
|
| - m_sqliteTransaction.clear();
|
| - }
|
| - m_database->enableAuthorizer();
|
| -
|
| - ASSERT(!m_database->sqliteDatabase().transactionInProgress());
|
| -}
|
| -
|
| -} // namespace blink
|
|
|