mirror of https://github.com/VinGarcia/ksql.git
parent
5c2b981696
commit
37298e2c24
|
@ -52,7 +52,7 @@ func BenchmarkInsert(b *testing.B) {
|
|||
})
|
||||
})
|
||||
|
||||
pgxDB, err := ksql.NewWithPGX(ctx, driver, connStr, ksql.Config{
|
||||
pgxDB, err := ksql.NewWithPGX(ctx, connStr, ksql.Config{
|
||||
MaxOpenConns: 1,
|
||||
})
|
||||
if err != nil {
|
||||
|
@ -165,7 +165,7 @@ func BenchmarkQuery(b *testing.B) {
|
|||
})
|
||||
})
|
||||
|
||||
pgxDB, err := ksql.NewWithPGX(ctx, driver, connStr, ksql.Config{
|
||||
pgxDB, err := ksql.NewWithPGX(ctx, connStr, ksql.Config{
|
||||
MaxOpenConns: 1,
|
||||
})
|
||||
if err != nil {
|
||||
|
|
3
ksql.go
3
ksql.go
|
@ -103,7 +103,6 @@ func New(
|
|||
// library in the backend
|
||||
func NewWithPGX(
|
||||
ctx context.Context,
|
||||
dbDriver string,
|
||||
connectionString string,
|
||||
config Config,
|
||||
) (db DB, err error) {
|
||||
|
@ -122,7 +121,7 @@ func NewWithPGX(
|
|||
return DB{}, err
|
||||
}
|
||||
|
||||
db, err = NewWithAdapter(PGXAdapter{pool}, dbDriver, connectionString)
|
||||
db, err = NewWithAdapter(PGXAdapter{pool}, "postgres", connectionString)
|
||||
return db, err
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue