Compare commits
8
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
799b7feb53 | ||
|
|
eb40201b59 | ||
|
|
1461f8f69f | ||
|
|
ea70e19a46 | ||
|
|
52f4642d97 | ||
|
|
a84592374c | ||
|
|
ca226e83df | ||
|
|
19a2cc1fe3 |
@@ -63,6 +63,8 @@ jobs:
|
|||||||
- name: Build release binaries
|
- name: Build release binaries
|
||||||
run: |
|
run: |
|
||||||
VERSION="${{ github.event.inputs.tag || github.ref_name }}"
|
VERSION="${{ github.event.inputs.tag || github.ref_name }}"
|
||||||
|
BUILD_DATE="$(date -u +"%Y-%m-%d %H:%M:%S UTC")"
|
||||||
|
LDFLAGS="-X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.Version=${VERSION}' -X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.BuildDate=${BUILD_DATE}'"
|
||||||
for target in "linux/amd64" "linux/arm64" "darwin/amd64" "darwin/arm64" "windows/amd64"; do
|
for target in "linux/amd64" "linux/arm64" "darwin/amd64" "darwin/arm64" "windows/amd64"; do
|
||||||
GOOS="${target%/*}"
|
GOOS="${target%/*}"
|
||||||
GOARCH="${target#*/}"
|
GOARCH="${target#*/}"
|
||||||
@@ -71,7 +73,7 @@ jobs:
|
|||||||
NAME="relspec-${GOOS}-${GOARCH}${EXT}"
|
NAME="relspec-${GOOS}-${GOARCH}${EXT}"
|
||||||
GOOS="$GOOS" GOARCH="$GOARCH" go build \
|
GOOS="$GOOS" GOARCH="$GOARCH" go build \
|
||||||
-trimpath \
|
-trimpath \
|
||||||
-ldflags "-X git.warky.dev/wdevs/relspecgo/cmd/relspec.version=${VERSION}" \
|
-ldflags "$LDFLAGS" \
|
||||||
-o "$NAME" ./cmd/relspec
|
-o "$NAME" ./cmd/relspec
|
||||||
echo "Built $NAME"
|
echo "Built $NAME"
|
||||||
done
|
done
|
||||||
@@ -234,11 +236,12 @@ jobs:
|
|||||||
run: |
|
run: |
|
||||||
VERSION="${{ github.event.inputs.tag || github.ref_name }}"
|
VERSION="${{ github.event.inputs.tag || github.ref_name }}"
|
||||||
PKGVER="${VERSION#v}"
|
PKGVER="${VERSION#v}"
|
||||||
|
BUILD_DATE="$(date -u +"%Y-%m-%d %H:%M:%S UTC")"
|
||||||
|
|
||||||
for GOARCH in amd64 arm64; do
|
for GOARCH in amd64 arm64; do
|
||||||
GOOS=linux GOARCH=$GOARCH go build \
|
GOOS=linux GOARCH=$GOARCH go build \
|
||||||
-trimpath \
|
-trimpath \
|
||||||
-ldflags "-X git.warky.dev/wdevs/relspecgo/cmd/relspec.version=${PKGVER}" \
|
-ldflags "-X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.Version=v${PKGVER}' -X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.BuildDate=${BUILD_DATE}'" \
|
||||||
-o relspec ./cmd/relspec
|
-o relspec ./cmd/relspec
|
||||||
|
|
||||||
PKGDIR="relspec_${PKGVER}_${GOARCH}"
|
PKGDIR="relspec_${PKGVER}_${GOARCH}"
|
||||||
@@ -309,7 +312,13 @@ jobs:
|
|||||||
rockylinux:9 \
|
rockylinux:9 \
|
||||||
bash -lc "
|
bash -lc "
|
||||||
set -euo pipefail
|
set -euo pipefail
|
||||||
dnf install -y rpm-build git &&
|
# Avoid transient/out-of-sync mirrors while bootstrapping the RPM builder.
|
||||||
|
sed -i \
|
||||||
|
-e 's|^mirrorlist=|#mirrorlist=|' \
|
||||||
|
-e 's|^#baseurl=http://dl.rockylinux.org|baseurl=https://dl.rockylinux.org|' \
|
||||||
|
/etc/yum.repos.d/rocky*.repo
|
||||||
|
dnf clean all
|
||||||
|
dnf -y --setopt=timeout=60 --setopt=retries=5 install rpm-build git
|
||||||
curl -fsSL https://go.dev/dl/go\${GO_VER}.linux-amd64.tar.gz | tar -C /usr/local -xz &&
|
curl -fsSL https://go.dev/dl/go\${GO_VER}.linux-amd64.tar.gz | tar -C /usr/local -xz &&
|
||||||
export PATH=\$PATH:/usr/local/go/bin &&
|
export PATH=\$PATH:/usr/local/go/bin &&
|
||||||
mkdir -p ~/rpmbuild/{BUILD,BUILDROOT,RPMS,SOURCES,SPECS,SRPMS} &&
|
mkdir -p ~/rpmbuild/{BUILD,BUILDROOT,RPMS,SOURCES,SPECS,SRPMS} &&
|
||||||
|
|||||||
@@ -20,9 +20,11 @@ STATICCHECK = go run honnef.co/go/tools/cmd/staticcheck@latest
|
|||||||
GOVULNCHECK = go run golang.org/x/vuln/cmd/govulncheck@latest
|
GOVULNCHECK = go run golang.org/x/vuln/cmd/govulncheck@latest
|
||||||
|
|
||||||
# Version information
|
# Version information
|
||||||
VERSION := $(shell git describe --tags --always --dirty 2>/dev/null || echo "dev")
|
# VERSION file is the single source of truth (bumped by `make release-version`).
|
||||||
|
# Falls back to git describe for ad-hoc builds where VERSION hasn't been committed yet.
|
||||||
|
VERSION := $(shell [ -f VERSION ] && echo "v$$(cat VERSION | tr -d '[:space:]')" || git describe --tags --always --dirty 2>/dev/null || echo "dev")
|
||||||
BUILD_DATE := $(shell date -u +"%Y-%m-%d %H:%M:%S UTC")
|
BUILD_DATE := $(shell date -u +"%Y-%m-%d %H:%M:%S UTC")
|
||||||
LDFLAGS := -X 'main.version=$(VERSION)' -X 'main.buildDate=$(BUILD_DATE)'
|
LDFLAGS := -X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.Version=$(VERSION)' -X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.BuildDate=$(BUILD_DATE)'
|
||||||
|
|
||||||
# Auto-detect container runtime (Docker or Podman)
|
# Auto-detect container runtime (Docker or Podman)
|
||||||
CONTAINER_RUNTIME := $(shell \
|
CONTAINER_RUNTIME := $(shell \
|
||||||
@@ -207,7 +209,7 @@ docker-test-integration: docker-up ## Start DB and run integration tests
|
|||||||
$(GOTEST) -v ./pkg/readers/pgsql/ -count=1 || (make docker-down && exit 1)
|
$(GOTEST) -v ./pkg/readers/pgsql/ -count=1 || (make docker-down && exit 1)
|
||||||
@make docker-down
|
@make docker-down
|
||||||
|
|
||||||
release: ## Create and push a new release tag (auto-increments patch version)
|
release: lint fmt-check test build ## Run lint, format check, tests, build, then create and push a new release tag
|
||||||
@echo "Creating new release..."
|
@echo "Creating new release..."
|
||||||
@latest_tag=$$(git describe --tags --abbrev=0 2>/dev/null || echo ""); \
|
@latest_tag=$$(git describe --tags --abbrev=0 2>/dev/null || echo ""); \
|
||||||
if [ -z "$$latest_tag" ]; then \
|
if [ -z "$$latest_tag" ]; then \
|
||||||
@@ -223,6 +225,15 @@ release: ## Create and push a new release tag (auto-increments patch version)
|
|||||||
echo "Creating new release: $$version"; \
|
echo "Creating new release: $$version"; \
|
||||||
commit_logs=$$(git log "$${latest_tag}..HEAD" --pretty=format:"- %s" --no-merges); \
|
commit_logs=$$(git log "$${latest_tag}..HEAD" --pretty=format:"- %s" --no-merges); \
|
||||||
fi; \
|
fi; \
|
||||||
|
PKGVER=$${version#v}; \
|
||||||
|
echo "Updating package metadata to $$PKGVER..."; \
|
||||||
|
echo "$$PKGVER" > VERSION; \
|
||||||
|
sed -i "s/^pkgver=.*/pkgver=$$PKGVER/" linux/arch/PKGBUILD; \
|
||||||
|
sed -i "s/^Version:.*/Version: $$PKGVER/" linux/centos/relspec.spec; \
|
||||||
|
git add VERSION linux/arch/PKGBUILD linux/centos/relspec.spec; \
|
||||||
|
if ! git diff --cached --quiet; then \
|
||||||
|
git commit -m "chore(release): update package version to $$PKGVER"; \
|
||||||
|
fi; \
|
||||||
if [ -z "$$commit_logs" ]; then \
|
if [ -z "$$commit_logs" ]; then \
|
||||||
tag_message="Release $$version"; \
|
tag_message="Release $$version"; \
|
||||||
else \
|
else \
|
||||||
@@ -232,17 +243,18 @@ release: ## Create and push a new release tag (auto-increments patch version)
|
|||||||
git push origin "$$version"; \
|
git push origin "$$version"; \
|
||||||
echo "Tag $$version created and pushed to remote repository."
|
echo "Tag $$version created and pushed to remote repository."
|
||||||
|
|
||||||
release-version: ## Auto-increment patch version, update package files, commit, tag, and push
|
release-version: ## Auto-increment patch version, update VERSION/package files, commit, tag, and push
|
||||||
@CURRENT=$$(git describe --tags --abbrev=0 2>/dev/null || echo "v0.0.0"); \
|
@CURRENT=$$([ -f VERSION ] && cat VERSION | tr -d '[:space:]' || (git describe --tags --abbrev=0 2>/dev/null | sed 's/^v//') || echo "0.0.0"); \
|
||||||
MAJOR=$$(echo $$CURRENT | sed 's/v\([0-9]*\)\.\([0-9]*\)\.\([0-9]*\).*/\1/'); \
|
MAJOR=$$(echo $$CURRENT | cut -d. -f1); \
|
||||||
MINOR=$$(echo $$CURRENT | sed 's/v\([0-9]*\)\.\([0-9]*\)\.\([0-9]*\).*/\2/'); \
|
MINOR=$$(echo $$CURRENT | cut -d. -f2); \
|
||||||
PATCH=$$(echo $$CURRENT | sed 's/v\([0-9]*\)\.\([0-9]*\)\.\([0-9]*\).*/\3/'); \
|
PATCH=$$(echo $$CURRENT | cut -d. -f3); \
|
||||||
NEXT="v$$MAJOR.$$MINOR.$$((PATCH + 1))"; \
|
|
||||||
PKGVER="$$MAJOR.$$MINOR.$$((PATCH + 1))"; \
|
PKGVER="$$MAJOR.$$MINOR.$$((PATCH + 1))"; \
|
||||||
echo "Current: $$CURRENT → Next: $$NEXT"; \
|
NEXT="v$$PKGVER"; \
|
||||||
|
echo "Current: v$$CURRENT → Next: $$NEXT"; \
|
||||||
|
echo "$$PKGVER" > VERSION; \
|
||||||
sed -i "s/^pkgver=.*/pkgver=$$PKGVER/" linux/arch/PKGBUILD; \
|
sed -i "s/^pkgver=.*/pkgver=$$PKGVER/" linux/arch/PKGBUILD; \
|
||||||
sed -i "s/^Version:.*/Version: $$PKGVER/" linux/centos/relspec.spec; \
|
sed -i "s/^Version:.*/Version: $$PKGVER/" linux/centos/relspec.spec; \
|
||||||
git add linux/arch/PKGBUILD linux/centos/relspec.spec; \
|
git add VERSION linux/arch/PKGBUILD linux/centos/relspec.spec; \
|
||||||
git commit -m "chore(release): update package version to $$PKGVER"; \
|
git commit -m "chore(release): update package version to $$PKGVER"; \
|
||||||
git tag -a "$$NEXT" -m "Release $$NEXT"; \
|
git tag -a "$$NEXT" -m "Release $$NEXT"; \
|
||||||
git push origin HEAD "$$NEXT"; \
|
git push origin HEAD "$$NEXT"; \
|
||||||
|
|||||||
@@ -126,7 +126,7 @@ relspec job run build-schema
|
|||||||
version: 1
|
version: 1
|
||||||
jobs:
|
jobs:
|
||||||
build-schema:
|
build-schema:
|
||||||
command: convert # closed allow-list: convert | merge | scripts-list
|
command: convert # closed allow-list: convert | merge | split | scripts-list | scripts-exec | templ | inspect | diff
|
||||||
description: Merge the DBML sources and emit PostgreSQL DDL
|
description: Merge the DBML sources and emit PostgreSQL DDL
|
||||||
inputs:
|
inputs:
|
||||||
- path: schema/core.dbml
|
- path: schema/core.dbml
|
||||||
@@ -147,7 +147,9 @@ resolved relative to the job file and may not escape it, and remote database
|
|||||||
credentials are referenced by environment-variable name (`conn_env:`) and
|
credentials are referenced by environment-variable name (`conn_env:`) and
|
||||||
redacted from logs. The whole plan — unknown commands/formats, duplicate job
|
redacted from logs. The whole plan — unknown commands/formats, duplicate job
|
||||||
names, missing inputs, path traversal, dependency cycles — is validated before
|
names, missing inputs, path traversal, dependency cycles — is validated before
|
||||||
any job runs. See [docs/JOB_FILES.md](docs/JOB_FILES.md).
|
any job runs. Path-like fields also support `${NAME}` environment-variable
|
||||||
|
references, which are expanded and safety-checked during pre-flight. See
|
||||||
|
[docs/JOB_FILES.md](docs/JOB_FILES.md).
|
||||||
|
|
||||||
### `edit` — Interactive TUI editor
|
### `edit` — Interactive TUI editor
|
||||||
|
|
||||||
|
|||||||
+52
-16
@@ -60,8 +60,9 @@ inputs, output and options:
|
|||||||
logfile: .relspec/log/build-schema.log
|
logfile: .relspec/log/build-schema.log
|
||||||
|
|
||||||
Rules and guarantees:
|
Rules and guarantees:
|
||||||
- command is a closed allow-list (convert, merge, scripts-list, templ). Arbitrary
|
- command is a closed allow-list (convert, merge, split, scripts-list,
|
||||||
shell strings are never executed.
|
scripts-exec, templ, inspect, diff). Arbitrary shell strings are never
|
||||||
|
executed.
|
||||||
- Every path is relative to the directory holding the job file and may not
|
- Every path is relative to the directory holding the job file and may not
|
||||||
escape it. Absolute and home-relative paths are rejected.
|
escape it. Absolute and home-relative paths are rejected.
|
||||||
- Remote database credentials are referenced by environment-variable name
|
- Remote database credentials are referenced by environment-variable name
|
||||||
@@ -246,22 +247,37 @@ type resolvedInput struct {
|
|||||||
func preflightJob(j *jobs.Job, resolvedByName map[string]*resolvedJob) (*resolvedJob, error) {
|
func preflightJob(j *jobs.Job, resolvedByName map[string]*resolvedJob) (*resolvedJob, error) {
|
||||||
root := j.Dir()
|
root := j.Dir()
|
||||||
rj := &resolvedJob{job: j, root: root, logPolicy: j.ResolvedLogPolicy()}
|
rj := &resolvedJob{job: j, root: root, logPolicy: j.ResolvedLogPolicy()}
|
||||||
|
expandPath := func(label, value string) (string, error) {
|
||||||
|
expanded, err := jobs.ExpandEnv(value)
|
||||||
|
if err != nil {
|
||||||
|
return "", fmt.Errorf("%s: %w", label, err)
|
||||||
|
}
|
||||||
|
return expanded, nil
|
||||||
|
}
|
||||||
|
|
||||||
if j.Logfile != "" {
|
if j.Logfile != "" {
|
||||||
p, err := jobs.SafeJoin(root, j.Logfile)
|
logfile, err := expandPath("logfile", j.Logfile)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
p, err := jobs.SafeJoin(root, logfile)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("logfile: %w", err)
|
return nil, fmt.Errorf("logfile: %w", err)
|
||||||
}
|
}
|
||||||
rj.logPath = p
|
rj.logPath = p
|
||||||
}
|
}
|
||||||
if j.Template != "" {
|
if j.Template != "" {
|
||||||
p, err := jobs.SafeJoin(root, j.Template)
|
templatePath, err := expandPath("template", j.Template)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
p, err := jobs.SafeJoin(root, templatePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("template: %w", err)
|
return nil, fmt.Errorf("template: %w", err)
|
||||||
}
|
}
|
||||||
info, err := os.Stat(p)
|
info, err := os.Stat(p)
|
||||||
if err != nil || info.IsDir() {
|
if err != nil || info.IsDir() {
|
||||||
return nil, fmt.Errorf("template %q: not found or is a directory", j.Template)
|
return nil, fmt.Errorf("template %q: not found or is a directory", templatePath)
|
||||||
}
|
}
|
||||||
rj.templatePath = p
|
rj.templatePath = p
|
||||||
}
|
}
|
||||||
@@ -291,16 +307,20 @@ func preflightJob(j *jobs.Job, resolvedByName map[string]*resolvedJob) (*resolve
|
|||||||
ri.connEnv = in.ConnEnv
|
ri.connEnv = in.ConnEnv
|
||||||
rj.secrets = append(rj.secrets, v)
|
rj.secrets = append(rj.secrets, v)
|
||||||
} else {
|
} else {
|
||||||
p, err := jobs.SafeJoin(root, in.Path)
|
inputPath, err := expandPath(fmt.Sprintf("input[%d]", i), in.Path)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
p, err := jobs.SafeJoin(root, inputPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("input[%d]: %w", i, err)
|
return nil, fmt.Errorf("input[%d]: %w", i, err)
|
||||||
}
|
}
|
||||||
info, err := os.Stat(p)
|
info, err := os.Stat(p)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("input[%d]: %s: file not found", i, in.Path)
|
return nil, fmt.Errorf("input[%d]: %s: file not found", i, inputPath)
|
||||||
}
|
}
|
||||||
if info.IsDir() {
|
if info.IsDir() {
|
||||||
return nil, fmt.Errorf("input[%d]: %s: is a directory, not a file", i, in.Path)
|
return nil, fmt.Errorf("input[%d]: %s: is a directory, not a file", i, inputPath)
|
||||||
}
|
}
|
||||||
ri.path = p
|
ri.path = p
|
||||||
}
|
}
|
||||||
@@ -308,13 +328,17 @@ func preflightJob(j *jobs.Job, resolvedByName map[string]*resolvedJob) (*resolve
|
|||||||
}
|
}
|
||||||
|
|
||||||
for _, d := range j.ScriptDirs {
|
for _, d := range j.ScriptDirs {
|
||||||
p, err := jobs.SafeJoin(root, d)
|
scriptDir, err := expandPath("script_dir", d)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
p, err := jobs.SafeJoin(root, scriptDir)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("script_dir %q: %w", d, err)
|
return nil, fmt.Errorf("script_dir %q: %w", d, err)
|
||||||
}
|
}
|
||||||
info, err := os.Stat(p)
|
info, err := os.Stat(p)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("script_dir %q: not found", d)
|
return nil, fmt.Errorf("script_dir %q: not found", scriptDir)
|
||||||
}
|
}
|
||||||
if !info.IsDir() {
|
if !info.IsDir() {
|
||||||
return nil, fmt.Errorf("script_dir %q: not a directory", d)
|
return nil, fmt.Errorf("script_dir %q: not a directory", d)
|
||||||
@@ -332,25 +356,33 @@ func preflightJob(j *jobs.Job, resolvedByName map[string]*resolvedJob) (*resolve
|
|||||||
rj.outputConnEnv = j.Output.ConnEnv
|
rj.outputConnEnv = j.Output.ConnEnv
|
||||||
rj.secrets = append(rj.secrets, v)
|
rj.secrets = append(rj.secrets, v)
|
||||||
} else {
|
} else {
|
||||||
p, err := jobs.SafeJoin(root, j.Output.Path)
|
outputPath, err := expandPath("output", j.Output.Path)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
p, err := jobs.SafeJoin(root, outputPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("output: %w", err)
|
return nil, fmt.Errorf("output: %w", err)
|
||||||
}
|
}
|
||||||
if _, err := os.Stat(p); err == nil && !j.Output.Overwrite {
|
if _, err := os.Stat(p); err == nil && !j.Output.Overwrite {
|
||||||
return nil, fmt.Errorf("output %s already exists (set output.overwrite: true to replace it)", j.Output.Path)
|
return nil, fmt.Errorf("output %s already exists (set output.overwrite: true to replace it)", outputPath)
|
||||||
}
|
}
|
||||||
rj.outputPath = p
|
rj.outputPath = p
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if j.Rules != "" {
|
if j.Rules != "" {
|
||||||
p, err := jobs.SafeJoin(root, j.Rules)
|
rulesPath, err := expandPath("rules", j.Rules)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
p, err := jobs.SafeJoin(root, rulesPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("rules: %w", err)
|
return nil, fmt.Errorf("rules: %w", err)
|
||||||
}
|
}
|
||||||
info, err := os.Stat(p)
|
info, err := os.Stat(p)
|
||||||
if err != nil || info.IsDir() {
|
if err != nil || info.IsDir() {
|
||||||
return nil, fmt.Errorf("rules %q: not found or is a directory", j.Rules)
|
return nil, fmt.Errorf("rules %q: not found or is a directory", rulesPath)
|
||||||
}
|
}
|
||||||
rj.rulesPath = p
|
rj.rulesPath = p
|
||||||
}
|
}
|
||||||
@@ -358,12 +390,16 @@ func preflightJob(j *jobs.Job, resolvedByName map[string]*resolvedJob) (*resolve
|
|||||||
if j.Report != nil {
|
if j.Report != nil {
|
||||||
rj.reportFormat = strings.ToLower(j.Report.Format)
|
rj.reportFormat = strings.ToLower(j.Report.Format)
|
||||||
if j.Report.Path != "" {
|
if j.Report.Path != "" {
|
||||||
p, err := jobs.SafeJoin(root, j.Report.Path)
|
reportPath, err := expandPath("report", j.Report.Path)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
p, err := jobs.SafeJoin(root, reportPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("report: %w", err)
|
return nil, fmt.Errorf("report: %w", err)
|
||||||
}
|
}
|
||||||
if _, err := os.Stat(p); err == nil && !j.Report.Overwrite {
|
if _, err := os.Stat(p); err == nil && !j.Report.Overwrite {
|
||||||
return nil, fmt.Errorf("report %s already exists (set report.overwrite: true to replace it)", j.Report.Path)
|
return nil, fmt.Errorf("report %s already exists (set report.overwrite: true to replace it)", reportPath)
|
||||||
}
|
}
|
||||||
rj.reportPath = p
|
rj.reportPath = p
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,6 +5,8 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// asciiLogo (see version.go) is printed by the `version` command.
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
args := os.Args[1:]
|
args := os.Args[1:]
|
||||||
isSilent := hasSilentFlag(args)
|
isSilent := hasSilentFlag(args)
|
||||||
|
|||||||
+6
-35
@@ -2,52 +2,23 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"runtime/debug"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// version/buildDate mirror pkg/buildinfo so existing call sites keep working.
|
||||||
|
// The actual values are set there via ldflags (see Makefile).
|
||||||
var (
|
var (
|
||||||
// Version information, set via ldflags during build
|
version = buildinfo.Version
|
||||||
version = "dev"
|
buildDate = buildinfo.BuildDate
|
||||||
buildDate = "unknown"
|
|
||||||
prisma7 bool
|
prisma7 bool
|
||||||
noVersion bool
|
noVersion bool
|
||||||
silent bool
|
silent bool
|
||||||
strictDirectives bool
|
strictDirectives bool
|
||||||
)
|
)
|
||||||
|
|
||||||
func init() {
|
|
||||||
// If version wasn't set via ldflags, try to get it from build info
|
|
||||||
if version == "dev" {
|
|
||||||
if info, ok := debug.ReadBuildInfo(); ok {
|
|
||||||
// Try to get version from VCS
|
|
||||||
var vcsRevision, vcsTime string
|
|
||||||
for _, setting := range info.Settings {
|
|
||||||
switch setting.Key {
|
|
||||||
case "vcs.revision":
|
|
||||||
if len(setting.Value) >= 7 {
|
|
||||||
vcsRevision = setting.Value[:7]
|
|
||||||
}
|
|
||||||
case "vcs.time":
|
|
||||||
vcsTime = setting.Value
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if vcsRevision != "" {
|
|
||||||
version = vcsRevision
|
|
||||||
}
|
|
||||||
|
|
||||||
if vcsTime != "" {
|
|
||||||
if t, err := time.Parse(time.RFC3339, vcsTime); err == nil {
|
|
||||||
buildDate = t.UTC().Format("2006-01-02 15:04:05 UTC")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
var rootCmd = &cobra.Command{
|
var rootCmd = &cobra.Command{
|
||||||
Use: "relspec",
|
Use: "relspec",
|
||||||
Short: "RelSpec - Database schema conversion and analysis tool",
|
Short: "RelSpec - Database schema conversion and analysis tool",
|
||||||
|
|||||||
@@ -4,13 +4,16 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
)
|
)
|
||||||
|
|
||||||
var versionCmd = &cobra.Command{
|
var versionCmd = &cobra.Command{
|
||||||
Use: "version",
|
Use: "version",
|
||||||
Short: "Print version information",
|
Short: "Print version information",
|
||||||
Run: func(cmd *cobra.Command, args []string) {
|
Run: func(cmd *cobra.Command, args []string) {
|
||||||
fmt.Printf("RelSpec %s\n", version)
|
fmt.Print(buildinfo.AsciiLogo)
|
||||||
fmt.Printf("Built: %s\n", buildDate)
|
fmt.Printf("RelSpec %s\n", buildinfo.Version)
|
||||||
|
fmt.Printf("Built: %s\n", buildinfo.BuildDate)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -55,6 +55,10 @@ already forbid duplicate keys within a single file.
|
|||||||
`script_dirs[]`, `template`, `logfile`) is **relative to the directory
|
`script_dirs[]`, `template`, `logfile`) is **relative to the directory
|
||||||
containing the job file that declared the job**, not the process working
|
containing the job file that declared the job**, not the process working
|
||||||
directory.
|
directory.
|
||||||
|
* Those path fields support `${NAME}` environment-variable references. They
|
||||||
|
are expanded immediately before execution; a missing variable is an error.
|
||||||
|
The expanded value is still subject to all relative-path and symlink safety
|
||||||
|
checks.
|
||||||
* Absolute paths, `~`-relative paths and any path that resolves outside the job
|
* Absolute paths, `~`-relative paths and any path that resolves outside the job
|
||||||
file directory (`../`, `a/../../b`, …) are **rejected during validation** —
|
file directory (`../`, `a/../../b`, …) are **rejected during validation** —
|
||||||
before anything runs.
|
before anything runs.
|
||||||
|
|||||||
@@ -0,0 +1,80 @@
|
|||||||
|
# RelSpec job examples
|
||||||
|
|
||||||
|
Run these commands from this directory:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
cd examples/jobs
|
||||||
|
|
||||||
|
# List every job from relspec.yml and the additional relspec.*.yml files.
|
||||||
|
relspec job list
|
||||||
|
|
||||||
|
# Validate a job and print its resolved plan without reading or writing data.
|
||||||
|
relspec job run build-schema --plan
|
||||||
|
|
||||||
|
# Build PostgreSQL DDL from the two DBML inputs.
|
||||||
|
relspec job run build-schema
|
||||||
|
|
||||||
|
# Run a job's dependency chain. This runs build-schema first, then build-json.
|
||||||
|
relspec job run build-json
|
||||||
|
|
||||||
|
# Inspect build-json's output. The from_job input adds the dependency automatically.
|
||||||
|
relspec job run lint-schema
|
||||||
|
|
||||||
|
# Extract only the posts table.
|
||||||
|
relspec job run posts-only
|
||||||
|
|
||||||
|
# List migration scripts in deterministic order without connecting to a database.
|
||||||
|
relspec job run migration-order
|
||||||
|
|
||||||
|
# Render one TypeScript file per table using the example template.
|
||||||
|
relspec job run generate-typescript
|
||||||
|
|
||||||
|
# Compare the two example schemas and write the summary to the logfile.
|
||||||
|
relspec job run compare-schemas
|
||||||
|
|
||||||
|
# Use an environment variable in an output path.
|
||||||
|
export VST=build/typescript
|
||||||
|
relspec job run generate-typescript --plan
|
||||||
|
relspec job run generate-typescript
|
||||||
|
```
|
||||||
|
|
||||||
|
Database jobs use environment variables for connection strings. Set them in
|
||||||
|
the shell before running the jobs; do not put connection strings in YAML:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
export SOURCE_DB_URL='postgres://user:password@localhost/source_db'
|
||||||
|
export TARGET_DB_URL='postgres://user:password@localhost/target_db'
|
||||||
|
|
||||||
|
# Read the source database and write a local DBML snapshot.
|
||||||
|
relspec job run snapshot-database
|
||||||
|
|
||||||
|
# Preview migration execution without connecting to PostgreSQL.
|
||||||
|
relspec job run apply-migrations --plan
|
||||||
|
|
||||||
|
# Execute the migrations against TARGET_DB_URL.
|
||||||
|
relspec job run apply-migrations
|
||||||
|
```
|
||||||
|
|
||||||
|
The `apply-migrations` job demonstrates execution from multiple directories:
|
||||||
|
|
||||||
|
```yaml
|
||||||
|
script_dirs:
|
||||||
|
- migrations/core
|
||||||
|
- migrations/tenant
|
||||||
|
output:
|
||||||
|
format: pgsql
|
||||||
|
conn_env: TARGET_DB_URL
|
||||||
|
```
|
||||||
|
|
||||||
|
RelSpec combines the SQL files from both folders in deterministic order before
|
||||||
|
executing them against the configured PostgreSQL database.
|
||||||
|
|
||||||
|
To use a different directory or manifest, pass `--dir` or `--file`:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
relspec job list --dir /path/to/project
|
||||||
|
relspec job run build-schema --file /path/to/project/relspec.yml --plan
|
||||||
|
```
|
||||||
|
|
||||||
|
See [../../docs/JOB_FILES.md](../../docs/JOB_FILES.md) for the complete job
|
||||||
|
file reference.
|
||||||
@@ -0,0 +1,29 @@
|
|||||||
|
# Database-oriented examples. Set the referenced environment variables before
|
||||||
|
# running these jobs; connection strings never belong in a job file.
|
||||||
|
version: 1
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
snapshot-database:
|
||||||
|
command: convert
|
||||||
|
description: Read a PostgreSQL database and write a DBML snapshot
|
||||||
|
inputs:
|
||||||
|
- format: pgsql
|
||||||
|
conn_env: SOURCE_DB_URL
|
||||||
|
output:
|
||||||
|
format: dbml
|
||||||
|
path: build/database-snapshot.dbml
|
||||||
|
overwrite: true
|
||||||
|
|
||||||
|
apply-migrations:
|
||||||
|
command: scripts-exec
|
||||||
|
description: Execute migrations from core and tenant folders against PostgreSQL
|
||||||
|
# All SQL files from these directories are discovered in deterministic order.
|
||||||
|
script_dirs:
|
||||||
|
- migrations/core
|
||||||
|
- migrations/tenant
|
||||||
|
output:
|
||||||
|
format: pgsql
|
||||||
|
conn_env: TARGET_DB_URL
|
||||||
|
options:
|
||||||
|
continue_on_error: false
|
||||||
|
logfile: .relspec/log/apply-migrations.log
|
||||||
@@ -0,0 +1,31 @@
|
|||||||
|
# Reporting and templating examples. These jobs are discovered together with
|
||||||
|
# relspec.yml when running `relspec job list` from this directory.
|
||||||
|
version: 1
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
generate-typescript:
|
||||||
|
command: templ
|
||||||
|
description: Render one TypeScript file per table from the merged schema
|
||||||
|
inputs:
|
||||||
|
- path: schema/core.dbml
|
||||||
|
format: dbml
|
||||||
|
- path: schema/tenant.dbml
|
||||||
|
format: dbml
|
||||||
|
template: templates/schema.tmpl
|
||||||
|
mode: table
|
||||||
|
filename_pattern: "{{.Name}}.ts"
|
||||||
|
output:
|
||||||
|
path: "${VST}"
|
||||||
|
overwrite: true
|
||||||
|
|
||||||
|
compare-schemas:
|
||||||
|
command: diff
|
||||||
|
description: Compare the two example schemas and print a summary
|
||||||
|
inputs:
|
||||||
|
- path: schema/core.dbml
|
||||||
|
format: dbml
|
||||||
|
- path: schema/tenant.dbml
|
||||||
|
format: dbml
|
||||||
|
report:
|
||||||
|
format: summary
|
||||||
|
logfile: .relspec/log/compare-schemas.log
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
// Code generated by RelSpec. DO NOT EDIT.
|
||||||
|
export interface {{.Name}} {
|
||||||
|
{{- range values .Table.Columns}}
|
||||||
|
{{.Name}}: {{.Type}};
|
||||||
|
{{- end}}
|
||||||
|
}
|
||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
# Maintainer: Hein (Warky Devs) <hein@warky.dev>
|
# Maintainer: Hein (Warky Devs) <hein@warky.dev>
|
||||||
pkgname=relspec
|
pkgname=relspec
|
||||||
pkgver=1.0.74
|
pkgver=1.0.82
|
||||||
pkgrel=1
|
pkgrel=1
|
||||||
pkgdesc="RelSpec is a comprehensive database relations management tool that reads, transforms, and writes database table specifications across multiple formats and ORMs."
|
pkgdesc="RelSpec is a comprehensive database relations management tool that reads, transforms, and writes database table specifications across multiple formats and ORMs."
|
||||||
arch=('x86_64' 'aarch64')
|
arch=('x86_64' 'aarch64')
|
||||||
@@ -15,7 +15,7 @@ build() {
|
|||||||
export CGO_ENABLED=0
|
export CGO_ENABLED=0
|
||||||
go build \
|
go build \
|
||||||
-trimpath \
|
-trimpath \
|
||||||
-ldflags "-X git.warky.dev/wdevs/relspecgo/cmd/relspec.version=$pkgver" \
|
-ldflags "-X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.Version=v$pkgver' -X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.BuildDate=$(date -u +"%Y-%m-%d %H:%M:%S UTC")'" \
|
||||||
-o "$pkgname" ./cmd/relspec
|
-o "$pkgname" ./cmd/relspec
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
Name: relspec
|
Name: relspec
|
||||||
Version: 1.0.74
|
Version: 1.0.82
|
||||||
Release: 1%{?dist}
|
Release: 1%{?dist}
|
||||||
Summary: RelSpec is a comprehensive database relations management tool that reads, transforms, and writes database table specifications across multiple formats and ORMs.
|
Summary: RelSpec is a comprehensive database relations management tool that reads, transforms, and writes database table specifications across multiple formats and ORMs.
|
||||||
|
|
||||||
@@ -25,7 +25,7 @@ DBML, GraphQL, and more.
|
|||||||
export CGO_ENABLED=0
|
export CGO_ENABLED=0
|
||||||
go build \
|
go build \
|
||||||
-trimpath \
|
-trimpath \
|
||||||
-ldflags "-X git.warky.dev/wdevs/relspecgo/cmd/relspec.version=%{version}" \
|
-ldflags "-X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.Version=v%{version}' -X 'git.warky.dev/wdevs/relspecgo/pkg/buildinfo.BuildDate=$(date -u +"%%Y-%%m-%%d %%H:%%M:%%S UTC")'" \
|
||||||
-o %{name} ./cmd/relspec
|
-o %{name} ./cmd/relspec
|
||||||
|
|
||||||
%install
|
%install
|
||||||
|
|||||||
@@ -0,0 +1,65 @@
|
|||||||
|
// Package buildinfo exposes the RelSpec version and build date so that both the
|
||||||
|
// CLI and the schema writers can stamp generated output with the same values.
|
||||||
|
package buildinfo
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"runtime/debug"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
// Version and BuildDate are set via -ldflags at build time (see Makefile). When
|
||||||
|
// built without ldflags they are backfilled from the Go module build info.
|
||||||
|
var (
|
||||||
|
Version = "dev"
|
||||||
|
BuildDate = "unknown"
|
||||||
|
)
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
if Version != "dev" {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
info, ok := debug.ReadBuildInfo()
|
||||||
|
if !ok {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
var rev, vcsTime string
|
||||||
|
for _, s := range info.Settings {
|
||||||
|
switch s.Key {
|
||||||
|
case "vcs.revision":
|
||||||
|
if len(s.Value) >= 7 {
|
||||||
|
rev = s.Value[:7]
|
||||||
|
}
|
||||||
|
case "vcs.time":
|
||||||
|
vcsTime = s.Value
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if rev != "" {
|
||||||
|
Version = rev
|
||||||
|
}
|
||||||
|
if t, err := time.Parse(time.RFC3339, vcsTime); err == nil {
|
||||||
|
BuildDate = t.UTC().Format("2006-01-02 15:04:05 UTC")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// GeneratedComment returns the one-line provenance string embedded in generated
|
||||||
|
// files, e.g. "RelSpec dev (built: unknown)".
|
||||||
|
func GeneratedComment() string {
|
||||||
|
return fmt.Sprintf("RelSpec %s (built: %s)", Version, BuildDate)
|
||||||
|
}
|
||||||
|
|
||||||
|
const AsciiLogo = `
|
||||||
|
██████╗ ███████╗██╗ ███████╗██████╗ ███████╗ ██████╗
|
||||||
|
██╔══██╗██╔════╝██║ ██╔════╝██╔══██╗██╔════╝██╔════╝
|
||||||
|
██████╔╝█████╗ ██║ ███████╗██████╔╝█████╗ ██║
|
||||||
|
██╔══██╗██╔══╝ ██║ ╚════██║██╔═══╝ ██╔══╝ ██║
|
||||||
|
██║ ██║███████╗███████╗███████║██║ ███████╗╚██████╗
|
||||||
|
╚═╝ ╚═╝╚══════╝╚══════╝╚══════╝╚═╝ ╚══════╝ ╚═════╝
|
||||||
|
[ IN ] ──▶ [ RELSPEC ] ──▶ [ OUT ]
|
||||||
|
╔══════════════════════════════════════╗
|
||||||
|
║ ║
|
||||||
|
║ © WARKY DEVS ║
|
||||||
|
║ Author: Hein (hein@warky.dev) ║
|
||||||
|
║ ║
|
||||||
|
╚══════════════════════════════════════╝
|
||||||
|
`
|
||||||
@@ -19,6 +19,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
"regexp"
|
||||||
"sort"
|
"sort"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
@@ -850,6 +851,29 @@ func SafeJoin(root, rel string) (string, error) {
|
|||||||
return joined, nil
|
return joined, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var envReferencePattern = regexp.MustCompile(`\$\{([A-Za-z_][A-Za-z0-9_]*)\}`)
|
||||||
|
|
||||||
|
// ExpandEnv expands ${NAME} references using the current process environment.
|
||||||
|
// It deliberately supports only shell-independent variable references; job
|
||||||
|
// files are never passed through a shell. An unset variable is an error so a
|
||||||
|
// typo cannot silently turn into a relative path.
|
||||||
|
func ExpandEnv(value string) (string, error) {
|
||||||
|
var missing string
|
||||||
|
expanded := envReferencePattern.ReplaceAllStringFunc(value, func(reference string) string {
|
||||||
|
name := reference[2 : len(reference)-1]
|
||||||
|
resolved, ok := os.LookupEnv(name)
|
||||||
|
if !ok {
|
||||||
|
missing = name
|
||||||
|
return reference
|
||||||
|
}
|
||||||
|
return resolved
|
||||||
|
})
|
||||||
|
if missing != "" {
|
||||||
|
return "", fmt.Errorf("environment variable %q referenced by ${%s} is not set", missing, missing)
|
||||||
|
}
|
||||||
|
return expanded, nil
|
||||||
|
}
|
||||||
|
|
||||||
// deepestExistingAncestor returns p itself if it exists, otherwise the nearest
|
// deepestExistingAncestor returns p itself if it exists, otherwise the nearest
|
||||||
// existing parent directory (falling back to the filesystem root).
|
// existing parent directory (falling back to the filesystem root).
|
||||||
func deepestExistingAncestor(p string) string {
|
func deepestExistingAncestor(p string) string {
|
||||||
|
|||||||
@@ -135,6 +135,21 @@ func TestParseHumanSize(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestExpandEnv(t *testing.T) {
|
||||||
|
t.Setenv("RELSPEC_TEST_ROOT", "build/output")
|
||||||
|
got, err := ExpandEnv("${RELSPEC_TEST_ROOT}/schema-${RELSPEC_TEST_ROOT}")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if want := "build/output/schema-build/output"; got != want {
|
||||||
|
t.Fatalf("ExpandEnv = %q, want %q", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
if _, err := ExpandEnv("build/${RELSPEC_TEST_MISSING}"); err == nil {
|
||||||
|
t.Fatal("expected missing environment variable error")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestLoadRejectsDuplicateJobAcrossFiles(t *testing.T) {
|
func TestLoadRejectsDuplicateJobAcrossFiles(t *testing.T) {
|
||||||
dir := t.TempDir()
|
dir := t.TempDir()
|
||||||
a := filepath.Join(dir, "relspec.yml")
|
a := filepath.Join(dir, "relspec.yml")
|
||||||
|
|||||||
+21
-17
@@ -227,23 +227,27 @@ func (d *Sequence) SQLName() string {
|
|||||||
|
|
||||||
// Column represents a table column
|
// Column represents a table column
|
||||||
type Column struct {
|
type Column struct {
|
||||||
Name string `json:"name" yaml:"name" xml:"name"`
|
Name string `json:"name" yaml:"name" xml:"name"`
|
||||||
Description string `json:"description,omitempty" yaml:"description,omitempty" xml:"description,omitempty"`
|
Description string `json:"description,omitempty" yaml:"description,omitempty" xml:"description,omitempty"`
|
||||||
Table string `json:"table" yaml:"table" xml:"table"`
|
Table string `json:"table" yaml:"table" xml:"table"`
|
||||||
Schema string `json:"schema" yaml:"schema" xml:"schema"`
|
Schema string `json:"schema" yaml:"schema" xml:"schema"`
|
||||||
Type string `json:"type" yaml:"type" xml:"type"`
|
Type string `json:"type" yaml:"type" xml:"type"`
|
||||||
Length int `json:"length,omitempty" yaml:"length,omitempty" xml:"length,omitempty"`
|
Length int `json:"length,omitempty" yaml:"length,omitempty" xml:"length,omitempty"`
|
||||||
Precision int `json:"precision,omitempty" yaml:"precision,omitempty" xml:"precision,omitempty"`
|
Precision int `json:"precision,omitempty" yaml:"precision,omitempty" xml:"precision,omitempty"`
|
||||||
Scale int `json:"scale,omitempty" yaml:"scale,omitempty" xml:"scale,omitempty"`
|
Scale int `json:"scale,omitempty" yaml:"scale,omitempty" xml:"scale,omitempty"`
|
||||||
NotNull bool `json:"not_null" yaml:"not_null" xml:"not_null"`
|
NotNull bool `json:"not_null" yaml:"not_null" xml:"not_null"`
|
||||||
Default any `json:"default,omitempty" yaml:"default,omitempty" xml:"default,omitempty"`
|
Default any `json:"default,omitempty" yaml:"default,omitempty" xml:"default,omitempty"`
|
||||||
AutoIncrement bool `json:"auto_increment" yaml:"auto_increment" xml:"auto_increment"`
|
AutoIncrement bool `json:"auto_increment" yaml:"auto_increment" xml:"auto_increment"`
|
||||||
IsPrimaryKey bool `json:"is_primary_key" yaml:"is_primary_key" xml:"is_primary_key"`
|
IsPrimaryKey bool `json:"is_primary_key" yaml:"is_primary_key" xml:"is_primary_key"`
|
||||||
Comment string `json:"comment,omitempty" yaml:"comment,omitempty" xml:"comment,omitempty"`
|
Comment string `json:"comment,omitempty" yaml:"comment,omitempty" xml:"comment,omitempty"`
|
||||||
Collation string `json:"collation,omitempty" yaml:"collation,omitempty" xml:"collation,omitempty"`
|
Collation string `json:"collation,omitempty" yaml:"collation,omitempty" xml:"collation,omitempty"`
|
||||||
Metadata map[string]any `json:"metadata,omitempty" yaml:"metadata,omitempty" xml:"-"`
|
Metadata map[string]any `json:"metadata,omitempty" yaml:"metadata,omitempty" xml:"-"`
|
||||||
Sequence uint `json:"sequence,omitempty" yaml:"sequence,omitempty" xml:"sequence,omitempty"`
|
Sequence uint `json:"sequence,omitempty" yaml:"sequence,omitempty" xml:"sequence,omitempty"`
|
||||||
GUID string `json:"guid" yaml:"guid" xml:"guid"`
|
GUID string `json:"guid" yaml:"guid" xml:"guid"`
|
||||||
|
Generated bool `json:"generated,omitempty" yaml:"generated,omitempty" xml:"generated,omitempty"`
|
||||||
|
GenerationExpression string `json:"generation_expression,omitempty" yaml:"generation_expression,omitempty" xml:"generation_expression,omitempty"`
|
||||||
|
Identity bool `json:"identity,omitempty" yaml:"identity,omitempty" xml:"identity,omitempty"`
|
||||||
|
IdentityGeneration string `json:"identity_generation,omitempty" yaml:"identity_generation,omitempty" xml:"identity_generation,omitempty"` // "ALWAYS" or "BY DEFAULT"
|
||||||
}
|
}
|
||||||
|
|
||||||
// SQLName returns the column name in lowercase for SQL compatibility.
|
// SQLName returns the column name in lowercase for SQL compatibility.
|
||||||
|
|||||||
@@ -305,9 +305,39 @@ func sortDBMLFiles(files []string) []string {
|
|||||||
// Merges: Columns (map), Constraints (map), Indexes (map), Relationships (map)
|
// Merges: Columns (map), Constraints (map), Indexes (map), Relationships (map)
|
||||||
// Uses first non-empty Description
|
// Uses first non-empty Description
|
||||||
func mergeTable(baseTable, fileTable *models.Table) {
|
func mergeTable(baseTable, fileTable *models.Table) {
|
||||||
// Merge columns (map naturally merges - later keys overwrite)
|
// Merge columns. Each file numbers its own columns from 1, so a table split
|
||||||
for key, col := range fileTable.Columns {
|
// across files would otherwise end up with colliding Column.Sequence values
|
||||||
baseTable.Columns[key] = col
|
// and writers would fall back to alphabetical order. Re-base the incoming
|
||||||
|
// file's new columns after the highest sequence already present, preserving
|
||||||
|
// their in-file order. Columns that overwrite an existing key keep the
|
||||||
|
// original position.
|
||||||
|
var maxSeq uint
|
||||||
|
for _, col := range baseTable.Columns {
|
||||||
|
if col.Sequence > maxSeq {
|
||||||
|
maxSeq = col.Sequence
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
incoming := make([]*models.Column, 0, len(fileTable.Columns))
|
||||||
|
for _, col := range fileTable.Columns {
|
||||||
|
incoming = append(incoming, col)
|
||||||
|
}
|
||||||
|
sort.Slice(incoming, func(i, j int) bool {
|
||||||
|
if incoming[i].Sequence != incoming[j].Sequence {
|
||||||
|
return incoming[i].Sequence < incoming[j].Sequence
|
||||||
|
}
|
||||||
|
return incoming[i].Name < incoming[j].Name
|
||||||
|
})
|
||||||
|
|
||||||
|
var added uint
|
||||||
|
for _, col := range incoming {
|
||||||
|
if existing, ok := baseTable.Columns[col.Name]; ok {
|
||||||
|
col.Sequence = existing.Sequence
|
||||||
|
} else {
|
||||||
|
added++
|
||||||
|
col.Sequence = maxSeq + added
|
||||||
|
}
|
||||||
|
baseTable.Columns[col.Name] = col
|
||||||
}
|
}
|
||||||
|
|
||||||
// Merge constraints
|
// Merge constraints
|
||||||
|
|||||||
@@ -652,6 +652,22 @@ func TestReadDirectory_TableMerging(t *testing.T) {
|
|||||||
if emailCol.Type != "varchar(255)" {
|
if emailCol.Type != "varchar(255)" {
|
||||||
t.Errorf("Expected email type 'varchar(255)', got '%s'", emailCol.Type)
|
t.Errorf("Expected email type 'varchar(255)', got '%s'", emailCol.Type)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Merged columns must keep declaration order (file 1: id, email; file 3:
|
||||||
|
// name, created_at) via strictly increasing, non-colliding Sequence values
|
||||||
|
// so downstream writers do not fall back to alphabetical order.
|
||||||
|
order := []string{"id", "email", "name", "created_at"}
|
||||||
|
var prev uint
|
||||||
|
for i, name := range order {
|
||||||
|
col := usersTable.Columns[name]
|
||||||
|
if col.Sequence == 0 {
|
||||||
|
t.Fatalf("column %q has zero Sequence after merge", name)
|
||||||
|
}
|
||||||
|
if i > 0 && col.Sequence <= prev {
|
||||||
|
t.Errorf("column %q Sequence %d not greater than previous %d (order not preserved across files)", name, col.Sequence, prev)
|
||||||
|
}
|
||||||
|
prev = col.Sequence
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestReadDirectory_CommentedRefsLast(t *testing.T) {
|
func TestReadDirectory_CommentedRefsLast(t *testing.T) {
|
||||||
|
|||||||
@@ -243,7 +243,11 @@ func (r *Reader) queryColumns(schemaName string) (map[string]map[string]*models.
|
|||||||
c.numeric_scale,
|
c.numeric_scale,
|
||||||
c.udt_name,
|
c.udt_name,
|
||||||
pg_catalog.format_type(a.atttypid, a.atttypmod) as formatted_data_type,
|
pg_catalog.format_type(a.atttypid, a.atttypmod) as formatted_data_type,
|
||||||
col_description((c.table_schema||'.'||c.table_name)::regclass, c.ordinal_position) as description
|
col_description((c.table_schema||'.'||c.table_name)::regclass, c.ordinal_position) as description,
|
||||||
|
c.is_generated,
|
||||||
|
c.generation_expression,
|
||||||
|
c.is_identity,
|
||||||
|
c.identity_generation
|
||||||
FROM information_schema.columns c
|
FROM information_schema.columns c
|
||||||
JOIN pg_catalog.pg_namespace n
|
JOIN pg_catalog.pg_namespace n
|
||||||
ON n.nspname = c.table_schema
|
ON n.nspname = c.table_schema
|
||||||
@@ -268,17 +272,36 @@ func (r *Reader) queryColumns(schemaName string) (map[string]map[string]*models.
|
|||||||
columnsMap := make(map[string]map[string]*models.Column)
|
columnsMap := make(map[string]map[string]*models.Column)
|
||||||
|
|
||||||
for rows.Next() {
|
for rows.Next() {
|
||||||
var schema, tableName, columnName, isNullable, dataType, udtName, formattedDataType string
|
var schema, tableName, columnName, isNullable, dataType, udtName, formattedDataType, isGenerated, isIdentity string
|
||||||
var ordinalPosition int
|
var ordinalPosition int
|
||||||
var columnDefault, description *string
|
var columnDefault, description, generationExpression, identityGeneration *string
|
||||||
var charMaxLength, numPrecision, numScale *int
|
var charMaxLength, numPrecision, numScale *int
|
||||||
|
|
||||||
if err := rows.Scan(&schema, &tableName, &columnName, &ordinalPosition, &columnDefault, &isNullable, &dataType, &charMaxLength, &numPrecision, &numScale, &udtName, &formattedDataType, &description); err != nil {
|
if err := rows.Scan(&schema, &tableName, &columnName, &ordinalPosition, &columnDefault, &isNullable, &dataType, &charMaxLength, &numPrecision, &numScale, &udtName, &formattedDataType, &description, &isGenerated, &generationExpression, &isIdentity, &identityGeneration); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
column := models.InitColumn(columnName, tableName, schema)
|
column := models.InitColumn(columnName, tableName, schema)
|
||||||
|
|
||||||
|
// GENERATED ALWAYS ... STORED columns are computed by Postgres and cannot
|
||||||
|
// have their default altered/dropped like a regular column.
|
||||||
|
column.Generated = isGenerated == "ALWAYS"
|
||||||
|
if generationExpression != nil {
|
||||||
|
column.GenerationExpression = *generationExpression
|
||||||
|
}
|
||||||
|
|
||||||
|
// GENERATED { ALWAYS | BY DEFAULT } AS IDENTITY columns are driven by an
|
||||||
|
// internal sequence rather than a literal default (unlike serial columns,
|
||||||
|
// they carry no pg_attrdef row at all), so they need the same DB-side
|
||||||
|
// handling as generated columns even though the underlying mechanism differs.
|
||||||
|
column.Identity = isIdentity == "YES"
|
||||||
|
if identityGeneration != nil {
|
||||||
|
column.IdentityGeneration = strings.ToUpper(strings.TrimSpace(*identityGeneration))
|
||||||
|
}
|
||||||
|
if column.Identity {
|
||||||
|
column.AutoIncrement = true
|
||||||
|
}
|
||||||
|
|
||||||
// Check if this is a serial type (has nextval default)
|
// Check if this is a serial type (has nextval default)
|
||||||
hasNextval := false
|
hasNextval := false
|
||||||
if columnDefault != nil {
|
if columnDefault != nil {
|
||||||
@@ -301,6 +324,24 @@ func (r *Reader) queryColumns(schemaName string) (map[string]map[string]*models.
|
|||||||
column.Description = *description
|
column.Description = *description
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if column.Generated {
|
||||||
|
note := "GENERATED ALWAYS AS (" + column.GenerationExpression + ") STORED"
|
||||||
|
if column.Description != "" {
|
||||||
|
column.Description = column.Description + " " + note
|
||||||
|
} else {
|
||||||
|
column.Description = note
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if column.Identity {
|
||||||
|
note := "GENERATED " + column.IdentityGeneration + " AS IDENTITY"
|
||||||
|
if column.Description != "" {
|
||||||
|
column.Description = column.Description + " " + note
|
||||||
|
} else {
|
||||||
|
column.Description = note
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if charMaxLength != nil {
|
if charMaxLength != nil {
|
||||||
column.Length = *charMaxLength
|
column.Length = *charMaxLength
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ import (
|
|||||||
"sort"
|
"sort"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
||||||
)
|
)
|
||||||
@@ -13,6 +14,7 @@ import (
|
|||||||
// TemplateData represents the data passed to the template for code generation
|
// TemplateData represents the data passed to the template for code generation
|
||||||
type TemplateData struct {
|
type TemplateData struct {
|
||||||
PackageName string
|
PackageName string
|
||||||
|
GeneratedBy string
|
||||||
Imports []string
|
Imports []string
|
||||||
Models []*ModelData
|
Models []*ModelData
|
||||||
Config *MethodConfig
|
Config *MethodConfig
|
||||||
@@ -165,6 +167,7 @@ func NewTemplateData(packageName string, config *MethodConfig) *TemplateData {
|
|||||||
|
|
||||||
return &TemplateData{
|
return &TemplateData{
|
||||||
PackageName: packageName,
|
PackageName: packageName,
|
||||||
|
GeneratedBy: buildinfo.GeneratedComment(),
|
||||||
Imports: make([]string, 0),
|
Imports: make([]string, 0),
|
||||||
Models: make([]*ModelData, 0),
|
Models: make([]*ModelData, 0),
|
||||||
Config: config,
|
Config: config,
|
||||||
|
|||||||
@@ -7,7 +7,8 @@ import (
|
|||||||
|
|
||||||
// modelTemplate defines the template for generating Bun models
|
// modelTemplate defines the template for generating Bun models
|
||||||
const modelTemplate = `// Code generated by relspecgo. DO NOT EDIT.
|
const modelTemplate = `// Code generated by relspecgo. DO NOT EDIT.
|
||||||
package {{.PackageName}}
|
{{if .GeneratedBy}}// {{.GeneratedBy}}
|
||||||
|
{{end}}package {{.PackageName}}
|
||||||
|
|
||||||
{{if .Imports -}}
|
{{if .Imports -}}
|
||||||
import (
|
import (
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
||||||
)
|
)
|
||||||
@@ -120,6 +121,42 @@ func TestWriter_WriteTable_MultilineDescriptionProducesValidGo(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestWriter_WriteTable_EmbedsRelspecVersionHeader(t *testing.T) {
|
||||||
|
table := models.InitTable("users", "public")
|
||||||
|
table.Columns["id"] = &models.Column{Name: "id", Type: "bigint", IsPrimaryKey: true, NotNull: true, Sequence: 1}
|
||||||
|
|
||||||
|
outputPath := filepath.Join(t.TempDir(), "users.go")
|
||||||
|
writer := NewWriter(&writers.WriterOptions{OutputPath: outputPath, PackageName: "models"})
|
||||||
|
if err := writer.WriteTable(table); err != nil {
|
||||||
|
t.Fatalf("WriteTable() error = %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
generated, err := os.ReadFile(outputPath)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("failed to read generated code: %v", err)
|
||||||
|
}
|
||||||
|
src := string(generated)
|
||||||
|
|
||||||
|
if _, err := parser.ParseFile(token.NewFileSet(), outputPath, generated, parser.AllErrors); err != nil {
|
||||||
|
t.Fatalf("generated code is invalid Go: %v\n%s", err, src)
|
||||||
|
}
|
||||||
|
|
||||||
|
wantHeader := "// " + buildinfo.GeneratedComment()
|
||||||
|
if !strings.Contains(src, wantHeader) {
|
||||||
|
t.Errorf("generated code missing RelSpec version header %q\n%s", wantHeader, src)
|
||||||
|
}
|
||||||
|
// The provenance comment must sit between the "Code generated" marker and the package clause.
|
||||||
|
genIdx := strings.Index(src, "// Code generated by relspecgo. DO NOT EDIT.")
|
||||||
|
hdrIdx := strings.Index(src, wantHeader)
|
||||||
|
pkgIdx := strings.Index(src, "package models")
|
||||||
|
if genIdx < 0 || hdrIdx < 0 || pkgIdx < 0 || !(genIdx < hdrIdx && hdrIdx < pkgIdx) {
|
||||||
|
t.Errorf("RelSpec version header is misplaced (gen=%d hdr=%d pkg=%d)\n%s", genIdx, hdrIdx, pkgIdx, src)
|
||||||
|
}
|
||||||
|
if !strings.Contains(wantHeader, "RelSpec ") || !strings.Contains(wantHeader, "(built: ") {
|
||||||
|
t.Errorf("version header not in expected 'RelSpec <version> (built: <date>)' form: %q", wantHeader)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestWriter_WriteDatabase_MultiFile(t *testing.T) {
|
func TestWriter_WriteDatabase_MultiFile(t *testing.T) {
|
||||||
// Create a database with two tables
|
// Create a database with two tables
|
||||||
db := models.InitDatabase("testdb")
|
db := models.InitDatabase("testdb")
|
||||||
|
|||||||
@@ -4,14 +4,16 @@ import (
|
|||||||
"sort"
|
"sort"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TemplateData represents the data passed to the template for code generation
|
// TemplateData represents the data passed to the template for code generation
|
||||||
type TemplateData struct {
|
type TemplateData struct {
|
||||||
Imports []string
|
GeneratedBy string
|
||||||
Enums []*EnumData
|
Imports []string
|
||||||
Tables []*TableData
|
Enums []*EnumData
|
||||||
|
Tables []*TableData
|
||||||
}
|
}
|
||||||
|
|
||||||
// EnumData represents an enum in the schema
|
// EnumData represents an enum in the schema
|
||||||
@@ -59,9 +61,10 @@ type IndexData struct {
|
|||||||
// NewTemplateData creates a new TemplateData
|
// NewTemplateData creates a new TemplateData
|
||||||
func NewTemplateData() *TemplateData {
|
func NewTemplateData() *TemplateData {
|
||||||
return &TemplateData{
|
return &TemplateData{
|
||||||
Imports: make([]string, 0),
|
GeneratedBy: buildinfo.GeneratedComment(),
|
||||||
Enums: make([]*EnumData, 0),
|
Imports: make([]string, 0),
|
||||||
Tables: make([]*TableData, 0),
|
Enums: make([]*EnumData, 0),
|
||||||
|
Tables: make([]*TableData, 0),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -7,7 +7,8 @@ import (
|
|||||||
|
|
||||||
// schemaTemplate defines the template for generating Drizzle schemas
|
// schemaTemplate defines the template for generating Drizzle schemas
|
||||||
const schemaTemplate = `// Code generated by relspecgo. DO NOT EDIT.
|
const schemaTemplate = `// Code generated by relspecgo. DO NOT EDIT.
|
||||||
{{range .Imports}}{{.}}
|
{{if .GeneratedBy}}// {{.GeneratedBy}}
|
||||||
|
{{end}}{{range .Imports}}{{.}}
|
||||||
{{end}}
|
{{end}}
|
||||||
{{if .Enums}}
|
{{if .Enums}}
|
||||||
// Enums
|
// Enums
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import (
|
|||||||
"sort"
|
"sort"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
||||||
)
|
)
|
||||||
@@ -11,6 +12,7 @@ import (
|
|||||||
// TemplateData represents the data passed to the template for code generation
|
// TemplateData represents the data passed to the template for code generation
|
||||||
type TemplateData struct {
|
type TemplateData struct {
|
||||||
PackageName string
|
PackageName string
|
||||||
|
GeneratedBy string
|
||||||
Imports []string
|
Imports []string
|
||||||
Models []*ModelData
|
Models []*ModelData
|
||||||
Config *MethodConfig
|
Config *MethodConfig
|
||||||
@@ -79,6 +81,7 @@ func NewTemplateData(packageName string, config *MethodConfig) *TemplateData {
|
|||||||
|
|
||||||
return &TemplateData{
|
return &TemplateData{
|
||||||
PackageName: packageName,
|
PackageName: packageName,
|
||||||
|
GeneratedBy: buildinfo.GeneratedComment(),
|
||||||
Imports: make([]string, 0),
|
Imports: make([]string, 0),
|
||||||
Models: make([]*ModelData, 0),
|
Models: make([]*ModelData, 0),
|
||||||
Config: config,
|
Config: config,
|
||||||
|
|||||||
@@ -7,7 +7,8 @@ import (
|
|||||||
|
|
||||||
// modelTemplate defines the template for generating GORM models
|
// modelTemplate defines the template for generating GORM models
|
||||||
const modelTemplate = `// Code generated by relspecgo. DO NOT EDIT.
|
const modelTemplate = `// Code generated by relspecgo. DO NOT EDIT.
|
||||||
package {{.PackageName}}
|
{{if .GeneratedBy}}// {{.GeneratedBy}}
|
||||||
|
{{end}}package {{.PackageName}}
|
||||||
|
|
||||||
{{if .Imports -}}
|
{{if .Imports -}}
|
||||||
import (
|
import (
|
||||||
|
|||||||
@@ -112,6 +112,46 @@ func TestWriter_WriteTable_MultilineDescriptionProducesValidGo(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestWriter_WriteTable_ColumnOrderFollowsSequence(t *testing.T) {
|
||||||
|
// Column.Sequence carries the source (e.g. DBML) declaration order; the
|
||||||
|
// generated struct fields must follow it, not fall back to alphabetical.
|
||||||
|
table := models.InitTable("widget", "public")
|
||||||
|
table.Columns["zeta"] = &models.Column{Name: "zeta", Type: "varchar", Length: 50, Sequence: 1}
|
||||||
|
table.Columns["alpha"] = &models.Column{Name: "alpha", Type: "bigint", NotNull: true, IsPrimaryKey: true, AutoIncrement: true, Sequence: 2}
|
||||||
|
table.Columns["mid_field"] = &models.Column{Name: "mid_field", Type: "integer", Sequence: 3}
|
||||||
|
table.Columns["beta"] = &models.Column{Name: "beta", Type: "varchar", Length: 100, Sequence: 4}
|
||||||
|
|
||||||
|
outputPath := filepath.Join(t.TempDir(), "widget.go")
|
||||||
|
writer := NewWriter(&writers.WriterOptions{OutputPath: outputPath, PackageName: "models"})
|
||||||
|
if err := writer.WriteTable(table); err != nil {
|
||||||
|
t.Fatalf("WriteTable() error = %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
generated, err := os.ReadFile(outputPath)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("failed to read generated code: %v", err)
|
||||||
|
}
|
||||||
|
src := string(generated)
|
||||||
|
if _, err := parser.ParseFile(token.NewFileSet(), outputPath, generated, parser.AllErrors); err != nil {
|
||||||
|
t.Fatalf("generated code is invalid Go: %v\n%s", err, src)
|
||||||
|
}
|
||||||
|
|
||||||
|
positions := make([]int, 0, 4)
|
||||||
|
for _, field := range []string{"Zeta ", "Alpha ", "MidField ", "Beta "} {
|
||||||
|
idx := strings.Index(src, "\t"+field)
|
||||||
|
if idx < 0 {
|
||||||
|
t.Fatalf("field %q missing from generated struct:\n%s", field, src)
|
||||||
|
}
|
||||||
|
positions = append(positions, idx)
|
||||||
|
}
|
||||||
|
for i := 1; i < len(positions); i++ {
|
||||||
|
if positions[i] <= positions[i-1] {
|
||||||
|
t.Errorf("struct fields not in Sequence order (want zeta, alpha, mid_field, beta):\n%s", src)
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestWriter_WriteDatabase_MultiFile(t *testing.T) {
|
func TestWriter_WriteDatabase_MultiFile(t *testing.T) {
|
||||||
// Create a database with two tables
|
// Create a database with two tables
|
||||||
db := models.InitDatabase("testdb")
|
db := models.InitDatabase("testdb")
|
||||||
|
|||||||
@@ -11,6 +11,7 @@ import (
|
|||||||
|
|
||||||
_ "github.com/microsoft/go-mssqldb" // MSSQL driver
|
_ "github.com/microsoft/go-mssqldb" // MSSQL driver
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/mssql"
|
"git.warky.dev/wdevs/relspecgo/pkg/mssql"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
||||||
@@ -68,7 +69,7 @@ func (w *Writer) WriteDatabase(db *models.Database) error {
|
|||||||
// Write header comment
|
// Write header comment
|
||||||
fmt.Fprintf(w.writer, "-- MSSQL Database Schema\n")
|
fmt.Fprintf(w.writer, "-- MSSQL Database Schema\n")
|
||||||
fmt.Fprintf(w.writer, "-- Database: %s\n", db.Name)
|
fmt.Fprintf(w.writer, "-- Database: %s\n", db.Name)
|
||||||
fmt.Fprintf(w.writer, "-- Generated by RelSpec\n\n")
|
fmt.Fprintf(w.writer, "-- Generated by %s\n\n", buildinfo.GeneratedComment())
|
||||||
|
|
||||||
// Process each schema in the database
|
// Process each schema in the database
|
||||||
for _, schema := range db.Schemas {
|
for _, schema := range db.Schemas {
|
||||||
@@ -477,7 +478,7 @@ func (w *Writer) executeDatabaseSQL(db *models.Database, connString string) erro
|
|||||||
statements := []string{}
|
statements := []string{}
|
||||||
statements = append(statements, "-- MSSQL Database Schema")
|
statements = append(statements, "-- MSSQL Database Schema")
|
||||||
statements = append(statements, fmt.Sprintf("-- Database: %s", db.Name))
|
statements = append(statements, fmt.Sprintf("-- Database: %s", db.Name))
|
||||||
statements = append(statements, "-- Generated by RelSpec")
|
statements = append(statements, "-- Generated by "+buildinfo.GeneratedComment())
|
||||||
|
|
||||||
for _, schema := range db.Schemas {
|
for _, schema := range db.Schemas {
|
||||||
if err := w.generateSchemaStatements(schema, &statements); err != nil {
|
if err := w.generateSchemaStatements(schema, &statements); err != nil {
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ import (
|
|||||||
"sort"
|
"sort"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/pgsql"
|
"git.warky.dev/wdevs/relspecgo/pkg/pgsql"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
||||||
@@ -143,7 +144,7 @@ func (w *MigrationWriter) WriteMigration(model, current *models.Database) error
|
|||||||
|
|
||||||
// Write header
|
// Write header
|
||||||
fmt.Fprintf(w.writer, "-- PostgreSQL Migration Script\n")
|
fmt.Fprintf(w.writer, "-- PostgreSQL Migration Script\n")
|
||||||
fmt.Fprintf(w.writer, "-- Generated by RelSpec\n")
|
fmt.Fprintf(w.writer, "-- Generated by %s\n", buildinfo.GeneratedComment())
|
||||||
fmt.Fprintf(w.writer, "-- Source: %s -> %s\n", current.Name, model.Name)
|
fmt.Fprintf(w.writer, "-- Source: %s -> %s\n", current.Name, model.Name)
|
||||||
if w.options.ContinueOnError {
|
if w.options.ContinueOnError {
|
||||||
fmt.Fprintf(w.writer, "\\set ON_ERROR_STOP off\n")
|
fmt.Fprintf(w.writer, "\\set ON_ERROR_STOP off\n")
|
||||||
@@ -432,6 +433,16 @@ func (w *MigrationWriter) generateAlterTableScripts(schema *models.Schema, model
|
|||||||
Body: sql,
|
Body: sql,
|
||||||
}
|
}
|
||||||
scripts = append(scripts, script)
|
scripts = append(scripts, script)
|
||||||
|
} else if currentCol.Generated || currentCol.Identity {
|
||||||
|
// GENERATED ALWAYS ... STORED columns and GENERATED ... AS IDENTITY
|
||||||
|
// columns are both driven by Postgres-side machinery (an expression, or
|
||||||
|
// a backing sequence + attidentity flag) that DBML cannot express, so
|
||||||
|
// the model side always looks like drift (missing type modifiers, no
|
||||||
|
// default, NOT NULL mismatches, etc). None of their properties are
|
||||||
|
// alterable the normal way (e.g. dropping a generated column's default
|
||||||
|
// requires DROP EXPRESSION, not DROP DEFAULT; identity columns have no
|
||||||
|
// default to alter at all), so these DB-side-only columns are left
|
||||||
|
// untouched rather than diffed.
|
||||||
} else if !columnsEqual(modelCol, currentCol) {
|
} else if !columnsEqual(modelCol, currentCol) {
|
||||||
// Column exists but properties changed
|
// Column exists but properties changed
|
||||||
if !columnTypesEqual(modelCol, currentCol) {
|
if !columnTypesEqual(modelCol, currentCol) {
|
||||||
|
|||||||
@@ -219,6 +219,91 @@ func TestWriteMigration_AltersColumnNullabilityWhenNotNullDiffers(t *testing.T)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestWriteMigration_DoesNotDropDefaultOnGeneratedColumn(t *testing.T) {
|
||||||
|
current := models.InitDatabase("testdb")
|
||||||
|
currentSchema := models.InitSchema("public")
|
||||||
|
currentTable := models.InitTable("info_city", "public")
|
||||||
|
currentGeom := models.InitColumn("geom", "info_city", "public")
|
||||||
|
currentGeom.Type = "text"
|
||||||
|
currentGeom.Generated = true
|
||||||
|
currentGeom.GenerationExpression = "st_makepoint(lon, lat)"
|
||||||
|
currentTable.Columns["geom"] = currentGeom
|
||||||
|
currentSchema.Tables = append(currentSchema.Tables, currentTable)
|
||||||
|
current.Schemas = append(current.Schemas, currentSchema)
|
||||||
|
|
||||||
|
model := models.InitDatabase("testdb")
|
||||||
|
modelSchema := models.InitSchema("public")
|
||||||
|
modelTable := models.InitTable("info_city", "public")
|
||||||
|
modelGeom := models.InitColumn("geom", "info_city", "public")
|
||||||
|
modelGeom.Type = "text"
|
||||||
|
// DBML cannot express GENERATED ALWAYS columns, so the model declares
|
||||||
|
// this as a plain column with no default — it must not be treated as a
|
||||||
|
// default-value drift against the DB-side generated column.
|
||||||
|
modelTable.Columns["geom"] = modelGeom
|
||||||
|
modelSchema.Tables = append(modelSchema.Tables, modelTable)
|
||||||
|
model.Schemas = append(model.Schemas, modelSchema)
|
||||||
|
|
||||||
|
var buf bytes.Buffer
|
||||||
|
writer, err := NewMigrationWriter(&writers.WriterOptions{})
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("Failed to create writer: %v", err)
|
||||||
|
}
|
||||||
|
writer.writer = &buf
|
||||||
|
|
||||||
|
if err := writer.WriteMigration(model, current); err != nil {
|
||||||
|
t.Fatalf("WriteMigration failed: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
output := buf.String()
|
||||||
|
if strings.Contains(output, "DROP DEFAULT") {
|
||||||
|
t.Fatalf("did not expect DROP DEFAULT against a generated column, got:\n%s", output)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestWriteMigration_DoesNotAlterIdentityColumn(t *testing.T) {
|
||||||
|
current := models.InitDatabase("testdb")
|
||||||
|
currentSchema := models.InitSchema("public")
|
||||||
|
currentTable := models.InitTable("users", "public")
|
||||||
|
currentID := models.InitColumn("id", "users", "public")
|
||||||
|
currentID.Type = "bigint"
|
||||||
|
currentID.NotNull = true
|
||||||
|
currentID.Identity = true
|
||||||
|
currentID.IdentityGeneration = "ALWAYS"
|
||||||
|
currentTable.Columns["id"] = currentID
|
||||||
|
currentSchema.Tables = append(currentSchema.Tables, currentTable)
|
||||||
|
current.Schemas = append(current.Schemas, currentSchema)
|
||||||
|
|
||||||
|
model := models.InitDatabase("testdb")
|
||||||
|
modelSchema := models.InitSchema("public")
|
||||||
|
modelTable := models.InitTable("users", "public")
|
||||||
|
modelID := models.InitColumn("id", "users", "public")
|
||||||
|
modelID.Type = "bigint"
|
||||||
|
// DBML cannot express GENERATED ... AS IDENTITY, so the model declares this
|
||||||
|
// as a plain nullable column — it must not be diffed as NOT NULL drift
|
||||||
|
// against the DB-side identity column (Postgres rejects DROP NOT NULL on
|
||||||
|
// an identity column).
|
||||||
|
modelID.NotNull = false
|
||||||
|
modelTable.Columns["id"] = modelID
|
||||||
|
modelSchema.Tables = append(modelSchema.Tables, modelTable)
|
||||||
|
model.Schemas = append(model.Schemas, modelSchema)
|
||||||
|
|
||||||
|
var buf bytes.Buffer
|
||||||
|
writer, err := NewMigrationWriter(&writers.WriterOptions{})
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("Failed to create writer: %v", err)
|
||||||
|
}
|
||||||
|
writer.writer = &buf
|
||||||
|
|
||||||
|
if err := writer.WriteMigration(model, current); err != nil {
|
||||||
|
t.Fatalf("WriteMigration failed: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
output := buf.String()
|
||||||
|
if strings.Contains(output, "DROP NOT NULL") {
|
||||||
|
t.Fatalf("did not expect DROP NOT NULL against an identity column, got:\n%s", output)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestWriteMigration_UsesStorageTypeForSerialAlterStatements(t *testing.T) {
|
func TestWriteMigration_UsesStorageTypeForSerialAlterStatements(t *testing.T) {
|
||||||
current := models.InitDatabase("testdb")
|
current := models.InitDatabase("testdb")
|
||||||
currentSchema := models.InitSchema("public")
|
currentSchema := models.InitSchema("public")
|
||||||
|
|||||||
+34
-16
@@ -12,6 +12,7 @@ import (
|
|||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/pgsql"
|
"git.warky.dev/wdevs/relspecgo/pkg/pgsql"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
||||||
@@ -101,7 +102,7 @@ func (w *Writer) WriteDatabase(db *models.Database) error {
|
|||||||
// Write header comment
|
// Write header comment
|
||||||
fmt.Fprintf(w.writer, "-- PostgreSQL Database Schema\n")
|
fmt.Fprintf(w.writer, "-- PostgreSQL Database Schema\n")
|
||||||
fmt.Fprintf(w.writer, "-- Database: %s\n", db.Name)
|
fmt.Fprintf(w.writer, "-- Database: %s\n", db.Name)
|
||||||
fmt.Fprintf(w.writer, "-- Generated by RelSpec\n")
|
fmt.Fprintf(w.writer, "-- Generated by %s\n", buildinfo.GeneratedComment())
|
||||||
if w.options.ContinueOnError {
|
if w.options.ContinueOnError {
|
||||||
fmt.Fprintf(w.writer, "\\set ON_ERROR_STOP off\n")
|
fmt.Fprintf(w.writer, "\\set ON_ERROR_STOP off\n")
|
||||||
}
|
}
|
||||||
@@ -125,7 +126,7 @@ func (w *Writer) GenerateDatabaseStatements(db *models.Database) ([]string, erro
|
|||||||
// Add header comment
|
// Add header comment
|
||||||
statements = append(statements, "-- PostgreSQL Database Schema")
|
statements = append(statements, "-- PostgreSQL Database Schema")
|
||||||
statements = append(statements, fmt.Sprintf("-- Database: %s", db.Name))
|
statements = append(statements, fmt.Sprintf("-- Database: %s", db.Name))
|
||||||
statements = append(statements, "-- Generated by RelSpec")
|
statements = append(statements, "-- Generated by "+buildinfo.GeneratedComment())
|
||||||
|
|
||||||
// Process each schema in the database
|
// Process each schema in the database
|
||||||
for _, schema := range db.Schemas {
|
for _, schema := range db.Schemas {
|
||||||
@@ -461,6 +462,12 @@ func (w *Writer) GenerateAlterColumnTypeStatements(schema *models.Schema) ([]str
|
|||||||
for _, table := range schema.Tables {
|
for _, table := range schema.Tables {
|
||||||
columns := getSortedColumns(table.Columns)
|
columns := getSortedColumns(table.Columns)
|
||||||
for _, col := range columns {
|
for _, col := range columns {
|
||||||
|
if col.Generated || col.Identity {
|
||||||
|
// Type is derived from the generation expression (generated columns) or
|
||||||
|
// tied to the backing sequence (identity columns); leave both alone here
|
||||||
|
// rather than risk an ALTER COLUMN TYPE Postgres won't accept cleanly.
|
||||||
|
continue
|
||||||
|
}
|
||||||
targetType := effectiveAlterColumnSQLType(col)
|
targetType := effectiveAlterColumnSQLType(col)
|
||||||
stmt, err := w.executor.ExecuteAlterColumnTypeWithCheck(AlterColumnTypeWithCheckData{
|
stmt, err := w.executor.ExecuteAlterColumnTypeWithCheck(AlterColumnTypeWithCheckData{
|
||||||
SchemaName: schema.Name,
|
SchemaName: schema.Name,
|
||||||
@@ -491,6 +498,14 @@ func (w *Writer) GenerateAlterColumnDefaultStatements(schema *models.Schema) ([]
|
|||||||
for _, table := range schema.Tables {
|
for _, table := range schema.Tables {
|
||||||
columns := getSortedColumns(table.Columns)
|
columns := getSortedColumns(table.Columns)
|
||||||
for _, col := range columns {
|
for _, col := range columns {
|
||||||
|
if col.Generated || col.Identity {
|
||||||
|
// Generated columns: Postgres stores the generation expression in
|
||||||
|
// pg_attrdef just like a real default, so the guard template would see
|
||||||
|
// it as a stray default and emit DROP DEFAULT, which Postgres rejects.
|
||||||
|
// Identity columns never carry a DEFAULT at all (they're driven by a
|
||||||
|
// backing sequence), so there is nothing for this generator to manage.
|
||||||
|
continue
|
||||||
|
}
|
||||||
setDefault, defaultVal := formatColumnDefaultSQL(col)
|
setDefault, defaultVal := formatColumnDefaultSQL(col)
|
||||||
stmt, err := w.executor.ExecuteAlterColumnDefaultWithCheck(AlterColumnDefaultWithCheckData{
|
stmt, err := w.executor.ExecuteAlterColumnDefaultWithCheck(AlterColumnDefaultWithCheckData{
|
||||||
SchemaName: schema.Name,
|
SchemaName: schema.Name,
|
||||||
@@ -555,7 +570,7 @@ func (w *Writer) GenerateAddColumnsForDatabase(db *models.Database) ([]string, e
|
|||||||
|
|
||||||
statements = append(statements, "-- Add missing columns to existing tables")
|
statements = append(statements, "-- Add missing columns to existing tables")
|
||||||
statements = append(statements, fmt.Sprintf("-- Database: %s", db.Name))
|
statements = append(statements, fmt.Sprintf("-- Database: %s", db.Name))
|
||||||
statements = append(statements, "-- Generated by RelSpec")
|
statements = append(statements, "-- Generated by "+buildinfo.GeneratedComment())
|
||||||
|
|
||||||
for _, schema := range db.Schemas {
|
for _, schema := range db.Schemas {
|
||||||
schemaStatements, err := w.GenerateAddColumnStatements(schema)
|
schemaStatements, err := w.GenerateAddColumnStatements(schema)
|
||||||
@@ -604,13 +619,25 @@ func (w *Writer) generateColumnDefinition(col *models.Column) string {
|
|||||||
|
|
||||||
parts = append(parts, effectiveColumnSQLType(col))
|
parts = append(parts, effectiveColumnSQLType(col))
|
||||||
|
|
||||||
|
// GENERATED ALWAYS ... STORED columns are computed from an expression and
|
||||||
|
// cannot also carry a DEFAULT, so this takes the place of the DEFAULT clause.
|
||||||
|
if col.Generated && col.GenerationExpression != "" {
|
||||||
|
parts = append(parts, fmt.Sprintf("GENERATED ALWAYS AS (%s) STORED", col.GenerationExpression))
|
||||||
|
}
|
||||||
|
|
||||||
|
// GENERATED { ALWAYS | BY DEFAULT } AS IDENTITY columns are driven by an
|
||||||
|
// internal sequence, not a literal DEFAULT, and cannot carry one either.
|
||||||
|
if col.Identity && col.IdentityGeneration != "" {
|
||||||
|
parts = append(parts, fmt.Sprintf("GENERATED %s AS IDENTITY", col.IdentityGeneration))
|
||||||
|
}
|
||||||
|
|
||||||
// NOT NULL
|
// NOT NULL
|
||||||
if col.NotNull {
|
if col.NotNull {
|
||||||
parts = append(parts, "NOT NULL")
|
parts = append(parts, "NOT NULL")
|
||||||
}
|
}
|
||||||
|
|
||||||
// DEFAULT
|
// DEFAULT
|
||||||
if col.Default != nil {
|
if !col.Generated && !col.Identity && col.Default != nil {
|
||||||
switch v := col.Default.(type) {
|
switch v := col.Default.(type) {
|
||||||
case string:
|
case string:
|
||||||
parts = append(parts, fmt.Sprintf("DEFAULT %s", writers.QuoteDefaultValue(stripBackticks(v), col.Type)))
|
parts = append(parts, fmt.Sprintf("DEFAULT %s", writers.QuoteDefaultValue(stripBackticks(v), col.Type)))
|
||||||
@@ -1446,19 +1473,10 @@ func (w *Writer) writeComments(schema *models.Schema) error {
|
|||||||
|
|
||||||
// Helper functions
|
// Helper functions
|
||||||
|
|
||||||
// getSortedColumns returns columns sorted by name
|
// getSortedColumns returns columns sorted by Sequence then Name, preserving the
|
||||||
|
// original column order from the source schema for deterministic output.
|
||||||
func getSortedColumns(columns map[string]*models.Column) []*models.Column {
|
func getSortedColumns(columns map[string]*models.Column) []*models.Column {
|
||||||
names := make([]string, 0, len(columns))
|
return sortColumns(columns)
|
||||||
for name := range columns {
|
|
||||||
names = append(names, name)
|
|
||||||
}
|
|
||||||
sort.Strings(names)
|
|
||||||
|
|
||||||
sorted := make([]*models.Column, 0, len(columns))
|
|
||||||
for _, name := range names {
|
|
||||||
sorted = append(sorted, columns[name])
|
|
||||||
}
|
|
||||||
return sorted
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// isIntegerType checks if a column type is an integer type
|
// isIntegerType checks if a column type is an integer type
|
||||||
|
|||||||
@@ -1510,3 +1510,42 @@ func TestIndexStorageParameters(t *testing.T) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestGenerateColumnDefinition_GeneratedColumnEmitsGeneratedClauseNotDefault(t *testing.T) {
|
||||||
|
w := &Writer{}
|
||||||
|
|
||||||
|
col := models.InitColumn("geom", "info_city", "public")
|
||||||
|
col.Type = "text"
|
||||||
|
col.NotNull = true
|
||||||
|
col.Generated = true
|
||||||
|
col.GenerationExpression = "st_makepoint(lon, lat)"
|
||||||
|
// A generated column's introspected "default" is actually its generation
|
||||||
|
// expression surfaced via pg_attrdef; it must never be rendered as DEFAULT.
|
||||||
|
col.Default = "st_makepoint(lon, lat)"
|
||||||
|
|
||||||
|
got := w.generateColumnDefinition(col)
|
||||||
|
|
||||||
|
want := "geom text GENERATED ALWAYS AS (st_makepoint(lon, lat)) STORED NOT NULL"
|
||||||
|
if got != want {
|
||||||
|
t.Fatalf("generateColumnDefinition() = %q, want %q", got, want)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestGenerateColumnDefinition_IdentityColumnEmitsIdentityClauseNotDefault(t *testing.T) {
|
||||||
|
w := &Writer{}
|
||||||
|
|
||||||
|
col := models.InitColumn("id", "users", "public")
|
||||||
|
col.Type = "bigint"
|
||||||
|
col.NotNull = true
|
||||||
|
col.Identity = true
|
||||||
|
col.IdentityGeneration = "ALWAYS"
|
||||||
|
// Identity columns never carry a literal default; this must never surface.
|
||||||
|
col.Default = "some-stray-value"
|
||||||
|
|
||||||
|
got := w.generateColumnDefinition(col)
|
||||||
|
|
||||||
|
want := "id bigint GENERATED ALWAYS AS IDENTITY NOT NULL"
|
||||||
|
if got != want {
|
||||||
|
t.Fatalf("generateColumnDefinition() = %q, want %q", got, want)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -10,6 +10,7 @@ import (
|
|||||||
|
|
||||||
_ "modernc.org/sqlite" // SQLite driver
|
_ "modernc.org/sqlite" // SQLite driver
|
||||||
|
|
||||||
|
"git.warky.dev/wdevs/relspecgo/pkg/buildinfo"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
"git.warky.dev/wdevs/relspecgo/pkg/models"
|
||||||
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
"git.warky.dev/wdevs/relspecgo/pkg/writers"
|
||||||
)
|
)
|
||||||
@@ -72,7 +73,7 @@ func (w *Writer) writeContent(db *models.Database) error {
|
|||||||
// Write header comment
|
// Write header comment
|
||||||
fmt.Fprintf(w.writer, "-- SQLite Database Schema\n")
|
fmt.Fprintf(w.writer, "-- SQLite Database Schema\n")
|
||||||
fmt.Fprintf(w.writer, "-- Database: %s\n", db.Name)
|
fmt.Fprintf(w.writer, "-- Database: %s\n", db.Name)
|
||||||
fmt.Fprintf(w.writer, "-- Generated by RelSpec\n")
|
fmt.Fprintf(w.writer, "-- Generated by %s\n", buildinfo.GeneratedComment())
|
||||||
fmt.Fprintf(w.writer, "-- Note: SQLite has no schema concept; non-default schema names are flattened into table name prefixes (e.g., auth.sessions -> auth_sessions)\n\n")
|
fmt.Fprintf(w.writer, "-- Note: SQLite has no schema concept; non-default schema names are flattened into table name prefixes (e.g., auth.sessions -> auth_sessions)\n\n")
|
||||||
|
|
||||||
// Enable foreign keys
|
// Enable foreign keys
|
||||||
|
|||||||
Reference in New Issue
Block a user