1 // Copyright (c) 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "content/browser/indexed_db/indexed_db_index_writer.h"
7 #include "base/logging.h"
8 #include "base/strings/utf_string_conversions.h"
9 #include "content/browser/indexed_db/indexed_db_backing_store.h"
10 #include "content/browser/indexed_db/indexed_db_tracing.h"
11 #include "content/browser/indexed_db/indexed_db_transaction.h"
12 #include "content/common/indexed_db/indexed_db_key.h"
13 #include "content/common/indexed_db/indexed_db_key_path.h"
14 #include "content/common/indexed_db/indexed_db_key_range.h"
16 using base::ASCIIToUTF16
;
20 IndexWriter::IndexWriter(
21 const IndexedDBIndexMetadata
& index_metadata
)
22 : index_metadata_(index_metadata
) {}
24 IndexWriter::IndexWriter(
25 const IndexedDBIndexMetadata
& index_metadata
,
26 const IndexedDBDatabase::IndexKeys
& index_keys
)
27 : index_metadata_(index_metadata
), index_keys_(index_keys
) {}
29 IndexWriter::~IndexWriter() {}
31 bool IndexWriter::VerifyIndexKeys(
32 IndexedDBBackingStore
* backing_store
,
33 IndexedDBBackingStore::Transaction
* transaction
,
35 int64 object_store_id
,
38 const IndexedDBKey
& primary_key
,
39 base::string16
* error_message
) const {
40 *can_add_keys
= false;
41 DCHECK_EQ(index_id
, index_keys_
.first
);
42 for (size_t i
= 0; i
< index_keys_
.second
.size(); ++i
) {
43 bool ok
= AddingKeyAllowed(backing_store
,
48 (index_keys_
.second
)[i
],
55 *error_message
= ASCIIToUTF16("Unable to add key to index '") +
56 index_metadata_
.name
+
57 ASCIIToUTF16("': at least one key does not satisfy "
58 "the uniqueness requirements.");
67 void IndexWriter::WriteIndexKeys(
68 const IndexedDBBackingStore::RecordIdentifier
& record_identifier
,
69 IndexedDBBackingStore
* backing_store
,
70 IndexedDBBackingStore::Transaction
* transaction
,
72 int64 object_store_id
) const {
73 int64 index_id
= index_metadata_
.id
;
74 DCHECK_EQ(index_id
, index_keys_
.first
);
75 for (size_t i
= 0; i
< index_keys_
.second
.size(); ++i
) {
77 backing_store
->PutIndexDataForRecord(transaction
,
81 index_keys_
.second
[i
],
83 // This should have already been verified as a valid write during
89 bool IndexWriter::AddingKeyAllowed(
90 IndexedDBBackingStore
* backing_store
,
91 IndexedDBBackingStore::Transaction
* transaction
,
93 int64 object_store_id
,
95 const IndexedDBKey
& index_key
,
96 const IndexedDBKey
& primary_key
,
97 bool* allowed
) const {
99 if (!index_metadata_
.unique
) {
104 scoped_ptr
<IndexedDBKey
> found_primary_key
;
106 leveldb::Status s
= backing_store
->KeyExistsInIndex(transaction
,
116 (primary_key
.IsValid() && found_primary_key
->Equals(primary_key
)))
121 bool MakeIndexWriters(
122 scoped_refptr
<IndexedDBTransaction
> transaction
,
123 IndexedDBBackingStore
* backing_store
,
125 const IndexedDBObjectStoreMetadata
& object_store
,
126 const IndexedDBKey
& primary_key
, // makes a copy
127 bool key_was_generated
,
128 const std::vector
<IndexedDBDatabase::IndexKeys
>& index_keys
,
129 ScopedVector
<IndexWriter
>* index_writers
,
130 base::string16
* error_message
,
134 for (std::vector
<IndexedDBDatabase::IndexKeys
>::const_iterator it
=
136 it
!= index_keys
.end();
138 IndexedDBObjectStoreMetadata::IndexMap::const_iterator found
=
139 object_store
.indexes
.find(it
->first
);
140 if (found
== object_store
.indexes
.end())
142 const IndexedDBIndexMetadata
& index
= found
->second
;
143 IndexedDBDatabase::IndexKeys keys
= *it
;
145 // If the object_store is using auto_increment, then any indexes with an
146 // identical key_path need to also use the primary (generated) key as a key.
147 if (key_was_generated
&& (index
.key_path
== object_store
.key_path
))
148 keys
.second
.push_back(primary_key
);
150 scoped_ptr
<IndexWriter
> index_writer(new IndexWriter(index
, keys
));
151 bool can_add_keys
= false;
152 bool backing_store_success
=
153 index_writer
->VerifyIndexKeys(backing_store
,
154 transaction
->BackingStoreTransaction(),
161 if (!backing_store_success
)
166 index_writers
->push_back(index_writer
.release());
173 } // namespace content