base on Pipelined Query Language # pipelined query language [](https://pql.dev) [](https://pql.dev) [](https://discord.gg/PbeXzrWP) This Go library compiles a pipelined-based query language (inspired by the [Kusto Query Language][]) into SQL. It has been specifically tested to work with the [Clickhouse SQL dialect][], but the generated SQL is intentionally database agnostic. This repository contains a Go library, and a CLI to invoke the library. For example, the following expression: ```plain StormEvents | where DamageProperty > 5000 and EventType == "Thunderstorm Wind" | top 3 by DamageProperty ``` will be compiled to SQL that is similar to: ```sql SELECT * FROM StormEvents WHERE DamageProperty > 5000 AND EventType = 'Thunderstorm Wind' ORDER BY DamageProperty DESC LIMIT 3; ``` [Kusto Query Language]: https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/ [Clickhouse SQL dialect]: https://clickhouse.com/docs/en/sql-reference ## Getting Started If you'd like to see a demo along with some examples, check out https://pql.dev. To use pql in your go code, a minimal example might look like this ``` package main import ( "github.com/runreveal/pql" ) func main() { sql, err := pql.Compile("users | project id, email | limit 5") if err != nil { panic(err) } println(sql) } ``` Running this program should give you the following output ``` $ go run test.go WITH "__subquery0" AS (SELECT "id" AS "id", "email" AS "email" FROM "users") SELECT * FROM "__subquery0" LIMIT 5; ``` ## Documentation The following tabular operators are supported and the Microsoft KQL documentation is representative of the current pql api. - [`as`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/as-operator) - [`count`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/count-operator) - [`join`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/join-operator) - [`let` statements](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/let-statement), but only scalar expressions are supported. - [`project`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/project-operator) - [`extend`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/extend-operator) - [`sort`/`order`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/sort-operator) - [`summarize`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/summarize-operator) - [`take`/`limit`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/take-operator) - [`top`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/top-operator) - [`where`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/where-operator) The following scalar functions are implemented within pql. Functions not in this list will be passed through to the underlying SQL engine. This allows the usage of the full APIs implemented by the underlying engine. - [`not`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/not-function) - [`now`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/now-function) - [`isnull`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/isnull-function) and [`isnotnull`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/isnotnull-function) - [`strcat`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/strcat-function) - [`iff`/`iif`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/iff-function) - [`count`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/count-aggregation-function) - [`countif`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/countif-aggregation-function) - [`tolower`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/tolower-function) - [`toupper`](https://learn.microsoft.com/en-us/azure/data-explorer/kusto/query/toupper-function) Column names with special characters can be escaped with backticks. ## Get involved - Join our [discord](https://discord.gg/NZS9QtCJXt) - Contribute a [scalar function](./CONTRIBUTING.md) ## License [Apache 2.0](LICENSE) ", Assign "at most 3 tags" to the expected json: {"id":"8196","tags":[]} "only from the tags list I provide: [{"id":77,"name":"3d"},{"id":89,"name":"agent"},{"id":17,"name":"ai"},{"id":54,"name":"algorithm"},{"id":24,"name":"api"},{"id":44,"name":"authentication"},{"id":3,"name":"aws"},{"id":27,"name":"backend"},{"id":60,"name":"benchmark"},{"id":72,"name":"best-practices"},{"id":39,"name":"bitcoin"},{"id":37,"name":"blockchain"},{"id":1,"name":"blog"},{"id":45,"name":"bundler"},{"id":58,"name":"cache"},{"id":21,"name":"chat"},{"id":49,"name":"cicd"},{"id":4,"name":"cli"},{"id":64,"name":"cloud-native"},{"id":48,"name":"cms"},{"id":61,"name":"compiler"},{"id":68,"name":"containerization"},{"id":92,"name":"crm"},{"id":34,"name":"data"},{"id":47,"name":"database"},{"id":8,"name":"declarative-gui "},{"id":9,"name":"deploy-tool"},{"id":53,"name":"desktop-app"},{"id":6,"name":"dev-exp-lib"},{"id":59,"name":"dev-tool"},{"id":13,"name":"ecommerce"},{"id":26,"name":"editor"},{"id":66,"name":"emulator"},{"id":62,"name":"filesystem"},{"id":80,"name":"finance"},{"id":15,"name":"firmware"},{"id":73,"name":"for-fun"},{"id":2,"name":"framework"},{"id":11,"name":"frontend"},{"id":22,"name":"game"},{"id":81,"name":"game-engine "},{"id":23,"name":"graphql"},{"id":84,"name":"gui"},{"id":91,"name":"http"},{"id":5,"name":"http-client"},{"id":51,"name":"iac"},{"id":30,"name":"ide"},{"id":78,"name":"iot"},{"id":40,"name":"json"},{"id":83,"name":"julian"},{"id":38,"name":"k8s"},{"id":31,"name":"language"},{"id":10,"name":"learning-resource"},{"id":33,"name":"lib"},{"id":41,"name":"linter"},{"id":28,"name":"lms"},{"id":16,"name":"logging"},{"id":76,"name":"low-code"},{"id":90,"name":"message-queue"},{"id":42,"name":"mobile-app"},{"id":18,"name":"monitoring"},{"id":36,"name":"networking"},{"id":7,"name":"node-version"},{"id":55,"name":"nosql"},{"id":57,"name":"observability"},{"id":46,"name":"orm"},{"id":52,"name":"os"},{"id":14,"name":"parser"},{"id":74,"name":"react"},{"id":82,"name":"real-time"},{"id":56,"name":"robot"},{"id":65,"name":"runtime"},{"id":32,"name":"sdk"},{"id":71,"name":"search"},{"id":63,"name":"secrets"},{"id":25,"name":"security"},{"id":85,"name":"server"},{"id":86,"name":"serverless"},{"id":70,"name":"storage"},{"id":75,"name":"system-design"},{"id":79,"name":"terminal"},{"id":29,"name":"testing"},{"id":12,"name":"ui"},{"id":50,"name":"ux"},{"id":88,"name":"video"},{"id":20,"name":"web-app"},{"id":35,"name":"web-server"},{"id":43,"name":"webassembly"},{"id":69,"name":"workflow"},{"id":87,"name":"yaml"}]" returns me the "expected json"