diff --git a/adapters/kmysql/kmysql.go b/adapters/kmysql/kmysql.go index ee618a9..1419411 100644 --- a/adapters/kmysql/kmysql.go +++ b/adapters/kmysql/kmysql.go @@ -11,6 +11,11 @@ import ( _ "github.com/go-sql-driver/mysql" ) +// NewFromSQLDB builds a ksql.DB from a *sql.DB instance +func NewFromSQLDB(db *sql.DB) (ksql.DB, error) { + return ksql.NewWithAdapter(NewSQLAdapter(db), "mysql") +} + // New instantiates a new KissSQL client using the "mysql" driver func New( _ context.Context, diff --git a/adapters/kpgx/kpgx.go b/adapters/kpgx/kpgx.go index 683cfb3..7ab6a4f 100644 --- a/adapters/kpgx/kpgx.go +++ b/adapters/kpgx/kpgx.go @@ -11,7 +11,7 @@ import ( _ "github.com/lib/pq" ) -// NewFromPgxPool builds a ksql.DB from a *pgxpool.Pool instance. +// NewFromPgxPool builds a ksql.DB from a *pgxpool.Pool instance func NewFromPgxPool(pool *pgxpool.Pool) (db ksql.DB, err error) { return ksql.NewWithAdapter(NewPGXAdapter(pool), "postgres") } diff --git a/adapters/ksqlite3/ksqlite3.go b/adapters/ksqlite3/ksqlite3.go index 261d6ef..a545e2a 100644 --- a/adapters/ksqlite3/ksqlite3.go +++ b/adapters/ksqlite3/ksqlite3.go @@ -11,6 +11,11 @@ import ( _ "github.com/mattn/go-sqlite3" ) +// NewFromSQLDB builds a ksql.DB from a *sql.DB instance +func NewFromSQLDB(db *sql.DB) (ksql.DB, error) { + return ksql.NewWithAdapter(NewSQLAdapter(db), "sqlite3") +} + // New instantiates a new KissSQL client using the "sqlite3" driver func New( _ context.Context, diff --git a/adapters/ksqlserver/ksqlserver.go b/adapters/ksqlserver/ksqlserver.go index eeffe08..6999df2 100644 --- a/adapters/ksqlserver/ksqlserver.go +++ b/adapters/ksqlserver/ksqlserver.go @@ -11,6 +11,11 @@ import ( _ "github.com/denisenkom/go-mssqldb" ) +// NewFromSQLDB builds a ksql.DB from a *sql.DB instance +func NewFromSQLDB(db *sql.DB) (ksql.DB, error) { + return ksql.NewWithAdapter(NewSQLAdapter(db), "sqlserver") +} + // New instantiates a new KissSQL client using the "sqlserver" driver func New( _ context.Context,