1// Code generated by smithy-go-codegen DO NOT EDIT. 2 3package athena 4 5import ( 6 "context" 7 "fmt" 8 awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware" 9 "github.com/aws/aws-sdk-go-v2/aws/signer/v4" 10 "github.com/aws/smithy-go/middleware" 11 smithyhttp "github.com/aws/smithy-go/transport/http" 12) 13 14// Creates a named query in the specified workgroup. Requires that you have access 15// to the workgroup. For code samples using the AWS SDK for Java, see Examples and 16// Code Samples (http://docs.aws.amazon.com/athena/latest/ug/code-samples.html) in 17// the Amazon Athena User Guide. 18func (c *Client) CreateNamedQuery(ctx context.Context, params *CreateNamedQueryInput, optFns ...func(*Options)) (*CreateNamedQueryOutput, error) { 19 if params == nil { 20 params = &CreateNamedQueryInput{} 21 } 22 23 result, metadata, err := c.invokeOperation(ctx, "CreateNamedQuery", params, optFns, addOperationCreateNamedQueryMiddlewares) 24 if err != nil { 25 return nil, err 26 } 27 28 out := result.(*CreateNamedQueryOutput) 29 out.ResultMetadata = metadata 30 return out, nil 31} 32 33type CreateNamedQueryInput struct { 34 35 // The database to which the query belongs. 36 // 37 // This member is required. 38 Database *string 39 40 // The query name. 41 // 42 // This member is required. 43 Name *string 44 45 // The contents of the query with all query statements. 46 // 47 // This member is required. 48 QueryString *string 49 50 // A unique case-sensitive string used to ensure the request to create the query is 51 // idempotent (executes only once). If another CreateNamedQuery request is 52 // received, the same response is returned and another query is not created. If a 53 // parameter has changed, for example, the QueryString, an error is returned. This 54 // token is listed as not required because AWS SDKs (for example the AWS SDK for 55 // Java) auto-generate the token for users. If you are not using the AWS SDK or the 56 // AWS CLI, you must provide this token or the action will fail. 57 ClientRequestToken *string 58 59 // The query description. 60 Description *string 61 62 // The name of the workgroup in which the named query is being created. 63 WorkGroup *string 64} 65 66type CreateNamedQueryOutput struct { 67 68 // The unique ID of the query. 69 NamedQueryId *string 70 71 // Metadata pertaining to the operation's result. 72 ResultMetadata middleware.Metadata 73} 74 75func addOperationCreateNamedQueryMiddlewares(stack *middleware.Stack, options Options) (err error) { 76 err = stack.Serialize.Add(&awsAwsjson11_serializeOpCreateNamedQuery{}, middleware.After) 77 if err != nil { 78 return err 79 } 80 err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpCreateNamedQuery{}, middleware.After) 81 if err != nil { 82 return err 83 } 84 if err = addSetLoggerMiddleware(stack, options); err != nil { 85 return err 86 } 87 if err = awsmiddleware.AddClientRequestIDMiddleware(stack); err != nil { 88 return err 89 } 90 if err = smithyhttp.AddComputeContentLengthMiddleware(stack); err != nil { 91 return err 92 } 93 if err = addResolveEndpointMiddleware(stack, options); err != nil { 94 return err 95 } 96 if err = v4.AddComputePayloadSHA256Middleware(stack); err != nil { 97 return err 98 } 99 if err = addRetryMiddlewares(stack, options); err != nil { 100 return err 101 } 102 if err = addHTTPSignerV4Middleware(stack, options); err != nil { 103 return err 104 } 105 if err = awsmiddleware.AddRawResponseToMetadata(stack); err != nil { 106 return err 107 } 108 if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil { 109 return err 110 } 111 if err = addClientUserAgent(stack); err != nil { 112 return err 113 } 114 if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil { 115 return err 116 } 117 if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil { 118 return err 119 } 120 if err = addIdempotencyToken_opCreateNamedQueryMiddleware(stack, options); err != nil { 121 return err 122 } 123 if err = addOpCreateNamedQueryValidationMiddleware(stack); err != nil { 124 return err 125 } 126 if err = stack.Initialize.Add(newServiceMetadataMiddleware_opCreateNamedQuery(options.Region), middleware.Before); err != nil { 127 return err 128 } 129 if err = addRequestIDRetrieverMiddleware(stack); err != nil { 130 return err 131 } 132 if err = addResponseErrorMiddleware(stack); err != nil { 133 return err 134 } 135 if err = addRequestResponseLogging(stack, options); err != nil { 136 return err 137 } 138 return nil 139} 140 141type idempotencyToken_initializeOpCreateNamedQuery struct { 142 tokenProvider IdempotencyTokenProvider 143} 144 145func (*idempotencyToken_initializeOpCreateNamedQuery) ID() string { 146 return "OperationIdempotencyTokenAutoFill" 147} 148 149func (m *idempotencyToken_initializeOpCreateNamedQuery) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( 150 out middleware.InitializeOutput, metadata middleware.Metadata, err error, 151) { 152 if m.tokenProvider == nil { 153 return next.HandleInitialize(ctx, in) 154 } 155 156 input, ok := in.Parameters.(*CreateNamedQueryInput) 157 if !ok { 158 return out, metadata, fmt.Errorf("expected middleware input to be of type *CreateNamedQueryInput ") 159 } 160 161 if input.ClientRequestToken == nil { 162 t, err := m.tokenProvider.GetIdempotencyToken() 163 if err != nil { 164 return out, metadata, err 165 } 166 input.ClientRequestToken = &t 167 } 168 return next.HandleInitialize(ctx, in) 169} 170func addIdempotencyToken_opCreateNamedQueryMiddleware(stack *middleware.Stack, cfg Options) error { 171 return stack.Initialize.Add(&idempotencyToken_initializeOpCreateNamedQuery{tokenProvider: cfg.IdempotencyTokenProvider}, middleware.Before) 172} 173 174func newServiceMetadataMiddleware_opCreateNamedQuery(region string) *awsmiddleware.RegisterServiceMetadata { 175 return &awsmiddleware.RegisterServiceMetadata{ 176 Region: region, 177 ServiceID: ServiceID, 178 SigningName: "athena", 179 OperationName: "CreateNamedQuery", 180 } 181} 182