Move gdbc package from codnect.io/procyon to codnect.io/procyon-data

Author: burakkoken

gdbc/connection.go

@@ -0,0 +1,131 @@
+package gdbc
+
+import (
+	"codnect.io/procyon-data/sql"
+	"context"
+	dsql "database/sql"
+	"database/sql/driver"
+	"errors"
+	"time"
+)
+
+var (
+	ErrConnectionDoesNotExist = errors.New("this connection has been closed")
+)
+
+type Connection struct {
+	db     *dsql.DB
+	closed bool
+}
+
+func (c *Connection) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error) {
+	if c.closed {
+		return nil, ErrConnectionDoesNotExist
+	}
+
+	return c.db.ExecContext(ctx, query, args...)
+}
+
+func (c *Connection) PrepareContext(ctx context.Context, query string, args ...any) (sql.Statement, error) {
+	if c.closed {
+		return nil, ErrConnectionDoesNotExist
+	}
+
+	statement, err := c.db.PrepareContext(ctx, query)
+	if err != nil {
+		return nil, err
+	}
+
+	preparedStatement := sql.NewPreparedStatement(statement)
+	return preparedStatement, nil
+}
+
+func (c *Connection) QueryContext(ctx context.Context, query string, args ...any) (sql.RowSet, error) {
+	if c.closed {
+		return nil, ErrConnectionDoesNotExist
+	}
+
+	return c.db.QueryContext(ctx, query, args...)
+}
+
+func (c *Connection) QueryRowContext(ctx context.Context, query string, args ...any) (sql.Row, error) {
+	if c.closed {
+		return nil, ErrConnectionDoesNotExist
+	}
+
+	return c.db.QueryRowContext(ctx, query, args...), nil
+}
+
+func (c *Connection) PingContext(ctx context.Context) error {
+	if c.closed {
+		return ErrConnectionDoesNotExist
+	}
+
+	return c.db.PingContext(ctx)
+}
+
+func (c *Connection) SetConnMaxLifetime(d time.Duration) error {
+	if c.closed {
+		return ErrConnectionDoesNotExist
+	}
+
+	c.db.SetConnMaxLifetime(d)
+	return nil
+}
+
+func (c *Connection) SetConnMaxIdleTime(d time.Duration) error {
+	if c.closed {
+		return ErrConnectionDoesNotExist
+	}
+
+	c.db.SetConnMaxIdleTime(d)
+	return nil
+}
+
+func (c *Connection) SetMaxIdleConns(n int) error {
+	if c.closed {
+		return ErrConnectionDoesNotExist
+	}
+
+	c.db.SetMaxIdleConns(n)
+	return nil
+}
+
+func (c *Connection) SetMaxOpenConns(n int) error {
+	if c.closed {
+		return ErrConnectionDoesNotExist
+	}
+
+	c.db.SetMaxOpenConns(n)
+	return nil
+}
+
+func (c *Connection) BeginTransaction(ctx context.Context) (sql.TransactionStatus, error) {
+	if c.closed {
+		return nil, ErrConnectionDoesNotExist
+	}
+
+	return nil, nil
+}
+
+func (c *Connection) Driver() driver.Driver {
+	return c.db.Driver()
+}
+
+func (c *Connection) Close() error {
+	if c.closed {
+		return ErrConnectionDoesNotExist
+	}
+
+	err := c.db.Close()
+	if err != nil {
+		return err
+	}
+
+	c.closed = true
+	return nil
+}
+
+func (c *Connection) IsClosed() bool {
+	return c.closed
+}

gdbc/datasource.go

@@ -0,0 +1,69 @@
+package gdbc
+
+import (
+	"codnect.io/procyon-data/sql"
+	dsql "database/sql"
+	"errors"
+	"strings"
+)
+
+type DataSource struct {
+	props DataSourceProperties
+}
+
+type DataSourceProperties struct {
+	Url      string
+	Username string
+	Password string
+}
+
+func NewDataSource(props DataSourceProperties) *DataSource {
+	return &DataSource{
+		props: props,
+	}
+}
+
+func (ds *DataSource) GetConnection() (sql.Connection, error) {
+	var (
+		db            *dsql.DB
+		driverName    string
+		connectionUrl string
+		err           error
+	)
+
+	driverName, connectionUrl, err = ds.parseDataSourceUrl()
+	if err != nil {
+		return nil, err
+	}
+
+	db, err = dsql.Open(driverName, connectionUrl)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return NewConnection(db), nil
+}
+
+func (ds *DataSource) parseDataSourceUrl() (string, string, error) {
+	if len(ds.props.Url) == 0 {
+		return "", "", errors.New("url must not be empty")
+	}
+
+	src := strings.Split(ds.props.Url, ":")
+	if len(src) < 3 {
+		return "", "", errors.New("url format is wrong : " + ds.props.Url)
+	}
+
+	scheme := src[0]
+	if "gdbc" != scheme {
+		return "", "", errors.New("driver name must not be empty")
+	}
+
+	driverName := src[1]
+	if len(driverName) == 0 {
+		return "", "", errors.New("driver name must not be empty")
+	}
+
+	return driverName, strings.Join(append(src[:1], src[2:]...), ":"), nil
+}

gdbc/gdbc.go

@@ -0,0 +1,13 @@
+package gdbc
+
+import "database/sql"
+
+func NewConnection(db *sql.DB) *Connection {
+	if db == nil {
+		panic("nil db")
+	}
+
+	return &Connection{
+		db: db,
+	}
+}

gdbc/operations.go

@@ -0,0 +1,13 @@
+package gdbc
+
+import (
+	"codnect.io/procyon-data/sql"
+	"context"
+)
+
+type Operations interface {
+	Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
+	Prepare(ctx context.Context, query string) (sql.Statement, error)
+	Query(ctx context.Context, query string, args ...any) (sql.RowSet, error)
+	QueryRow(ctx context.Context, query string, args ...any) sql.Row
+}

gdbc/template.go

@@ -0,0 +1,32 @@
+package gdbc
+
+import (
+	"codnect.io/procyon-data/sql"
+	"context"
+)
+
+type Template struct {
+	dataSource sql.DataSource
+}
+
+func NewTemplate(dataSource sql.DataSource) *Template {
+	return &Template{
+		dataSource: dataSource,
+	}
+}
+
+func (t *Template) Exec(ctx context.Context, query string, args ...any) (sql.Result, error) {
+	return nil, nil
+}
+
+func (t *Template) Prepare(ctx context.Context, query string) (sql.Statement, error) {
+	return nil, nil
+}
+
+func (t *Template) Query(ctx context.Context, query string, args ...any) (sql.RowSet, error) {
+	return nil, nil
+}
+
+func (t *Template) QueryRow(ctx context.Context, query string, args ...any) sql.Row {
+	return nil
+}