--- title: Validate SQL --- [Skip to content](#_top) [API Reference](https://developers.cloudflare.com/api/go) [Pipelines](https://developers.cloudflare.com/api/go/resources/pipelines) Copy Markdown Open in **Claude**Open in **ChatGPT**Open in **Cursor** --- **Copy Markdown****View as Markdown** # Validate SQL client.Pipelines.ValidateSql(ctx, params) (\*[PipelineValidateSqlResponse](), error) POST/accounts/{account\_id}/pipelines/v1/validate\_sql Validates that the Pipelines SQL is correct. ##### Security
API Token The preferred authorization scheme for interacting with the Cloudflare API. Create a token. **Example:**Authorization: Bearer Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY
API Email + API Key The previous authorization scheme for interacting with the Cloudflare API, used in conjunction with a Global API key. **Example:**X-Auth-Email: user@example.com The previous authorization scheme for interacting with the Cloudflare API. When possible, use API tokens instead of Global API keys. **Example:**X-Auth-Key: 144c9defac04969c7bfad8efaa8ea194
##### Accepted Permissions (at least one required) `Pipelines Write` ##### ParametersExpand Collapse
params PipelineValidateSqlParams AccountID param.Field\[string] Path param: Specifies the public ID of the account. Link to this property Sql param.Field\[string] Body param: Specifies SQL to validate. Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(method)%20validate_sql%20%3E%20(params)%20default>) ##### ReturnsExpand Collapse
type PipelineValidateSqlResponse struct{…}
Tables map\[string, PipelineValidateSqlResponseTable] Indicates tables involved in the processing. ID string Link to this property Name string Link to this property Type string Link to this property Version float64 Link to this property
Link to this property
Graph PipelineValidateSqlResponseGraphOptional Indicates the processing flow to implement the SQL.
Edges \[]PipelineValidateSqlResponseGraphEdge DestID int64 formatint32 minimum0 Link to this property EdgeType string Link to this property KeyType string Link to this property SrcID int64 formatint32 minimum0 Link to this property ValueType string Link to this property
Link to this property
Nodes \[]PipelineValidateSqlResponseGraphNode Description string Link to this property NodeID int64 formatint32 minimum0 Link to this property Operator string Link to this property Parallelism int64 formatint32 minimum0 Link to this property
Link to this property
Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(model)%20PipelineValidateSqlResponse%20%3E%20(schema)>) ### Validate SQL Go HTTPTypeScriptPythonGoTerraform ``` package main import ( "context" "fmt" "github.com/cloudflare/cloudflare-go" "github.com/cloudflare/cloudflare-go/option" "github.com/cloudflare/cloudflare-go/pipelines" ) func main() { client := cloudflare.NewClient( option.WithAPIToken("Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY"), ) response, err := client.Pipelines.ValidateSql(context.TODO(), pipelines.PipelineValidateSqlParams{ AccountID: cloudflare.F("0123105f4ecef8ad9ca31a8372d0c353"), Sql: cloudflare.F("insert into sink select * from source;"), }) if err != nil { panic(err.Error()) } fmt.Printf("%+v\n", response.Tables) } ``` 200 example ``` { "result": { "tables": { "foo": { "id": "id", "name": "name", "type": "type", "version": 0 } }, "graph": { "edges": [ { "dest_id": 0, "edge_type": "edge_type", "key_type": "key_type", "src_id": 0, "value_type": "value_type" } ], "nodes": [ { "description": "description", "node_id": 0, "operator": "operator", "parallelism": 0 } ] } }, "success": true } ``` ##### Returns Examples 200 example ``` { "result": { "tables": { "foo": { "id": "id", "name": "name", "type": "type", "version": 0 } }, "graph": { "edges": [ { "dest_id": 0, "edge_type": "edge_type", "key_type": "key_type", "src_id": 0, "value_type": "value_type" } ], "nodes": [ { "description": "description", "node_id": 0, "operator": "operator", "parallelism": 0 } ] } }, "success": true } ```