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 |