Readme quick start example.
This commit is contained in:
go-jet
parent
b15d8491fb
commit
4f247ab63e
8 changed files with 8344 additions and 2 deletions
1
.gitignore
vendored
1
.gitignore
vendored
|
|
@ -15,4 +15,5 @@
|
||||||
.idea
|
.idea
|
||||||
|
|
||||||
# Test files
|
# Test files
|
||||||
|
gen
|
||||||
.gentestdata
|
.gentestdata
|
||||||
319
README.md
319
README.md
|
|
@ -2,3 +2,322 @@
|
||||||
|
|
||||||
[](https://circleci.com/gh/go-jet/jet/tree/develop)
|
[](https://circleci.com/gh/go-jet/jet/tree/develop)
|
||||||
|
|
||||||
|
Jet is sql builder for Postgresql(support for MySql and OracleSql will be added later). Jet enables writing typesafe SQL queries in Go, and ability to easily convert query result to desired arbitrary structure.
|
||||||
|
|
||||||
|
#Features
|
||||||
|
* TODO
|
||||||
|
|
||||||
|
# Getting Started
|
||||||
|
|
||||||
|
##Prerequisites
|
||||||
|
|
||||||
|
To install Jet package, you need to install Go and set your Go workspace first.
|
||||||
|
|
||||||
|
[Go](https://golang.org/) **version 1.8+ is required**
|
||||||
|
|
||||||
|
##Installation
|
||||||
|
|
||||||
|
Use the bellow command to install jet
|
||||||
|
```sh
|
||||||
|
$ go get -u github.com/go-jet/jet
|
||||||
|
```
|
||||||
|
|
||||||
|
Install jetgen to GOPATH bin folder. This will allow generating jet files from the command line.
|
||||||
|
|
||||||
|
```sh
|
||||||
|
go install github.com/go-jet/jet/cmd/jetgen
|
||||||
|
```
|
||||||
|
|
||||||
|
Make sure GOPATH bin folder is added to the PATH environment variable.
|
||||||
|
|
||||||
|
##Quick Start
|
||||||
|
For this quick start example we will use sample dvd rental database. Full database dump can be found in [./tests/init/data/dvds.sql](./tests/init/data/dvds.sql)
|
||||||
|
Schema diagram of interest for example can be found [here](./examples/quick-start/diagram.png).
|
||||||
|
|
||||||
|
###Generate sql builder and model files
|
||||||
|
To generate sql builder and data model go files we need to call jetgen, and provide it with postgres connection parameters and destination folder for generated go files.
|
||||||
|
Sample command used in tests:
|
||||||
|
```sh
|
||||||
|
jetgen -host=localhost -port=5432 -user=jet -password=jet -dbname=jetdb -schema dvds -path ./gen
|
||||||
|
```
|
||||||
|
```sh
|
||||||
|
Connecting to postgres database: host=localhost port=5432 user=jet password=jet dbname=jetdb sslmode=disable
|
||||||
|
Retrieving schema information...
|
||||||
|
FOUND 15 table(s), 1 enum(s)
|
||||||
|
Cleaning up destination directory...
|
||||||
|
Generating table sql builder files...
|
||||||
|
Generating table model files...
|
||||||
|
Generating enum sql builder files...
|
||||||
|
Generating enum model files...
|
||||||
|
Done
|
||||||
|
```
|
||||||
|
As jetgen command output suggest, jetgen will:
|
||||||
|
-connect to `dvds` database to retrieve information about the structure of database
|
||||||
|
-delete everything in destination folder `./gen`,
|
||||||
|
-and finally generate sql builder and model *.go files for all database tables and enums in destination folder `./tests/gentestdata`.
|
||||||
|
|
||||||
|
###Now lets write some SQL queries in go
|
||||||
|
|
||||||
|
First lets import jet and generated files from previous step
|
||||||
|
```go
|
||||||
|
import (
|
||||||
|
. "github.com/go-jet/jet" // dot import so go code would resemble as much as native SQL
|
||||||
|
. "github.com/go-jet/jet/examples/quick-start/gen/jetdb/dvds/table" // dot import is not mandatory
|
||||||
|
|
||||||
|
"github.com/go-jet/jet/examples/quick-start/gen/jetdb/dvds/model"
|
||||||
|
)
|
||||||
|
```
|
||||||
|
Lets say we want to retrieve the list of all actors that acted in films longer than 180 minutes, film language is 'English'
|
||||||
|
and film category is not 'Action'.
|
||||||
|
```go
|
||||||
|
stmt := SELECT(
|
||||||
|
Actor.ActorID, Actor.FirstName, Actor.LastName, Actor.LastUpdate, // list of all actor columns (equivalent to Actor.AllColumns)
|
||||||
|
Film.AllColumns, // list of all film columns (equivalent to Film.FilmID, Film.Title, ...)
|
||||||
|
Language.AllColumns,
|
||||||
|
Category.AllColumns,
|
||||||
|
).FROM(
|
||||||
|
Actor.
|
||||||
|
INNER_JOIN(FilmActor, Actor.ActorID.EQ(FilmActor.ActorID)). // INNER JOIN Actor with FilmActor on condition Actor.ActorID = FilmActor.ActorID
|
||||||
|
INNER_JOIN(Film, Film.FilmID.EQ(FilmActor.FilmID)). // then with Film, Language, FilmCategory and Category.
|
||||||
|
INNER_JOIN(Language, Language.LanguageID.EQ(Film.LanguageID)).
|
||||||
|
INNER_JOIN(FilmCategory, FilmCategory.FilmID.EQ(Film.FilmID)).
|
||||||
|
INNER_JOIN(Category, Category.CategoryID.EQ(FilmCategory.CategoryID)),
|
||||||
|
).WHERE(
|
||||||
|
Language.Name.EQ(String("English")). // note every column has type.
|
||||||
|
AND(Category.Name.NOT_EQ(String("Action"))). // String column Language.Name and Category.Name can be compared only with string columns and expressions
|
||||||
|
AND(Film.Length.GT(Int(180))), // Film.Length is integer column and can be compared only with integer columns and expressions
|
||||||
|
).ORDER_BY(
|
||||||
|
Actor.ActorID.ASC(),
|
||||||
|
Film.FilmID.ASC(),
|
||||||
|
)
|
||||||
|
```
|
||||||
|
To see sql formed with this statement:
|
||||||
|
```go
|
||||||
|
query, args, err := stmt.Sql()
|
||||||
|
```
|
||||||
|
query - is parametrized query
|
||||||
|
args - are parameters for the query
|
||||||
|
|
||||||
|
To see debug sql that can be copy pasted to sql editor and executed.
|
||||||
|
```go
|
||||||
|
query, err := stmt.DebugSql()
|
||||||
|
```
|
||||||
|
query - is parametrized query where every parameter is replaced with appropriate string argument representation
|
||||||
|
|
||||||
|
Well formed sql is just a first half the job. Now lets execute sql statement and store result in desired structure.
|
||||||
|
Let's say this is our desired structure:
|
||||||
|
```go
|
||||||
|
var dest []struct {
|
||||||
|
model.Actor
|
||||||
|
Films []struct {
|
||||||
|
model.Film
|
||||||
|
Language model.Language
|
||||||
|
Category []model.Category
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
|
There is no limitation for how big or nested destination structure can be.
|
||||||
|
|
||||||
|
Now to execute a statement on open database connection db.
|
||||||
|
|
||||||
|
```go
|
||||||
|
err := stmt.Query(db, &dest)
|
||||||
|
handleError(err)
|
||||||
|
```
|
||||||
|
|
||||||
|
And thats it. `dest` now contains the list of all actors that acted in films longer than 180 minutes, film language is 'English'
|
||||||
|
and film category is not 'Action'.
|
||||||
|
|
||||||
|
Lets print `dest` as a json to see:
|
||||||
|
```go
|
||||||
|
jsonText, _ := json.MarshalIndent(dest, "", "\t")
|
||||||
|
fmt.Println(string(jsonText))
|
||||||
|
```
|
||||||
|
|
||||||
|
```json
|
||||||
|
[
|
||||||
|
{
|
||||||
|
"ActorID": 1,
|
||||||
|
"FirstName": "Penelope",
|
||||||
|
"LastName": "Guiness",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z",
|
||||||
|
"Films": [
|
||||||
|
{
|
||||||
|
"FilmID": 499,
|
||||||
|
"Title": "King Evolution",
|
||||||
|
"Description": "A Action-Packed Tale of a Boy And a Lumberjack who must Chase a Madman in A Baloon",
|
||||||
|
"ReleaseYear": 2006,
|
||||||
|
"LanguageID": 1,
|
||||||
|
"RentalDuration": 3,
|
||||||
|
"RentalRate": 4.99,
|
||||||
|
"Length": 184,
|
||||||
|
"ReplacementCost": 24.99,
|
||||||
|
"Rating": "NC-17",
|
||||||
|
"LastUpdate": "2013-05-26T14:50:58.951Z",
|
||||||
|
"SpecialFeatures": "{Trailers,\"Deleted Scenes\",\"Behind the Scenes\"}",
|
||||||
|
"Fulltext": "'action':5 'action-pack':4 'baloon':21 'boy':10 'chase':16 'evolut':2 'king':1 'lumberjack':13 'madman':18 'must':15 'pack':6 'tale':7",
|
||||||
|
"Language": {
|
||||||
|
"LanguageID": 1,
|
||||||
|
"Name": "English ",
|
||||||
|
"LastUpdate": "2006-02-15T10:02:19Z"
|
||||||
|
},
|
||||||
|
"Category": [
|
||||||
|
{
|
||||||
|
"CategoryID": 8,
|
||||||
|
"Name": "Family",
|
||||||
|
"LastUpdate": "2006-02-15T09:46:27Z"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"ActorID": 3,
|
||||||
|
"FirstName": "Ed",
|
||||||
|
"LastName": "Chase",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z",
|
||||||
|
"Films": [
|
||||||
|
{
|
||||||
|
"FilmID": 996,
|
||||||
|
"Title": "Young Language",
|
||||||
|
"Description": "A Unbelieveable Yarn of a Boat And a Database Administrator who must Meet a Boy in The First Manned Space Station",
|
||||||
|
"ReleaseYear": 2006,
|
||||||
|
"LanguageID": 1,
|
||||||
|
"RentalDuration": 6,
|
||||||
|
"RentalRate": 0.99,
|
||||||
|
"Length": 183,
|
||||||
|
"ReplacementCost": 9.99,
|
||||||
|
"Rating": "G",
|
||||||
|
"LastUpdate": "2013-05-26T14:50:58.951Z",
|
||||||
|
"SpecialFeatures": "{Trailers,\"Behind the Scenes\"}",
|
||||||
|
"Fulltext": "'administr':12 'boat':8 'boy':17 'databas':11 'first':20 'languag':2 'man':21 'meet':15 'must':14 'space':22 'station':23 'unbeliev':4 'yarn':5 'young':1",
|
||||||
|
"Language": {
|
||||||
|
"LanguageID": 1,
|
||||||
|
"Name": "English ",
|
||||||
|
"LastUpdate": "2006-02-15T10:02:19Z"
|
||||||
|
},
|
||||||
|
"Category": [
|
||||||
|
{
|
||||||
|
"CategoryID": 6,
|
||||||
|
"Name": "Documentary",
|
||||||
|
"LastUpdate": "2006-02-15T09:46:27Z"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
...(125 more items)
|
||||||
|
```
|
||||||
|
|
||||||
|
What if we also want to have list of films per category and actors per category, where films are longer than 180 minutes, film language is 'English'
|
||||||
|
and film category is not 'Action'.
|
||||||
|
In that case we can reuse above statement `stmt`, and just change our destination:
|
||||||
|
|
||||||
|
```go
|
||||||
|
var dest2 []struct {
|
||||||
|
model.Category
|
||||||
|
|
||||||
|
Film []model.Film
|
||||||
|
Actor []model.Actor
|
||||||
|
}
|
||||||
|
|
||||||
|
err = stmt.Query(db, &dest2)
|
||||||
|
handleError(err)
|
||||||
|
```
|
||||||
|
<details>
|
||||||
|
<summary>`dest2` json: </summary>
|
||||||
|
|
||||||
|
```json
|
||||||
|
[
|
||||||
|
{
|
||||||
|
"CategoryID": 8,
|
||||||
|
"Name": "Family",
|
||||||
|
"LastUpdate": "2006-02-15T09:46:27Z",
|
||||||
|
"Film": [
|
||||||
|
{
|
||||||
|
"FilmID": 499,
|
||||||
|
"Title": "King Evolution",
|
||||||
|
"Description": "A Action-Packed Tale of a Boy And a Lumberjack who must Chase a Madman in A Baloon",
|
||||||
|
"ReleaseYear": 2006,
|
||||||
|
"LanguageID": 1,
|
||||||
|
"RentalDuration": 3,
|
||||||
|
"RentalRate": 4.99,
|
||||||
|
"Length": 184,
|
||||||
|
"ReplacementCost": 24.99,
|
||||||
|
"Rating": "NC-17",
|
||||||
|
"LastUpdate": "2013-05-26T14:50:58.951Z",
|
||||||
|
"SpecialFeatures": "{Trailers,\"Deleted Scenes\",\"Behind the Scenes\"}",
|
||||||
|
"Fulltext": "'action':5 'action-pack':4 'baloon':21 'boy':10 'chase':16 'evolut':2 'king':1 'lumberjack':13 'madman':18 'must':15 'pack':6 'tale':7"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"FilmID": 50,
|
||||||
|
"Title": "Baked Cleopatra",
|
||||||
|
"Description": "A Stunning Drama of a Forensic Psychologist And a Husband who must Overcome a Waitress in A Monastery",
|
||||||
|
"ReleaseYear": 2006,
|
||||||
|
"LanguageID": 1,
|
||||||
|
"RentalDuration": 3,
|
||||||
|
"RentalRate": 2.99,
|
||||||
|
"Length": 182,
|
||||||
|
"ReplacementCost": 20.99,
|
||||||
|
"Rating": "G",
|
||||||
|
"LastUpdate": "2013-05-26T14:50:58.951Z",
|
||||||
|
"SpecialFeatures": "{Commentaries,\"Behind the Scenes\"}",
|
||||||
|
"Fulltext": "'bake':1 'cleopatra':2 'drama':5 'forens':8 'husband':12 'monasteri':20 'must':14 'overcom':15 'psychologist':9 'stun':4 'waitress':17"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"Actor": [
|
||||||
|
{
|
||||||
|
"ActorID": 1,
|
||||||
|
"FirstName": "Penelope",
|
||||||
|
"LastName": "Guiness",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"ActorID": 20,
|
||||||
|
"FirstName": "Lucille",
|
||||||
|
"LastName": "Tracy",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"ActorID": 36,
|
||||||
|
"FirstName": "Burt",
|
||||||
|
"LastName": "Dukakis",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"ActorID": 70,
|
||||||
|
"FirstName": "Michelle",
|
||||||
|
"LastName": "Mcconaughey",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"ActorID": 118,
|
||||||
|
"FirstName": "Cuba",
|
||||||
|
"LastName": "Allen",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"ActorID": 187,
|
||||||
|
"FirstName": "Renee",
|
||||||
|
"LastName": "Ball",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"ActorID": 198,
|
||||||
|
"FirstName": "Mary",
|
||||||
|
"LastName": "Keitel",
|
||||||
|
"LastUpdate": "2013-05-26T14:47:57.62Z"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
...
|
||||||
|
```
|
||||||
|
</details>
|
||||||
|
|
||||||
|
Complete code example can be found at [./examples/quick-start/quick-start.go](./examples/quick-start/quick-start.go)
|
||||||
|
|
||||||
|
#Contributing
|
||||||
|
|
||||||
|
#Versioning
|
||||||
|
|
||||||
|
#Licence
|
||||||
|
|
@ -25,8 +25,8 @@ func init() {
|
||||||
flag.StringVar(&port, "port", "", "Database port")
|
flag.StringVar(&port, "port", "", "Database port")
|
||||||
flag.StringVar(&user, "user", "", "Database user")
|
flag.StringVar(&user, "user", "", "Database user")
|
||||||
flag.StringVar(&password, "password", "", "The user’s password")
|
flag.StringVar(&password, "password", "", "The user’s password")
|
||||||
flag.StringVar(&sslmode, "sslmode", "disable", "Whether or not to use SSL")
|
flag.StringVar(&sslmode, "sslmode", "disable", "Whether or not to use SSL(optional)")
|
||||||
flag.StringVar(¶ms, "params", "", "Additional connection string parameters.")
|
flag.StringVar(¶ms, "params", "", "Additional connection string parameters(optional)")
|
||||||
|
|
||||||
flag.StringVar(&dbName, "dbname", "", "name of the database")
|
flag.StringVar(&dbName, "dbname", "", "name of the database")
|
||||||
flag.StringVar(&schemaName, "schema", "public", "Database schema name.")
|
flag.StringVar(&schemaName, "schema", "public", "Database schema name.")
|
||||||
|
|
@ -38,6 +38,12 @@ func init() {
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
|
||||||
|
if host == "" || port == "" || user == "" || dbName == "" || schemaName == "" {
|
||||||
|
fmt.Println("jetgen: required flag missing")
|
||||||
|
flag.Usage()
|
||||||
|
os.Exit(-2)
|
||||||
|
}
|
||||||
|
|
||||||
genData := postgresgen.DBConnection{
|
genData := postgresgen.DBConnection{
|
||||||
Host: host,
|
Host: host,
|
||||||
Port: port,
|
Port: port,
|
||||||
|
|
|
||||||
BIN
examples/quick-start/diagram.png
Normal file
BIN
examples/quick-start/diagram.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 28 KiB |
91
examples/quick-start/quick-start.go
Normal file
91
examples/quick-start/quick-start.go
Normal file
|
|
@ -0,0 +1,91 @@
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"encoding/json"
|
||||||
|
"fmt"
|
||||||
|
|
||||||
|
. "github.com/go-jet/jet" // dot import so go code would resemble as much as native SQL
|
||||||
|
. "github.com/go-jet/jet/examples/quick-start/gen/jetdb/dvds/table" // dot import is not mandatory
|
||||||
|
|
||||||
|
"github.com/go-jet/jet/examples/quick-start/gen/jetdb/dvds/model"
|
||||||
|
"github.com/go-jet/jet/tests/dbconfig"
|
||||||
|
)
|
||||||
|
|
||||||
|
func main() {
|
||||||
|
|
||||||
|
db, err := sql.Open("postgres", dbconfig.ConnectString)
|
||||||
|
panicOnError(err)
|
||||||
|
defer db.Close()
|
||||||
|
|
||||||
|
stmt := SELECT(
|
||||||
|
Actor.ActorID, Actor.FirstName, Actor.LastName, Actor.LastUpdate, // list of all actor columns (equivalent to Actor.AllColumns)
|
||||||
|
Film.AllColumns, // list of all film columns (equivalent to Film.FilmID, Film.Title, ...)
|
||||||
|
Language.AllColumns,
|
||||||
|
Category.AllColumns,
|
||||||
|
).FROM(
|
||||||
|
Actor.
|
||||||
|
INNER_JOIN(FilmActor, Actor.ActorID.EQ(FilmActor.ActorID)). // INNER JOIN Actor with FilmActor on condition Actor.ActorID = FilmActor.ActorID
|
||||||
|
INNER_JOIN(Film, Film.FilmID.EQ(FilmActor.FilmID)). // then with Film, Language, FilmCategory and Category.
|
||||||
|
INNER_JOIN(Language, Language.LanguageID.EQ(Film.LanguageID)).
|
||||||
|
INNER_JOIN(FilmCategory, FilmCategory.FilmID.EQ(Film.FilmID)).
|
||||||
|
INNER_JOIN(Category, Category.CategoryID.EQ(FilmCategory.CategoryID)),
|
||||||
|
).WHERE(
|
||||||
|
Language.Name.EQ(String("English")). // note every column has type.
|
||||||
|
AND(Category.Name.NOT_EQ(String("Action"))). // String column Language.Name and Category.Name can be compared only with string columns and expressions
|
||||||
|
AND(Film.Length.GT(Int(180))), // Film.Length is integer column and can be compared only with integer columns and expressions
|
||||||
|
).ORDER_BY(
|
||||||
|
Actor.ActorID.ASC(),
|
||||||
|
Film.FilmID.ASC(),
|
||||||
|
)
|
||||||
|
|
||||||
|
query, args, err := stmt.Sql()
|
||||||
|
panicOnError(err)
|
||||||
|
|
||||||
|
fmt.Println("Parameterized query: ")
|
||||||
|
fmt.Println(query)
|
||||||
|
fmt.Println("Arguments: ")
|
||||||
|
fmt.Println(args)
|
||||||
|
|
||||||
|
debugSql, err := stmt.DebugSql()
|
||||||
|
panicOnError(err)
|
||||||
|
|
||||||
|
fmt.Println("Debug sql: ")
|
||||||
|
fmt.Println(debugSql)
|
||||||
|
|
||||||
|
var dest []struct {
|
||||||
|
model.Actor
|
||||||
|
Films []struct {
|
||||||
|
model.Film
|
||||||
|
Language model.Language
|
||||||
|
Category []model.Category
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
err = stmt.Query(db, &dest)
|
||||||
|
panicOnError(err)
|
||||||
|
|
||||||
|
fmt.Println("dest to json: ")
|
||||||
|
jsonText, _ := json.MarshalIndent(dest, "", "\t")
|
||||||
|
fmt.Println(string(jsonText))
|
||||||
|
|
||||||
|
var dest2 []struct {
|
||||||
|
model.Category
|
||||||
|
|
||||||
|
Film []model.Film
|
||||||
|
Actor []model.Actor
|
||||||
|
}
|
||||||
|
|
||||||
|
err = stmt.Query(db, &dest2)
|
||||||
|
panicOnError(err)
|
||||||
|
|
||||||
|
fmt.Println("dest2 to json: ")
|
||||||
|
jsonText, _ = json.MarshalIndent(dest2, "", "\t")
|
||||||
|
fmt.Println(string(jsonText))
|
||||||
|
}
|
||||||
|
|
||||||
|
func panicOnError(err error) {
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -1218,3 +1218,92 @@ FOR`
|
||||||
assert.NilError(t, err)
|
assert.NilError(t, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestForQuickStart(t *testing.T) {
|
||||||
|
|
||||||
|
var expectedSql = `
|
||||||
|
SELECT actor.actor_id AS "actor.actor_id",
|
||||||
|
actor.first_name AS "actor.first_name",
|
||||||
|
actor.last_name AS "actor.last_name",
|
||||||
|
actor.last_update AS "actor.last_update",
|
||||||
|
film.film_id AS "film.film_id",
|
||||||
|
film.title AS "film.title",
|
||||||
|
film.description AS "film.description",
|
||||||
|
film.release_year AS "film.release_year",
|
||||||
|
film.language_id AS "film.language_id",
|
||||||
|
film.rental_duration AS "film.rental_duration",
|
||||||
|
film.rental_rate AS "film.rental_rate",
|
||||||
|
film.length AS "film.length",
|
||||||
|
film.replacement_cost AS "film.replacement_cost",
|
||||||
|
film.rating AS "film.rating",
|
||||||
|
film.last_update AS "film.last_update",
|
||||||
|
film.special_features AS "film.special_features",
|
||||||
|
film.fulltext AS "film.fulltext",
|
||||||
|
language.language_id AS "language.language_id",
|
||||||
|
language.name AS "language.name",
|
||||||
|
language.last_update AS "language.last_update",
|
||||||
|
category.category_id AS "category.category_id",
|
||||||
|
category.name AS "category.name",
|
||||||
|
category.last_update AS "category.last_update"
|
||||||
|
FROM dvds.actor
|
||||||
|
INNER JOIN dvds.film_actor ON (actor.actor_id = film_actor.actor_id)
|
||||||
|
INNER JOIN dvds.film ON (film.film_id = film_actor.film_id)
|
||||||
|
INNER JOIN dvds.language ON (language.language_id = film.language_id)
|
||||||
|
INNER JOIN dvds.film_category ON (film_category.film_id = film.film_id)
|
||||||
|
INNER JOIN dvds.category ON (category.category_id = film_category.category_id)
|
||||||
|
WHERE ((language.name = 'English') AND (category.name != 'Action')) AND (film.length > 180)
|
||||||
|
ORDER BY actor.actor_id ASC, film.film_id ASC;
|
||||||
|
`
|
||||||
|
|
||||||
|
stmt := SELECT(
|
||||||
|
Actor.ActorID, Actor.FirstName, Actor.LastName, Actor.LastUpdate, // list of all actor columns (equivalent to Actor.AllColumns)
|
||||||
|
Film.AllColumns, // list of all film columns (equivalent to Film.FilmID, Film.Title, ...)
|
||||||
|
Language.AllColumns,
|
||||||
|
Category.AllColumns,
|
||||||
|
).FROM(
|
||||||
|
Actor.
|
||||||
|
INNER_JOIN(FilmActor, Actor.ActorID.EQ(FilmActor.ActorID)). // INNER JOIN Actor with FilmActor on condition Actor.ActorID = FilmActor.ActorID
|
||||||
|
INNER_JOIN(Film, Film.FilmID.EQ(FilmActor.FilmID)). // then with Film, Language, FilmCategory and Category.
|
||||||
|
INNER_JOIN(Language, Language.LanguageID.EQ(Film.LanguageID)).
|
||||||
|
INNER_JOIN(FilmCategory, FilmCategory.FilmID.EQ(Film.FilmID)).
|
||||||
|
INNER_JOIN(Category, Category.CategoryID.EQ(FilmCategory.CategoryID)),
|
||||||
|
).WHERE(
|
||||||
|
Language.Name.EQ(String("English")). // note that every column has type.
|
||||||
|
AND(Category.Name.NOT_EQ(String("Action"))). // String column Language.Name and Category.Name can be compared only with string expression
|
||||||
|
AND(Film.Length.GT(Int(180))), // Film.Length is integer column and can be compared only with integer expression
|
||||||
|
).ORDER_BY(
|
||||||
|
Actor.ActorID.ASC(),
|
||||||
|
Film.FilmID.ASC(),
|
||||||
|
)
|
||||||
|
|
||||||
|
assertStatementSql(t, stmt, expectedSql, "English", "Action", int64(180))
|
||||||
|
|
||||||
|
var dest []struct {
|
||||||
|
model.Actor
|
||||||
|
|
||||||
|
Films []struct {
|
||||||
|
model.Film
|
||||||
|
|
||||||
|
Language model.Language
|
||||||
|
|
||||||
|
Category []model.Category
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
err := stmt.Query(db, &dest)
|
||||||
|
assert.NilError(t, err)
|
||||||
|
|
||||||
|
assertJson(t, "./testdata/quick-start-dest.json", dest)
|
||||||
|
|
||||||
|
var dest2 []struct {
|
||||||
|
model.Category
|
||||||
|
|
||||||
|
Film []model.Film
|
||||||
|
Actor []model.Actor
|
||||||
|
}
|
||||||
|
|
||||||
|
err = stmt.Query(db, &dest2)
|
||||||
|
assert.NilError(t, err)
|
||||||
|
|
||||||
|
assertJson(t, "./testdata/quick-start-dest2.json", dest2)
|
||||||
|
}
|
||||||
|
|
|
||||||
6067
tests/testdata/quick-start-dest.json
vendored
Normal file
6067
tests/testdata/quick-start-dest.json
vendored
Normal file
File diff suppressed because it is too large
Load diff
1769
tests/testdata/quick-start-dest2.json
vendored
Normal file
1769
tests/testdata/quick-start-dest2.json
vendored
Normal file
File diff suppressed because it is too large
Load diff
Loading…
Add table
Add a link
Reference in a new issue