Compare commits

7 Commits

Author SHA1 Message Date
fe00943b01 Merge pull request 'adding in file path option' (#2) from new/file-path into main
Reviewed-on: #2
2025-09-08 21:05:09 +00:00
20f6e45150 moving to errors 2025-09-08 17:04:22 -04:00
a2cb04fd09 adding in file path option 2025-09-07 01:29:18 -04:00
006af98328 removing forced paths 2025-08-28 21:11:59 -04:00
8c317fc3b6 Merge pull request 'updating methods' (#1) from fix/connect-methodology into main
Reviewed-on: #1
2025-07-15 23:01:10 +00:00
efc047c965 updating methods
- removing connect method
- db is connected to on call to New
2025-07-15 19:00:33 -04:00
5e9ba524e9 adding better error handling around connections 2025-07-15 18:22:46 -04:00
2 changed files with 24 additions and 21 deletions

View File

@@ -1,15 +1,26 @@
package lite
type Option func(d *database)
import "errors"
var (
ErrBadFilename error = errors.New("database filename cannot be empty")
)
type Option func(d *database) error
func WithFile(name string) Option {
return func(d *database) {
return func(d *database) error {
if name == "" {
return ErrBadFilename
}
d.file = name
return nil
}
}
func WithPath(path string) Option {
return func(d *database) {
return func(d *database) error {
d.path = path
return nil
}
}

View File

@@ -4,7 +4,7 @@ import (
"context"
"database/sql"
"fmt"
"os"
"path"
"github.com/jmoiron/sqlx"
_ "github.com/ncruces/go-sqlite3/driver"
@@ -18,7 +18,6 @@ type database struct {
}
type Database interface {
Connect() error
Close() error
Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
Query(ctx context.Context, query string, args ...any) (*sqlx.Rows, error)
@@ -27,35 +26,28 @@ type Database interface {
}
func New(opts ...Option) (Database, error) {
home, err := os.UserHomeDir()
if err != nil {
return nil, err
}
defaultFile := "lite-db"
db := &database{
file: defaultFile,
path: home,
}
for _, opt := range opts {
opt(db)
}
return db, nil
filePath := db.file
if db.path != "" {
filePath = path.Join(db.path, db.file)
}
// connects to database file
func (d *database) Connect() error {
db, err := sqlx.Open("sqlite3", fmt.Sprintf("file:%s/%s", d.path, d.file))
slite, err := sqlx.Open("sqlite3", fmt.Sprintf("file:%s", filePath))
if err != nil {
return err
return nil, err
}
db.sqlite = slite
d.sqlite = db
return nil
return db, nil
}
// closes database file connection