diff --git a/.idea/.gitignore b/.idea/.gitignore
new file mode 100644
index 0000000..13566b8
--- /dev/null
+++ b/.idea/.gitignore
@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml
diff --git a/.idea/ksql.iml b/.idea/ksql.iml
new file mode 100644
index 0000000..5e764c4
--- /dev/null
+++ b/.idea/ksql.iml
@@ -0,0 +1,9 @@
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/modules.xml b/.idea/modules.xml
new file mode 100644
index 0000000..eaa56cf
--- /dev/null
+++ b/.idea/modules.xml
@@ -0,0 +1,8 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/vcs.xml b/.idea/vcs.xml
new file mode 100644
index 0000000..35eb1dd
--- /dev/null
+++ b/.idea/vcs.xml
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/adapters/kpgx/kpgx_test.go b/adapters/kpgx/kpgx_test.go
index f060e25..fcc95aa 100644
--- a/adapters/kpgx/kpgx_test.go
+++ b/adapters/kpgx/kpgx_test.go
@@ -4,16 +4,16 @@ import (
"context"
"database/sql"
"fmt"
- "io"
- "log"
- "testing"
- "time"
-
"github.com/jackc/pgx/v4/pgxpool"
+ _ "github.com/lib/pq"
"github.com/ory/dockertest"
"github.com/ory/dockertest/docker"
"github.com/vingarcia/ksql"
"github.com/vingarcia/ksql/sqldialect"
+ "io"
+ "log"
+ "testing"
+ "time"
)
func TestAdapter(t *testing.T) {
@@ -38,7 +38,7 @@ func TestSQLAdapter(t *testing.T) {
defer closePostgres()
ksql.RunTestsForAdapter(t, "kpgx", sqldialect.PostgresDialect{}, postgresURL, func(t *testing.T) (ksql.DBAdapter, io.Closer) {
- sqldb, err := sql.Open("pgx", postgresURL)
+ sqldb, err := sql.Open("postgres", postgresURL)
if err != nil {
t.Fatal(err.Error())
}
diff --git a/adapters/kpgx/pgx_adapter_db.go b/adapters/kpgx/pgx_adapter_db.go
index f98b35a..1f275b1 100644
--- a/adapters/kpgx/pgx_adapter_db.go
+++ b/adapters/kpgx/pgx_adapter_db.go
@@ -3,11 +3,11 @@ package kpgx
import (
"context"
"database/sql"
+
+ "github.com/vingarcia/ksql"
"strconv"
"strings"
"unicode"
-
- "github.com/vingarcia/ksql"
)
// SQLAdapter adapts the sql.DB type to be compatible with the `DBAdapter` interface