Preliminary work on resuming downloads whose connections have expired.

chrome/browser/history/download_database.cc

 // Copyright (c) 2010 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 "app/sql/statement.h"
@@ skipping 128 matching lines @@
   sql::Statement statement(GetDB().GetCachedStatement(SQL_FROM_HERE,
       "UPDATE downloads SET state=? WHERE state=?"));
   if (!statement)
     return false;
   statement.BindInt(0, DownloadItem::CANCELLED);
   statement.BindInt(1, DownloadItem::IN_PROGRESS);
   return statement.Run();
 }
 
 int64 DownloadDatabase::CreateDownload(const DownloadCreateInfo& info) {
-  sql::Statement statement(GetDB().GetCachedStatement(SQL_FROM_HERE,
-      "INSERT INTO downloads "
-      "(full_path, url, start_time, received_bytes, total_bytes, state) "
-      "VALUES (?, ?, ?, ?, ?, ?)"));
+  // If the database contains the 'last_modified' field, then set it to blank.
+  bool has_last_mod = GetDB().DoesColumnExist("downloads", "last_modified");
+  sql::Statement statement;
+  if (has_last_mod) {
+    statement.Assign(GetDB().GetCachedStatement(SQL_FROM_HERE,
+        "INSERT INTO downloads "
+        "(full_path, url, start_time, received_bytes, total_bytes, state, "
+        "last_modified) "
+        "VALUES (?, ?, ?, ?, ?, ?, ?)"));
+  } else {
+    statement.Assign(GetDB().GetCachedStatement(SQL_FROM_HERE,
+        "INSERT INTO downloads "
+        "(full_path, url, start_time, received_bytes, total_bytes, state) "
+        "VALUES (?, ?, ?, ?, ?, ?)"));
+  }
   if (!statement)
     return 0;
 
   BindFilePath(statement, info.path, 0);
   statement.BindString(1, info.url.spec());
   statement.BindInt64(2, info.start_time.ToTimeT());
   statement.BindInt64(3, info.received_bytes);
   statement.BindInt64(4, info.total_bytes);
   statement.BindInt(5, info.state);
+  if (has_last_mod)
+    statement.BindString(6, "");
 
   if (statement.Run())
     return GetDB().GetLastInsertRowId();
   return 0;
 }
 
 void DownloadDatabase::RemoveDownload(DownloadID db_handle) {
   sql::Statement statement(GetDB().GetCachedStatement(SQL_FROM_HERE,
       "DELETE FROM downloads WHERE id=?"));
   if (!statement)
@@ skipping 18 matching lines @@
   statement.BindInt64(0, start_time);
   statement.BindInt64(
       1,
       end_time ? end_time : std::numeric_limits<int64>::max());
   statement.BindInt(2, DownloadItem::COMPLETE);
   statement.BindInt(3, DownloadItem::CANCELLED);
   statement.Run();
 }
 
 }  // namespace history