refactor(db,javadb): add schema versions as tag only if repo doesn't …

…contain tag

pkg/db/db.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"strings"
 	"time"
 
 	"github.com/google/go-containerregistry/pkg/v1/remote/transport"
@@ -78,7 +79,10 @@ func NewClient(cacheDir string, quiet bool, opts ...Option) *Client {
 		opt(o)
 	}
 
-	o.dbRepository = fmt.Sprintf("%s:%d", o.dbRepository, db.SchemaVersion)
+	// Add the schema version as a tag if the tag doesn't exist.
+	if !strings.Contains(o.dbRepository, ":") {
+		o.dbRepository = fmt.Sprintf("%s:%d", o.dbRepository, db.SchemaVersion)
+	}
 
 	return &Client{
 		options:  o,

pkg/javadb/client.go

@@ -7,6 +7,7 @@ import (
 	"os"
 	"path/filepath"
 	"sort"
+	"strings"
 	"sync"
 	"time"
 
@@ -82,8 +83,12 @@ func (u *Updater) Update() error {
 }
 
 func Init(cacheDir, javaDBRepository string, skip, quiet bool, registryOption ftypes.RegistryOptions) {
+	// Add the schema version as a tag if the tag doesn't exist.
+	if !strings.Contains(javaDBRepository, ":") {
+		javaDBRepository = fmt.Sprintf("%s:%d", javaDBRepository, db.SchemaVersion)
+	}
 	updater = &Updater{
-		repo:           fmt.Sprintf("%s:%d", javaDBRepository, db.SchemaVersion),
+		repo:           javaDBRepository,
 		dbDir:          filepath.Join(cacheDir, "java-db"),
 		skip:           skip,
 		quiet:          quiet,