GOMODULES
/
ksql
mirror of https://github.com/VinGarcia/ksql.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add constructor to SQLAdapter struct

pull/13/head
Vinícius Garcia 2021-11-14 18:57:57 -03:00
parent 25781352cb
commit 83f0ce5369
4 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
adapters/kmysql/kmysql.go
View File

@ -29,5 +29,5 @@ func New(
db.SetMaxOpenConns(config.MaxOpenConns) db.SetMaxOpenConns(config.MaxOpenConns)
return ksql.NewWithAdapter(ksql.SQLAdapter{DB: db}, "mysql") return ksql.NewWithAdapter(ksql.NewSQLAdapter(db), "mysql")
} }

2
adapters/ksqlite3/ksqlite3.go
View File

@ -29,5 +29,5 @@ func New(
db.SetMaxOpenConns(config.MaxOpenConns) db.SetMaxOpenConns(config.MaxOpenConns)
return ksql.NewWithAdapter(ksql.SQLAdapter{DB: db}, "sqlite3") return ksql.NewWithAdapter(ksql.NewSQLAdapter(db), "sqlite3")
} }

2
adapters/ksqlserver/ksqlserver.go
View File

@ -29,5 +29,5 @@ func New(
db.SetMaxOpenConns(config.MaxOpenConns) db.SetMaxOpenConns(config.MaxOpenConns)
return ksql.NewWithAdapter(ksql.SQLAdapter{DB: db}, "sqlserver") return ksql.NewWithAdapter(ksql.NewSQLAdapter(db), "sqlserver")
} }

8
sql_adapter.go
View File

@ -12,6 +12,14 @@ type SQLAdapter struct {
var _ DBAdapter = SQLAdapter{} var _ DBAdapter = SQLAdapter{}
// NewSQLAdapter returns a new instance of SQLAdapter with
// the provided database instance.
func NewSQLAdapter(db *sql.DB) SQLAdapter {
return SQLAdapter{
DB: db,
}
}
// ExecContext implements the DBAdapter interface // ExecContext implements the DBAdapter interface
func (s SQLAdapter) ExecContext(ctx context.Context, query string, args ...interface{}) (Result, error) { func (s SQLAdapter) ExecContext(ctx context.Context, query string, args ...interface{}) (Result, error) {
return s.DB.ExecContext(ctx, query, args...) return s.DB.ExecContext(ctx, query, args...)