1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package rdsdata 4 5import ( 6 "context" 7 "fmt" 8 smithy "github.com/aws/smithy-go" 9 "github.com/aws/smithy-go/middleware" 10) 11 12type validateOpBatchExecuteStatement struct { 13} 14 15func (*validateOpBatchExecuteStatement) ID() string { 16 return "OperationInputValidation" 17} 18 19func (m *validateOpBatchExecuteStatement) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 20 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 21) { 22 input, ok := in.Parameters.(*BatchExecuteStatementInput) 23 if !ok { 24 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 25 } 26 if err := validateOpBatchExecuteStatementInput(input); err != nil { 27 return out, metadata, err 28 } 29 return next.HandleInitialize(ctx, in) 30} 31 32type validateOpBeginTransaction struct { 33} 34 35func (*validateOpBeginTransaction) ID() string { 36 return "OperationInputValidation" 37} 38 39func (m *validateOpBeginTransaction) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 40 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 41) { 42 input, ok := in.Parameters.(*BeginTransactionInput) 43 if !ok { 44 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 45 } 46 if err := validateOpBeginTransactionInput(input); err != nil { 47 return out, metadata, err 48 } 49 return next.HandleInitialize(ctx, in) 50} 51 52type validateOpCommitTransaction struct { 53} 54 55func (*validateOpCommitTransaction) ID() string { 56 return "OperationInputValidation" 57} 58 59func (m *validateOpCommitTransaction) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 60 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 61) { 62 input, ok := in.Parameters.(*CommitTransactionInput) 63 if !ok { 64 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 65 } 66 if err := validateOpCommitTransactionInput(input); err != nil { 67 return out, metadata, err 68 } 69 return next.HandleInitialize(ctx, in) 70} 71 72type validateOpExecuteSql struct { 73} 74 75func (*validateOpExecuteSql) ID() string { 76 return "OperationInputValidation" 77} 78 79func (m *validateOpExecuteSql) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 80 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 81) { 82 input, ok := in.Parameters.(*ExecuteSqlInput) 83 if !ok { 84 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 85 } 86 if err := validateOpExecuteSqlInput(input); err != nil { 87 return out, metadata, err 88 } 89 return next.HandleInitialize(ctx, in) 90} 91 92type validateOpExecuteStatement struct { 93} 94 95func (*validateOpExecuteStatement) ID() string { 96 return "OperationInputValidation" 97} 98 99func (m *validateOpExecuteStatement) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 100 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 101) { 102 input, ok := in.Parameters.(*ExecuteStatementInput) 103 if !ok { 104 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 105 } 106 if err := validateOpExecuteStatementInput(input); err != nil { 107 return out, metadata, err 108 } 109 return next.HandleInitialize(ctx, in) 110} 111 112type validateOpRollbackTransaction struct { 113} 114 115func (*validateOpRollbackTransaction) ID() string { 116 return "OperationInputValidation" 117} 118 119func (m *validateOpRollbackTransaction) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 120 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 121) { 122 input, ok := in.Parameters.(*RollbackTransactionInput) 123 if !ok { 124 return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters) 125 } 126 if err := validateOpRollbackTransactionInput(input); err != nil { 127 return out, metadata, err 128 } 129 return next.HandleInitialize(ctx, in) 130} 131 132func addOpBatchExecuteStatementValidationMiddleware(stack *middleware.Stack) error { 133 return stack.Initialize.Add(&validateOpBatchExecuteStatement{}, middleware.After) 134} 135 136func addOpBeginTransactionValidationMiddleware(stack *middleware.Stack) error { 137 return stack.Initialize.Add(&validateOpBeginTransaction{}, middleware.After) 138} 139 140func addOpCommitTransactionValidationMiddleware(stack *middleware.Stack) error { 141 return stack.Initialize.Add(&validateOpCommitTransaction{}, middleware.After) 142} 143 144func addOpExecuteSqlValidationMiddleware(stack *middleware.Stack) error { 145 return stack.Initialize.Add(&validateOpExecuteSql{}, middleware.After) 146} 147 148func addOpExecuteStatementValidationMiddleware(stack *middleware.Stack) error { 149 return stack.Initialize.Add(&validateOpExecuteStatement{}, middleware.After) 150} 151 152func addOpRollbackTransactionValidationMiddleware(stack *middleware.Stack) error { 153 return stack.Initialize.Add(&validateOpRollbackTransaction{}, middleware.After) 154} 155 156func validateOpBatchExecuteStatementInput(v *BatchExecuteStatementInput) error { 157 if v == nil { 158 return nil 159 } 160 invalidParams := smithy.InvalidParamsError{Context: "BatchExecuteStatementInput"} 161 if v.ResourceArn == nil { 162 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 163 } 164 if v.SecretArn == nil { 165 invalidParams.Add(smithy.NewErrParamRequired("SecretArn")) 166 } 167 if v.Sql == nil { 168 invalidParams.Add(smithy.NewErrParamRequired("Sql")) 169 } 170 if invalidParams.Len() > 0 { 171 return invalidParams 172 } else { 173 return nil 174 } 175} 176 177func validateOpBeginTransactionInput(v *BeginTransactionInput) error { 178 if v == nil { 179 return nil 180 } 181 invalidParams := smithy.InvalidParamsError{Context: "BeginTransactionInput"} 182 if v.ResourceArn == nil { 183 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 184 } 185 if v.SecretArn == nil { 186 invalidParams.Add(smithy.NewErrParamRequired("SecretArn")) 187 } 188 if invalidParams.Len() > 0 { 189 return invalidParams 190 } else { 191 return nil 192 } 193} 194 195func validateOpCommitTransactionInput(v *CommitTransactionInput) error { 196 if v == nil { 197 return nil 198 } 199 invalidParams := smithy.InvalidParamsError{Context: "CommitTransactionInput"} 200 if v.ResourceArn == nil { 201 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 202 } 203 if v.SecretArn == nil { 204 invalidParams.Add(smithy.NewErrParamRequired("SecretArn")) 205 } 206 if v.TransactionId == nil { 207 invalidParams.Add(smithy.NewErrParamRequired("TransactionId")) 208 } 209 if invalidParams.Len() > 0 { 210 return invalidParams 211 } else { 212 return nil 213 } 214} 215 216func validateOpExecuteSqlInput(v *ExecuteSqlInput) error { 217 if v == nil { 218 return nil 219 } 220 invalidParams := smithy.InvalidParamsError{Context: "ExecuteSqlInput"} 221 if v.DbClusterOrInstanceArn == nil { 222 invalidParams.Add(smithy.NewErrParamRequired("DbClusterOrInstanceArn")) 223 } 224 if v.AwsSecretStoreArn == nil { 225 invalidParams.Add(smithy.NewErrParamRequired("AwsSecretStoreArn")) 226 } 227 if v.SqlStatements == nil { 228 invalidParams.Add(smithy.NewErrParamRequired("SqlStatements")) 229 } 230 if invalidParams.Len() > 0 { 231 return invalidParams 232 } else { 233 return nil 234 } 235} 236 237func validateOpExecuteStatementInput(v *ExecuteStatementInput) error { 238 if v == nil { 239 return nil 240 } 241 invalidParams := smithy.InvalidParamsError{Context: "ExecuteStatementInput"} 242 if v.ResourceArn == nil { 243 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 244 } 245 if v.SecretArn == nil { 246 invalidParams.Add(smithy.NewErrParamRequired("SecretArn")) 247 } 248 if v.Sql == nil { 249 invalidParams.Add(smithy.NewErrParamRequired("Sql")) 250 } 251 if invalidParams.Len() > 0 { 252 return invalidParams 253 } else { 254 return nil 255 } 256} 257 258func validateOpRollbackTransactionInput(v *RollbackTransactionInput) error { 259 if v == nil { 260 return nil 261 } 262 invalidParams := smithy.InvalidParamsError{Context: "RollbackTransactionInput"} 263 if v.ResourceArn == nil { 264 invalidParams.Add(smithy.NewErrParamRequired("ResourceArn")) 265 } 266 if v.SecretArn == nil { 267 invalidParams.Add(smithy.NewErrParamRequired("SecretArn")) 268 } 269 if v.TransactionId == nil { 270 invalidParams.Add(smithy.NewErrParamRequired("TransactionId")) 271 } 272 if invalidParams.Len() > 0 { 273 return invalidParams 274 } else { 275 return nil 276 } 277} 278