fn ast_insert_default_confluent_wire_format_0_7_1(
    stmt: &mut sql::ast::Statement<Raw>,
) -> Result<(), anyhow::Error> {
    match stmt {
        Statement::CreateSource(CreateSourceStatement {
            format:
                CreateSourceFormat::Bare(Format::Avro(AvroSchema::InlineSchema {
                    ref mut with_options,
                    ..
                })),
            ..
        }) => {
            if with_options.is_empty() {
                with_options.push(WithOption {
                    key: Ident::new("confluent_wire_format"),
                    value: Some(WithOptionValue::Value(Value::Boolean(true))),
                })
            }
        }
        Statement::CreateSource(CreateSourceStatement {
            format:
                CreateSourceFormat::Bare(Format::Avro(AvroSchema::Csr {
                    csr_connector:
                        CsrConnectorAvro {
                            ref mut with_options,
                            ..
                        },
                })),
            ..
        }) => {
            if with_options.is_empty() {
                with_options.push(SqlOption::Value {
                    name: Ident::new("confluent_wire_format"),
                    value: Value::Boolean(true),
                })
            }
        }
        _ => {}
    }
    Ok(())
}
// Insert default value for confluent_wire_format.
//
// This PR introduced a new `WITH` options block attached to the inline schema
// clause. Previously-created versions of this object must have no options
// specified, so we explicitly set them to their existing behavior, which is
// now described by `confluent_wire_format = true`.
//
// This gives us flexibility to change the default to `false` in the future,
// if desired.
Insert default value for confluent_wire_format.
This PR introduced a new `WITH` options block attached to the inline schema
clause. Previously-created versions of this object must have no options
specified, so we explicitly set them to their existing behavior, which is
now described by `confluent_wire_format = true`.

This gives us flexibility to change the default to `false` in the future,
if desired.
Insert default value for confluent_wire_format . This PR introduced a new ` WITH ` options block attached to the inline schema clause . Previously - created versions of this object must have no options specified so we explicitly set them to their existing behavior which is now described by ` confluent_wire_format = true ` . This gives us flexibility to change the default to ` false ` in the future if desired .
fn ast_insert_default_confluent_wire_format_0_7_1(
    stmt: &mut sql::ast::Statement<Raw>,
) -> Result<(), anyhow::Error> {
    match stmt {
        Statement::CreateSource(CreateSourceStatement {
            format:
                CreateSourceFormat::Bare(Format::Avro(AvroSchema::InlineSchema {
                    ref mut with_options,
                    ..
                })),
            ..
        }) => {
            if with_options.is_empty() {
                with_options.push(WithOption {
                    key: Ident::new("confluent_wire_format"),
                    value: Some(WithOptionValue::Value(Value::Boolean(true))),
                })
            }
        }
        Statement::CreateSource(CreateSourceStatement {
            format:
                CreateSourceFormat::Bare(Format::Avro(AvroSchema::Csr {
                    csr_connector:
                        CsrConnectorAvro {
                            ref mut with_options,
                            ..
                        },
                })),
            ..
        }) => {
            if with_options.is_empty() {
                with_options.push(SqlOption::Value {
                    name: Ident::new("confluent_wire_format"),
                    value: Value::Boolean(true),
                })
            }
        }
        _ => {}
    }
    Ok(())
}
fn ast_insert_default_confluent_wire_format_0_7_1 ( stmt : & mut sql :: ast :: Statement < Raw > , ) -> Result < ( ) , anyhow :: Error > { match stmt { Statement :: CreateSource ( CreateSourceStatement { format : CreateSourceFormat :: Bare ( Format :: Avro ( AvroSchema :: InlineSchema { ref mut with_options , .. } ) ) , .. } ) => { if with_options . is_empty ( ) { with_options . push ( WithOption { key : Ident :: new ( " " ) , value : Some ( WithOptionValue :: Value ( Value :: Boolean ( true ) ) ) , } ) } } Statement :: CreateSource ( CreateSourceStatement { format : CreateSourceFormat :: Bare ( Format :: Avro ( AvroSchema :: Csr { csr_connector : CsrConnectorAvro { ref mut with_options , .. } , } ) ) , .. } ) => { if with_options . is_empty ( ) { with_options . push ( SqlOption :: Value { name : Ident :: new ( " " ) , value : Value :: Boolean ( true ) , } ) } } _ => { } } Ok ( ( ) ) }
Insert default value for confluent_wire_format.
Insert default value for confluent_wire_format .
stmt
&mut sql::ast::Statement<Raw>
stmt
&mut sql::ast::Statement<Raw>