Method get_current_version

src/migration/runner.rs:299–334

(&self)

    }
    
    fn get_current_version(&self) -> Result<u32> {
        // First check if metadata table exists
        let metadata_exists = self.conn.query_row(
            "SELECT 1 FROM sqlite_master WHERE type='table' AND name='__pgsqlite_metadata'",
            [],
            |_| Ok(true)
        ).unwrap_or(false);
        
        if !metadata_exists {
            // Check if we have the original __pgsqlite_schema table
            let has_pgsqlite_schema = self.conn.query_row(
                "SELECT 1 FROM sqlite_master WHERE type='table' AND name='__pgsqlite_schema'",
                [],
                |_| Ok(true)
            ).unwrap_or(false);
            
            if has_pgsqlite_schema {
                // This is a pre-migration database, but we need to verify
                // it hasn't been marked as version 1 yet
                return Ok(0);
            } else {
                // Brand new database
                return Ok(0);
            }
        }
        
        // Metadata table exists, get version from it
        match self.conn.query_row(
            "SELECT value FROM __pgsqlite_metadata WHERE key = 'schema_version'",
            [],
            |row| row.get::<_, String>(0)
        ) {
            Ok(version) => Ok(version.parse::<u32>()?),
            Err(_) => Ok(0), // Metadata exists but no version set
        }
    }
    
    fn has_legacy_schema(&self) -> Result<bool> {
        // Check if we have the original __pgsqlite_schema table