refactor: sqlite remove cgo dependencies

Author: lianxmfor

internal/database/dbutil/database.go

@@ -7,15 +7,16 @@ import (
 	"github.com/jackc/pgerrcode"
 	"github.com/jmoiron/sqlx"
 	"github.com/lib/pq"
-	"github.com/mattn/go-sqlite3"
 	"github.com/oom-ai/oomstore/pkg/oomstore/types"
 	"github.com/pkg/errors"
 	"github.com/snowflakedb/gosnowflake"
 	"google.golang.org/api/googleapi"
+	"modernc.org/sqlite"
+	sqlite3 "modernc.org/sqlite/lib"
 )
 
 func OpenSQLite(dbFile string) (*sqlx.DB, error) {
-	db, err := sqlx.Open("sqlite3", dbFile)
+	db, err := sqlx.Open("sqlite", dbFile)
 	return db, errors.WithStack(err)
 }
 
@@ -59,10 +60,9 @@ func DeserializeString(i interface{}, backend types.BackendType) string {
 func IsTableNotFoundError(err error, backend types.BackendType) bool {
 	err = errors.Cause(err)
 	switch backend {
-	// https://github.com/mattn/go-sqlite3/issues/244
 	case types.BackendSQLite:
-		if sqliteErr, ok := err.(sqlite3.Error); ok {
-			return sqliteErr.Code == sqlite3.ErrError
+		if sqliteErr, ok := err.(*sqlite.Error); ok {
+			return sqliteErr.Code() == sqlite3.SQLITE_CORE
 		}
 
 	// https://dev.mysql.com/doc/mysql-errors/5.7/en/server-error-reference.html#error_er_no_such_table

internal/database/metadata/sqlite/entity.go

@@ -3,8 +3,9 @@ package sqlite
 import (
 	"context"
 
-	"github.com/mattn/go-sqlite3"
 	"github.com/pkg/errors"
+	"modernc.org/sqlite"
+	sqlite3 "modernc.org/sqlite/lib"
 
 	"github.com/oom-ai/oomstore/internal/database/metadata"
 )
@@ -13,11 +14,12 @@ func createEntity(ctx context.Context, sqlxCtx metadata.SqlxContext, opt metadat
 	query := "INSERT INTO entity(name, description) VALUES(?, ?)"
 	res, err := sqlxCtx.ExecContext(ctx, query, opt.EntityName, opt.Description)
 	if err != nil {
-		if er, ok := err.(sqlite3.Error); ok {
-			if er.ExtendedCode == sqlite3.ErrConstraintUnique {
+		if er, ok := err.(*sqlite.Error); ok {
+			if er.Code() == sqlite3.SQLITE_CONSTRAINT_UNIQUE {
 				return 0, errors.Errorf("entity %s already exists", opt.EntityName)
 			}
 		}
+
 		return 0, err
 	}
 

internal/database/metadata/sqlite/feature.go

@@ -3,8 +3,9 @@ package sqlite
 import (
 	"context"
 
-	"github.com/mattn/go-sqlite3"
 	"github.com/pkg/errors"
+	"modernc.org/sqlite"
+	sqlite3 "modernc.org/sqlite/lib"
 
 	"github.com/oom-ai/oomstore/internal/database/metadata"
 )
@@ -16,8 +17,8 @@ func createFeature(ctx context.Context, sqlxCtx metadata.SqlxContext, opt metada
 	query := "INSERT INTO feature(name, full_name, group_id, value_type, description) VALUES (?, ?, ?, ?, ?)"
 	res, err := sqlxCtx.ExecContext(ctx, sqlxCtx.Rebind(query), opt.FeatureName, opt.FullName, opt.GroupID, opt.ValueType, opt.Description)
 	if err != nil {
-		if sqliteErr, ok := err.(sqlite3.Error); ok {
-			if sqliteErr.ExtendedCode == sqlite3.ErrConstraintUnique {
+		if sqliteErr, ok := err.(*sqlite.Error); ok {
+			if sqliteErr.Code() == sqlite3.SQLITE_CONSTRAINT_UNIQUE {
 				return 0, errors.Errorf("feature %s already exists", opt.FeatureName)
 			}
 		}

internal/database/metadata/sqlite/group.go

@@ -4,8 +4,9 @@ import (
 	"context"
 
 	"github.com/pkg/errors"
+	"modernc.org/sqlite"
+	sqlite3 "modernc.org/sqlite/lib"
 
-	"github.com/mattn/go-sqlite3"
 	"github.com/oom-ai/oomstore/internal/database/metadata"
 	"github.com/oom-ai/oomstore/pkg/errdefs"
 	"github.com/oom-ai/oomstore/pkg/oomstore/types"
@@ -19,8 +20,8 @@ func createGroup(ctx context.Context, sqlxCtx metadata.SqlxContext, opt metadata
 	query := "INSERT INTO feature_group(name, entity_id, category, description) VALUES(?, ?, ?, ?)"
 	res, err := sqlxCtx.ExecContext(ctx, query, opt.GroupName, opt.EntityID, opt.Category, opt.Description)
 	if err != nil {
-		if sqliteErr, ok := err.(sqlite3.Error); ok {
-			if sqliteErr.ExtendedCode == sqlite3.ErrConstraintUnique {
+		if sqliteErr, ok := err.(*sqlite.Error); ok {
+			if sqliteErr.Code() == sqlite3.SQLITE_CONSTRAINT_UNIQUE {
 				return 0, errors.Errorf("feature group %s already exists", opt.GroupName)
 			}
 		}

internal/database/metadata/sqlite/revision.go

@@ -3,10 +3,12 @@ package sqlite
 import (
 	"context"
 
-	"github.com/mattn/go-sqlite3"
+	"github.com/pkg/errors"
+	"modernc.org/sqlite"
+	sqlite3 "modernc.org/sqlite/lib"
+
 	"github.com/oom-ai/oomstore/internal/database/dbutil"
 	"github.com/oom-ai/oomstore/internal/database/metadata"
-	"github.com/pkg/errors"
 )
 
 func createRevision(ctx context.Context, sqlxCtx metadata.SqlxContext, opt metadata.CreateRevisionOpt) (int, string, error) {
@@ -21,8 +23,8 @@ func createRevision(ctx context.Context, sqlxCtx metadata.SqlxContext, opt metad
 	insertQuery := "INSERT INTO feature_group_revision(group_id, revision, snapshot_table, cdc_table, anchored, description) VALUES (?, ?, ?, ?, ?, ?)"
 	res, err := sqlxCtx.ExecContext(ctx, sqlxCtx.Rebind(insertQuery), opt.GroupID, opt.Revision, snapshotTable, cdcTable, opt.Anchored, opt.Description)
 	if err != nil {
-		if sqliteErr, ok := err.(sqlite3.Error); ok {
-			if sqliteErr.ExtendedCode == sqlite3.ErrConstraintUnique {
+		if sqliteErr, ok := err.(*sqlite.Error); ok {
+			if sqliteErr.Code() == sqlite3.SQLITE_CONSTRAINT_UNIQUE {
 				return 0, "", errors.Errorf("revision already exists: groupID=%d, revision=%d", opt.GroupID, opt.Revision)
 			}
 		}