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.AwsSecretStoreArn == nil {
222		invalidParams.Add(smithy.NewErrParamRequired("AwsSecretStoreArn"))
223	}
224	if v.DbClusterOrInstanceArn == nil {
225		invalidParams.Add(smithy.NewErrParamRequired("DbClusterOrInstanceArn"))
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