diff --git a/src/metadata_provider_mysql.rs b/src/metadata_provider_mysql.rs index e802523..08ea16d 100644 --- a/src/metadata_provider_mysql.rs +++ b/src/metadata_provider_mysql.rs @@ -141,7 +141,7 @@ impl MetadataProvider for MySqlMetadataProvider { let rows = sqlx::query( "SELECT column_id, column_name, column_type, nulls_allowed FROM ducklake_column - WHERE table_id = ? + WHERE table_id = ? AND end_snapshot IS NULL ORDER BY column_order", ) .bind(table_id) diff --git a/src/metadata_provider_postgres.rs b/src/metadata_provider_postgres.rs index 7cbc934..568f276 100644 --- a/src/metadata_provider_postgres.rs +++ b/src/metadata_provider_postgres.rs @@ -175,7 +175,7 @@ impl MetadataProvider for PostgresMetadataProvider { let rows = sqlx::query( "SELECT column_id, column_name, column_type, nulls_allowed FROM ducklake_column - WHERE table_id = $1 + WHERE table_id = $1 AND end_snapshot IS NULL ORDER BY column_order", ) .bind(table_id)