risingwave_meta_model_migration/
m20250710_065220_sink_auto_refresh_schema.rs

1use sea_orm_migration::prelude::*;
2
3#[derive(DeriveMigrationName)]
4pub struct Migration;
5
6#[async_trait::async_trait]
7impl MigrationTrait for Migration {
8    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
9        manager
10            .alter_table(
11                Table::alter()
12                    .table(Sink::Table)
13                    .add_column(
14                        ColumnDef::new(Sink::AutoRefreshSchemaFromTable)
15                            .null()
16                            .integer(),
17                    )
18                    .to_owned(),
19            )
20            .await?;
21
22        Ok(())
23    }
24
25    async fn down(&self, _manager: &SchemaManager) -> Result<(), DbErr> {
26        Ok(())
27    }
28}
29
30#[derive(DeriveIden)]
31enum Sink {
32    Table,
33    AutoRefreshSchemaFromTable,
34}