cli/cache/cache_db.rs - main - githubmirror/deno

cli/cache/cache_db.rs
818 строк25 KB
fix(cache): retry locked cache database instead of deleting it (#34873)
05 июн 2026, 07:38
05 июн 2026, 07:38a9f636a
// Copyright 2018-2026 the Deno authors. MIT license.

use std::io::IsTerminal;
use std::path::Path;
use std::path::PathBuf;
use std::sync::Arc;
use std::time::Duration;

use deno_core::error::AnyError;
use deno_core::parking_lot::Mutex;
use deno_core::parking_lot::MutexGuard;
use deno_core::unsync::spawn_blocking;
use deno_lib::util::hash::FastInsecureHasher;
use deno_runtime::deno_webstorage::rusqlite;
use deno_runtime::deno_webstorage::rusqlite::Connection;
use deno_runtime::deno_webstorage::rusqlite::OptionalExtension;
use deno_runtime::deno_webstorage::rusqlite::Params;
use once_cell::sync::OnceCell;

#[derive(Debug, Copy, Clone, PartialEq, Eq, Hash)]
pub struct CacheDBHash(u64);

impl CacheDBHash {
  pub fn new(hash: u64) -> Self {
    Self(hash)
  }

  pub fn from_hashable(hashable: impl std::hash::Hash) -> Self {
    Self::new(
      // always write in the deno version just in case
      // the clearing on deno version change doesn't work
      FastInsecureHasher::new_deno_versioned()
        .write_hashable(hashable)
        .finish(),
    )
  }

  pub fn inner(&self) -> u64 {
    self.0
  }
}

impl rusqlite::types::ToSql for CacheDBHash {
  fn to_sql(&self) -> rusqlite::Result<rusqlite::types::ToSqlOutput<'_>> {
    Ok(rusqlite::types::ToSqlOutput::Owned(
      // sqlite doesn't support u64, but it does support i64 so store
      // this value "incorrectly" as i64 then convert back to u64 on read
      rusqlite::types::Value::Integer(self.0 as i64),
    ))
  }
}

impl rusqlite::types::FromSql for CacheDBHash {
  fn column_result(
    value: rusqlite::types::ValueRef,
  ) -> rusqlite::types::FromSqlResult<Self> {
    match value {
      rusqlite::types::ValueRef::Integer(i) => Ok(Self::new(i as u64)),
      _ => Err(rusqlite::types::FromSqlError::InvalidType),
    }
  }
}

/// What should the cache should do on failure?
#[derive(Debug, Default)]
pub enum CacheFailure {
  /// Return errors if failure mode otherwise unspecified.
  #[default]
  Error,
  /// Create an in-memory cache that is not persistent.
  InMemory,
  /// Create a blackhole cache that ignores writes and returns empty reads.
  Blackhole,
}

/// Configuration SQL and other parameters for a [`CacheDB`].
#[derive(Debug)]
pub struct CacheDBConfiguration {
  /// SQL to run for a new database.
  pub table_initializer: &'static str,
  /// SQL to run when the version from [`crate::version::deno()`] changes.
  pub on_version_change: &'static str,
  /// Prepared statements to pre-heat while initializing the database.
  pub preheat_queries: &'static [&'static str],
  /// What the cache should do on failure.
  pub on_failure: CacheFailure,
}

impl CacheDBConfiguration {
  fn create_combined_sql(&self) -> String {
    // WSL-1's filesystem translation layer doesn't support WAL's
    // shared-memory locking, which surfaces as `SQLITE_PROTOCOL` (error
    // code 15: "Database lock protocol error") when two Deno processes
    // open the same cache DB at once. Fall back to TRUNCATE journal mode
    // there. See https://github.com/denoland/deno/issues/26441.
    let journal_mode = if is_wsl1() { "TRUNCATE" } else { "WAL" };
    format!(
      "PRAGMA journal_mode={journal_mode};\
       PRAGMA synchronous=NORMAL;\
       PRAGMA temp_store=memory;\
       PRAGMA page_size=4096;\
       PRAGMA mmap_size=6000000;\
       PRAGMA optimize;\
       CREATE TABLE IF NOT EXISTS info (key TEXT PRIMARY KEY, value TEXT NOT NULL);\
       {table_initializer}",
      table_initializer = self.table_initializer
    )
  }
}

/// Returns whether the underlying `osrelease` string was produced by
/// the WSL-1 kernel. The WSL-1 kernel string contains "Microsoft"; the
/// WSL-2 kernel string contains both "microsoft" and "WSL2".
#[cfg(any(target_os = "linux", test))]
fn parse_wsl1_from_osrelease(osrelease: &str) -> bool {
  let lower = osrelease.to_ascii_lowercase();
  lower.contains("microsoft") && !lower.contains("wsl2")
}

#[cfg(target_os = "linux")]
fn is_wsl1() -> bool {
  use std::sync::OnceLock;
  static IS_WSL1: OnceLock<bool> = OnceLock::new();
  *IS_WSL1.get_or_init(|| {
    std::fs::read_to_string("/proc/sys/kernel/osrelease")
      .map(|s| parse_wsl1_from_osrelease(&s))
      .unwrap_or(false)
  })
}

#[cfg(not(target_os = "linux"))]
fn is_wsl1() -> bool {
  false
}

#[derive(Debug)]
enum ConnectionState {
  Connected(Connection),
  Blackhole,
  Error(Arc<AnyError>),
}

/// A cache database that eagerly initializes itself off-thread, preventing initialization operations
/// from blocking the main thread.
#[derive(Debug, Clone)]
pub struct CacheDB {
  // TODO(mmastrac): We can probably simplify our thread-safe implementation here
  conn: Arc<Mutex<OnceCell<ConnectionState>>>,
  path: Option<PathBuf>,
  config: &'static CacheDBConfiguration,
  version: &'static str,
}

impl Drop for CacheDB {
  fn drop(&mut self) {
    // No need to clean up an in-memory cache in an way -- just drop and go.
    let path = match self.path.take() {
      Some(path) => path,
      _ => return,
    };

    // If Deno is panicking, tokio is sometimes gone before we have a chance to shutdown. In
    // that case, we just allow the drop to happen as expected.
    if tokio::runtime::Handle::try_current().is_err() {
      return;
    }

    // For on-disk caches, see if we're the last holder of the Arc.
    let arc = std::mem::take(&mut self.conn);
    if let Ok(inner) = Arc::try_unwrap(arc) {
      // Hand off SQLite connection to another thread to do the surprisingly expensive cleanup
      let inner = inner.into_inner().into_inner();
      if let Some(conn) = inner {
        spawn_blocking(move || {
          drop(conn);
          log::trace!(
            "Cleaned up SQLite connection at {}",
            path.to_string_lossy()
          );
        });
      }
    }
  }
}

impl CacheDB {
  pub fn in_memory(
    config: &'static CacheDBConfiguration,
    version: &'static str,
  ) -> Self {
    CacheDB {
      conn: Arc::new(Mutex::new(OnceCell::new())),
      path: None,
      config,
      version,
    }
  }

  pub fn from_path(
    config: &'static CacheDBConfiguration,
    path: PathBuf,
    version: &'static str,
  ) -> Self {
    log::debug!("Opening cache {}...", path.to_string_lossy());
    let new = Self {
      conn: Arc::new(Mutex::new(OnceCell::new())),
      path: Some(path),
      config,
      version,
    };

    new.spawn_eager_init_thread();
    new
  }

  /// Useful for testing: re-create this cache DB with a different current version.
  #[cfg(test)]
  pub(crate) fn recreate_with_version(mut self, version: &'static str) -> Self {
    // By taking the lock, we know there are no initialization threads alive
    drop(self.conn.lock());

    let arc = std::mem::take(&mut self.conn);
    let conn = match Arc::try_unwrap(arc) {
      Err(_) => panic!("Failed to unwrap connection"),
      Ok(conn) => match conn.into_inner().into_inner() {
        Some(ConnectionState::Connected(conn)) => conn,
        _ => panic!("Connection had failed and cannot be unwrapped"),
      },
    };

    Self::initialize_connection(self.config, &conn, version).unwrap();

    let cell = OnceCell::new();
    _ = cell.set(ConnectionState::Connected(conn));
    Self {
      conn: Arc::new(Mutex::new(cell)),
      path: self.path.clone(),
      config: self.config,
      version,
    }
  }

  fn spawn_eager_init_thread(&self) {
    let clone = self.clone();
    debug_assert!(tokio::runtime::Handle::try_current().is_ok());
    spawn_blocking(move || {
      let lock = clone.conn.lock();
      clone.initialize(&lock);
    });
  }

  /// Open the connection in memory or on disk.
  fn actually_open_connection(
    &self,
    path: Option<&Path>,
  ) -> Result<Connection, rusqlite::Error> {
    match path {
      // This should never fail unless something is very wrong
      None => Connection::open_in_memory(),
      Some(path) => Connection::open(path),
    }
  }

  /// Attempt to initialize that connection.
  fn initialize_connection(
    config: &CacheDBConfiguration,
    conn: &Connection,
    version: &str,
  ) -> Result<(), rusqlite::Error> {
    let sql = config.create_combined_sql();
    conn.execute_batch(&sql)?;

    // Check the version
    let existing_version = conn
      .query_row(
        "SELECT value FROM info WHERE key='CLI_VERSION' LIMIT 1",
        [],
        |row| row.get::<_, String>(0),
      )
      .optional()?
      .unwrap_or_default();

    // If Deno has been upgraded, run the SQL to update the version
    if existing_version != version {
      conn.execute_batch(config.on_version_change)?;
      let mut stmt = conn
        .prepare("INSERT OR REPLACE INTO info (key, value) VALUES (?1, ?2)")?;
      stmt.execute(["CLI_VERSION", version])?;
    }

    // Preheat any prepared queries
    for preheat in config.preheat_queries {
      drop(conn.prepare_cached(preheat)?);
    }
    Ok(())
  }

  /// Open and initialize a connection.
  fn open_connection_and_init(
    &self,
    path: Option<&Path>,
  ) -> Result<Connection, rusqlite::Error> {
    let conn = self.actually_open_connection(path)?;
    Self::initialize_connection(self.config, &conn, self.version)?;
    Ok(conn)
  }

  /// This function represents the policy for dealing with corrupted cache files. We try fairly aggressively
  /// to repair the situation, and if we can't, we prefer to log noisily and continue with in-memory caches.
  fn open_connection(&self) -> Result<ConnectionState, AnyError> {
    open_connection(self.config, self.path.as_deref(), |maybe_path| {
      self.open_connection_and_init(maybe_path)
    })
  }

  fn initialize<'a>(
    &self,
    lock: &'a MutexGuard<OnceCell<ConnectionState>>,
  ) -> &'a ConnectionState {
    lock.get_or_init(|| match self.open_connection() {
      Ok(conn) => conn,
      Err(e) => ConnectionState::Error(e.into()),
    })
  }

  pub fn with_connection<T: Default>(
    &self,
    f: impl FnOnce(&Connection) -> Result<T, AnyError>,
  ) -> Result<T, AnyError> {
    let lock = self.conn.lock();
    let conn = self.initialize(&lock);

    match conn {
      ConnectionState::Blackhole => {
        // Cache is a blackhole - nothing in or out.
        Ok(T::default())
      }
      ConnectionState::Error(e) => {
        // This isn't ideal because we lose the original underlying error
        let err = AnyError::msg(e.clone().to_string());
        Err(err)
      }
      ConnectionState::Connected(conn) => f(conn),
    }
  }

  #[cfg(test)]
  pub fn ensure_connected(&self) -> Result<(), AnyError> {
    self.with_connection(|_| Ok(()))
  }

  pub fn execute(
    &self,
    sql: &'static str,
    params: impl Params,
  ) -> Result<usize, AnyError> {
    self.with_connection(|conn| {
      let mut stmt = conn.prepare_cached(sql)?;
      let res = stmt.execute(params)?;
      Ok(res)
    })
  }

  pub fn exists(
    &self,
    sql: &'static str,
    params: impl Params,
  ) -> Result<bool, AnyError> {
    self.with_connection(|conn| {
      let mut stmt = conn.prepare_cached(sql)?;
      let res = stmt.exists(params)?;
      Ok(res)
    })
  }

  /// Query a row from the database with a mapping function.
  pub fn query_row<T, F>(
    &self,
    sql: &'static str,
    params: impl Params,
    f: F,
  ) -> Result<Option<T>, AnyError>
  where
    F: FnOnce(&rusqlite::Row<'_>) -> Result<T, AnyError>,
  {
    let res = self.with_connection(|conn| {
      let mut stmt = conn.prepare_cached(sql)?;
      let mut rows = stmt.query(params)?;
      if let Some(row) = rows.next()? {
        let res = f(row)?;
        Ok(Some(res))
      } else {
        Ok(None)
      }
    })?;
    Ok(res)
  }
}

/// This function represents the policy for dealing with corrupted cache files. We try fairly aggressively
/// to repair the situation, and if we can't, we prefer to log noisily and continue with in-memory caches.
fn open_connection(
  config: &CacheDBConfiguration,
  path: Option<&Path>,
  open_connection_and_init: impl Fn(
    Option<&Path>,
  ) -> Result<Connection, rusqlite::Error>,
) -> Result<ConnectionState, AnyError> {
  // Success on first try? We hope that this is the case.
  let err = match open_connection_and_init(path) {
    Ok(conn) => return Ok(ConnectionState::Connected(conn)),
    Err(err) => err,
  };

  let Some(path) = path.as_ref() else {
    // If an in-memory DB fails, that's game over
    log::error!("Failed to initialize in-memory cache database.");
    return Err(err.into());
  };

  // reduce logging for readonly file system
  if let rusqlite::Error::SqliteFailure(ffi_err, _) = &err
    && ffi_err.code == rusqlite::ErrorCode::ReadOnly
  {
    log::debug!(
      "Failed creating cache db. Folder readonly: {}",
      path.display()
    );
    return handle_failure_mode(config, err, open_connection_and_init);
  }

  // ensure the parent directory exists
  if let Some(parent) = path.parent() {
    match std::fs::create_dir_all(parent) {
      Ok(_) => {
        log::debug!("Created parent directory for cache db.");
      }
      Err(err) => {
        log::debug!("Failed creating the cache db parent dir: {:#}", err);
      }
    }
  }

  // If the failure is just transient lock contention (another process is
  // currently operating on the database — for example recovering a WAL-mode
  // database, which surfaces as SQLITE_BUSY_RECOVERY / error code 261), the
  // file is not corrupt. Wait for the other process to finish by retrying with
  // exponential backoff instead of deleting it.
  // See https://github.com/denoland/deno/issues/27283.
  if is_lock_contention_error(&err) {
    match retry_open_with_backoff(path, &open_connection_and_init) {
      Ok(conn) => return Ok(ConnectionState::Connected(conn)),
      Err(err) => {
        // Still locked after exhausting retries. Don't delete the file — it
        // belongs to another process and is not corrupt — just degrade
        // gracefully to the configured failure mode.
        log_failure_mode(path, std::io::stderr().is_terminal(), config);
        return handle_failure_mode(config, err, open_connection_and_init);
      }
    }
  }

  // There are rare times in the tests when we can't initialize a cache DB the first time, but it succeeds the second time, so
  // we don't log these at a debug level.
  log::trace!(
    "Could not initialize cache database '{}', retrying... ({err:?})",
    path.to_string_lossy(),
  );

  // Try a second time
  let err = match open_connection_and_init(Some(path)) {
    Ok(conn) => return Ok(ConnectionState::Connected(conn)),
    Err(err) => err,
  };

  // Failed, try deleting it
  let is_tty = std::io::stderr().is_terminal();
  log::log!(
    if is_tty {
      log::Level::Warn
    } else {
      log::Level::Trace
    },
    "Could not initialize cache database '{}', deleting and retrying... ({err:?})",
    path.to_string_lossy()
  );

  if std::fs::remove_file(path).is_ok() {
    // Try a third time if we successfully deleted it
    let res = open_connection_and_init(Some(path));
    if let Ok(conn) = res {
      return Ok(ConnectionState::Connected(conn));
    };
  }

  log_failure_mode(path, is_tty, config);
  handle_failure_mode(config, err, open_connection_and_init)
}

/// Returns whether the error is transient lock contention that just means
/// another process is currently operating on the database (e.g. recovering a
/// WAL-mode database file, which surfaces as `SQLITE_BUSY_RECOVERY`). The
/// underlying file is not corrupt and the operation should be retried rather
/// than the file deleted.
fn is_lock_contention_error(err: &rusqlite::Error) -> bool {
  matches!(
    err,
    rusqlite::Error::SqliteFailure(ffi_err, _)
      if matches!(
        ffi_err.code,
        rusqlite::ErrorCode::DatabaseBusy
          | rusqlite::ErrorCode::DatabaseLocked
      )
  )
}

/// Maximum number of times to retry opening a database that is busy because
/// another process is operating on it.
const LOCK_CONTENTION_RETRIES: u32 = 7;
/// Base delay used for the first retry; doubles on each subsequent retry up to
/// [`LOCK_CONTENTION_MAX_DELAY`]. The default schedule waits ~1.3s in total.
const LOCK_CONTENTION_BASE_DELAY: Duration = Duration::from_millis(10);
const LOCK_CONTENTION_MAX_DELAY: Duration = Duration::from_millis(1000);

/// Retry opening the database with exponential backoff while it remains locked
/// by another process. Returns the last error if the contention does not clear
/// within [`LOCK_CONTENTION_RETRIES`] attempts, or immediately if a different
/// (non-contention) error is encountered.
fn retry_open_with_backoff(
  path: &Path,
  open_connection_and_init: impl Fn(
    Option<&Path>,
  ) -> Result<Connection, rusqlite::Error>,
) -> Result<Connection, rusqlite::Error> {
  let mut delay = LOCK_CONTENTION_BASE_DELAY;
  let mut last_err = None;
  for attempt in 1..=LOCK_CONTENTION_RETRIES {
    log::debug!(
      "Cache database '{}' is locked by another process, retrying in {}ms (attempt {}/{}).",
      path.to_string_lossy(),
      delay.as_millis(),
      attempt,
      LOCK_CONTENTION_RETRIES,
    );
    std::thread::sleep(delay);
    match open_connection_and_init(Some(path)) {
      Ok(conn) => return Ok(conn),
      Err(err) => {
        // If the error changed to something other than lock contention, stop
        // retrying and surface it to the regular recovery path.
        if !is_lock_contention_error(&err) {
          return Err(err);
        }
        last_err = Some(err);
      }
    }
    delay = (delay * 2).min(LOCK_CONTENTION_MAX_DELAY);
  }
  Err(last_err.unwrap_or(rusqlite::Error::SqliteSingleThreadedMode))
}

fn log_failure_mode(path: &Path, is_tty: bool, config: &CacheDBConfiguration) {
  match config.on_failure {
    CacheFailure::InMemory => {
      log::log!(
        if is_tty {
          log::Level::Error
        } else {
          log::Level::Trace
        },
        "Failed to open cache file '{}', opening in-memory cache.",
        path.display()
      );
    }
    CacheFailure::Blackhole => {
      log::log!(
        if is_tty {
          log::Level::Error
        } else {
          log::Level::Trace
        },
        "Failed to open cache file '{}', performance may be degraded.",
        path.display()
      );
    }
    CacheFailure::Error => {
      log::error!(
        "Failed to open cache file '{}', expect further errors.",
        path.display()
      );
    }
  }
}

fn handle_failure_mode(
  config: &CacheDBConfiguration,
  err: rusqlite::Error,
  open_connection_and_init: impl Fn(
    Option<&Path>,
  ) -> Result<Connection, rusqlite::Error>,
) -> Result<ConnectionState, AnyError> {
  match config.on_failure {
    CacheFailure::InMemory => {
      Ok(ConnectionState::Connected(open_connection_and_init(None)?))
    }
    CacheFailure::Blackhole => Ok(ConnectionState::Blackhole),
    CacheFailure::Error => Err(err.into()),
  }
}

#[cfg(test)]
mod tests {
  use test_util::TempDir;

  use super::*;

  static TEST_DB: CacheDBConfiguration = CacheDBConfiguration {
    table_initializer: "create table if not exists test(value TEXT);",
    on_version_change: "delete from test;",
    preheat_queries: &[],
    on_failure: CacheFailure::InMemory,
  };

  static TEST_DB_BLACKHOLE: CacheDBConfiguration = CacheDBConfiguration {
    table_initializer: "syntax error", // intentionally cause an error
    on_version_change: "",
    preheat_queries: &[],
    on_failure: CacheFailure::Blackhole,
  };

  static TEST_DB_ERROR: CacheDBConfiguration = CacheDBConfiguration {
    table_initializer: "syntax error", // intentionally cause an error
    on_version_change: "",
    preheat_queries: &[],
    on_failure: CacheFailure::Error,
  };

  static BAD_SQL_TEST_DB: CacheDBConfiguration = CacheDBConfiguration {
    table_initializer: "bad sql;",
    on_version_change: "delete from test;",
    preheat_queries: &[],
    on_failure: CacheFailure::InMemory,
  };

  #[tokio::test]
  async fn simple_database() {
    let db = CacheDB::in_memory(&TEST_DB, "1.0");
    db.ensure_connected()
      .expect("Failed to initialize in-memory database");

    db.execute("insert into test values (?1)", [1]).unwrap();
    let res = db
      .query_row("select * from test", [], |row| {
        Ok(row.get::<_, String>(0).unwrap())
      })
      .unwrap();
    assert_eq!(res, Some("1".into()));
  }

  #[tokio::test]
  async fn bad_sql() {
    let db = CacheDB::in_memory(&BAD_SQL_TEST_DB, "1.0");
    db.ensure_connected()
      .expect_err("Expected to fail, but succeeded");
  }

  #[tokio::test]
  async fn failure_mode_in_memory() {
    let temp_dir = TempDir::new();
    let path = temp_dir.path().join("data").to_path_buf();
    let state = open_connection(&TEST_DB, Some(path.as_path()), |maybe_path| {
      match maybe_path {
        // this error was chosen because it was an error easy to construct
        Some(_) => Err(rusqlite::Error::SqliteSingleThreadedMode),
        None => Ok(Connection::open_in_memory().unwrap()),
      }
    })
    .unwrap();
    assert!(matches!(state, ConnectionState::Connected(_)));
  }

  #[tokio::test]
  async fn lock_contention_retries_then_succeeds() {
    use std::sync::atomic::AtomicUsize;
    use std::sync::atomic::Ordering;

    let temp_dir = TempDir::new();
    let path = temp_dir.path().join("data").to_path_buf();
    let attempts = AtomicUsize::new(0);
    let state = open_connection(&TEST_DB, Some(path.as_path()), |maybe_path| {
      let n = attempts.fetch_add(1, Ordering::SeqCst);
      if n < 2 {
        // SQLITE_BUSY_RECOVERY (261): another process is recovering the WAL db.
        Err(rusqlite::Error::SqliteFailure(
          rusqlite::ffi::Error::new(261),
          Some("recovering".to_string()),
        ))
      } else {
        Connection::open(maybe_path.unwrap())
      }
    })
    .unwrap();
    assert!(matches!(state, ConnectionState::Connected(_)));
    // The first open plus at least two retries should have happened.
    assert!(attempts.load(Ordering::SeqCst) >= 3);
    // The file must not have been deleted — it was never corrupt.
    assert!(path.exists());
  }

  #[tokio::test]
  async fn lock_contention_does_not_delete_on_giving_up() {
    let temp_dir = TempDir::new();
    let path = temp_dir.path().join("data").to_path_buf();
    // Create a sentinel file so we can assert it is not deleted.
    std::fs::write(&path, b"not a real db").unwrap();
    let state = open_connection(&TEST_DB, Some(path.as_path()), |maybe_path| {
      match maybe_path {
        // Always busy: simulate a database that never finishes recovering.
        Some(_) => Err(rusqlite::Error::SqliteFailure(
          rusqlite::ffi::Error::new(261),
          Some("recovering".to_string()),
        )),
        None => Ok(Connection::open_in_memory().unwrap()),
      }
    })
    .unwrap();
    // Falls back to the in-memory failure mode rather than erroring.
    assert!(matches!(state, ConnectionState::Connected(_)));
    // Crucially, the on-disk file owned by another process is preserved.
    assert!(path.exists());
  }

  #[tokio::test]
  async fn failure_mode_blackhole() {
    let temp_dir = TempDir::new();
    let path = temp_dir.path().join("data");
    let db = CacheDB::from_path(&TEST_DB_BLACKHOLE, path.to_path_buf(), "1.0");
    db.ensure_connected()
      .expect("Should have created a database");

    db.execute("insert into test values (?1)", [1]).unwrap();
    let res = db
      .query_row("select * from test", [], |row| {
        Ok(row.get::<_, String>(0).unwrap())
      })
      .unwrap();
    assert_eq!(res, None);
  }

  #[tokio::test]
  async fn failure_mode_error() {
    let temp_dir = TempDir::new();
    let path = temp_dir.path().join("data");
    let db = CacheDB::from_path(&TEST_DB_ERROR, path.to_path_buf(), "1.0");
    db.ensure_connected().expect_err("Should have failed");

    db.execute("insert into test values (?1)", [1])
      .expect_err("Should have failed");
    db.query_row("select * from test", [], |row| {
      Ok(row.get::<_, String>(0).unwrap())
    })
    .expect_err("Should have failed");
  }

  #[test]
  fn cache_db_hash_max_u64_value() {
    assert_same_serialize_deserialize(CacheDBHash::new(u64::MAX));
    assert_same_serialize_deserialize(CacheDBHash::new(u64::MAX - 1));
    assert_same_serialize_deserialize(CacheDBHash::new(u64::MIN));
    assert_same_serialize_deserialize(CacheDBHash::new(1));
  }

  #[test]
  fn detects_wsl1_kernel() {
    assert!(parse_wsl1_from_osrelease("4.4.0-19041-Microsoft"));
    assert!(parse_wsl1_from_osrelease("4.4.0-19041-Microsoft\n"));
    assert!(!parse_wsl1_from_osrelease(
      "5.10.16.3-microsoft-standard-WSL2"
    ));
    assert!(!parse_wsl1_from_osrelease(
      "5.15.146.1-microsoft-standard-WSL2+"
    ));
    assert!(!parse_wsl1_from_osrelease("5.15.0-91-generic"));
    assert!(!parse_wsl1_from_osrelease(""));
  }

  #[test]
  fn combined_sql_uses_truncate_on_wsl1_only() {
    let sql = TEST_DB.create_combined_sql();
    if is_wsl1() {
      assert!(sql.contains("PRAGMA journal_mode=TRUNCATE"));
      assert!(!sql.contains("PRAGMA journal_mode=WAL"));
    } else {
      assert!(sql.contains("PRAGMA journal_mode=WAL"));
      assert!(!sql.contains("PRAGMA journal_mode=TRUNCATE"));
    }
  }

  fn assert_same_serialize_deserialize(original_hash: CacheDBHash) {
    use rusqlite::ToSql;
    use rusqlite::types::FromSql;
    use rusqlite::types::ValueRef;

    let value = original_hash.to_sql().unwrap();
    match value {
      rusqlite::types::ToSqlOutput::Owned(rusqlite::types::Value::Integer(
        value,
      )) => {
        let value_ref = ValueRef::Integer(value);
        assert_eq!(
          original_hash,
          CacheDBHash::column_result(value_ref).unwrap()
        );
      }
      _ => unreachable!(),
    }
  }
}