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