Merge pull request #138 from nkonin/fix/dsn-ignore-tables
fix -ignore-tables, -ignore-enums and -ignore-views when -dsn is present
This commit is contained in:
commit
3ff9241eea
5 changed files with 214 additions and 78 deletions
6
.github/dependabot.yml
vendored
Normal file
6
.github/dependabot.yml
vendored
Normal file
|
|
@ -0,0 +1,6 @@
|
||||||
|
version: 2
|
||||||
|
updates:
|
||||||
|
- package-ecosystem: gomod
|
||||||
|
directory: /
|
||||||
|
schedule:
|
||||||
|
interval: daily
|
||||||
70
.github/workflows/codeql-analysis.yml
vendored
Normal file
70
.github/workflows/codeql-analysis.yml
vendored
Normal file
|
|
@ -0,0 +1,70 @@
|
||||||
|
# For most projects, this workflow file will not need changing; you simply need
|
||||||
|
# to commit it to your repository.
|
||||||
|
#
|
||||||
|
# You may wish to alter this file to override the set of languages analyzed,
|
||||||
|
# or to provide custom queries or build logic.
|
||||||
|
#
|
||||||
|
# ******** NOTE ********
|
||||||
|
# We have attempted to detect the languages in your repository. Please check
|
||||||
|
# the `language` matrix defined below to confirm you have the correct set of
|
||||||
|
# supported CodeQL languages.
|
||||||
|
#
|
||||||
|
name: "CodeQL"
|
||||||
|
|
||||||
|
on:
|
||||||
|
push:
|
||||||
|
branches: [ master ]
|
||||||
|
pull_request:
|
||||||
|
# The branches below must be a subset of the branches above
|
||||||
|
branches: [ master ]
|
||||||
|
schedule:
|
||||||
|
- cron: '36 17 * * 0'
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
analyze:
|
||||||
|
name: Analyze
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
permissions:
|
||||||
|
actions: read
|
||||||
|
contents: read
|
||||||
|
security-events: write
|
||||||
|
|
||||||
|
strategy:
|
||||||
|
fail-fast: false
|
||||||
|
matrix:
|
||||||
|
language: [ 'go' ]
|
||||||
|
# CodeQL supports [ 'cpp', 'csharp', 'go', 'java', 'javascript', 'python', 'ruby' ]
|
||||||
|
# Learn more about CodeQL language support at https://git.io/codeql-language-support
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: Checkout repository
|
||||||
|
uses: actions/checkout@v3
|
||||||
|
|
||||||
|
# Initializes the CodeQL tools for scanning.
|
||||||
|
- name: Initialize CodeQL
|
||||||
|
uses: github/codeql-action/init@v2
|
||||||
|
with:
|
||||||
|
languages: ${{ matrix.language }}
|
||||||
|
# If you wish to specify custom queries, you can do so here or in a config file.
|
||||||
|
# By default, queries listed here will override any specified in a config file.
|
||||||
|
# Prefix the list here with "+" to use these queries and those in the config file.
|
||||||
|
# queries: ./path/to/local/query, your-org/your-repo/queries@main
|
||||||
|
|
||||||
|
# Autobuild attempts to build any compiled languages (C/C++, C#, or Java).
|
||||||
|
# If this step fails, then you should remove it and run the build manually (see below)
|
||||||
|
- name: Autobuild
|
||||||
|
uses: github/codeql-action/autobuild@v2
|
||||||
|
|
||||||
|
# ℹ️ Command-line programs to run using the OS shell.
|
||||||
|
# 📚 https://git.io/JvXDl
|
||||||
|
|
||||||
|
# ✏️ If the Autobuild fails above, remove it and uncomment the following three lines
|
||||||
|
# and modify them (or add more) to build your code if your project
|
||||||
|
# uses a compiled language
|
||||||
|
|
||||||
|
#- run: |
|
||||||
|
# make bootstrap
|
||||||
|
# make release
|
||||||
|
|
||||||
|
- name: Perform CodeQL Analysis
|
||||||
|
uses: github/codeql-action/analyze@v2
|
||||||
|
|
@ -3,6 +3,9 @@ package main
|
||||||
import (
|
import (
|
||||||
"flag"
|
"flag"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"os"
|
||||||
|
"strings"
|
||||||
|
|
||||||
"github.com/go-jet/jet/v2/generator/metadata"
|
"github.com/go-jet/jet/v2/generator/metadata"
|
||||||
sqlitegen "github.com/go-jet/jet/v2/generator/sqlite"
|
sqlitegen "github.com/go-jet/jet/v2/generator/sqlite"
|
||||||
"github.com/go-jet/jet/v2/generator/template"
|
"github.com/go-jet/jet/v2/generator/template"
|
||||||
|
|
@ -11,8 +14,6 @@ import (
|
||||||
"github.com/go-jet/jet/v2/mysql"
|
"github.com/go-jet/jet/v2/mysql"
|
||||||
postgres2 "github.com/go-jet/jet/v2/postgres"
|
postgres2 "github.com/go-jet/jet/v2/postgres"
|
||||||
"github.com/go-jet/jet/v2/sqlite"
|
"github.com/go-jet/jet/v2/sqlite"
|
||||||
"os"
|
|
||||||
"strings"
|
|
||||||
|
|
||||||
mysqlgen "github.com/go-jet/jet/v2/generator/mysql"
|
mysqlgen "github.com/go-jet/jet/v2/generator/mysql"
|
||||||
postgresgen "github.com/go-jet/jet/v2/generator/postgres"
|
postgresgen "github.com/go-jet/jet/v2/generator/postgres"
|
||||||
|
|
@ -112,8 +113,9 @@ func main() {
|
||||||
|
|
||||||
switch source {
|
switch source {
|
||||||
case "postgresql", "postgres":
|
case "postgresql", "postgres":
|
||||||
|
generatorTemplate := genTemplate(postgres2.Dialect, ignoreTablesList, ignoreViewsList, ignoreEnumsList)
|
||||||
if dsn != "" {
|
if dsn != "" {
|
||||||
err = postgresgen.GenerateDSN(dsn, schemaName, destDir)
|
err = postgresgen.GenerateDSN(dsn, schemaName, destDir, generatorTemplate)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
dbConn := postgresgen.DBConnection{
|
dbConn := postgresgen.DBConnection{
|
||||||
|
|
@ -131,12 +133,13 @@ func main() {
|
||||||
err = postgresgen.Generate(
|
err = postgresgen.Generate(
|
||||||
destDir,
|
destDir,
|
||||||
dbConn,
|
dbConn,
|
||||||
genTemplate(postgres2.Dialect, ignoreTablesList, ignoreViewsList, ignoreEnumsList),
|
generatorTemplate,
|
||||||
)
|
)
|
||||||
|
|
||||||
case "mysql", "mysqlx", "mariadb":
|
case "mysql", "mysqlx", "mariadb":
|
||||||
|
generatorTemplate := genTemplate(mysql.Dialect, ignoreTablesList, ignoreViewsList, ignoreEnumsList)
|
||||||
if dsn != "" {
|
if dsn != "" {
|
||||||
err = mysqlgen.GenerateDSN(dsn, destDir)
|
err = mysqlgen.GenerateDSN(dsn, destDir, generatorTemplate)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
dbConn := mysqlgen.DBConnection{
|
dbConn := mysqlgen.DBConnection{
|
||||||
|
|
@ -151,7 +154,7 @@ func main() {
|
||||||
err = mysqlgen.Generate(
|
err = mysqlgen.Generate(
|
||||||
destDir,
|
destDir,
|
||||||
dbConn,
|
dbConn,
|
||||||
genTemplate(mysql.Dialect, ignoreTablesList, ignoreViewsList, ignoreEnumsList),
|
generatorTemplate,
|
||||||
)
|
)
|
||||||
case "sqlite":
|
case "sqlite":
|
||||||
if dsn == "" {
|
if dsn == "" {
|
||||||
|
|
|
||||||
|
|
@ -88,45 +88,70 @@ func TestCmdGenerator(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestIgnoreTablesViewsEnums(t *testing.T) {
|
func TestIgnoreTablesViewsEnums(t *testing.T) {
|
||||||
cmd := exec.Command("jet",
|
tests := []struct {
|
||||||
"-source=MySQL",
|
name string
|
||||||
"-dbname=dvds",
|
args []string
|
||||||
"-host="+dbconfig.MySqLHost,
|
}{
|
||||||
"-port="+strconv.Itoa(dbconfig.MySQLPort),
|
{
|
||||||
"-user="+dbconfig.MySQLUser,
|
name: "with dsn",
|
||||||
"-password="+dbconfig.MySQLPassword,
|
args: []string{
|
||||||
"-ignore-tables=actor,ADDRESS,Category, city ,country,staff,store,rental",
|
"-dsn=mysql://" + dbconfig.MySQLConnectionString(sourceIsMariaDB(), "dvds"),
|
||||||
"-ignore-views=actor_info,CUSTomER_LIST, film_list",
|
"-ignore-tables=actor,ADDRESS,Category, city ,country,staff,store,rental",
|
||||||
"-ignore-enums=film_list_rating,film_rating",
|
"-ignore-views=actor_info,CUSTomER_LIST, film_list",
|
||||||
"-path="+genTestDir3)
|
"-ignore-enums=film_list_rating,film_rating",
|
||||||
|
"-path=" + genTestDir3,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "without dsn",
|
||||||
|
args: []string{
|
||||||
|
"-source=MySQL",
|
||||||
|
"-dbname=dvds",
|
||||||
|
"-host=" + dbconfig.MySqLHost,
|
||||||
|
"-port=" + strconv.Itoa(dbconfig.MySQLPort),
|
||||||
|
"-user=" + dbconfig.MySQLUser,
|
||||||
|
"-password=" + dbconfig.MySQLPassword,
|
||||||
|
"-ignore-tables=actor,ADDRESS,Category, city ,country,staff,store,rental",
|
||||||
|
"-ignore-views=actor_info,CUSTomER_LIST, film_list",
|
||||||
|
"-ignore-enums=film_list_rating,film_rating",
|
||||||
|
"-path=" + genTestDir3,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
cmd.Stderr = os.Stderr
|
for _, tt := range tests {
|
||||||
cmd.Stdout = os.Stdout
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
cmd := exec.Command("jet", tt.args...)
|
||||||
|
|
||||||
err := cmd.Run()
|
cmd.Stderr = os.Stderr
|
||||||
require.NoError(t, err)
|
cmd.Stdout = os.Stdout
|
||||||
|
|
||||||
tableSQLBuilderFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/table")
|
err := cmd.Run()
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
testutils.AssertFileNamesEqual(t, tableSQLBuilderFiles, "customer.go", "film.go", "film_actor.go",
|
|
||||||
"film_category.go", "film_text.go", "inventory.go", "language.go", "payment.go")
|
|
||||||
|
|
||||||
viewSQLBuilderFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/view")
|
tableSQLBuilderFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/table")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
testutils.AssertFileNamesEqual(t, viewSQLBuilderFiles, "nicer_but_slower_film_list.go",
|
testutils.AssertFileNamesEqual(t, tableSQLBuilderFiles, "customer.go", "film.go", "film_actor.go",
|
||||||
"sales_by_film_category.go", "sales_by_store.go", "staff_list.go")
|
"film_category.go", "film_text.go", "inventory.go", "language.go", "payment.go")
|
||||||
|
|
||||||
enumFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/enum")
|
viewSQLBuilderFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/view")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
testutils.AssertFileNamesEqual(t, enumFiles, "nicer_but_slower_film_list_rating.go")
|
testutils.AssertFileNamesEqual(t, viewSQLBuilderFiles, "nicer_but_slower_film_list.go",
|
||||||
|
"sales_by_film_category.go", "sales_by_store.go", "staff_list.go")
|
||||||
|
|
||||||
modelFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/model")
|
enumFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/enum")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
testutils.AssertFileNamesEqual(t, enumFiles, "nicer_but_slower_film_list_rating.go")
|
||||||
|
|
||||||
testutils.AssertFileNamesEqual(t, modelFiles,
|
modelFiles, err := ioutil.ReadDir(genTestDir3 + "/dvds/model")
|
||||||
"customer.go", "film.go", "film_actor.go", "film_category.go", "film_text.go", "inventory.go", "language.go",
|
require.NoError(t, err)
|
||||||
"payment.go", "nicer_but_slower_film_list_rating.go", "nicer_but_slower_film_list.go", "sales_by_film_category.go",
|
|
||||||
"sales_by_store.go", "staff_list.go")
|
testutils.AssertFileNamesEqual(t, modelFiles,
|
||||||
|
"customer.go", "film.go", "film_actor.go", "film_category.go", "film_text.go", "inventory.go", "language.go",
|
||||||
|
"payment.go", "nicer_but_slower_film_list_rating.go", "nicer_but_slower_film_list.go", "sales_by_film_category.go",
|
||||||
|
"sales_by_store.go", "staff_list.go")
|
||||||
|
})
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func assertGeneratedFiles(t *testing.T) {
|
func assertGeneratedFiles(t *testing.T) {
|
||||||
|
|
|
||||||
|
|
@ -93,56 +93,88 @@ func TestCmdGenerator(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestGeneratorIgnoreTables(t *testing.T) {
|
func TestGeneratorIgnoreTables(t *testing.T) {
|
||||||
err := os.RemoveAll(genTestDir2)
|
tests := []struct {
|
||||||
require.NoError(t, err)
|
name string
|
||||||
|
args []string
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "with dsn",
|
||||||
|
args: []string{
|
||||||
|
"-dsn=" + fmt.Sprintf("postgresql://%s:%s@%s:%d/%s?sslmode=disable",
|
||||||
|
dbconfig.PgUser,
|
||||||
|
dbconfig.PgPassword,
|
||||||
|
dbconfig.PgHost,
|
||||||
|
dbconfig.PgPort,
|
||||||
|
"jetdb",
|
||||||
|
),
|
||||||
|
"-schema=dvds",
|
||||||
|
"-ignore-tables=actor,ADDRESS,country, Film , cITY,",
|
||||||
|
"-ignore-views=Actor_info, FILM_LIST ,staff_list",
|
||||||
|
"-ignore-enums=mpaa_rating",
|
||||||
|
"-path=" + genTestDir2,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "without dsn",
|
||||||
|
args: []string{
|
||||||
|
"-source=PostgreSQL",
|
||||||
|
"-host=localhost",
|
||||||
|
"-port=" + strconv.Itoa(dbconfig.PgPort),
|
||||||
|
"-user=jet",
|
||||||
|
"-password=jet",
|
||||||
|
"-dbname=jetdb",
|
||||||
|
"-schema=dvds",
|
||||||
|
"-ignore-tables=actor,ADDRESS,country, Film , cITY,",
|
||||||
|
"-ignore-views=Actor_info, FILM_LIST ,staff_list",
|
||||||
|
"-ignore-enums=mpaa_rating",
|
||||||
|
"-path=" + genTestDir2,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
cmd := exec.Command("jet",
|
for _, tt := range tests {
|
||||||
"-source=PostgreSQL",
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
"-host=localhost",
|
err := os.RemoveAll(genTestDir2)
|
||||||
"-port="+strconv.Itoa(dbconfig.PgPort),
|
require.NoError(t, err)
|
||||||
"-user=jet",
|
|
||||||
"-password=jet",
|
|
||||||
"-dbname=jetdb",
|
|
||||||
"-schema=dvds",
|
|
||||||
"-ignore-tables=actor,ADDRESS,country, Film , cITY,",
|
|
||||||
"-ignore-views=Actor_info, FILM_LIST ,staff_list",
|
|
||||||
"-ignore-enums=mpaa_rating",
|
|
||||||
"-path="+genTestDir2)
|
|
||||||
|
|
||||||
fmt.Println(cmd.Args)
|
cmd := exec.Command("jet", tt.args...)
|
||||||
cmd.Stderr = os.Stderr
|
|
||||||
cmd.Stdout = os.Stdout
|
|
||||||
|
|
||||||
err = cmd.Run()
|
fmt.Println(cmd.Args)
|
||||||
require.NoError(t, err)
|
cmd.Stderr = os.Stderr
|
||||||
|
cmd.Stdout = os.Stdout
|
||||||
|
|
||||||
// Table SQL Builder files
|
err = cmd.Run()
|
||||||
tableSQLBuilderFiles, err := ioutil.ReadDir("./.gentestdata2/jetdb/dvds/table")
|
require.NoError(t, err)
|
||||||
require.NoError(t, err)
|
|
||||||
|
|
||||||
testutils.AssertFileNamesEqual(t, tableSQLBuilderFiles, "category.go",
|
// Table SQL Builder files
|
||||||
"customer.go", "film_actor.go", "film_category.go", "inventory.go", "language.go",
|
tableSQLBuilderFiles, err := ioutil.ReadDir("./.gentestdata2/jetdb/dvds/table")
|
||||||
"payment.go", "rental.go", "staff.go", "store.go")
|
require.NoError(t, err)
|
||||||
|
|
||||||
// View SQL Builder files
|
testutils.AssertFileNamesEqual(t, tableSQLBuilderFiles, "category.go",
|
||||||
viewSQLBuilderFiles, err := ioutil.ReadDir("./.gentestdata2/jetdb/dvds/view")
|
"customer.go", "film_actor.go", "film_category.go", "inventory.go", "language.go",
|
||||||
require.NoError(t, err)
|
"payment.go", "rental.go", "staff.go", "store.go")
|
||||||
|
|
||||||
testutils.AssertFileNamesEqual(t, viewSQLBuilderFiles, "nicer_but_slower_film_list.go",
|
// View SQL Builder files
|
||||||
"sales_by_film_category.go", "customer_list.go", "sales_by_store.go")
|
viewSQLBuilderFiles, err := ioutil.ReadDir("./.gentestdata2/jetdb/dvds/view")
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
// Enums SQL Builder files
|
testutils.AssertFileNamesEqual(t, viewSQLBuilderFiles, "nicer_but_slower_film_list.go",
|
||||||
_, err = ioutil.ReadDir("./.gentestdata2/jetdb/dvds/enum")
|
"sales_by_film_category.go", "customer_list.go", "sales_by_store.go")
|
||||||
require.Error(t, err, "open ./.gentestdata2/jetdb/dvds/enum: no such file or directory")
|
|
||||||
|
|
||||||
modelFiles, err := ioutil.ReadDir("./.gentestdata2/jetdb/dvds/model")
|
// Enums SQL Builder files
|
||||||
require.NoError(t, err)
|
_, err = ioutil.ReadDir("./.gentestdata2/jetdb/dvds/enum")
|
||||||
|
require.Error(t, err, "open ./.gentestdata2/jetdb/dvds/enum: no such file or directory")
|
||||||
|
|
||||||
testutils.AssertFileNamesEqual(t, modelFiles, "category.go",
|
modelFiles, err := ioutil.ReadDir("./.gentestdata2/jetdb/dvds/model")
|
||||||
"customer.go", "film_actor.go", "film_category.go", "inventory.go", "language.go",
|
require.NoError(t, err)
|
||||||
"payment.go", "rental.go", "staff.go", "store.go",
|
|
||||||
"nicer_but_slower_film_list.go", "sales_by_film_category.go",
|
testutils.AssertFileNamesEqual(t, modelFiles, "category.go",
|
||||||
"customer_list.go", "sales_by_store.go")
|
"customer.go", "film_actor.go", "film_category.go", "inventory.go", "language.go",
|
||||||
|
"payment.go", "rental.go", "staff.go", "store.go",
|
||||||
|
"nicer_but_slower_film_list.go", "sales_by_film_category.go",
|
||||||
|
"customer_list.go", "sales_by_store.go")
|
||||||
|
})
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestGenerator(t *testing.T) {
|
func TestGenerator(t *testing.T) {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue