risingwave_meta_model_migration/
m20251112_114514_streaming_job_config_override.rs

1use sea_orm_migration::prelude::*;
2
3use crate::utils::ColumnDefExt;
4
5#[derive(DeriveMigrationName)]
6pub struct Migration;
7
8#[async_trait::async_trait]
9impl MigrationTrait for Migration {
10    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
11        manager
12            .alter_table(
13                Table::alter()
14                    .table(StreamingJob::Table)
15                    // MySQL does not support default value for long text column.
16                    // So we have to make it nullable here.
17                    .add_column(ColumnDef::new(StreamingJob::ConfigOverride).rw_long_text(manager))
18                    .to_owned(),
19            )
20            .await
21    }
22
23    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
24        manager
25            .alter_table(
26                Table::alter()
27                    .table(StreamingJob::Table)
28                    .drop_column(StreamingJob::ConfigOverride)
29                    .to_owned(),
30            )
31            .await
32    }
33}
34
35#[derive(DeriveIden)]
36enum StreamingJob {
37    Table,
38    ConfigOverride,
39}