1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
|
// Code generated by smithy-go-codegen DO NOT EDIT.
package redshiftdata
import (
"context"
awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware"
"github.com/aws/aws-sdk-go-v2/aws/signer/v4"
"github.com/aws/aws-sdk-go-v2/service/redshiftdata/types"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
"time"
)
// Runs an SQL statement, which can be data manipulation language (DML) or data
// definition language (DDL). This statement must be a single SQL statement.
// Depending on the authorization method, use one of the following combinations of
// request parameters:
//
// * Secrets Manager - when connecting to a cluster, specify
// the Amazon Resource Name (ARN) of the secret, the database name, and the cluster
// identifier that matches the cluster in the secret. When connecting to a
// serverless workgroup, specify the Amazon Resource Name (ARN) of the secret and
// the database name.
//
// * Temporary credentials - when connecting to a cluster,
// specify the cluster identifier, the database name, and the database user name.
// Also, permission to call the redshift:GetClusterCredentials operation is
// required. When connecting to a serverless workgroup, specify the workgroup name
// and database name. Also, permission to call the
// redshift-serverless:GetCredentials operation is required.
func (c *Client) ExecuteStatement(ctx context.Context, params *ExecuteStatementInput, optFns ...func(*Options)) (*ExecuteStatementOutput, error) {
if params == nil {
params = &ExecuteStatementInput{}
}
result, metadata, err := c.invokeOperation(ctx, "ExecuteStatement", params, optFns, c.addOperationExecuteStatementMiddlewares)
if err != nil {
return nil, err
}
out := result.(*ExecuteStatementOutput)
out.ResultMetadata = metadata
return out, nil
}
type ExecuteStatementInput struct {
// The name of the database. This parameter is required when authenticating using
// either Secrets Manager or temporary credentials.
//
// This member is required.
Database *string
// The SQL statement text to run.
//
// This member is required.
Sql *string
// The cluster identifier. This parameter is required when connecting to a cluster
// and authenticating using either Secrets Manager or temporary credentials.
ClusterIdentifier *string
// The database user name. This parameter is required when connecting to a cluster
// and authenticating using temporary credentials.
DbUser *string
// The parameters for the SQL statement.
Parameters []types.SqlParameter
// The name or ARN of the secret that enables access to the database. This
// parameter is required when authenticating using Secrets Manager.
SecretArn *string
// The name of the SQL statement. You can name the SQL statement when you create it
// to identify the query.
StatementName *string
// A value that indicates whether to send an event to the Amazon EventBridge event
// bus after the SQL statement runs.
WithEvent *bool
// The serverless workgroup name. This parameter is required when connecting to a
// serverless workgroup and authenticating using either Secrets Manager or
// temporary credentials.
WorkgroupName *string
noSmithyDocumentSerde
}
type ExecuteStatementOutput struct {
// The cluster identifier. This element is not returned when connecting to a
// serverless workgroup.
ClusterIdentifier *string
// The date and time (UTC) the statement was created.
CreatedAt *time.Time
// The name of the database.
Database *string
// The database user name.
DbUser *string
// The identifier of the SQL statement whose results are to be fetched. This value
// is a universally unique identifier (UUID) generated by Amazon Redshift Data API.
Id *string
// The name or ARN of the secret that enables access to the database.
SecretArn *string
// The serverless workgroup name. This element is not returned when connecting to a
// provisioned cluster.
WorkgroupName *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
noSmithyDocumentSerde
}
func (c *Client) addOperationExecuteStatementMiddlewares(stack *middleware.Stack, options Options) (err error) {
err = stack.Serialize.Add(&awsAwsjson11_serializeOpExecuteStatement{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpExecuteStatement{}, middleware.After)
if err != nil {
return err
}
if err = addSetLoggerMiddleware(stack, options); err != nil {
return err
}
if err = awsmiddleware.AddClientRequestIDMiddleware(stack); err != nil {
return err
}
if err = smithyhttp.AddComputeContentLengthMiddleware(stack); err != nil {
return err
}
if err = addResolveEndpointMiddleware(stack, options); err != nil {
return err
}
if err = v4.AddComputePayloadSHA256Middleware(stack); err != nil {
return err
}
if err = addRetryMiddlewares(stack, options); err != nil {
return err
}
if err = addHTTPSignerV4Middleware(stack, options); err != nil {
return err
}
if err = awsmiddleware.AddRawResponseToMetadata(stack); err != nil {
return err
}
if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil {
return err
}
if err = addClientUserAgent(stack); err != nil {
return err
}
if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil {
return err
}
if err = addOpExecuteStatementValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opExecuteStatement(options.Region), middleware.Before); err != nil {
return err
}
if err = addRequestIDRetrieverMiddleware(stack); err != nil {
return err
}
if err = addResponseErrorMiddleware(stack); err != nil {
return err
}
if err = addRequestResponseLogging(stack, options); err != nil {
return err
}
return nil
}
func newServiceMetadataMiddleware_opExecuteStatement(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
SigningName: "redshift-data",
OperationName: "ExecuteStatement",
}
}
|
