Home | History | Annotate | Download | only in storage 
      1 /*
      2  * Copyright (C) 2011 Google Inc. All rights reserved.
      3  *
      4  * Redistribution and use in source and binary forms, with or without
      5  * modification, are permitted provided that the following conditions
      6  * are met:
      7  *
      8  * 1.  Redistributions of source code must retain the above copyright
      9  *     notice, this list of conditions and the following disclaimer.
     10  * 2.  Redistributions in binary form must reproduce the above copyright
     11  *     notice, this list of conditions and the following disclaimer in the
     12  *     documentation and/or other materials provided with the distribution.
     13  *
     14  * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY
     15  * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     16  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
     17  * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY
     18  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
     19  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
     20  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
     21  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     22  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     23  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     24  */
     25 
     26 #include "config.h"
     27 #include "IDBIndexBackendImpl.h"
     28 
     29 #if ENABLE(INDEXED_DATABASE)
     30 
     31 #include "CrossThreadTask.h"
     32 #include "IDBBackingStore.h"
     33 #include "IDBCallbacks.h"
     34 #include "IDBCursorBackendImpl.h"
     35 #include "IDBDatabaseBackendImpl.h"
     36 #include "IDBDatabaseException.h"
     37 #include "IDBKey.h"
     38 #include "IDBKeyRange.h"
     39 #include "IDBObjectStoreBackendImpl.h"
     40 
     41 namespace WebCore {
     42 
     43 IDBIndexBackendImpl::IDBIndexBackendImpl(IDBBackingStore* backingStore, int64_t databaseId, const IDBObjectStoreBackendImpl* objectStoreBackend, int64_t id, const String& name, const String& storeName, const String& keyPath, bool unique)
     44     : m_backingStore(backingStore)
     45     , m_databaseId(databaseId)
     46     , m_objectStoreBackend(objectStoreBackend)
     47     , m_id(id)
     48     , m_name(name)
     49     , m_storeName(storeName)
     50     , m_keyPath(keyPath)
     51     , m_unique(unique)
     52 {
     53 }
     54 
     55 IDBIndexBackendImpl::IDBIndexBackendImpl(IDBBackingStore* backingStore, int64_t databaseId, const IDBObjectStoreBackendImpl* objectStoreBackend, const String& name, const String& storeName, const String& keyPath, bool unique)
     56     : m_backingStore(backingStore)
     57     , m_databaseId(databaseId)
     58     , m_objectStoreBackend(objectStoreBackend)
     59     , m_id(InvalidId)
     60     , m_name(name)
     61     , m_storeName(storeName)
     62     , m_keyPath(keyPath)
     63     , m_unique(unique)
     64 {
     65 }
     66 
     67 IDBIndexBackendImpl::~IDBIndexBackendImpl()
     68 {
     69 }
     70 
     71 void IDBIndexBackendImpl::openCursorInternal(ScriptExecutionContext*, PassRefPtr<IDBIndexBackendImpl> index, PassRefPtr<IDBKeyRange> range, unsigned short untypedDirection, IDBCursorBackendInterface::CursorType cursorType, PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<IDBTransactionBackendInterface> transaction)
     72 {
     73     IDBCursor::Direction direction = static_cast<IDBCursor::Direction>(untypedDirection);
     74 
     75     RefPtr<IDBBackingStore::Cursor> backingStoreCursor;
     76 
     77     switch (cursorType) {
     78     case IDBCursorBackendInterface::IndexKeyCursor:
     79         backingStoreCursor = index->m_backingStore->openIndexKeyCursor(index->m_databaseId, index->m_objectStoreBackend->id(), index->id(), range.get(), direction);
     80         break;
     81     case IDBCursorBackendInterface::IndexCursor:
     82         backingStoreCursor = index->m_backingStore->openIndexCursor(index->m_databaseId, index->m_objectStoreBackend->id(), index->id(), range.get(), direction);
     83         break;
     84     case IDBCursorBackendInterface::ObjectStoreCursor:
     85     case IDBCursorBackendInterface::InvalidCursorType:
     86         ASSERT_NOT_REACHED();
     87         break;
     88     }
     89 
     90     if (!backingStoreCursor) {
     91         callbacks->onSuccess(SerializedScriptValue::nullValue());
     92         return;
     93     }
     94 
     95     ExceptionCode ec = 0;
     96     RefPtr<IDBObjectStoreBackendInterface> objectStore = transaction->objectStore(index->m_storeName, ec);
     97     ASSERT(objectStore && !ec);
     98 
     99     RefPtr<IDBCursorBackendInterface> cursor = IDBCursorBackendImpl::create(backingStoreCursor.get(), direction, cursorType, transaction.get(), objectStore.get());
    100     callbacks->onSuccess(cursor.release());
    101 }
    102 
    103 void IDBIndexBackendImpl::openCursor(PassRefPtr<IDBKeyRange> prpKeyRange, unsigned short direction, PassRefPtr<IDBCallbacks> prpCallbacks, IDBTransactionBackendInterface* transactionPtr, ExceptionCode& ec)
    104 {
    105     RefPtr<IDBIndexBackendImpl> index = this;
    106     RefPtr<IDBKeyRange> keyRange = prpKeyRange;
    107     RefPtr<IDBCallbacks> callbacks = prpCallbacks;
    108     RefPtr<IDBTransactionBackendInterface> transaction = transactionPtr;
    109     if (!transaction->scheduleTask(createCallbackTask(&openCursorInternal, index, keyRange, direction, IDBCursorBackendInterface::IndexCursor, callbacks, transaction)))
    110         ec = IDBDatabaseException::NOT_ALLOWED_ERR;
    111 }
    112 
    113 void IDBIndexBackendImpl::openKeyCursor(PassRefPtr<IDBKeyRange> prpKeyRange, unsigned short direction, PassRefPtr<IDBCallbacks> prpCallbacks, IDBTransactionBackendInterface* transactionPtr, ExceptionCode& ec)
    114 {
    115     RefPtr<IDBIndexBackendImpl> index = this;
    116     RefPtr<IDBKeyRange> keyRange = prpKeyRange;
    117     RefPtr<IDBCallbacks> callbacks = prpCallbacks;
    118     RefPtr<IDBTransactionBackendInterface> transaction = transactionPtr;
    119     if (!transaction->scheduleTask(createCallbackTask(&openCursorInternal, index, keyRange, direction, IDBCursorBackendInterface::IndexKeyCursor, callbacks, transaction)))
    120         ec = IDBDatabaseException::NOT_ALLOWED_ERR;
    121 }
    122 
    123 void IDBIndexBackendImpl::getInternal(ScriptExecutionContext*, PassRefPtr<IDBIndexBackendImpl> index, PassRefPtr<IDBKey> key, bool getObject, PassRefPtr<IDBCallbacks> callbacks)
    124 {
    125     // FIXME: Split getInternal into two functions, getting rid off |getObject|.
    126     if (getObject) {
    127         String value = index->m_backingStore->getObjectViaIndex(index->m_databaseId, index->m_objectStoreBackend->id(), index->id(), *key);
    128         if (value.isNull()) {
    129             callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::NOT_FOUND_ERR, "Key does not exist in the index."));
    130             return;
    131         }
    132         callbacks->onSuccess(SerializedScriptValue::createFromWire(value));
    133     } else {
    134         RefPtr<IDBKey> keyResult = index->m_backingStore->getPrimaryKeyViaIndex(index->m_databaseId, index->m_objectStoreBackend->id(), index->id(), *key);
    135         if (!keyResult) {
    136             callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::NOT_FOUND_ERR, "Key does not exist in the index."));
    137             return;
    138         }
    139         callbacks->onSuccess(keyResult.get());
    140     }
    141 }
    142 
    143 void IDBIndexBackendImpl::get(PassRefPtr<IDBKey> prpKey, PassRefPtr<IDBCallbacks> prpCallbacks, IDBTransactionBackendInterface* transaction, ExceptionCode& ec)
    144 {
    145     RefPtr<IDBIndexBackendImpl> index = this;
    146     RefPtr<IDBKey> key = prpKey;
    147     RefPtr<IDBCallbacks> callbacks = prpCallbacks;
    148     if (!transaction->scheduleTask(createCallbackTask(&getInternal, index, key, true, callbacks)))
    149         ec = IDBDatabaseException::NOT_ALLOWED_ERR;
    150 }
    151 
    152 void IDBIndexBackendImpl::getKey(PassRefPtr<IDBKey> prpKey, PassRefPtr<IDBCallbacks> prpCallbacks, IDBTransactionBackendInterface* transaction, ExceptionCode& ec)
    153 {
    154     RefPtr<IDBIndexBackendImpl> index = this;
    155     RefPtr<IDBKey> key = prpKey;
    156     RefPtr<IDBCallbacks> callbacks = prpCallbacks;
    157     if (!transaction->scheduleTask(createCallbackTask(&getInternal, index, key, false, callbacks)))
    158         ec = IDBDatabaseException::NOT_ALLOWED_ERR;
    159 }
    160 
    161 bool IDBIndexBackendImpl::addingKeyAllowed(IDBKey* key)
    162 {
    163     if (!m_unique)
    164         return true;
    165 
    166     return !m_backingStore->keyExistsInIndex(m_databaseId, m_objectStoreBackend->id(), m_id, *key);
    167 }
    168 
    169 } // namespace WebCore
    170 
    171 #endif // ENABLE(INDEXED_DATABASE)
    172