1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
// Copyright 2025 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CONTENT_BROWSER_INDEXED_DB_INSTANCE_SQLITE_DATABASE_CONNECTION_H_
#define CONTENT_BROWSER_INDEXED_DB_INSTANCE_SQLITE_DATABASE_CONNECTION_H_
#include <memory>
#include <optional>
#include <string>
#include "base/files/file_path.h"
#include "base/memory/weak_ptr.h"
#include "base/types/expected.h"
#include "base/types/pass_key.h"
#include "content/browser/indexed_db/status.h"
#include "third_party/blink/public/common/indexeddb/indexeddb_metadata.h"
#include "third_party/blink/public/mojom/indexeddb/indexeddb.mojom-forward.h"
namespace sql {
class Database;
class MetaTable;
} // namespace sql
namespace content::indexed_db::sqlite {
class BackingStoreDatabaseImpl;
class BackingStoreTransactionImpl;
// Owns the sole connection to the SQLite database that is backing a given
// IndexedDB database. Also owns the schema, operations and in-memory metadata
// for this database. BackingStore interface methods call into this class to
// perform the actual database operations.
class DatabaseConnection {
public:
// Opens the SQL database for the IndexedDB database with `name` at
// `file_path`, creating it if it doesn't exist.
static StatusOr<std::unique_ptr<DatabaseConnection>> Open(
const std::u16string& name,
const base::FilePath& file_path);
DatabaseConnection(const DatabaseConnection&) = delete;
DatabaseConnection& operator=(const DatabaseConnection&) = delete;
~DatabaseConnection();
const blink::IndexedDBDatabaseMetadata& metadata() const { return metadata_; }
base::WeakPtr<DatabaseConnection> GetWeakPtr();
// Exposed to `BackingStoreDatabaseImpl`.
std::unique_ptr<BackingStoreTransactionImpl> CreateTransaction(
base::PassKey<BackingStoreDatabaseImpl>,
blink::mojom::IDBTransactionDurability durability,
blink::mojom::IDBTransactionMode mode);
// Exposed to `BackingStoreTransactionImpl`.
void OnTransactionBegin(base::PassKey<BackingStoreTransactionImpl>,
const BackingStoreTransactionImpl& transaction);
void OnBeforeTransactionCommit(
base::PassKey<BackingStoreTransactionImpl>,
const BackingStoreTransactionImpl& transaction);
void OnTransactionCommit(base::PassKey<BackingStoreTransactionImpl>,
const BackingStoreTransactionImpl& transaction);
void OnTransactionRollback(base::PassKey<BackingStoreTransactionImpl>,
const BackingStoreTransactionImpl& transaction);
Status SetDatabaseVersion(base::PassKey<BackingStoreTransactionImpl>,
int64_t version);
Status CreateObjectStore(base::PassKey<BackingStoreTransactionImpl>,
int64_t object_store_id,
std::u16string name,
blink::IndexedDBKeyPath key_path,
bool auto_increment);
private:
DatabaseConnection(std::unique_ptr<sql::Database> db,
std::unique_ptr<sql::MetaTable> meta_table,
blink::IndexedDBDatabaseMetadata metadata);
bool HasActiveVersionChangeTransaction() const {
return metadata_snapshot_.has_value();
}
std::unique_ptr<sql::Database> db_;
std::unique_ptr<sql::MetaTable> meta_table_;
blink::IndexedDBDatabaseMetadata metadata_;
// Only set while a version change transaction is active.
std::optional<blink::IndexedDBDatabaseMetadata> metadata_snapshot_;
base::WeakPtrFactory<DatabaseConnection> weak_factory_{this};
};
} // namespace content::indexed_db::sqlite
#endif // CONTENT_BROWSER_INDEXED_DB_INSTANCE_SQLITE_DATABASE_CONNECTION_H_
|
