sqlc: add migration support for sqlc scene

internal/dao/slonik/ce/embed.go

@@ -0,0 +1,15 @@
+// Copyright 2023 ROC. All rights reserved.
+// Use of this source code is governed by a MIT style
+// license that can be found in the LICENSE file.
+
+//go:build migration
+// +build migration
+
+package ce
+
+import (
+	"embed"
+)
+
+//go:embed postgres/schema
+var Files embed.FS

internal/dao/slonik/ce/postgres/query.sql

@@ -1,56 +0,0 @@
--- name: GetAuthor :one
-SELECT * FROM authors
-WHERE author_id = $1;
-
--- name: DeleteBookExecResult :execresult
-DELETE FROM books
-WHERE book_id = $1;
-
--- name: DeleteBook :batchexec
-DELETE FROM books
-WHERE book_id = $1;
-
--- name: DeleteBookNamedFunc :batchexec
-DELETE FROM books
-WHERE book_id = sqlc.arg(book_id);
-
--- name: DeleteBookNamedSign :batchexec
-DELETE FROM books
-WHERE book_id = @book_id;
-
--- name: BooksByYear :batchmany
-SELECT * FROM books
-WHERE year = $1;
-
--- name: CreateAuthor :one
-INSERT INTO authors (name) VALUES ($1)
-RETURNING *;
-
--- name: CreateBook :batchone
-INSERT INTO books (
-    author_id,
-    isbn,
-    book_type,
-    title,
-    year,
-    available,
-    tags
-) VALUES (
-    $1,
-    $2,
-    $3,
-    $4,
-    $5,
-    $6,
-    $7
-)
-RETURNING *;
-
--- name: UpdateBook :batchexec
-UPDATE books
-SET title = $1, tags = $2
-WHERE book_id = $3;
-
--- name: GetBiography :batchone
-SELECT biography FROM authors
-WHERE author_id = $1;

internal/dao/slonik/ce/postgres/schema.sql

@@ -1,21 +0,0 @@
-CREATE TABLE authors (
-          author_id SERIAL PRIMARY KEY,
-          name text NOT NULL DEFAULT '',
-          biography JSONB
-);
-
-CREATE TYPE book_type AS ENUM (
-          'FICTION',
-          'NONFICTION'
-);
-
-CREATE TABLE books (
-          book_id SERIAL PRIMARY KEY,
-          author_id integer NOT NULL REFERENCES authors(author_id),
-          isbn text NOT NULL DEFAULT '' UNIQUE,
-          book_type book_type NOT NULL DEFAULT 'FICTION',
-          title text NOT NULL DEFAULT '',
-          year integer NOT NULL DEFAULT 2000,
-          available timestamp with time zone NOT NULL DEFAULT 'NOW()',
-          tags varchar[] NOT NULL DEFAULT '{}'
-);

internal/dao/slonik/topics.go

@@ -18,19 +18,19 @@ type topicServant struct {
 	*pgxServant
 }
 
-func (s *topicServant) CreateTag(tag *core.Tag) (*core.Tag, error) {
+func (s *topicServant) UpsertTags(userId int64, tags []string) ([]*core.Tag, error) {
 	// TODO
 	debug.NotImplemented()
 	return nil, nil
 }
 
-func (s *topicServant) DeleteTag(tag *core.Tag) error {
+func (s *topicServant) DecrTagsById(ids []int64) error {
 	// TODO
 	debug.NotImplemented()
 	return nil
 }
 
-func (s *topicServant) GetTags(conditions *core.ConditionsT, offset, limit int) ([]*core.Tag, error) {
+func (s *topicServant) GetTags(category core.TagCategory, offset int, limit int) ([]*core.Tag, error) {
 	// TODO
 	debug.NotImplemented()
 	return nil, nil

internal/migration/migration_embed.go

@@ -19,6 +19,7 @@ import (
 	"github.com/golang-migrate/migrate/v4/source"
 	"github.com/golang-migrate/migrate/v4/source/iofs"
 	"github.com/rocboss/paopao-ce/internal/conf"
+	"github.com/rocboss/paopao-ce/internal/dao/slonik/ce"
 	"github.com/rocboss/paopao-ce/scripts/migration"
 	"github.com/sirupsen/logrus"
 )
@@ -55,18 +56,25 @@ func Run() {
 	}
 
 	migrationsTable := conf.DatabaseSetting.TablePrefix + "schema_migrations"
-	if cfg.If("MySQL") {
+	if cfg.If("Gorm") || cfg.If("Sqlx") {
-		srcDriver, err = iofs.New(migration.Files, "mysql")
+		if cfg.If("MySQL") {
-		dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{MigrationsTable: migrationsTable})
+			srcDriver, err = iofs.New(migration.Files, "mysql")
-	} else if cfg.If("PostgreSQL") || cfg.If("Postgres") {
+			dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{MigrationsTable: migrationsTable})
-		srcDriver, err = iofs.New(migration.Files, "postgres")
+		} else if cfg.If("PostgreSQL") || cfg.If("Postgres") {
-		dbDriver, err2 = postgres.WithInstance(db, &postgres.Config{MigrationsTable: migrationsTable})
+			srcDriver, err = iofs.New(migration.Files, "postgres")
-	} else if cfg.If("Sqlite3") {
+			dbDriver, err2 = postgres.WithInstance(db, &postgres.Config{MigrationsTable: migrationsTable})
-		srcDriver, err = iofs.New(migration.Files, "sqlite3")
+		} else if cfg.If("Sqlite3") {
-		dbDriver, err2 = sqlite3.WithInstance(db, &sqlite3.Config{MigrationsTable: migrationsTable})
+			srcDriver, err = iofs.New(migration.Files, "sqlite3")
-	} else {
+			dbDriver, err2 = sqlite3.WithInstance(db, &sqlite3.Config{MigrationsTable: migrationsTable})
-		srcDriver, err = iofs.New(migration.Files, "mysql")
+		} else {
-		dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{MigrationsTable: migrationsTable})
+			srcDriver, err = iofs.New(migration.Files, "mysql")
+			dbDriver, err2 = mysql.WithInstance(db, &mysql.Config{MigrationsTable: migrationsTable})
+		}
+	} else if cfg.If("Sqlc") {
+		if cfg.If("PostgreSQL") || cfg.If("Postgres") {
+			srcDriver, err = iofs.New(ce.Files, "postgres/schema")
+			dbDriver, err2 = postgres.WithInstance(db, &postgres.Config{MigrationsTable: migrationsTable})
+		}
 	}
 
 	if err2 != nil {