refactor: split code into more files

Author: ralvarezdev

sql/config.go

@@ -7,16 +7,6 @@ import (
 )
 
 type (
-	// Config interface
-	Config interface {
-		DriverName() string
-		DataSourceName() string
-		MaxOpenConnections() int
-		MaxIdleConnections() int
-		ConnectionMaxLifetime() time.Duration
-		ConnectionMaxIdleTime() time.Duration
-	}
-
 	// ConnConfig struct
 	ConnConfig struct {
 		driverName            string

sql/interfaces.go

@@ -0,0 +1,28 @@
+package sql
+
+import (
+	"database/sql"
+	"time"
+)
+
+type (
+	// Config interface
+	Config interface {
+		DriverName() string
+		DataSourceName() string
+		MaxOpenConnections() int
+		MaxIdleConnections() int
+		ConnectionMaxLifetime() time.Duration
+		ConnectionMaxIdleTime() time.Duration
+	}
+
+	// Service is the interface for the service
+	Service interface {
+		DB() *sql.DB
+		Migrate(queries ...string) error
+		CreateTransaction(fn TransactionFn) error
+		Exec(query *string, params ...interface{}) (sql.Result, error)
+		QueryRow(query *string, params ...interface{}) *sql.Row
+		ScanRow(row *sql.Row, destinations ...interface{}) error
+	}
+)

sql/pgxpool/interfaces.go

@@ -0,0 +1,54 @@
+package pgxpool
+
+import (
+	"context"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type (
+	// PoolHandler interface
+	PoolHandler interface {
+		Connect() (*pgxpool.Pool, error)
+		Pool() (*pgxpool.Pool, error)
+		Disconnect()
+	}
+
+	// Service is the interface for the service
+	Service interface {
+		Pool() *pgxpool.Pool
+		Migrate(queries ...string) error
+		CreateTransaction(fn TransactionWithCtxFn) error
+		CreateTransactionWithCtx(
+			ctx context.Context,
+			fn TransactionWithCtxFn,
+		) error
+		Exec(query *string, params ...interface{}) (*pgconn.CommandTag, error)
+		ExecWithCtx(
+			ctx context.Context,
+			query *string,
+			params ...interface{},
+		) (*pgconn.CommandTag, error)
+		Query(query *string, params ...interface{}) (pgx.Rows, error)
+		QueryWithCtx(
+			ctx context.Context,
+			query *string,
+			params ...interface{},
+		) (pgx.Rows, error)
+		QueryRow(query *string, params ...interface{}) (pgx.Row, error)
+		QueryRowWithCtx(
+			ctx context.Context,
+			query *string,
+			params ...interface{},
+		) (pgx.Row, error)
+		ScanRow(row pgx.Row, destinations ...interface{}) error
+		SetStatTicker(
+			duration time.Duration,
+			fn func(*pgxpool.Stat),
+		)
+		ClearStatTicker()
+	}
+)

sql/pgxpool/pool.go

@@ -8,13 +8,6 @@ import (
 )
 
 type (
-	// PoolHandler interface
-	PoolHandler interface {
-		Connect() (*pgxpool.Pool, error)
-		Pool() (*pgxpool.Pool, error)
-		Disconnect()
-	}
-
 	// DefaultPoolHandler struct
 	DefaultPoolHandler struct {
 		config Config

sql/pgxpool/service.go

@@ -11,41 +11,6 @@ import (
 )
 
 type (
-	// Service is the interface for the service
-	Service interface {
-		Pool() *pgxpool.Pool
-		Migrate(queries ...string) error
-		CreateTransaction(fn TransactionWithCtxFn) error
-		CreateTransactionWithCtx(
-			ctx context.Context,
-			fn TransactionWithCtxFn,
-		) error
-		Exec(query *string, params ...interface{}) (*pgconn.CommandTag, error)
-		ExecWithCtx(
-			ctx context.Context,
-			query *string,
-			params ...interface{},
-		) (*pgconn.CommandTag, error)
-		Query(query *string, params ...interface{}) (pgx.Rows, error)
-		QueryWithCtx(
-			ctx context.Context,
-			query *string,
-			params ...interface{},
-		) (pgx.Rows, error)
-		QueryRow(query *string, params ...interface{}) (pgx.Row, error)
-		QueryRowWithCtx(
-			ctx context.Context,
-			query *string,
-			params ...interface{},
-		) (pgx.Row, error)
-		ScanRow(row pgx.Row, destinations ...interface{}) error
-		SetStatTicker(
-			duration time.Duration,
-			fn func(*pgxpool.Stat),
-		)
-		ClearStatTicker()
-	}
-
 	// DefaultService is the default service struct
 	DefaultService struct {
 		pool       *pgxpool.Pool

sql/service.go

@@ -7,16 +7,6 @@ import (
 )
 
 type (
-	// Service is the interface for the service
-	Service interface {
-		DB() *sql.DB
-		Migrate(queries ...string) error
-		CreateTransaction(fn TransactionFn) error
-		Exec(query *string, params ...interface{}) (sql.Result, error)
-		QueryRow(query *string, params ...interface{}) *sql.Row
-		ScanRow(row *sql.Row, destinations ...interface{}) error
-	}
-
 	// DefaultService is the default service struct
 	DefaultService struct {
 		db *sql.DB