diff --git a/benchmark_test.go b/benchmark_test.go index 0b52dda..605ee7a 100644 --- a/benchmark_test.go +++ b/benchmark_test.go @@ -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 { diff --git a/ksql.go b/ksql.go index 049fec4..eafeefe 100644 --- a/ksql.go +++ b/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 }