IDBIndexWriterLevelDB.cpp [plain text]
#include "config.h"
#include "IDBIndexWriterLevelDB.h"
#include "IDBKey.h"
#include <wtf/text/CString.h>
#if ENABLE(INDEXED_DATABASE)
#if USE(LEVELDB)
namespace WebCore {
IDBIndexWriterLevelDB::IDBIndexWriterLevelDB(const IDBIndexMetadata& metadata, const IndexKeys& keys)
: m_indexMetadata(metadata)
, m_indexKeys(keys)
{
}
void IDBIndexWriterLevelDB::writeIndexKeys(const IDBRecordIdentifier* recordIdentifier, IDBBackingStoreLevelDB& backingStore, IDBBackingStoreTransactionLevelDB& transaction, int64_t databaseId, int64_t objectStoreId) const
{
ASSERT(recordIdentifier);
int64_t indexId = m_indexMetadata.id;
for (size_t i = 0; i < m_indexKeys.size(); ++i) {
bool ok = backingStore.putIndexDataForRecord(transaction, databaseId, objectStoreId, indexId, *(m_indexKeys)[i].get(), recordIdentifier);
ASSERT_UNUSED(ok, ok);
}
}
bool IDBIndexWriterLevelDB::verifyIndexKeys(IDBBackingStoreLevelDB& backingStore, IDBBackingStoreTransactionLevelDB& transaction, int64_t databaseId, int64_t objectStoreId, int64_t indexId, bool& canAddKeys, const IDBKey* primaryKey, String* errorMessage) const
{
canAddKeys = false;
for (size_t i = 0; i < m_indexKeys.size(); ++i) {
bool ok = addingKeyAllowed(backingStore, transaction, databaseId, objectStoreId, indexId, (m_indexKeys)[i].get(), primaryKey, canAddKeys);
if (!ok)
return false;
if (!canAddKeys) {
if (errorMessage)
*errorMessage = String::format("Unable to add key to index '%s': at least one key does not satisfy the uniqueness requirements.", m_indexMetadata.name.utf8().data());
return true;
}
}
canAddKeys = true;
return true;
}
bool IDBIndexWriterLevelDB::addingKeyAllowed(IDBBackingStoreLevelDB& backingStore, IDBBackingStoreTransactionLevelDB& transaction, int64_t databaseId, int64_t objectStoreId, int64_t indexId, const IDBKey* indexKey, const IDBKey* primaryKey, bool& allowed) const
{
allowed = false;
if (!m_indexMetadata.unique) {
allowed = true;
return true;
}
RefPtr<IDBKey> foundPrimaryKey;
bool found = false;
bool ok = backingStore.keyExistsInIndex(transaction, databaseId, objectStoreId, indexId, *indexKey, foundPrimaryKey, found);
if (!ok)
return false;
if (!found || (primaryKey && foundPrimaryKey->isEqual(primaryKey)))
allowed = true;
return true;
}
}
#endif // USE(LEVELDB)
#endif // ENABLE(INDEXED_DATABASE)