DownloadId

chrome/browser/history/download_database.cc

 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/history/download_database.h"
 
 #include <limits>
 #include <vector>
 
 #include "base/file_path.h"
@@ skipping 35 matching lines @@
 // See above.
 void BindFilePath(sql::Statement& statement, const FilePath& path, int col) {
   statement.BindString(col, UTF16ToUTF8(path.value()));
 }
 FilePath ColumnFilePath(sql::Statement& statement, int col) {
   return FilePath(UTF8ToUTF16(statement.ColumnString(col)));
 }
 
 #endif
 
+// Key in the meta_table containing the next id to use for a new download in
+// this profile.
+static const char kNextDownloadId[] = "next_download_id";
+
 }  // namespace
 
 DownloadDatabase::DownloadDatabase()
-    : owning_thread_set_(false) {
+    : owning_thread_set_(false),
+      next_id_(0) {
 }
 
 DownloadDatabase::~DownloadDatabase() {
 }
 
 bool DownloadDatabase::InitDownloadTable() {
   if (!GetDB().DoesTableExist("downloads")) {
     if (!GetDB().Execute(
         "CREATE TABLE downloads ("
         "id INTEGER PRIMARY KEY,"
         "full_path LONGVARCHAR NOT NULL,"
         "url LONGVARCHAR NOT NULL,"
         "start_time INTEGER NOT NULL,"
         "received_bytes INTEGER NOT NULL,"
         "total_bytes INTEGER NOT NULL,"
         "state INTEGER NOT NULL)"))
       return false;
   }
+  meta_table_.Init(&GetDB(), 0, 0);
+  meta_table_.GetValue(kNextDownloadId, &next_id_);
   return true;
 }
 
 bool DownloadDatabase::DropDownloadTable() {
   return GetDB().Execute("DROP TABLE downloads");
 }
 
 void DownloadDatabase::QueryDownloads(
     std::vector<DownloadPersistentStoreInfo>* results) {
   results->clear();
@@ skipping 81 matching lines @@
   statement.BindInt64(3, info.received_bytes);
   statement.BindInt64(4, info.total_bytes);
   statement.BindInt(5, info.state);
 
   if (statement.Run()) {
     int64 id = GetDB().GetLastInsertRowId();
 
     CHECK_EQ(0u, returned_ids_.count(id));
     returned_ids_.insert(id);
 
+    // TODO(benjhayden) if(info.id>next_id_){setvalue;next_id_=info.id;}
+    meta_table_.SetValue(kNextDownloadId, ++next_id_);
+
     return id;
   }
   return 0;
 }
 
 void DownloadDatabase::RemoveDownload(DownloadID db_handle) {
   sql::Statement statement(GetDB().GetCachedStatement(SQL_FROM_HERE,
       "DELETE FROM downloads WHERE id=?"));
   if (!statement)
     return;
@@ skipping 42 matching lines @@
   statement.BindInt64(
       1,
       end_time ? end_time : std::numeric_limits<int64>::max());
   statement.BindInt(2, DownloadItem::COMPLETE);
   statement.BindInt(3, DownloadItem::CANCELLED);
   statement.BindInt(4, DownloadItem::INTERRUPTED);
   statement.Run();
 }
 
 }  // namespace history